计轴磁头监测系统的制作方法

1.本发明涉及轨道交通技术领域，尤其涉及一种计轴磁头监测系统。


背景技术：

2.计轴是用于检测地铁线路区间空闲与占用状态的一种设备。计轴以其优越的安全性、经济性和可靠性，满足了众多轨道交通运营商提出的高要求，且其具有快速、少故障、多功能和易维护等优点，广泛应用于地铁线路。
3.由于位于室外设备的计轴处于恶劣的自然环境中，经常发生计轴磁头受干扰的故障，给行车安全带来隐患，严重时还会导致大面积列车晚点，影响行车效率。因此，需要对计轴磁头的状态进行监测，以在计轴磁头发生故障时对其进行维护。
4.相关技术中，采用人工方式对计轴磁头的状态进行一一检查，即通过人工使用万用表和示波器等电压监测仪器进行现场测试，然后根据经验对测试结果进行分析，确定计轴磁头是否出现异常。采用这种检查方式的监测效率较低。


技术实现要素：

5.针对现有技术存在的问题，本发明实施例提供一种计轴磁头监测系统。
6.本发明提供一种计轴磁头监测系统，包括：电压数据采集装置、数据接收子系统、消息队列子系统、解析子系统和状态分析子系统；
7.所述数据接收子系统用于接收所述电压数据采集装置发送的数据报文，并推送所述数据报文至消息队列子系统，所述数据报文包括计轴磁头的占用状态电压数据；
8.所述解析子系统用于从所述消息队列子系统拉取所述数据报文，以及解析所述数据报文以获取所述占用状态电压数据，以及推送所述占用状态电压数据至所述消息队列子系统；
9.所述状态分析子系统用于从所述消息队列子系统拉取所述占用状态电压数据，以及基于预设电压区间和所述占用状态电压数据，确定所述计轴磁头的运行状态。
10.可选地，根据本发明提供的一种计轴磁头监测系统，所述消息队列子系统为kafka消息队列集群。
11.可选地，根据本发明提供的一种计轴磁头监测系统，所述kafka消息队列集群用于：
12.接收所述数据接收子系统推送的所述数据报文，并将所述数据报文存入第一主题topic的第一分区partition；以及接收所述解析子系统推送的所述占用状态电压数据，并将所述占用状态电压数据存入第二主题topic的第二分区partition；
13.所述第一分区partition和所述第二分区partition是基于所述电压数据采集装置的ip地址确定的。
14.可选地，根据本发明提供的一种计轴磁头监测系统，所述数据接收子系统为netty数据接收集群。
15.可选地，根据本发明提供的一种计轴磁头监测系统，所述netty数据接收集群具体用于：
16.通过tcp服务接收所述电压数据采集装置发送的所述数据报文，并推送所述数据报文至所述kafka消息队列集群。
17.可选地，根据本发明提供的一种计轴磁头监测系统，所述状态分析子系统具体用于：
18.从所述消息队列子系统拉取所述占用状态电压数据；
19.判断所述占用状态电压数据是否在所述预设电压区间内，获取判断结果；
20.若所述判断结果指示所述占用状态电压数据在所述预设电压区间内，则确定所述计轴磁头的运行状态为健康状态；或，若所述判断结果指示所述占用状态电压数据中一个或多个电压值不在所述预设电压区间内，则确定所述计轴磁头的运行状态为故障状态。
21.可选地，根据本发明提供的一种计轴磁头监测系统，在确定所述计轴磁头的运行状态为健康状态之后，所述状态分析子系统还用于：
22.判断所述占用状态电压数据是否在预警电压区间内，所述预警电压区间为所述预设电压区间的子区间；
23.若所述占用状态电压数据中一个或多个电压值处于所述预警电压区间内，则确定所述计轴磁头的运行状态为健康预警状态。
24.可选地，根据本发明提供的一种计轴磁头监测系统，在基于预设电压区间和所述占用状态电压数据，确定所述计轴磁头的运行状态之后，所述状态分析子系统还用于：
25.基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据。
26.可选地，根据本发明提供的一种计轴磁头监测系统，所述运行状态统计数据包括所述计轴磁头的故障累计次数和健康预警累计次数，在基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据之后，所述状态分析子系统还用于：
27.判断所述故障累计次数是否大于第一阈值以及判断所述健康预警累计次数是否大于第二阈值；
28.若确定所述故障累计次数大于所述第一阈值和/或确定所述健康预警累计次数大于所述第二阈值，则生成用于检修所述计轴磁头的检修工单。
29.可选地，根据本发明提供的一种计轴磁头监测系统，在基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据之后，所述状态分析子系统还用于：
30.接收目标输入，所述目标输入用于指示查询所述计轴磁头的运行状态；
31.响应于所述目标输入，显示所述计轴磁头的运行状态统计数据。
32.本发明提供的计轴磁头监测系统，通过数据接收子系统可以接收电压数据采集装置发送的数据报文，进而数据接收子系统可以推送数据报文至消息队列子系统，进而解析子系统可以从消息队列子系统拉取数据报文并对数据报文进行解释以获取占用状态电压数据，进而解析子系统可以推送占用状态电压数据至消息队列子系统，进而状态分析子系统可以从消息队列子系统拉取占用状态电压数据，进而状态分析子系统可以基于预设电压区间，分析占用状态电压数据以确定计轴磁头的运行状态，能够实时地对携带有计轴磁头的占用状态电压数据的数据报文进行分析处理，实现高效地监测计轴磁头。
附图说明
33.为了更清楚地说明本发明或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
34.图1是本发明提供的计轴磁头监测系统的结构示意图；
35.图2是本发明提供的计轴器运行状态统计数据的界面示意图。
具体实施方式
36.为使本发明的目的、技术方案和优点更加清楚，下面将结合本发明中的附图，对本发明中的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
37.图1是本发明提供的计轴磁头监测系统的结构示意图，如图1所示，所述计轴磁头监测系统包括：电压数据采集装置101、数据接收子系统102、消息队列子系统103、解析子系统104和状态分析子系统105，其中：
38.所述数据接收子系统102用于接收所述电压数据采集装置101发送的数据报文，并推送所述数据报文至消息队列子系统103，所述数据报文包括计轴磁头的占用状态电压数据；
39.所述解析子系统104用于从所述消息队列子系统103拉取所述数据报文，以及解析所述数据报文以获取所述占用状态电压数据，以及推送所述占用状态电压数据至所述消息队列子系统103；
40.所述状态分析子系统105用于从所述消息队列子系统103拉取所述占用状态电压数据，以及基于预设电压区间和所述占用状态电压数据，确定所述计轴磁头的运行状态。
41.具体地，计轴磁头监测系统可以包括一个或多个电压数据采集装置，电压数据采集装置可以对计轴磁头的占用状态电压数据进行采集，并可以将占用状态电压数据携带在数据报文中发送至数据接收子系统，其中，占用状态电压数据可以是在列车经过计轴磁头的情况下(计轴处于占用状态)电压数据采集装置针对计轴磁头所采集到的电压数据。
42.可选地，在列车经过计轴磁头的情况下，电压数据采集装置可以生成并发送一个数据报文至数据接收子系统。
43.具体地，通过数据接收子系统可以接收电压数据采集装置发送的数据报文，进而数据接收子系统可以推送数据报文至消息队列子系统，进而解析子系统可以从消息队列子系统拉取数据报文并对数据报文进行解释以获取占用状态电压数据。
44.可以理解的是，解析子系统可以按异步方式，从消息队列子系统拉取消息队列消息(也即拉取数据报文)，可以提升消息处理能力，利用消息队列作为临时数据存储节点，解析子系统可以根据自身数据处理能力，通过拉取的方式控制数据处理速度，达到流量削峰的目的，缓冲瞬时流量。
45.可选地，可以将数据报文以文本形式保存在服务器对应目录，以便后期校验数据的可靠性和问题排查。
46.具体地，解析子系统可以推送占用状态电压数据至消息队列子系统，进而状态分析子系统可以从消息队列子系统拉取占用状态电压数据，进而状态分析子系统可以基于预设电压区间，分析占用状态电压数据以确定计轴磁头的运行状态。
47.可以理解的是，状态分析子系统可以按异步方式，从消息队列子系统拉取消息队列消息(也即拉取占用状态电压数据)，可以提升消息处理能力，利用消息队列作为临时数据存储节点，状态分析子系统可以根据自身数据处理能力，通过拉取的方式控制数据处理速度，达到流量削峰的目的，缓冲瞬时流量。
48.本发明提供的计轴磁头监测系统，通过数据接收子系统可以接收电压数据采集装置发送的数据报文，进而数据接收子系统可以推送数据报文至消息队列子系统，进而解析子系统可以从消息队列子系统拉取数据报文并对数据报文进行解释以获取占用状态电压数据，进而解析子系统可以推送占用状态电压数据至消息队列子系统，进而状态分析子系统可以从消息队列子系统拉取占用状态电压数据，进而状态分析子系统可以基于预设电压区间，分析占用状态电压数据以确定计轴磁头的运行状态，能够实时地对携带有计轴磁头的占用状态电压数据的数据报文进行分析处理，实现高效地监测计轴磁头。
49.可选地，根据本发明提供的一种计轴磁头监测系统，所述消息队列子系统为kafka消息队列集群。
50.具体地，通过数据接收子系统可以接收电压数据采集装置发送的数据报文，进而数据接收子系统可以推送数据报文至kafka消息队列集群，进而解析子系统可以从kafka消息队列集群拉取数据报文并对数据报文进行解释以获取占用状态电压数据，进而解析子系统可以推送占用状态电压数据至kafka消息队列集群，进而状态分析子系统可以从kafka消息队列集群拉取占用状态电压数据，进而状态分析子系统可以基于预设电压区间，分析占用状态电压数据以确定计轴磁头的运行状态。
51.可以理解的是，kafka是一个高吞吐量分布式消息系统，采用scala和java语言编写，它提供了快速、可扩展的、分布式、分区的和可复制的日志订阅服务。它由producer、broker、consumer三部分构成。producer向某个topic发布消息，而consumer订阅某个topic的消息。一旦有某个topic新产生的消息，broker会传递给订阅它的所有consumer。kafka还具有速度快、高吞吐量、分布式、多分区，支持多消费者，支持online和offline的场景等特点。
52.可以理解的是，解析子系统(或状态分析子系统)可以作为消费者(consumers)按异步方式，从kafka消息队列集群拉取消息队列消息，可以提升消息处理能力，利用消息队列作为临时数据存储节点，解析子系统(或状态分析子系统)可以根据自身消费能力，通过拉取的方式控制消费速度，达到流量削峰的目的，缓冲瞬时流量。
53.可选地，可以依据java的map接口key唯一的特性，将同一个计轴磁头的占用状态电压数据拼接在一个集合中，以多线程的方式存入数据库，同时推送至kafka消息队列集群。
54.可选地，根据本发明提供的一种计轴磁头监测系统，所述kafka消息队列集群用于：
55.接收所述数据接收子系统推送的所述数据报文，并将所述数据报文存入第一主题topic的第一分区partition；以及接收所述解析子系统推送的所述占用状态电压数据，并
将所述占用状态电压数据存入第二主题topic的第二分区partition；
56.所述第一分区partition和所述第二分区partition是基于所述电压数据采集装置的ip地址确定的。
57.具体地，通过数据接收子系统可以接收电压数据采集装置发送的数据报文，进而数据接收子系统可以推送数据报文至kafka消息队列集群，kafka消息队列集群可以将数据报文存入第一主题topic的第一分区partition，进而解析子系统可以从第一主题topic的第一分区partition拉取数据报文并对数据报文进行解释以获取占用状态电压数据。
58.具体地，解析子系统可以推送占用状态电压数据至kafka消息队列集群，kafka消息队列集群可以将占用状态电压数据存入第二主题topic的第二分区partition，进而状态分析子系统可以从第二主题topic的第二分区partition拉取占用状态电压数据，进而状态分析子系统可以基于预设电压区间，分析占用状态电压数据以确定计轴磁头的运行状态。
59.可选地，kafka消息队列集群可以基于电压数据采集装置的ip地址，ip地址可以是ipv4，可以提取该ip地址的“点分十进制”的最后一位的数值(例如ip地址的点分十进制可以是100.4.5.6，最后一位的数值是6)，进而可以将最后一位的数值取模30，将取到的值作为分区值，基于该分区值可以确定对应的分区，在第一主题topic下，该分区值可以对应第一分区partition，在第二主题topic下，该分区值可以对应第二分区partition。
60.可以理解的是，为了实现能够实时地处理大量的数据报文，可以把数据分割为多个分区(partition)，生产者(produce)发送的消息分发到不同的partition中，消费者(consumer)接收数据的时候是按照消费者群(group)来接收，kafka可以确保每个partition只能同一个group中的同一个consumer消费，能够提高与计轴数据交互效率。
61.可以理解的是，当大量计轴数据上传时，可以利用kafka的异步和削峰特性，缓解解析子系统(或状态分析子系统)数据处理压力，不会造成数据丢失，能够提高子系统与子系统之间容错性。
62.可选地，根据本发明提供的一种计轴磁头监测系统，所述数据接收子系统为netty数据接收集群。
63.具体地，通过netty数据接收集群可以接收电压数据采集装置发送的数据报文，进而netty数据接收集群可以推送数据报文至kafka消息队列集群。
64.可以理解的是，netty是由jboss提供的一个java开源框架，netty提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。netty还具有处理大容量数据流更简单，处理协议编码和单元测试更简单的特性，便于对海量数据进行处理和报文转换。
65.可选地，可以根据计轴数据实际交互场景，通过netty框架下的channelhandler，以软件作为服务端，电压数据采集装置作为客服端，以预设通信协议进行数据传输。其中，channelhandler是一个包含所有应用处理逻辑的容器载体，用来对netty的输入输出数据进行加工处理。
66.可以理解的是，对于netty数据接收集群，可以利用java的nio零拷贝特性，通过bytebuf直接对数据进行操作，采用异步非阻塞通信，支持高并发，能够实现大数据量传输。其中，bytebuf是netty的服务端与客户端之间通信的数据传输载体(netty的数据容器)。
67.可选地，根据本发明提供的一种计轴磁头监测系统，所述netty数据接收集群具体
用于：
68.通过tcp服务接收所述电压数据采集装置发送的所述数据报文，并推送所述数据报文至所述kafka消息队列集群。
69.具体地，netty数据接收集群可以通过tcp服务接收电压数据采集装置发送的数据报文，进而netty数据接收集群可以推送数据报文至kafka消息队列集群。基于netty框架实现tcp协议，能够保证数据传输的稳定性。
70.可选地，根据本发明提供的一种计轴磁头监测系统，所述状态分析子系统具体用于：
71.从所述消息队列子系统拉取所述占用状态电压数据；
72.判断所述占用状态电压数据是否在所述预设电压区间内，获取判断结果；
73.若所述判断结果指示所述占用状态电压数据在所述预设电压区间内，则确定所述计轴磁头的运行状态为健康状态；或，若所述判断结果指示所述占用状态电压数据中一个或多个电压值不在所述预设电压区间内，则确定所述计轴磁头的运行状态为故障状态。
74.具体地，状态分析子系统可以按异步方式从消息队列子系统拉取占用状态电压数据，进而可以判断占用状态电压数据是否在所述预设电压区间内，若确定占用状态电压数据中各电压值在预设电压区间内，则可以确定计轴磁头的运行状态为健康状态，若确定占用状态电压数据中一个或多个电压值不在预设电压区间内，则可以确定计轴磁头的运行状态为故障状态。
75.例如，预设电压区间可以是4.79v至12v，可以判断占用状态电压数据是否在4.79v至12v之间，若确定占用状态电压数据中各电压值在4.79v至12v之间，则可以确定计轴磁头的运行状态为健康状态，若确定占用状态电压数据中一个或多个电压值不在4.79v至12v之间，则可以确定计轴磁头的运行状态为故障状态。
76.可以理解的是，针对某一计轴磁头，电压数据采集装置每上报一次数据报文，状态分析子系统可以基于数据报文所携带的占用状态电压数据分析一次该计轴磁头的运行状态。
77.因此，状态分析子系统通过判断占用状态电压数据是否在预设电5压区间内，可以确定计轴磁头的运行状态，能够实时地对携带有计轴
78.磁头的占用状态电压数据的数据报文进行分析处理，实现高效地监测计轴磁头。
79.可选地，根据本发明提供的一种计轴磁头监测系统，在确定所述
80.计轴磁头的运行状态为健康状态之后，所述状态分析子系统还用于：0判断所述占用状态电压数据是否在预警电压区间内，所述预警电
81.压区间为所述预设电压区间的子区间；
82.若所述占用状态电压数据中一个或多个电压值处于所述预警电压区间内，则确定所述计轴磁头的运行状态为健康预警状态。
83.具体地，在确定计轴磁头的运行状态为健康状态的情况下，为了5进一步分析计轴磁头是否已临近出现故障，可以预先配置预警电压区
84.间(预警电压区间为预设电压区间的子区间)，进而可以判断占用状态电压数据是否在预警电压区间内，若确定占用状态电压数据中一个或多个电压值处于预警电压区间内，则可以确定计轴磁头的运行状态为健康预警状态，也即计轴磁头已临近出现故障。
85.0例如，预设电压区间可以是4.79v至12v，预警电压区间可以是11v至12v，可以判断占用状态电压数据是否在11v至12v之间，若确定占用状态电压数据中一个或多个电压值处于11v至12v之间，则可以确定计轴磁头的运行状态为健康预警状态，也即计轴磁头已临近出现故障。
86.5可选地，根据本发明提供的一种计轴磁头监测系统，在基于预设
87.电压区间和所述占用状态电压数据，确定所述计轴磁头的运行状态之后，所述状态分析子系统还用于：
88.基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据。
89.具体地，为了持续统计计轴磁头的运行状态，在确定计轴磁头的运行状态之后，状态分析子系统可以基于计轴磁头的运行状态，更新计轴磁头的运行状态统计数据，该运行状态统计数据可以包括本次分析所获得的运行状态以及以前若干次分析所获得的运行状态，通过运行状态统计数据可以对计轴磁头进行统计分析。
90.可选地，根据本发明提供的一种计轴磁头监测系统，所述运行状态统计数据包括所述计轴磁头的故障累计次数和健康预警累计次数，在基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据之后，所述状态分析子系统还用于：
91.判断所述故障累计次数是否大于第一阈值以及判断所述健康预警累计次数是否大于第二阈值；
92.若确定所述故障累计次数大于所述第一阈值和/或确定所述健康预警累计次数大于所述第二阈值，则生成用于检修所述计轴磁头的检修工单。
93.具体地，在更新计轴磁头的运行状态统计数据之后，状态分析子系统可以判断故障累计次数是否大于第一阈值以及判断健康预警累计次数是否大于第二阈值，若确定故障累计次数大于第一阈值和/或确定健康预警累计次数大于所述第二阈值，则表明需要对该计轴磁头进行检修，进而可以生成用于检修计轴磁头的检修工单，能够自动触发检修流程，实现及时检修计轴磁头。
94.可选地，根据本发明提供的一种计轴磁头监测系统，在基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据之后，所述状态分析子系统还用于：
95.接收目标输入，所述目标输入用于指示查询所述计轴磁头的运行状态；
96.响应于所述目标输入，显示所述计轴磁头的运行状态统计数据。
97.具体地，为了方便检修人员查询计轴磁头的运行状态，状态分析子系统可以支持人机交互，接收用户的目标输入，该目标输入可以是指示查询计轴磁头的运行状态的输入，响应于该输入，状态分析子系统可以显示计轴磁头的运行状态统计数据。
98.可选地，状态分析子系统可以采用vue框架进行页面功能展示。
99.可选地，图2是本发明提供的计轴器运行状态统计数据的界面示意图，如图2所示，可以通过“选择计轴磁头”控件接收用户的目标输入，该目标输入可以指示查询某一计轴磁头的运行状态，响应于该目标输入，可以显示该计轴磁头的运行状态统计数据，该运行状态统计数据可以包括以前若干次分析所获得的运行状态，每一次分析可以对应一个“查看曲线”控件，点击查看曲线控件，可以查看占用状态电压数据的电压曲线。
100.因此，状态分析子系统可以支持人机交互，以便检修人员查询计轴磁头的运行状态。
101.本发明提供的计轴磁头监测系统，通过数据接收子系统可以接收电压数据采集装置发送的数据报文，进而数据接收子系统可以推送数据报文至消息队列子系统，进而解析子系统可以从消息队列子系统拉取数据报文并对数据报文进行解释以获取占用状态电压数据，进而解析子系统可以推送占用状态电压数据至消息队列子系统，进而状态分析子系统可以从消息队列子系统拉取占用状态电压数据，进而状态分析子系统可以基于预设电压区间，分析占用状态电压数据以确定计轴磁头的运行状态，能够实时地对携带有计轴磁头的占用状态电压数据的数据报文进行分析处理，实现高效地监测计轴磁头。
102.以上所描述的装置实施例仅仅是示意性的，其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下，即可以理解并实施。
103.通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件。基于这样的理解，上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在计算机可读存储介质中，如rom/ram、磁碟、光盘等，包括若干指令用以使得一台计算机设备(可以是个人计算机，服务器，或者网络设备等)执行各个实施例或者实施例的某些部分所述的方法。
104.最后应说明的是：以上实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。

