TWI617208B - Method and system for connection monitoring of message queue protocol - Google Patents

Abstract

The invention provides a connection monitoring mechanism for a message queue protocol, which is suitable for a one-to-many or many-to-many communication mode. The communication monitoring system of the present invention discloses that at least one publishing device is configured to continuously send an online notification message at least for a specified time interval; a message proxy device; and at least one subscribing device is at least The configuration is to record and update the online notification record of each publishing device based on the online notification message, establish and periodically check the online status record table, find that the online status is offline, and continuously receive the online notification message of the publishing device, and then send the reconnection. Notification, requiring the publisher to resend the connection notification.

Description

Method and system for monitoring the connection of communication protocol

The present invention relates to a connection monitoring mechanism for a message queue protocol, and more particularly to a method and system for monitoring the connection of a message protocol for the Internet of Things.

Since the Internet of Things (IoT) has become a trend of future technology development, the highly flexible Publish/Subscribe (pub/sub) has gradually become the main communication mode of the Internet of Things, which is applicable to this communication mode. In the Internet of Things, the communication protocol for message transmission between devices and devices includes: MQTT, AMQP, RabbitMQ, and so on.

In the pub/sub communication mode, the subscriber subscribes to the topic of the message broker, and the message broker filters the message sent by the publisher, and then subscribes the subscriber through the message broker. The subject-related messages are sent to the subscriber, so it can be applied to one-to-one, many-to-one or one-to-many messaging systems in pub/sub.

But also because the message between the subscriber and the publisher must pass through the message proxy, and there is no direct information transfer between the subscriber and the publisher, and the message broker has no specification of the online status of the subscriber and the publisher, so that the subscription In the pub/sub communication mode, the online status of the publishing terminal cannot be updated in time and correctly. This problem will make the server side (which can be the subscription end) in the Internet of Things cannot provide accurate services to the client (which can be the publishing end), or cause the message. The problem of loss of interest.

Therefore, the market still needs to change the existing communication mode without increasing the burden of the message transmission on the system itself, but it can timely and correctly connect the monitoring mechanism to enhance the application scope of the Internet of Things system.

In view of the fact that the technology of the prior art cannot correctly and correctly grasp the online state of the device in the system, the present invention provides a connection monitoring mechanism for the message protocol, and provides the device manager without changing the existing communication protocol specification. A lightweight and accurate monitoring mechanism for online status of system devices.

The invention provides a connection monitoring system for a message queue protocol, which is used for monitoring the online status of devices in the system. The message monitoring system of the communication protocol includes: at least one publishing device, configured to communicate with a message The proxy device establishes a connection and continuously sends an online notification message including an online status to the message proxy device for a specified time interval; the message proxy device is configured to receive the online notification message and send the at least one publishing device The online notification message is to the at least one subscribing device; and the at least one subscribing device includes a first data storage device, and the at least one subscribing device is configured to establish a connection with the message proxy device, and record and update based on the online notification message An online notification message of each of the publishing devices to establish a first online status record table to record an online status and an update time record of each of the publishing devices, and store the first online status record in the first data storage Device, further check the online status of each publishing device and more regularly Time record, and send online messages proxy end device status notification message is not reconnect continuously updated on-line, but the publishing side of the device.

Furthermore, the present invention provides a method for monitoring the connection of a message queue protocol for monitoring the status of a device in a system. The method for monitoring the connection of the message protocol includes: at least one publisher device and a message agent The end device is connected to each other; each of the publishing devices continuously sends an online notification message including an online status to the message proxy device for a specified time interval; a subscribing device is connected to the message proxy device; and a subscribing device Subscribing to at least one online device related online notification message of the publishing device to the message proxy device; the message proxy device sending the online notification message to the subscribing device; and the subscribing device updating the online state of the at least one publishing device based on the online notification message The subscribing device periodically checks the online status of each of the publishing devices; and the subscribing device sends a reconnection notification message to the messaging device to the publishing device whose online status is not online but is continuously updated.

