一种面向站端监控系统的变量信息监视方法与流程

1.本发明涉及一种面向站端监控系统的变量信息监视方法，属于数据处理技术领域。


背景技术：

2.目前对于变量信息的监视方法主要是将变量信息保存至数据库中进行查看，例如专利公开号为cn1096345774b的中国专利申请文件，该文件公布了一种基于微内核架构的变量实时监视方法及系统，该方法主要基于微内核的架构开发了一个包装类对变量监视其变化情况，并对变量的真值进行标记和存储，当需要监视其变化情况时，会启动监视插件将存入本地数据库的值取出进行展示。该方法虽然能够监视到变量的变化情况，但是程序内的变量值的变化是毫秒级别的，如果先存到数据库再取出会有一定的传输时延，实时性很难保证。


技术实现要素：

3.本发明的目的是提供一种面向站端监控系统的变量信息监视方法，以解决目前监视过程存在的传输时延高、实时性差的问题。
4.本发明为解决上述技术问题而提供一种面向站端监控系统的变量信息监视方法，该监视方法包括以下步骤：
5.1)在监控系统和接收者之间设置kafka集群，并建立kafka集群与监控系统和接收者之间的通信连接以及要发送的消息类别topic；
6.2)利用站端监控系统的应用程序选择需要监视的变量，将所选择变量的原始数据与对应的时间数据组合后形成监视数据，并发送给kafka集群；
7.3)kafka集群在接收到所述监视数据后，将接收到的数据转发至接收者；
8.4)接收者在收到类别为topic的消息后，对消息进行解析，将解析出的原始数据进行展示并将消息存入历史存储数据库。
9.本发明首先建立kafka集群与监控系统和接收者之间的通信连接以及要发送的消息类别topic，通过应用程序将变量的原始数据和对应的时间数据发送至kafka集群，kafka集群收到消息后将其转发至接收者，接收者在收到类别为topic的消息后会对其进行解析得到原始数据进行展示，并将其存入历史存储数据库。本发明通过借助kafka的这种实时通信优势，对程序变量的值进行消息的实时传递并监视，可以有效降低发送方和接收方的传输时延，为站端监控系统提供有效的数据分析支撑，还可以作为守护进程对变量进行持久可靠的监视。
10.进一步地，若接收者未收到消息，则从历史存储中找到最近的一条数据进行展示。
11.接收者未收到消息时会展示最近的一条数据，直至接收到新的消息，避免了因显示问题而出现的错误判断，有利于更好地对变量进行监视。
12.进一步地，所述步骤3)kafka集群接收到消息后将消息放入消息队列，按照队列中
的顺序进行转发。
13.将消息放在消息队列按照队列中的顺序进行转发，保证了消息转发过程的有序进行。
14.进一步地，所述步骤4)接收者通过设置接收者程序进行数据接收，并对接收到的消息进行解析得到原始数据。
15.接收者程序可以快速准确的对接收到的消息进行解析，得到原始数据，有利于消息的快速传递，减少传输时延。
16.进一步地，所述步骤1)通过在kafka集群中注册用于发送和接收的类别为topic的消息建立通信连接。
17.topic为主题，是接收者需要的一种消息类型，可以理解为发送者和接收者之间的暗号，用来标记接收者收到消息类别的唯一性，接收者可以快速准确的得到所需变量的原始数据，提高发送端的传输效率，减少传输时延。
18.进一步地，所述步骤2)的原始数据是“变量地址+变量值”，对应的时间数据是发送消息的时间戳。
19.对应的时间数据是发送消息的时间戳，可以确保消息内容的唯一性。
20.进一步地，所述接收者程序为守护程序，在其他程序发送消息期间一直处于运行状态并准备实时接收消息。
21.守护程序会在其他程序发送消息期间一直处于运行状态并准备实时接收消息，实现了对变量的实时监视，有利于对变量进行持久可靠的监视。
附图说明
22.图1是本发明面向站端监控系统的变量信息监视方法的流程图。
具体实施方式
23.下面结合附图对本发明的具体实施方式作进一步地说明。
24.面向站端监控系统的变量信息监视方法的实施例
25.本发明首先在监控系统和接收者之间设置kafka集群，并建立kafka集群与监控系统和接收者之间的通信连接以及要发送的消息类别topic；然后通过站端监控系统的应用程序选择需要监视的变量，将“变量地址+变量值”作为原始数据，并将该数据与发送消息时所对应的时间戳组合成最终监视数据进行传递；kafka集群接收到监视数据消息后则将其放入kafka消息队列等待进一步转发至接收者，若未接收到则程序结束；最后在接收者中设置接收者程序，并将接收者程序设为守护程序，在其他程序发送消息期间一直处于运行状态并准备实时接收消息，若接收到消息则对消息进行解析，得到原始数据用于ui展示，并将其存入历史存储数据库，若未接收到消息则从历史存储中找到最近的一条数据进行展示。该方法的实现流程如图1所示，下面结合具体的实例来进行说明。
26.1.在监控系统和接收者之间设置kafka集群，并建立kafka集群与监控系统和接收者之间的通信连接。
27.kafka是一个开源流处理平台，是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据，具有高水平扩展和高吞吐量的特征。topic为主
题，用来标记消息类型的唯一性，运行过程中必须在消息中设定topic，指明是什么样的数据。本实施例中通过在kafka集群中注册用于发送和接收的固定topic消息建立通信连接。
28.2.利用站端监控系统的应用程序选择需要监视的变量，将所选择变量的原始数据与对应的时间数据组合后形成监视数据进行传递。
29.向kafka发送数据首先需要一个生产者应用程序，这个应用程序发送的消息，就是包含的这个数据。本实施例中，站端监控系统的应用程序选择需要监视的变量，指明将“变量地址+变量值”作为原始数据，与发送消息时的时间戳组合成监视数据，通过应用程序发送给kafka集群。
30.3.kafka集群接收到所述监视数据则将接收到的数据消息放入kafka消息队列等待进一步转发至接收者。
31.kafka会判断是否接收到数据消息，若未接收到数据消息则程序直接结束，若接收到数据消息，则将接收到的监视数据消息放入kafka消息队列等待进一步转发，最终将接收到的监视数据消息转发至接收者。
32.4.接收者在收到消息后，对消息进行解析，将解析出的原始数据进行展示并将消息存入历史存储数据库。
33.接收者设置接收者程序用来接收kafka集群传递的数据消息，并将接收者程序设置为守护程序，该守护程序会在其他程序发送消息期间一直处于运行状态并准备实时接收消息，如果收到消息，则对消息进行解析，解析得出原始数据“变量地址+变量值”用于ui展示，并将其存入历史存储数据库，若未接收到消息，则从历史存储中找到最近的一条数据进行展示。


