[go: up one dir, main page]

CN110224890A - 列车过车报文解析方法及解析装置 - Google Patents

列车过车报文解析方法及解析装置 Download PDF

Info

Publication number
CN110224890A
CN110224890A CN201910506246.9A CN201910506246A CN110224890A CN 110224890 A CN110224890 A CN 110224890A CN 201910506246 A CN201910506246 A CN 201910506246A CN 110224890 A CN110224890 A CN 110224890A
Authority
CN
China
Prior art keywords
message
vehicle
information
vehicle message
crossing
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN201910506246.9A
Other languages
English (en)
Inventor
宋宗莹
张静轩
丁源
康凤伟
李权福
王洪昆
王文刚
边志宏
卢宇星
王蒙
方琪琦
王萌
刘洋
高哲
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Shenhua Energy Co Ltd
Shenhua Rail and Freight Wagons Transport Co Ltd
Original Assignee
China Shenhua Energy Co Ltd
Shenhua Rail and Freight Wagons Transport Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by China Shenhua Energy Co Ltd, Shenhua Rail and Freight Wagons Transport Co Ltd filed Critical China Shenhua Energy Co Ltd
Priority to CN201910506246.9A priority Critical patent/CN110224890A/zh
Publication of CN110224890A publication Critical patent/CN110224890A/zh
Pending legal-status Critical Current

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00—Arrangements for monitoring or testing data switching networks
    • H04L43/10—Active monitoring, e.g. heartbeat, ping or trace-route
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/06—Protocols specially adapted for file transfer, e.g. file transfer protocol [FTP]
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/50—Network services
    • H04L67/56—Provisioning of proxy services
    • H04L67/568—Storing data temporarily at an intermediate stage, e.g. caching
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/22—Parsing or analysis of headers

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer Security & Cryptography (AREA)
  • Health & Medical Sciences (AREA)
  • Cardiology (AREA)
  • General Health & Medical Sciences (AREA)
  • Management, Administration, Business Operations System, And Electronic Commerce (AREA)

Abstract

本发明涉及列车检修领域，公开了一种列车过程报文解析方法及解析装置，所述列车过车报文解析方法包括：获取车辆信息，并将所述车辆信息形成指定格式的过车报文存储至报文服务器；实时监测所述报文服务器中的所述过车报文的更新；在监测到所述过车报文存在更新时，开启所述报文服务器和所述解析服务器之间的若干个传输通道，以传输所述过车报文至解析服务器；以及在解析服务器中，对所述过车报文进行解析。通过上述技术方案，无需考虑过车报文的采集频率问题，实时获取报文更新，以数据块形式通过多个传输通道传递报文内容，避免信息拥堵，提高解析准确度和解析效率。

Description