In addition, the present invention also provides a method for monitoring a connection of a message queue protocol, comprising: establishing an online status record record, recording an online status of each of the issue devices based on an online notification message of at least one of the issue devices; An update time record, defining a transmission period and a maximum tolerance loss number, and periodically checking the online status, comprising: determining whether the last update time to the inspection time exceeds a specified maximum tolerance time, wherein the maximum tolerance time is maximum tolerance The number of lost times is multiplied by the transfer time, and the following steps are performed: when the specified maximum tolerated time is exceeded and the online status of the publishing device is online, the online status is modified to be offline and the online status data of the publishing device is deleted, and the process ends. This periodic check; when the specified maximum tolerance time is exceeded and the online status of the publishing device is not online, the online status data of the publishing device is deleted, and the periodic inspection is ended; if the maximum tolerance time is not exceeded And when the online status of the publishing device is online, the node is The periodic inspection; online status or when the formulation does not exceed the maximum tolerable time and the release end of the device is not online, the message on behalf of the The remote device sends a reconnection notification message of the publishing device, and ends the periodic check.

The invention is to be understood as being limited to the details of the invention, and is not intended to limit the invention.

101-105‧‧‧Publishing device, Pub

110‧‧‧Message Agent Device, Broker

121-124‧‧‧Subscribing device, Sub

121a‧‧‧Data storage device

301, 303-304‧‧‧ messages

302, 401‧‧‧Subscription message

402-407, 603-606‧‧‧Online notification message

601-602, 608-609‧‧‧Online notification message

607‧‧‧Reconnection notification message

611-612‧‧‧Check regularly

701‧‧‧Online Status Record

501-506, 801-809‧‧‧ steps

The first figure is an architectural diagram illustrating an Internet of Things many-to-many system of the present invention.

The second figure is a device architecture diagram of one of the multi-systems of the present invention.

The third figure is a message transfer mode of the one-to-many system of the present invention under the MQTT communication protocol.

The fourth figure is a schematic diagram of message transmission of the connection monitoring mechanism of the present invention applied under the MQTT communication protocol.

The fifth figure is a flow chart of the connection monitoring of the present invention applied to the MQTT communication protocol.

The sixth figure is a schematic diagram of message transmission of the invention for applying the inspection mechanism of the connection monitoring under the MQTT communication protocol.

The seventh figure is an online status record table to which the present invention is applied under the MQTT communication protocol.

The eighth figure is a flow chart for checking the connection monitoring of the present invention under the MQTT communication protocol.

The connection monitoring mechanism of the message queue protocol provided by the present invention can be implemented by means of systems, methods, and the like. Therefore, the general knowledge in this field can understand that the connection monitoring mechanism is completed. It is implemented entirely in software, in combination with software and hardware, or entirely in hardware.

Many-to-many and one-to-many system architecture

The present invention is applicable to a communication model of a message queue, and can be applied to a one-to-many and many-to-many system architecture, see the first figure. The first figure is an architectural diagram illustrating an Internet of Things many-to-many system of the present invention, wherein the message proxy device 110 can simultaneously serve a plurality of subscribing devices 121, 122, 123, 124 and a plurality of publishing devices 101, 102, 103, 104, 105, wherein the subscribing devices 121, 122, 123, 124 can be computer computing devices such as servers and personal computers, and the publishing devices 101, 102, 103, 104, 105 can be personal computers, mobile phones, and senses. A computer arithmetic device such as a detector node device.

In particular, both the subscribing device and the publishing device are connected to the message proxy device without actual connection relationship with each other, wherein the connection mechanism does not limit the connection between the wireless or wired mode.

It can be seen from the above that such a one-to-many, many-to-many system architecture is applicable to the field of Internet of Things technology. The standard transmission protocol of M2M (Machine to Machine) communication can be applied to MQTT, AMQP, RabbitMQ, etc. The following is an example of MQTT. The protocol is wired and wirelessly wired using the TCP/IP connection protocol.