技术特征：
1.一种面向站端监控系统的变量信息监视方法，其特征在于，该监视方法包括以下步骤：1)在监控系统和接收者之间设置kafka集群，并建立kafka集群与监控系统和接收者之间的通信连接以及要发送的消息类别topic；2)利用站端监控系统的应用程序选择需要监视的变量，将所选择变量的原始数据与对应的时间数据组合后形成监视数据，并发送给kafka集群；3)kafka集群在接收到所述监视数据后，将接收到的数据转发至接收者；4)接收者在收到类别为topic的消息后，对消息进行解析，将解析出的原始数据进行展示并将消息存入历史存储数据库。2.根据权利要求1所述的面向站端监控系统的变量信息监视方法，其特征在于，若接收者未收到消息，则从历史存储中找到最近的一条数据进行展示。3.根据权利要求1或2所述的面向站端监控系统的变量信息监视方法，其特征在于，所述步骤3)kafka集群接收到消息后将消息放入消息队列，按照在消息队列中的顺序进行转发。4.根据权利要求1所述的面向站端监控系统的变量信息监视方法，其特征在于，所述步骤4)接收者通过设置接收者程序进行数据接收，并对接收到的消息进行解析得到原始数据。5.根据权利要求1所述的面向站端监控系统的变量信息监视方法，其特征在于，所述步骤1)通过在kafka集群中注册用于发送和接收的且类别为topic的消息建立通信连接。6.根据权利要求1所述的面向站端监控系统的变量信息监视方法，其特征在于，所述步骤2)的原始数据是“变量地址+变量值”，对应的时间数据是发送消息的时间戳。7.根据权利要求4所述的面向站端监控系统的变量信息监视方法，其特征在于，所述接收者程序为守护程序，在其他程序发送消息期间一直处于运行状态并准备实时接收消息。

技术总结
本发明涉及一种面向站端监控系统的变量信息监视方法，属于数据处理技术领域。本发明首先建立Kafka集群与监控系统和接收者之间的连接以及要发送的消息类别topic，通过应用程序将原始数据和时间数据发送至Kafka，Kafka收到消息后将其转发至接收者程序，接收者程序一直处于运行状态并准备实时接收消息，在收到消息后会对其进行解析得到原始数据和时间数据用于ui展示，并将其存入历史存储数据库，若未接收到消息则从历史存储中找到最近的一条数据进行展示。本发明通过借助Kafka的实时通信优势，对程序变量的值进行消息的实时传递并监视，有效降低发送方和接收方的传输时延，为站端监控系统提供有效的数据分析支撑，还可以作为守护进程对变量进行持久可靠的监视。为守护进程对变量进行持久可靠的监视。为守护进程对变量进行持久可靠的监视。


技术研发人员：付奇龙 周少清 王卫东 邵广时 慕宗君 骆建豪 常志飞 尹丽楠 陈二玲 何涵菁 程慧杰 李红 赵德玉 刘登鑫 吴正青 车帅 牛雪朋 铁勇魁 胡斌
受保护的技术使用者：许昌许继软件技术有限公司
技术研发日：2023.05.24
技术公布日：2023/10/7