列车过车报文解析方法及解析装置
技术领域
本发明涉及列车检修领域，具体地涉及列车过车报文解析方法及解析装置。
背景技术
传统铁路货车检修制度为“日常检查、定期检修”的预防性计划检修，时间年限是判定车辆进行哪种维修的决定因素，存在重复作业、过度检修等诸多弊病，导致了人力资源的浪费、修车成本的徒增以及运输效率的降低。因此，神华铁路货车寻求变革，进入以运行里程为度量的状态修模式。状态修是利用信息化手段采集神华货车的技术状态，经过数理统计和科学分析判定修程、指导检修，其重要标志是“状态”，因此如何保证状态相关信息的实时性、准确性显得格外重要。而铁路货车过车报文是指列车经过设有监测装置的轨道后，报文服务器中自动存储的车号、运行方向、经过时间等过车信息，是车辆运行里程计算的重要数据源。
当前铁路货车领域对过车报文的实际处理方法为以一固定的时间频率直接将报文抓取到本地服务器后，统一解析。
这种方法在操作过程中存在以下问题：
(1)、铁路货车领域常规使用的FTP(File Transfer Protocol，文件传输协议)操作较复杂，传输速度、分配解析任务速度很难满足状态修实时性的要求。
(2)、抓取频率合理性很难掌握。若抓取频率设置过快，会出现上一波报文还没有解析完，而下一波已经被自动抓取过来的情况，进而造成严重的信息拥堵，导致解析错误；若频率过慢，又将无法满足实时性的要求。
(3)、解析顺序及容量无法根据不同路段报文量的多少而分别匹配，解析效率低。
因此，如何设计出一种高实时性、高效率的过车报文解析方法，成为业界亟待解决的重要课题。
发明内容
本发明提供了一种列车过车报文的解析方法，以解决现有的报文解析方法实时性差、解析效率低的缺陷。
为了实现上述目的，本发明一方面提供一种列车过程报文解析方法，所述列车过车报文解析方法包括：获取车辆信息，并将所述车辆信息形成指定格式的过车报文存储至报文服务器；实时监测所述报文服务器中的所述过车报文的更新；在监测到所述过车报文存在更新时，开启所述报文服务器和所述解析服务器之间的若干个传输通道，以传输所述过车报文至解析服务器；以及在解析服务器中，对所述过车报文进行解析。
优选的，所述传输所述过车报文至解析服务器包括：将所述过车报文以数据块形式传输至所述解析服务器。
优选的，所述对所述过车报文进行解析包括：对所述过车报文进行全范围扫描统计，获取报文统计信息；以及根据所述报文统计信息对所述过车报文进行分组，形成若干个线程信息。
优选的，所述对所述过车报文进行解析还包括：获取所述线程信息中的明细信息；将所述过车报文按明细信息生成RDD缓存进行存放；以及将所述线程信息按车号信息分解成若干个车辆报文信息。
优选的，所述对所述过车报文进行解析还包括：删除所述RDD缓存过程中的动态信息；以及将所述车辆报文信息中的固定类型的信息形成字典库。
本发明第二方面提供一种列车过车报文解析装置，所述列车过车报文解析装置包括：采集模块，用于获取车辆信息，并将所述车辆信息形成指定格式的过车报文存储至报文服务器；监测模块，用于实时监测所述报文服务器中的所述过车报文的更新；传输模块，与所述监测模块通信，用于在所述监测模块监测到所述过车报文存在更新时，开启所述报文服务器和所述解析服务器之间的若干个传输通道，以传输所述过车报文至解析服务器；以及解析模块，与所述传输模块连接，用于接收所述传输模块所传输的过车报文，并在所述解析服务器中对所述过车报文进行解析。
优选的，所述传输模块用于将所述过车报文以数据块形式传输至所述解析服务器。
优选的，所述解析模块包括：第一解析子模块，用于对所述过车报文进行全范围扫描统计，获取报文统计信息；以及第二解析子模块，用于根据所述报文统计信息对所述过车报文进行分组，形成若干个线程信息。
优选的，所述第二解析子模块还用于：获取所述线程信息中的明细信息；将所述过车报文按所述明细信息生成RDD缓存进行存放；将所述线程信息按车号信息分解成若干个车辆报文信息；删除所述RDD缓存过程中的动态信息；以及将所述车辆报文信息中的固定类型的信息形成字典库。
另外，本发明实施例提供一种机器可读存储介质，所述机器可读存储介质上存储有指令，所述指令用于使得机器执行上述列车过车报文解析方法。
通过上述技术方案，无需考虑过车报文的采集频率问题，实时获取报文更新，以数据块形式通过多个传输通道传递报文内容，避免信息拥堵，提高解析准确度和解析效率。
本发明的其它特征和优点将在随后的具体实施方式部分予以详细说明。
附图说明
构成本发明的一部分的附图用来提供对本发明的进一步理解，本发明的示意性实施方式及其说明用于解释本发明，并不构成对本发明的不当限定。在附图中：
图1是本发明实施例提供的列车过车报文解析方法的流程图；
图2是本发明实施例提供的对所述过车报文进行解析的流程图；
图3是本发明实施例提供的列车过车报文解析装置的框图。
附图标记说明
1、采集模块 2、监测模块
3、传输模块 4、解析模块
具体实施方式
以下结合附图对本发明的具体实施方式进行详细说明。应当理解的是，此处所描述的具体实施方式仅用于说明和解释本发明，并不用于限制本发明。
图1是本发明实施例提供的列车过车报文解析方法的流程图，如图1所示，可以包括如下步骤：
S100、获取车辆信息，并形成过车报文存储至报文服务器。
通常每一列车包括多个车辆(车辆相当于日常人们所说的一节车厢)，当列车通过铁路线上安装的探测设备时，设备主机把采集到的所有车辆信息形成指定格式的过车报文上传并存储至报文服务器，该服务器可以是一台window server服务器。
S200、实时监测所述过车报文的更新。
可以利用报文服务器中的心跳监测组件，实时监测报文服务器中是否有新的过车报文产生。
S300、传输所述过车报文至解析服务器。
在心跳监测组件监测到报文服务器中过车报文存在更新时，开启报文服务器和解析服务器之间的若干个传输通道，以传输过车报文至解析服务器；
传输通道由采集器、消息服务器作为中间桥梁而建立，将报文内容以数据块的形式从报文服务器输送至解析服务器中，传输过程中不存在对纯实体文件的操作。
其中，消息服务器和解析服务器可以为Linux服务器。
S400、对所述过车报文进行解析。
过车报文的解析过程在解析服务器中进行，图2是本发明实施例提供的对所述过车报文进行解析的流程图，如图2所示，通常可以包括以下步骤：
S401、获取报文统计信息。
在解析服务器中对接收到的过车报文进行全范围扫描，获取报文数量、名称、个数等统计信息。
例如：解析服务器在每1分钟对报文信息进行一次全范围扫描和统计，即全范围指一分钟内收集到的报文范围。
S402、将统计信息分组形成若干个线程信息。
根据报文统计信息对过车报文进行分组，形成若干个线程信息，线程信息包含每列列车通过时该列车的所有车辆的过车报文。
S403、获取明细信息。
扫描每个线程信息中的报文内容，获取明细信息。明细信息包括：车型、车号、车次、设备编号等。
S404、存放信息。
将过车报文按明细信息生成RDD缓存进行存放，并将线程信息按车号信息分解成若干个针对车辆的过车报文。
存储过程中，首先，按过车报文属性分位数，读取信息，分别存放。具体来讲，是指过车报文中每一位具有相应的含义，例如：过车报文的第一位为J代表机车，第一为H代表货车等。也可以是其中的多位对应车辆的某一个信息，例如，过车报文的第6-9位对应车辆的车号。
进一步的，存放过程中，自动生成RDD(Resilient Distributed Dataset，弹性分布式数据集)缓存，对所有线程信息同时备份，当解析过后的过车报文的某一位显示为空时，可直接补充空位，无需再遍历比对找出差异后再补充。也即在存放过程中，每一个车辆的过车报文组成是固定的，可以对多个线程信息进行解析并自动生成RDD缓存，因为一个线程信息中包含多个车辆的过车报文，而每个过车报文的每一位表示相应的车辆信息，存储过程中可以利用RDD缓存加快对解析结果的分类和存储。
最后，匹配车号信息，将上述列报文分解为每一车辆对应一条报文，即车辆报文。
解析完毕后，将报文解析结果信息进行保存，结束流程。
进一步的，报文解析结果的存储过程中，可以将RDD缓存过程中的动态位所含信息自动删除，并将车辆报文信息中的车型、车号、设备编号等固定类型的信息形成字典库，避免过车报文更新时重复缓存。
图3是本发明实施例提供的列车过车报文解析装置的框图，如图3所示，可以包括：采集模块1，用于获取车辆信息，并将车辆信息形成指定格式的过车报文存储至报文服务器(图中未示出)；监测模块2，用于实时监测报文服务器中的过车报文的更新；传输模块3，与监测模块2通信，用于在监测模块2监测到过车报文存在更新时，开启报文服务器和解析服务器(图中未示出)之间的若干个传输通道，以传输过车报文至解析服务器；以及解析模块4，与传输模块3连接，用于接收传输模块3所传输的过车报文，并在解析服务器中对过车报文进行解析。
进一步的，传输模块3用于将过车报文以数据块形式传输至解析服务器。
解析模块4包括：第一解析子模块(图中未示出)，用于对过车报文进行全范围扫描统计，获取报文统计信息；以及第二解析子模块(图中未示出)，用于根据报文统计信息对过车报文进行分组，形成若干个线程信息。
进一步的，第二解析子模块还用于：获取线程信息中的明细信息；将过车报文按明细信息生成RDD缓存进行存放；将线程信息按车号信息分解成若干个车辆报文信息；删除RDD缓存过程中的动态信息；以及将车辆报文信息中的固定类型的信息形成字典库。
列车过车报文解析装置的其他具体细节同上述列车过车报文解析方法，此处不再赘述。
通过上述技术方案，无需考虑过车报文的采集频率问题，实时获取报文更新，以数据块形式通过多个传输通道传递报文内容，避免信息拥堵，提高解析准确度和解析效率。
需要说明的是，本发明中所述的技术方案主要应用于对货车的检修，且对货车的检修采用状态修模式，当然，本发明的技术方案同样适用于其他类型的列车检修过程。
以上结合附图详细描述了本发明实施例的可选实施方式，但是，本发明实施例并不限于上述实施方式中的具体细节，在本发明实施例的技术构思范围内，可以对本发明实施例的技术方案进行多种简单变型，这些简单变型均属于本发明实施例的保护范围。
另外需要说明的是，在上述具体实施方式中所描述的各个具体技术特征，在不矛盾的情况下，可以通过任何合适的方式进行组合。为了避免不必要的重复，本发明实施例对各种可能的组合方式不再另行说明。
本领域技术人员可以理解实现上述实施例方法中的全部或部分步骤是可以通过程序来指令相关的硬件来完成，该程序存储在一个存储介质中，包括若干指令用以使得单片机、芯片或处理器(processor)执行本申请各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：U盘、移动硬盘、只读存储器(ROM，Read-Only Memory)、随机存取存储器(RAM，Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。
此外，本发明实施例的各种不同的实施方式之间也可以进行任意组合，只要其不违背本发明实施例的思想，其同样应当视为本发明实施例所公开的内容。以上结合附图详细描述了本发明实施例的可选实施方式，但是，本发明实施例并不限于上述实施方式中的具体细节，在本发明实施例的技术构思范围内，可以对本发明实施例的技术方案进行多种简单变型，这些简单变型均属于本发明实施例的保护范围。

Claims (10)

1.一种列车过程报文解析方法，其特征在于，所述列车过车报文解析方法包括：
获取车辆信息，并将所述车辆信息形成指定格式的过车报文存储至报文服务器；
实时监测所述报文服务器中的所述过车报文的更新；
在监测到所述过车报文存在更新时，开启所述报文服务器和解析服务器之间的若干个传输通道，以传输所述过车报文至所述解析服务器；以及
在所述解析服务器中，对所述过车报文进行解析。
2.根据权利要求1所述的列车过程报文解析方法，其特征在于，所述传输所述过车报文至所述解析服务器包括：
将所述过车报文以数据块形式传输至所述解析服务器。
3.根据权利要求1所述的列车过程报文解析方法，其特征在于，所述对所述过车报文进行解析包括：
对所述过车报文进行全范围扫描统计，获取报文统计信息；以及
根据所述报文统计信息对所述过车报文进行分组，形成若干个线程信息。
4.根据权利要求3所述的列车过程报文解析方法，其特征在于，所述对所述过车报文进行解析还包括：
获取所述线程信息中的明细信息；
将所述过车报文按明细信息生成RDD缓存进行存放；以及
将所述线程信息按车号信息分解成若干个车辆报文信息。
5.根据权利要求4所述的列车过程报文解析方法，其特征在于，所述对所述过车报文进行解析还包括：
删除所述RDD缓存过程中的动态信息；以及
将所述车辆报文信息中的固定类型的信息形成字典库。
6.一种列车过车报文解析装置，其特征在于，所述列车过车报文解析装置包括：
采集模块，用于获取车辆信息，并将所述车辆信息形成指定格式的过车报文存储至报文服务器；
监测模块，用于实时监测所述报文服务器中的所述过车报文的更新；
传输模块，与所述监测模块通信，用于在所述监测模块监测到所述过车报文存在更新时，开启所述报文服务器和解析服务器之间的若干个传输通道，以传输所述过车报文至所述解析服务器；以及
解析模块，与所述传输模块连接，用于接收所述传输模块所传输的过车报文，并在所述解析服务器中对所述过车报文进行解析。
7.根据权利要求6所述的列车过程报文解析装置，其特征在于，所述传输模块用于将所述过车报文以数据块形式传输至所述解析服务器。
8.根据权利要求6所述的列车过程报文解析装置，其特征在于，所述解析模块包括：
第一解析子模块，用于对所述过车报文进行全范围扫描统计，获取报文统计信息；以及
第二解析子模块，用于根据所述报文统计信息对所述过车报文进行分组，形成若干个线程信息。
9.根据权利要求8所述的列车过程报文解析装置，其特征在于，所述第二解析子模块还用于：
获取所述线程信息中的明细信息；
将所述过车报文按所述明细信息生成RDD缓存进行存放；将所述线程信息按车号信息分解成若干个车辆报文信息；
删除所述RDD缓存过程中的动态信息；以及
将所述车辆报文信息中的固定类型的信息形成字典库。
10.一种机器可读存储介质，所述机器可读存储介质上存储有指令，所述指令用于使得机器执行权利要求1-5中任一项所述的列车过车报文解析方法。
CN201910506246.9A 2019-06-12 2019-06-12 列车过车报文解析方法及解析装置 Pending CN110224890A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN201910506246.9A CN110224890A (zh) 2019-06-12 2019-06-12 列车过车报文解析方法及解析装置

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201910506246.9A CN110224890A (zh) 2019-06-12 2019-06-12 列车过车报文解析方法及解析装置

Publications (1)

Publication Number Publication Date
CN110224890A true CN110224890A (zh) 2019-09-10

Family

ID=67816636

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201910506246.9A Pending CN110224890A (zh) 2019-06-12 2019-06-12 列车过车报文解析方法及解析装置

Country Status (1)

Country Link
CN (1) CN110224890A (zh)

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20030061337A1 (en) * 2001-09-27 2003-03-27 Kabushiki Kaisha Toshiba Data transfer scheme using caching technique for reducing network load
CN101547156A (zh) * 2009-05-04 2009-09-30 华为技术有限公司 报文解析方法和装置
CN105045681A (zh) * 2015-07-10 2015-11-11 上海爱数软件有限公司 一种Oracle多通道并行备份及恢复方法

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US20030061337A1 (en) * 2001-09-27 2003-03-27 Kabushiki Kaisha Toshiba Data transfer scheme using caching technique for reducing network load
CN101547156A (zh) * 2009-05-04 2009-09-30 华为技术有限公司 报文解析方法和装置
CN105045681A (zh) * 2015-07-10 2015-11-11 上海爱数软件有限公司 一种Oracle多通道并行备份及恢复方法

Non-Patent Citations (3)

* Cited by examiner, † Cited by third party
Title
刘瑞扬等: "《铁路车号自动识别系统原理及应用》", 31 December 2003 *
朱剑辉等: "AEI-W1型车号自动识别设备专家诊断系统的研制与应用", 《哈尔滨铁道科技》 *
车彦亮: "铁路车辆信息系统的研发与应用", 《科技创新导报》 *

Similar Documents

Publication Publication Date Title
El‐Geneidy et al. Analyzing transit service reliability using detailed data from automatic vehicular locator systems
Weik et al. Extending UIC 406-based capacity analysis–New approaches for railway nodes and network effects
CN107168278A (zh) 地铁列车信号系统的自动维护与预警系统
Prescott et al. A track ballast maintenance and inspection model for a rail network
Huang et al. Modeling the Influence of Disturbances in High‐Speed Railway Systems
CN107145951A (zh) 工务机械车云管理系统
CN107139972A (zh) 一种用于列车运行监控系统的设备故障智能诊断及处理销号的方法
CN110686700B (zh) 铁路货车运行里程统计方法及系统
Barabino et al. Regularity analysis on bus networks and route directions by automatic vehicle location raw data
Liu et al. Data analytics approach for train timetable performance measures using automatic train supervision data
CN110224890A (zh) 列车过车报文解析方法及解析装置
US20230331271A1 (en) System and method of railroad track data aggregation and analysis for determining inspection frequency
CN112732791A (zh) 无线ap数据分析平台及方法
Landex Capacity statement for railways
CN111930813B (zh) 一种以列车为统计单元的pis日志等效运行图生成方法
CN110228508B (zh) 列车过车报文异常检测方法及检测装置
CN116664371B (zh) 一种铁路货运站作业情况综合预警分析方法及系统
CN110232529A (zh) 管理车辆的零部件的方法和装置及机器可读存储介质
CN116450520A (zh) 轨道交通集成项目遗留缺陷分析的方法、介质和设备
Mandelzys et al. Automatically identifying the causes of bus transit schedule adherence performance issues using AVL/APC archived data
Butunov et al. THE CURRENT STATE AND DEVELOPMENT OF METHODS FOR ASSESSING THE TECHNICAL AND OPERATIONAL PERFORMANCE OF SORTING STATION
JP2004220072A (ja) 自動取引装置の設置計画支援
Zhong et al. Railway Infrastructure Capacity Utilization Description through Data Integration in Blocking Time Theory
Soltani Investigating the Effect of Trackwork on Punctuality of Swedish Railways
WEBER COMPARATIVE ANALYSIS OF TRANSPORTATION SYSTEMS: SUSTAINABILITY AND INNOVATION IN CHINA, USA, AND EUROPE

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination
RJ01 Rejection of invention patent application after publication

Application publication date: 20190910

RJ01 Rejection of invention patent application after publication