Please refer to the second figure. The second figure is a device architecture diagram of a multi-system according to the present invention. The subscriber device 121 (which may be a server) may include a data storage device 121a and is established with the message proxy device 110. The connection, and the distribution devices 101, 102, 103, 104, 105 respectively establish a connection with the message proxy device 110, but does not directly establish a connection with the subscribing device 121.

In this architecture, the subscribing device 121 subscribes to the message proxy device 110 for a topic, and the publisher device 101, 102, 103, 104, 105 transmits the message to the message broker. The message 110 is not directly transmitted to the subscribing device 121. The message proxy device 110 classifies all received messages and transmits the message related to the topic to the subscribing device 121. In addition, the subscribing device 121 can simultaneously subscribe to the plurality of topics to the message broker device 110, and the message proxy device 110 classifies one or more messages of different topics received by the publisher devices 101, 102, 103, 104, 105. And transmitting a message related to the subscribed plurality of topics to the subscribing device 121.

Connection monitoring mechanism

Please refer to the third figure. The third figure is a message transfer mode of the one-to-many system of the present invention under the MQTT protocol. The publishing device 101 (Pub) transmits the message 301 to the message proxy device 110 (broker). There will be at least one topic and data related to the topic, and the message broker device 110 will classify the materials according to the theme. However, because the message broker device 110 does not accept any topic related subscription messages, the message broker device 110 does not make any transmissions to the message 301.

When the subscribing device 121 (Sub) sends a subscription message 302 to the message broker device 110, the subscription message 302 will contain at least one subject. Therefore, when the publishing device 101 issues a message 303 including at least a topic and a topic-related data to the message proxy device 110, the message proxy device 110 will use the message 303 according to the theme. The data is classified, and the information of the same subject further sends a message 304 to the subscribing device 121.

Please refer to the fourth figure. The fourth figure is a connection monitoring mechanism applied to the MQTT communication protocol. The connection monitoring mechanism of the present invention further sets the issuer device 101 to send an online notification message including at least a connection monitoring subject (Keep-connection) to the message broker 110 for a specified time (eg, 60 seconds).

Therefore, when the subscribing device 121 sends the subscription message 401 including at least the connection monitoring subject to the message proxy device 110, the message proxy device 110 still accepts the issue device 101 to send at least the connection monitoring topic. (Keep-connection) online notification message 402.

The message proxy device 110 classifies the online notification message 402 and sends the online notification message 403 including at least the connection monitoring subject (Keep-connection) to the subscribing device 121, and the publishing device 101 is at a specified time (for example, 60 seconds). The interval notification message 404, 406 is continuously sent to the message proxy 110 for at least the connection monitoring subject (Keep-connection), and the subscribing device 121 receives the at least the connection monitoring topic sent by the message proxy device 110. (Keep-connection) online notification messages 405, 407.

As can be seen from the above, as long as the publishing device 101 is online on the system and continuously sends the online notification messages 402, 404, and 406 to the message proxy 110, the subscribing device 121 can be online including at least a connection monitoring theme (Keep-connection). The notification messages 405, 407 determine that the originating device 101 is online. The connection monitoring mechanism enables the subscribing device 121 to timely and correctly grasp the online status of the publishing device 101.

Preferably, the online notification message may further include the number (DeviceID) of the publishing device 101. The system to which the present invention is applicable may be a one-to-many or many-to-many system architecture. Therefore, the subscribing device 121 may judge by number simultaneously. Publisher devices (eg, 101, 102, 103, 104, 105).

Preferably, when the publishing device 101 needs to simultaneously send a message including at least a plurality of topics monitored by the connection, the connection monitoring topic may be merged with other topics to reduce the message blocking of the publishing device 101, and even if the message is fully loaded. In case of still maintaining a zone at a specified time The frequency of online notification messages.

Online status check mechanism

The present invention further provides an online status check mechanism, see Figure 5. The fifth figure is a flow chart of the connection monitoring of the present invention applied to the MQTT communication protocol, so that the status of the online notification message is lost due to factors such as unstable connection conditions of the publishing device, so that the subscribing device still considers The publisher device is offline, which may result in no further indication of the publisher device.