技术特征：
1.一种计轴磁头监测系统，其特征在于，包括：电压数据采集装置、数据接收子系统、消息队列子系统、解析子系统和状态分析子系统；所述数据接收子系统用于接收所述电压数据采集装置发送的数据报文，并推送所述数据报文至消息队列子系统，所述数据报文包括计轴磁头的占用状态电压数据；所述解析子系统用于从所述消息队列子系统拉取所述数据报文，以及解析所述数据报文以获取所述占用状态电压数据，以及推送所述占用状态电压数据至所述消息队列子系统；所述状态分析子系统用于从所述消息队列子系统拉取所述占用状态电压数据，以及基于预设电压区间和所述占用状态电压数据，确定所述计轴磁头的运行状态。2.根据权利要求1所述计轴磁头监测系统，其特征在于，所述消息队列子系统为kafka消息队列集群。3.根据权利要求2所述计轴磁头监测系统，其特征在于，所述kafka消息队列集群用于：接收所述数据接收子系统推送的所述数据报文，并将所述数据报文存入第一主题topic的第一分区partition；以及接收所述解析子系统推送的所述占用状态电压数据，并将所述占用状态电压数据存入第二主题topic的第二分区partition；所述第一分区partition和所述第二分区partition是基于所述电压数据采集装置的ip地址确定的。4.根据权利要求2所述计轴磁头监测系统，其特征在于，所述数据接收子系统为netty数据接收集群。5.根据权利要求4所述计轴磁头监测系统，其特征在于，所述netty数据接收集群具体用于：通过tcp服务接收所述电压数据采集装置发送的所述数据报文，并推送所述数据报文至所述kafka消息队列集群。6.根据权利要求1-5任一项所述计轴磁头监测系统，其特征在于，所述状态分析子系统具体用于：从所述消息队列子系统拉取所述占用状态电压数据；判断所述占用状态电压数据是否在所述预设电压区间内，获取判断结果；若所述判断结果指示所述占用状态电压数据在所述预设电压区间内，则确定所述计轴磁头的运行状态为健康状态；或，若所述判断结果指示所述占用状态电压数据中一个或多个电压值不在所述预设电压区间内，则确定所述计轴磁头的运行状态为故障状态。7.根据权利要求6所述计轴磁头监测系统，其特征在于，在确定所述计轴磁头的运行状态为健康状态之后，所述状态分析子系统还用于：判断所述占用状态电压数据是否在预警电压区间内，所述预警电压区间为所述预设电压区间的子区间；若所述占用状态电压数据中一个或多个电压值处于所述预警电压区间内，则确定所述计轴磁头的运行状态为健康预警状态。8.根据权利要求7所述计轴磁头监测系统，其特征在于，在基于预设电压区间和所述占用状态电压数据，确定所述计轴磁头的运行状态之后，所述状态分析子系统还用于：基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据。
9.根据权利要求8所述计轴磁头监测系统，其特征在于，所述运行状态统计数据包括所述计轴磁头的故障累计次数和健康预警累计次数，在基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据之后，所述状态分析子系统还用于：判断所述故障累计次数是否大于第一阈值以及判断所述健康预警累计次数是否大于第二阈值；若确定所述故障累计次数大于所述第一阈值和/或确定所述健康预警累计次数大于所述第二阈值，则生成用于检修所述计轴磁头的检修工单。10.根据权利要求8所述计轴磁头监测系统，其特征在于，在基于所述计轴磁头的运行状态，更新所述计轴磁头的运行状态统计数据之后，所述状态分析子系统还用于：接收目标输入，所述目标输入用于指示查询所述计轴磁头的运行状态；响应于所述目标输入，显示所述计轴磁头的运行状态统计数据。

技术总结
本发明提供一种计轴磁头监测系统，包括：电压数据采集装置、数据接收子系统、消息队列子系统、解析子系统和状态分析子系统；数据接收子系统用于接收电压数据采集装置发送的数据报文，并推送数据报文至消息队列子系统，数据报文包括计轴磁头的占用状态电压数据；解析子系统用于从消息队列子系统拉取数据报文，以及解析数据报文以获取占用状态电压数据，以及推送占用状态电压数据至消息队列子系统；状态分析子系统用于从消息队列子系统拉取占用状态电压数据，以及基于预设电压区间和占用状态电压数据，确定计轴磁头的运行状态。通过计轴磁头监测系统能够实时地对携带有计轴磁头的占用状态电压数据的数据报文进行处理，实现高效地监测计轴磁头。效地监测计轴磁头。效地监测计轴磁头。


技术研发人员：赖治平 陈智 黄胜 黄俊霖
受保护的技术使用者：广西交控智维科技发展有限公司
技术研发日：2022.12.29
技术公布日：2023/5/4