CN115242768A - Data forwarding method and device for subway comprehensive monitoring system and storage medium - Google Patents
Data forwarding method and device for subway comprehensive monitoring system and storage medium Download PDFInfo
- Publication number
- CN115242768A CN115242768A CN202210756729.6A CN202210756729A CN115242768A CN 115242768 A CN115242768 A CN 115242768A CN 202210756729 A CN202210756729 A CN 202210756729A CN 115242768 A CN115242768 A CN 115242768A
- Authority
- CN
- China
- Prior art keywords
- subscription
- data
- message
- monitoring system
- subway
- 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
Links
- 238000012544 monitoring process Methods 0.000 title claims abstract description 76
- 238000000034 method Methods 0.000 title claims abstract description 27
- 230000004044 response Effects 0.000 claims abstract description 14
- 238000004891 communication Methods 0.000 claims description 14
- 238000004590 computer program Methods 0.000 claims description 10
- 238000007781 pre-processing Methods 0.000 claims description 9
- 238000006243 chemical reaction Methods 0.000 claims description 3
- 238000005070 sampling Methods 0.000 claims description 3
- 230000003993 interaction Effects 0.000 abstract description 6
- 238000010586 diagram Methods 0.000 description 9
- 238000012545 processing Methods 0.000 description 6
- 230000006870 function Effects 0.000 description 4
- 238000012423 maintenance Methods 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 230000008859 change Effects 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 238000013507 mapping Methods 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 238000004364 calculation method Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000007613 environmental effect Effects 0.000 description 1
- 238000004519 manufacturing process Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 238000012856 packing Methods 0.000 description 1
Images
Classifications
-
- 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/02—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP]
- H04L67/025—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP] for remote control or remote monitoring of applications
-
- 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/02—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP]
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Train Traffic Observation, Control, And Security (AREA)
Abstract
The invention discloses a data forwarding method, a device and a storage medium of a subway integrated monitoring system, wherein the data forwarding method comprises the following steps: generating a subscription message according to the subscription requirement of a third-party system and sending the subscription message to a subway comprehensive monitoring system, wherein the subscription message comprises a message notification type, timeout time and a data receiving callback address; judging whether to allow subscription according to the subscription message, generating a subscription response message, and if the subscription is successful, containing a subscription identifier in the subscription response message; after the subscription is successful, acquiring data to be forwarded required by the subscription message from the subway comprehensive monitoring system according to the message notification type; pushing the data to be forwarded to a third-party system according to the data receiving callback address; and after the third-party system finishes data receiving, generating a subscription cancellation message according to the subscription identifier and sending the subscription cancellation message to the subway comprehensive monitoring system. The invention can realize the high-efficiency data interaction between the subway comprehensive monitoring system and other third-party systems, and ensures the safety and reliability of data forwarding.
Description
Technical Field
The invention relates to a data forwarding method, a data forwarding device and a storage medium of a subway comprehensive monitoring system, and belongs to the technical field of subway comprehensive monitoring management.
Background
Urban rail transit has the advantages of punctuality, safety, comfort, environmental protection and the like, and the domestic urban rail transit shows a rapid development trend in recent years. The rail transit system comprises a plurality of software and hardware systems, such as an environment monitoring system, an access control system, a fire alarm system, an electric power monitoring system, a broadcasting system, a passenger information system, a ticket selling and checking system, a security door system and the like, most of the subsystems are independent, data acquisition, forwarding and calculation are carried out in the subsystems, data interaction exists among partial subsystems, different subsystems are monitored and operated by different workers, the operation cost is high, and the efficiency is limited.
At present, a comprehensive monitoring system is provided, which utilizes a unified software and hardware platform to exchange data with each subsystem in rail transit, each subsystem sends the data to the comprehensive monitoring system, and the comprehensive monitoring system realizes resource sharing and common maintenance management among different systems, thereby improving the operating efficiency of the system.
Disclosure of Invention
In order to solve the problems in the prior art, the invention provides a data forwarding method, a data forwarding device and a storage medium for a subway integrated monitoring system, which are used for realizing efficient data interaction between the subway integrated monitoring system and other third-party systems based on a general event notification architecture GENA, ensuring the safety and reliability of data forwarding and providing powerful guarantee for the safe and efficient operation of rail transit.
In order to solve the technical problems, the invention adopts the following technical means:
in a first aspect, the invention provides a data forwarding device of a subway integrated monitoring system, which comprises a forwarding data configuration module, a forwarding data preprocessing module and a GENA communication management module;
the forwarding data configuration module is used for configuring data of the subway comprehensive monitoring system according to forwarding requirements;
the forwarding preprocessing module is used for updating the value and the state of data to be forwarded in the subway comprehensive monitoring system according to the configuration information of the forwarding data configuration module, acquiring and organizing data of the subway comprehensive monitoring system according to a subscription message of a third-party system, adding a subscription identifier and then forwarding the data to the GENA communication management module;
and the GENA communication management module is used for interacting with a third-party system through an expanded HTTP command and forwarding the data stream to be forwarded to the third-party system according to the subscription identifier and an agreed format.
With reference to the first aspect, further, the configuration information includes a data name, a conversion coefficient, and a sampling period.
With reference to the first aspect, further, the extended HTTP commands include SUBSCRIBE commands, UNSUBSCRIBE commands, and NOTIFY commands.
In a second aspect, the invention provides a data forwarding method for a subway integrated monitoring system, which comprises the following steps:
generating a subscription message according to the subscription requirement of a third-party system and sending the subscription message to a subway comprehensive monitoring system, wherein the subscription message comprises a message notification type, timeout time and a data receiving callback address;
judging whether to allow subscription according to the subscription message, generating a subscription response message, and if the subscription is successful, containing a subscription identifier in the subscription response message;
after the subscription is successful, acquiring data to be forwarded required by the subscription message from the subway comprehensive monitoring system according to the message notification type in the subscription message;
pushing the data to be forwarded to a third-party system according to the data receiving callback address;
and after the third-party system finishes data receiving, generating a subscription cancellation message according to the subscription identifier and sending the subscription cancellation message to the subway comprehensive monitoring system to finish data forwarding.
With reference to the second aspect, further, according to the subscription requirement of the third-party system, subscribing to the message event of the subway integrated monitoring system through the SUBSCRIBE command of HTTP, and generating subscription information.
With reference to the second aspect, further, the data to be forwarded is pushed to the third-party system according to the data receiving callback address through the NOTIFY command of HTTP.
With reference to the second aspect, further, after the third-party system completes data reception, a subscription cancellation message is generated according to the subscription identifier and through an UNSUBSCRIBE command of HTTP.
In a third aspect, the invention provides a data forwarding device for a subway integrated monitoring system, which comprises a processor and a storage medium;
the storage medium is used for storing instructions;
the processor is configured to operate in accordance with the instructions to perform the steps of the method of the second aspect.
In a fourth aspect, the invention proposes a computer-readable storage medium, on which a computer program is stored which, when being executed by a processor, carries out the steps of the method according to the second aspect.
The following advantages can be obtained by adopting the technical means:
the invention provides a data forwarding method, a device and a storage medium of a subway integrated monitoring system, which are used for realizing efficient data interaction between the subway integrated monitoring system and other third-party systems based on a general event notification architecture GENA, acquiring and forwarding data according to subscription information in the data forwarding process, quickly positioning required data, avoiding the need of periodically polling a database to detect data change, improving the data forwarding efficiency, ensuring the safety and reliability of data forwarding, carrying out resource sharing and common maintenance management through the subway integrated management system, reducing the subway operation cost, improving the subway monitoring effect and providing powerful guarantee for the safe and efficient operation of rail transit.
Drawings
Fig. 1 is a schematic structural diagram of a data forwarding device of a comprehensive subway monitoring system according to the present invention;
FIG. 2 is a flow chart illustrating steps of a data forwarding method of a comprehensive subway monitoring system according to the present invention;
fig. 3 is a flowchart illustrating a subscription of a train monitoring system to a power supply information event according to an embodiment of the present invention.
Detailed Description
The technical scheme of the invention is further explained by combining the accompanying drawings as follows:
general Event Notification Architecture (GENA), which can provide the ability to send and receive messages, can use message Notification-based subscriptions to enable communication between interconnected systems, by subscribing to specified events related to the system of interest by client systems using HTTP messages, without having to periodically poll databases to detect data changes. GENA provides a solution for the efficient data interaction between the comprehensive monitoring system and the third-party system.
Example 1:
the invention provides a data forwarding device of a subway comprehensive monitoring system, which mainly comprises a forwarding data configuration module, a forwarding data preprocessing module and a GENA communication management module as shown in figure 1.
The forwarding data configuration module is used for configuring data of the subway comprehensive monitoring system according to forwarding requirements, such as subarea warning information of a fire warning system, contact net live information of a power supply system and the like, the configuration information comprises a data name, a conversion coefficient, a sampling period and the like, and the configuration information can be adjusted in real time according to the cluttering requirements.
The forwarding preprocessing module is used for updating the value and the state of data to be forwarded in the subway comprehensive monitoring system according to the configuration information of the forwarding data configuration module, acquiring and organizing data of the subway comprehensive monitoring system according to the subscription message of the third-party system, adding the subscription identifier and then forwarding the data to the GENA communication management module.
The GENA communication management module is used for interacting with a third-party system through an expanded HTTP command and forwarding the data stream to be forwarded to the third-party system according to the subscription identifier and the appointed format, wherein the expanded HTTP command comprises a SUBSCRIBE command, an UNSUBSCRIBE command and a NOTIFY command.
Example 2:
the invention also provides a data forwarding method of the subway integrated monitoring system, which specifically comprises the following steps as shown in fig. 2:
step A, generating a subscription message according to subscription requirements of a third-party system and sending the subscription message to a subway comprehensive monitoring system, wherein the subscription message comprises information such as a message notification type, timeout time, a data receiving callback address and the like, and the message notification type identifies specific types of data required by the third-party system, such as fire alarm information and contact network electrification information.
The generation method of the subscription message comprises the following steps: and according to the subscription requirement of the third-party system, subscribing the message event of the subway comprehensive monitoring system through the SUBSCRIBE command of the HTTP to generate subscription information.
And step B, judging whether the subscription is allowed according to the subscription message, generating a subscription response message and sending the subscription response message to a third-party system. And analyzing the information in the subscription message by using the subway comprehensive monitoring system, judging whether the data required by the subscription message can be forwarded or not, if so, generating a subscription response message with successful subscription, and if not, generating a subscription response message with failed subscription.
If the subscription is successful, the subscription response message contains a unique subscription identifier.
And C, after the subscription is successful, acquiring data (changed data or full data) to be forwarded, which is required by the subscription message, from the subway comprehensive monitoring system according to the message notification type in the subscription message.
And step D, pushing the data to be forwarded to a third-party system according to the data receiving callback address through a NOTIFY command of the HTTP.
And E, after the third-party system finishes data receiving, generating a subscription cancellation message according to the subscription identifier and sending the subscription cancellation message to the subway comprehensive monitoring system to finish data forwarding. The third-party system can generate a subscription cancellation message through an UNSUBSCRIBE command of HTTP, and cancel the message event corresponding to the subscription specific identifier.
Example 3:
the invention also provides a data forwarding device of the subway comprehensive monitoring system, which comprises a processor and a storage medium; wherein the storage medium is used for storing instructions; the processor is configured to operate according to the instruction to execute the steps of the data forwarding method of the subway integrated monitoring system in embodiment 2.
Example 4:
the present invention also proposes a computer-readable storage medium, on which a computer program is stored, which when executed by a processor, implements the steps of the data forwarding method of the subway integrated monitoring system in embodiment 2.
The following explains the present invention by taking the subscription of the power supply information of the train monitoring system as an example, as shown in fig. 3:
s1, subscribing power supply information events for train monitoring system
The train monitoring system serves as a GENA client side, sends a subscription message to a GENA server side (namely a subway comprehensive monitoring system) through an HTTP extension command SUBSCRIBE, declares that the train monitoring system is interested in a power supply information event of the subway comprehensive monitoring system, and comprises the following steps:
SUBSCRIBE /PowerSection HTTP/1.1 CRLF
NT: gena:birth, gena:update CRLF
Timeout:60000 CRLF
Call-Back:http://192.168.1.2:8888/dataRecv CRLF
CRLF
wherein,/PowerSection represents subscription power supply information, NT message header represents a notification list, gena: birthday represents a notification generation message, gena: update represents a notification update message, timeout message header represents a Timeout value in milliseconds, and Call-Back represents a URI of a data receiving server of a gena client.
S2, the subway comprehensive monitoring system responds to the subscription and generates a subscription response message. When the subscription is successful, the subway integrated monitoring system responds to a HTTP 200 status code message without content, wherein a message header contains a subscription identifier SID distributed by the subway integrated monitoring system, and subscription response messages with status codes larger than 300 are all considered as subscription failures. The subscription response message with successful subscription is as follows:
HTTP/1.1 200 OK CRLF
SID: 12345678 CRLF
CRLF
and S3, forwarding the power supply information event by the subway comprehensive monitoring system.
After receiving a subscription message of the train monitoring system, a GENA communication module of the subway comprehensive monitoring system analyzes a message event in the URI and an NT part in a message header, then sends the message event subscribed by the GENA client, a message notification type and a subscription identifier to a data preprocessing module in a data flow mode, and simultaneously maintains a mapping relation between the subscription identifier and a data receiving callback URI; the data preprocessing module maintains the mapping relation between the subscription identifier and the message event, and packages all attributes of the message event to be sent to the GENA communication module for the next processing after receiving a subscription message for the first time if a message generated by subscribing the message event by the client; and if the client subscribes the update message of the message event, only packing the changed attribute and sending the packed attribute to the GENA communication module for further processing after the attribute of the message event changes. The GENA communication module routes to the corresponding data receiving callback URI according to the subscription identifier in the data packet sent by the data preprocessing module, and pushes the data to the train monitoring system through the expanded HTTP command NOTIFY.
The method comprises the following steps of sending an update message of a message event to a subway comprehensive monitoring and controlling system:
NOTIFY /dataRecv HTTP 1.1 CRLF
Content-Length : 235 CRLF
NT: gena:update CRLF
SID: 12345678 CRLF
<Envelope>
CRLF
<Body cls="PowerSection" obj="1">
<PowerStatus>Energized</PowerStatus>
</Body>
<Body cls="PowerSection" obj="2">
<PowerStatus>Energized</PowerStatus>
</Body>
</Envelope>
and S4, canceling the subscription of the power supply information event by the train monitoring system. If the train monitoring system needs to cancel the subscription power supply information event, a subscription cancellation message can be sent through an extended HTTP command UNSUBSCRIBE, wherein a message header of the subscription cancellation message needs to contain a subscription identifier. The subscription cancellation message is as follows:
UNSUBSCIBE /PowerSection HTTP/1.1 CRLF
SID: 12345678 CRLF
Content-Length: 0 CRLF
CRLF
the invention realizes the high-efficiency data interaction between the subway comprehensive monitoring system and other third-party systems based on the GENA, acquires and forwards data according to subscription information in the data forwarding process, can quickly position the required data, does not need to periodically poll a database to detect data change, improves the data forwarding efficiency, can ensure the safety and reliability of data forwarding, carries out resource sharing and common maintenance management through the subway comprehensive management system, can reduce the subway operation cost, improves the subway monitoring effect, and provides powerful guarantee for the safe and high-efficiency operation of rail transit.
As will be appreciated by one skilled in the art, embodiments of the present application may be provided as a method, system, or computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein.
The present application is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems), and computer program products according to embodiments of the application. It will be understood that each flow and/or block of the flow diagrams and/or block diagrams, and combinations of flows and/or blocks in the flow diagrams and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
The above description is only a preferred embodiment of the present invention, and it should be noted that, for those skilled in the art, several modifications and variations can be made without departing from the technical principle of the present invention, and these modifications and variations should also be regarded as the protection scope of the present invention.
Claims (9)
1. The data forwarding device of the subway integrated monitoring system is characterized by comprising a forwarding data configuration module, a forwarding data preprocessing module and a GENA communication management module;
the forwarding data configuration module is used for configuring data of the subway comprehensive monitoring system according to forwarding requirements;
the forwarding preprocessing module is used for updating the value and the state of data to be forwarded in the subway comprehensive monitoring system according to the configuration information of the forwarding data configuration module, acquiring and organizing data of the subway comprehensive monitoring system according to a subscription message of a third-party system, adding a subscription identifier and then forwarding the data to the GENA communication management module;
and the GENA communication management module is used for interacting with a third-party system through an expanded HTTP command and forwarding the data stream to be forwarded to the third-party system according to the subscription identifier and an agreed format.
2. The data forwarding device of claim 1, wherein the configuration information comprises a data name, a conversion coefficient and a sampling period.
3. The integrated monitoring system data forwarding apparatus for subway according to claim 1, wherein said extended HTTP commands include SUBSCRIBE command, UNSUBSCRIBE command and NOTIFY command.
4. A data forwarding method of a subway integrated monitoring system is characterized by comprising the following steps:
generating a subscription message according to the subscription requirement of a third-party system and sending the subscription message to a subway comprehensive monitoring system, wherein the subscription message comprises a message notification type, timeout time and a data receiving callback address;
judging whether to allow subscription according to the subscription message, generating a subscription response message, and if the subscription is successful, containing a subscription identifier in the subscription response message;
after the subscription is successful, acquiring data to be forwarded required by the subscription message from the subway comprehensive monitoring system according to the message notification type in the subscription message;
pushing the data to be forwarded to a third-party system according to the data receiving callback address;
and after the third-party system finishes data receiving, generating a subscription cancellation message according to the subscription identifier and sending the subscription cancellation message to the subway comprehensive monitoring system to finish data forwarding.
5. The data forwarding method of claim 4, wherein subscription information is generated by subscribing to a message event of the subway integrated monitoring system through a SUBSCRIBE command of HTTP according to a subscription requirement of a third-party system.
6. The data forwarding method of the integrated subway monitoring system as claimed in claim 4, wherein the data to be forwarded is pushed to the third party system according to the data receiving callback address by the NOTIFY command of HTTP.
7. The data forwarding method of claim 4, wherein after the third-party system completes data reception, a subscription cancellation message is generated according to the subscription identifier and through an UNSUBSCRIBE command of HTTP.
8. The data forwarding device of the subway integrated monitoring system is characterized by comprising a processor and a storage medium;
the storage medium is used for storing instructions;
the processor is configured to operate in accordance with the instructions to carry out the steps of the method according to any one of claims 4 to 7.
9. Computer-readable storage medium, on which a computer program is stored which, when being executed by a processor, carries out the steps of the method according to any one of claims 4 to 7.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210756729.6A CN115242768A (en) | 2022-06-30 | 2022-06-30 | Data forwarding method and device for subway comprehensive monitoring system and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210756729.6A CN115242768A (en) | 2022-06-30 | 2022-06-30 | Data forwarding method and device for subway comprehensive monitoring system and storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN115242768A true CN115242768A (en) | 2022-10-25 |
Family
ID=83670551
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202210756729.6A Pending CN115242768A (en) | 2022-06-30 | 2022-06-30 | Data forwarding method and device for subway comprehensive monitoring system and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115242768A (en) |
Citations (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20050267935A1 (en) * | 1999-06-11 | 2005-12-01 | Microsoft Corporation | Data driven remote device control model with general programming interface-to-network messaging adaptor |
| US20070192325A1 (en) * | 2006-02-01 | 2007-08-16 | Morris Robert P | HTTP publish/subscribe communication protocol |
| CN103888437A (en) * | 2013-03-01 | 2014-06-25 | 上海富欣智能交通控制有限公司 | Protocol conversion method sending data from control center to emergency center |
| WO2018206610A1 (en) * | 2017-05-08 | 2018-11-15 | Apollo Rail Ltd | A decentralised communications based train control system |
| US20180359201A1 (en) * | 2017-06-09 | 2018-12-13 | Equinix, Inc. | Near real-time messaging service for data center infrastructure monitoring data |
| CN109743344A (en) * | 2018-10-12 | 2019-05-10 | 比亚迪股份有限公司 | The event storage method and its equipment of comprehensive monitoring system based on rail traffic |
| CN110266801A (en) * | 2019-06-24 | 2019-09-20 | 宁波中车时代电气设备有限公司 | A kind of gate monitoring system and method based on subscription Issuance model |
| WO2020038447A1 (en) * | 2018-08-23 | 2020-02-27 | 比亚迪股份有限公司 | Integrated network management method and apparatus for rail traffic system, and system |
| CN111857585A (en) * | 2020-07-10 | 2020-10-30 | 苏州浪潮智能科技有限公司 | Storage system custom service function configuration method, device, device and medium |
| CN112104720A (en) * | 2020-09-03 | 2020-12-18 | 国电南瑞科技股份有限公司 | MQTT double-Broker data interaction method and system suitable for edge Internet of things terminal |
-
2022
- 2022-06-30 CN CN202210756729.6A patent/CN115242768A/en active Pending
Patent Citations (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20050267935A1 (en) * | 1999-06-11 | 2005-12-01 | Microsoft Corporation | Data driven remote device control model with general programming interface-to-network messaging adaptor |
| US20070192325A1 (en) * | 2006-02-01 | 2007-08-16 | Morris Robert P | HTTP publish/subscribe communication protocol |
| CN103888437A (en) * | 2013-03-01 | 2014-06-25 | 上海富欣智能交通控制有限公司 | Protocol conversion method sending data from control center to emergency center |
| WO2018206610A1 (en) * | 2017-05-08 | 2018-11-15 | Apollo Rail Ltd | A decentralised communications based train control system |
| US20180359201A1 (en) * | 2017-06-09 | 2018-12-13 | Equinix, Inc. | Near real-time messaging service for data center infrastructure monitoring data |
| WO2020038447A1 (en) * | 2018-08-23 | 2020-02-27 | 比亚迪股份有限公司 | Integrated network management method and apparatus for rail traffic system, and system |
| CN109743344A (en) * | 2018-10-12 | 2019-05-10 | 比亚迪股份有限公司 | The event storage method and its equipment of comprehensive monitoring system based on rail traffic |
| CN110266801A (en) * | 2019-06-24 | 2019-09-20 | 宁波中车时代电气设备有限公司 | A kind of gate monitoring system and method based on subscription Issuance model |
| CN111857585A (en) * | 2020-07-10 | 2020-10-30 | 苏州浪潮智能科技有限公司 | Storage system custom service function configuration method, device, device and medium |
| CN112104720A (en) * | 2020-09-03 | 2020-12-18 | 国电南瑞科技股份有限公司 | MQTT double-Broker data interaction method and system suitable for edge Internet of things terminal |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111737329A (en) | Unified data acquisition platform for rail transit | |
| CN112549029B (en) | Robot behavior control method and device based on behavior tree | |
| CN103927218B (en) | Event distributing method and system | |
| CN101446965B (en) | Data query method and system thereof | |
| KR101886855B1 (en) | Method and system for update message tracking and checking | |
| CN112711635B (en) | Method for cross-regional data consistency of distributed Internet of things equipment and service cluster | |
| CN108881408A (en) | A kind of multi-service operating system based on platform of internet of things | |
| CN105260842B (en) | Communication method and system between heterogeneous ERP systems | |
| CN110008267B (en) | Data processing system and method | |
| CN116382943A (en) | Sequential message processing method, bus system, computer device, and storage medium | |
| CN103544060A (en) | WEBSERVICE based service dispatching system and method | |
| Morariu et al. | Manufacturing service bus integration model for implementing highly flexible and scalable manufacturing systems | |
| CN104217314B (en) | Routing iinformation grasping means and device | |
| CN115242768A (en) | Data forwarding method and device for subway comprehensive monitoring system and storage medium | |
| CN113051086B (en) | Data processing method and device, electronic equipment and storage medium | |
| CN114124881A (en) | Message pushing method based on priority and related device | |
| JP2009515474A (en) | Independent message store and message transport agent | |
| CN113641509A (en) | Internet of things data processing method and device | |
| JP2000075907A (en) | Production system | |
| CN116886792A (en) | Intelligent operation message and data hub center system | |
| CN114501347B (en) | Method, device and system for information interaction between heterogeneous systems | |
| JP7013326B2 (en) | Information processing system, information processing device, and control method of information processing system | |
| Tjung et al. | A Model And Implementation Of Academic Data Integration In Near-Real Time Using Message-Oriented Middleware To Support Analysis Of Student Performance In The Information Technology Department Of Politeknik Caltex Riau | |
| CN111988283A (en) | Data transmission method, system, device and computer readable storage medium | |
| CN106850283B (en) | Event-driven cloud AC alarm processing system and method |
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 |