When the publishing device is connected to the message proxy device, the online notification message is sent to the message proxy device, and each of the publishing devices continuously sends the online notification related to the online state to the message proxy device for a specified time interval. Message (step 501). Preferably, the online notification message of the publishing device 101 can be enqueried in a non-online related notification message.

Therefore, when the subscribing device is connected to the message proxy device and subscribes to the at least one publishing device's online presence related online notification message to the message proxy device (step 502), the message proxy device sends the current message to the subscribing device. The online notification message is sent to the online publishing device, and the online notification message of the at least one publishing device is sent (step 503), wherein the at least one publishing device must first send the online notification message to the message proxy device.

The subscribing device updates the online status of each of the publishing device and the update time record of the online notification message based on the online notification message (step 504). Preferably, the online status and update time records of each of the publishing devices are respectively stored in the data storage device stored by the subscribing device. Preferably, the online status of each publishing device and the update time record of the online notification message are sequentially stored according to the number (DeviceID) of each publishing device.

Preferably, the message proxy device updates the online status of each of the publishing device and the update time record of the online notification message based on the online notification message. Preferably, the online status and update time records of each of the publishing devices are respectively stored in the data storage device included in the information agent device. Preferably, the online status of each publishing device and the update time record of the online notification message are sequentially stored according to the number (DeviceID) of each publishing device.

In addition, the subscriber device periodically checks the online status of each of the publisher devices (step 505). If the update time record of the online notification message is continuously updated, the message proxy device or the subscriber device continues to receive the publisher device. The online notification message, but when the online status of the publishing device is offline, the online notification message of the publishing device is lost.

Therefore, the subscribing device sends a reconnection notification message to the message proxy device (step 506), and the subscribing device changes the issuer when receiving an online notification message of the originating device. The online status of the device is changed to online.

This detection mechanism is greatly helpful to the system administrator. Correctly determining the online status of the device allows the system administrator to further instruct the on-line issuing device to perform an action or instruct other devices to perform reconnection or disconnection processing.

Please refer to the sixth figure. The sixth figure is a schematic diagram of message transmission of the inspection mechanism of the invention for applying the connection monitoring under the MQTT communication protocol. When the originating device 101 has sent the online notification message 601 to the message proxy device 110, the message loss occurs when the message proxy device 110 transmits the online notification message 602 of the publishing device 101 to the subscribing device 121.

Then, the originating device 101 continues to send the online notification message 603, 605 including at least the connection monitoring subject (Keep-connection) to the subscribing device 121, and the subscribing device 121 Online notification messages 604, 606, at least including a link-up monitoring subject (Keep-connection) sent by the message broker device 110, are also continuously received.

The subscribing device 121 periodically checks 611 for the update time record of the online notification message that may not have been updated. Therefore, the subscribing device 121 will surely find that the update time record of the online notification message is updated at least when the periodic check 612 is performed, and the issue device is updated. The online status of 101 is offline.

In this case, the subscribing device 121 transmits the reconnection notification message 607 of the distribution device 101 to the message proxy device 110, and the message proxy device 110 transmits the reconnection notification message 607a to the distribution device 101, and then issues the message. The end device 101 sends an online notification message 608 in response to the request, and the subscribing device 121 updates the online status of the issuing device 101 after receiving the first notification message 609.

Online message record update mechanism

Please refer to the seventh figure. The seventh figure is an online status record table of the present invention applied to the MQTT communication protocol. The subscribing device 121 updates the update time record in the online status record table 701 according to the received online notification message, wherein the online status record table 701 is stored in the data storage device 121a of the subscribing device 121 (eg, a server).

Preferably, the online status record table 701 can further store the online status of the issuer devices 101, 102, 103, 104, 105. Preferably, the online status record table 701 can be stored in the data storage device included in the message broker device 110. Preferably, the data storage device of the message proxy device 110 and the data storage device of the subscribing device 121 respectively store the online state record table 701, which can be used in comparison with the comparison. Preferably, the subscribing device 121 can further determine the validity of the non-online status related message based on the online status record table 701.

Please refer to the eighth figure. The eighth figure is a flow chart for checking the connection monitoring of the present invention under the MQTT communication protocol. The present invention further provides an update mechanism for the online status record table to ensure the correctness and immediacy of the information provided to the system.

The system administrator can set a transmission time and a maximum tolerance loss number according to requirements, wherein the transmission time can be set as the time when the online notification message is sent from the issuing device 101, 102, 103, 104, 105 to the subscribing device 121. The time difference between the last time you received the online notification message, for example: 60 seconds, 30 seconds, and so on. Preferably, the time can be adjusted depending on the needs of the system administrator or the difference in system architecture. In addition, the system administrator can set a maximum tolerance loss count as required, and the maximum tolerance time will be related to the transmission time and the maximum number of tolerable loss. In this embodiment, the maximum tolerance time is the transmission time multiplied by the maximum tolerance loss number plus one. For example, when the transmission time is 60 seconds and the maximum tolerance loss number is 2, the maximum tolerance time is 180 seconds.

In this field, the general knowledge person should understand that the maximum tolerance time is the system's latest update time requirement for the online notification message. When the maximum tolerance time is exceeded, the system determines that the publishing device is offline and further deletes the unupdated online notification message. The time record is updated online to help reduce the amount of data that needs to be read in the online status record table 701 for the next check.

When the periodic check mechanism of the subscribing device 121 starts (step start), at a specified time period, the subscribing device periodically checks the online status record table (step 801) and online status of each of the issuer devices.

The subscribing device calculates a time difference from the last update time of the update time record of each of the issuer devices to the check time (current time) (step 802), and determines whether the time difference exceeds the maximum tolerance time (step 803). When the maximum tolerance time is not exceeded, it is checked whether the online status of the issuing device is online (step 804), and if the online status of the publishing device is online, the end is ended. This check (end of step); if the online status of the publishing device is offline, the re-connection notification message of the publishing device is sent to the message proxy device (step 805), and the current check is ended (the step ends).

However, when the maximum tolerance time is exceeded, it is checked whether the online status of the publishing device is online (step 806), and if the online status of the publishing device is online, the online status of the publishing device is changed to offline (step 807). And deleting the update time record of the publishing device (step 808), and then ending the current check (the step ends); if the online state of the publishing device is offline, deleting the update time record of the publishing device (step 808), And end this check (end of step).

The vocabulary used herein is for illustrative purposes only, and is not intended to limit the scope of the invention. The functions, steps and components described in the specification are not limited to a specific number, and those skilled in the art can understand one or more functions, steps and components. It is within the scope of the invention to achieve the same or similar effects.

Claims (20)

A connection monitoring system for a message routing protocol, comprising: at least one publishing device configured to: establish a connection with a message proxy device; and continuously send the message to the message proxy device for a specified time interval Include an online notification message related to the online status; the message proxy device is configured to: receive the online notification message of the at least one publishing device; and send the online notification message to the at least one subscribing device; and at least one a subscriber device, comprising: a first data storage device, at least one of the subscriber devices configured to: establish a connection with the message proxy device; record and update each online notification of the publisher device based on the online notification message a message, a first online status record table is created to record an online status and an update time record of each of the publishing device, and stored in the first data storage device; and the online of each of the publishing devices is periodically checked. Status and the update time record, and resend the online status to the message proxy device The release notification to reconnect the line on one end of the device. The connection monitoring system of claim 1, wherein the subscription device sets a maximum tolerance time, and when the latest online update status corresponding to the first online status record table is recorded, the update time is recorded to the periodic check. The checking time exceeds the maximum tolerance time, and the corresponding update time record in the first online status record table is deleted. The connection monitoring system of claim 2, wherein when the corresponding online status in the first online status record table is online, the corresponding online status in the first online status record is changed to offline. And deleting the corresponding update time record in the first online status record table. The connection monitoring system of claim 1, wherein the subscribing device further assigns a specific one or more of the issuing devices to perform one or more actions based on the first online status record table. The connection monitoring system of claim 1, wherein the online notification message of the publishing device is entrained in a non-online related notification message. The connection monitoring system of claim 5, wherein the subscribing device further determines the validity of the non-online status related message based on the first online status record table. The connection monitoring system of claim 5, wherein the message proxy device comprises a second data storage device, based on the online notification message, establishing and continuously updating a second of the at least one publishing device The online status record table is stored in the second data storage device. The connection monitoring system of claim 7, wherein the subscribing device further assigns a specific one or more of the issuing devices to perform one or more actions based on the second online status record table. The connection monitoring system of claim 8, wherein the subscribing device further determines, according to the first online status record table and/or the second online status record table, that the information related to the non-online status is valid. Sex. A method for monitoring the connection of a communication protocol, comprising: At least one publishing device is connected to a message proxy device; each of the publishing devices continuously sends an online notification message including an online state to the message proxy device for a specified time interval; a subscribing device and the The message proxy device is connected to the message proxy device, and subscribes to the at least one online notification message of the publishing device that is related to the online state; the message proxy device sends the online notification message to the subscription terminal The device: the subscription device records and updates at least one online status of the publishing device based on the online notification message to a first online status record table, where the first online status record table records at least one online of each of the publishing devices. a status and an update time record; the subscribing device periodically checks the online status of each of the publishing devices; and the subscribing device transmits to the message proxy device one of the publishing devices whose online status is not online Reconnect notification message. The method for monitoring a connection according to claim 10, further comprising: setting, by the subscribing device, a maximum tolerance time, when the latest update time of the online state corresponding to the first online status record table is recorded The inspection time of the periodic inspection exceeds the maximum tolerance time, and the corresponding update time record in the first online status record table is deleted. The connection monitoring method of claim 11, further comprising: when the online status corresponding to the first online status record table is online, the corresponding online status change in the first online status record table The offline line is deleted, and the corresponding update time record in the first online status record table is deleted. The method for monitoring a connection as described in claim 10, further comprising: the message agent The end device simultaneously provides at least one of the subscribing device services. The method for monitoring a connection according to claim 10, further comprising: the subscribing device further assigning the one or more specific publishing device to perform one or more actions based on the first online status record table. The method for monitoring the connection according to claim 10, further comprising: the online notification message of the publishing device may be entrapped in a notification message related to the offline state. The method for monitoring a connection according to claim 15, further comprising: the subscribing device further determining the validity of the information related to the offline status based on the first online status record table. The method for monitoring a connection according to claim 15 , further comprising: the message proxy device, based on the online notification message, establishing and continuously updating a second online status record table of the at least one publishing device. The method for monitoring a connection according to claim 17, further comprising: the subscribing device further assigning the one or more specific publishing device to perform one or more actions based on the second online status record table. The method for monitoring a connection according to claim 18, further comprising: the subscribing device further determining, by the first online status record table and/or the second online status record table, the notification related to determining the non-online status The validity of the message. A method for monitoring a connection of a communication protocol includes establishing an online status record record, and recording an online status and an update time record of each of the distribution devices based on an online notification message of at least one of the distribution devices. Define a delivery period and a maximum tolerance loss count, and periodically check the online status, which includes: Determining whether the last updated time to the inspection time exceeds a specified maximum tolerance time, wherein the maximum tolerance time is the maximum tolerance loss number plus one multiplied by the transmission time, and performing the following steps: when the specified maximum tolerance is exceeded If the online status of the publishing device is online, modify the online status to be offline and delete the online status data of the publishing device, and end the periodic check; when the specified maximum tolerance time is exceeded and the issuing end If the online status of the device is not online, the online status data of the publishing device is deleted, and the current periodic check is ended; and when the established maximum tolerance time is not exceeded and the online status of the publishing device is online, Ending the periodic check; or when the specified maximum tolerance time is not exceeded and the online status of the publishing device is not online, sending a reconnection notification message to the message proxy device And end this regular inspection.