Message Publishing and Subscribing Method and Apparatus

• US 20150006555A1
• Filed: 09/18/2014
• Published: 01/01/2015
• Est. Priority Date: 06/03/2013
• Status: Active Grant

• Current Assignee: Huawei Technologies Co., Ltd. (Huawei Investment & Holding Co., Ltd.)
• Original Assignee: Huawei Technologies Co., Ltd. (Huawei Investment & Holding Co., Ltd.)
• Inventors: Fang, Yuan, Tang, Guanjun, Wang, Yunpeng
• Granted Patent: US 9,110,884 B2
• Time in Patent Office: Days
• US Class Current: 707/755
• CPC Class Codes: G06F 40/30 Semantic analysis
• CPC Class Codes: H04L 51/212 using filtering or selective blocking
• CPC Class Codes: H04L 51/214 using selective forwarding

Abstract

A message publishing and subscribing method and apparatus, which relate to the information processing field and provide higher information transmission efficiency and better flexibility mainly by providing a corresponding dummy topic in a message broker for a publisher and a subscriber or by performing semantic recognition in the message broker for the publisher and the subscriber.

Claims

1. A message publishing method comprising:

obtaining a message that a publisher has sent to a dummy topic corresponding to the publisher;

searching for, according to a stored routing rule, all transmission paths with the dummy topic corresponding to the publisher being a start point and the dummy topic corresponding to any one subscriber being an end point, wherein the dummy topic is configured to forward a message between the actual topic, and wherein the actual topic is configured to forward a message between the publisher and the subscriber;

transmitting the message or identification information corresponding to the message on a found transmission path when the transmission path with the dummy topic corresponding to the publisher being the start point and the dummy topic corresponding to any one subscriber being the end point is found; and

sending the message to a subscriber corresponding to the end point of the transmission path after the message or the identification information corresponding to the message is transmitted to an end point of each transmission path.

2. The method according to claim 1, wherein the dummy topic is further configured to forward a message between the actual topic and the subscriber.

3. The method according to claim 1 further comprising:

performing semantic parsing on the message to obtain a semantic parsing result when the transmission path with the dummy topic corresponding to the publisher being the start point and the dummy topic corresponding to any one subscriber being the end point is not found;

searching for, according to the semantic parsing result, an actual topic that matches the semantic parsing result in stored actual topics; and

generating and storing a routing rule between the dummy topic corresponding to the publisher and the found actual topic when the actual topic that matches the semantic parsing result is found.

4. The method according to claim 3, wherein after generating and storing a routing rule between the dummy topic corresponding to the publisher and the found actual topic, the method further comprises:

searching for, according to a currently stored routing rule between the dummy topic and the actual topic, the transmission path with the dummy topic corresponding to the publisher being the start point and the dummy topic corresponding to any one subscriber being the end point;

transmitting the message or the identification information corresponding to the message on the found transmission path when the transmission path with the dummy topic corresponding to the publisher being the start point and the dummy topic corresponding to any one subscriber being the end point is found; and

sending the message to the subscriber corresponding to the end point of the transmission path when the message or the identification information corresponding to the message is transmitted to the end point of each transmission path.

5. The method according to claim 3 further comprising:

creating a new actual topic when the actual topic that matches the semantic parsing result is not found; and

generating and storing a routing rule between the dummy topic corresponding to the publisher and the newly-created actual topic.

6. The method according to claim 1 further comprising:

obtaining a control message sent by the publisher, wherein the control message is used to update the stored routing rule between the dummy topic and the actual topic;

modifying a currently stored routing rule between a dummy topic and an actual topic according to the control message; and

storing the modified routing rule.

7. A message subscribing method comprising:

obtaining a message that a subscriber has sent to a dummy topic corresponding to the subscriber; and

creating, according to the obtained message, a routing rule between the dummy topic corresponding to the subscriber and a target actual topic, wherein the target actual topic is an actual topic that is currently subscribed to by the subscriber, and wherein the dummy topic is configured to forward a message between the actual topic and a publisher.

8. The method according to claim 7, wherein the dummy topic is further configured to forward a message between the actual topic and the subscriber.

9. The method according to claim 7, wherein creating, according to the obtained message, the routing rule between the dummy topic corresponding to the subscriber and the target actual topic comprises:

determining, according to the control message, an actual topic subscribed to by the subscriber when the obtained message is a control message;

using the actual topic subscribed to by the subscriber as the target actual topic, wherein the control message comprises a message of the actual topic subscribed to by the subscriber; and

creating a routing rule between the dummy topic corresponding to the subscriber and the target actual topic.

10. The method according to claim 9 further comprising:

performing semantic parsing on the message when the obtained message is not a control message;

searching for, according to a semantic parsing result, an actual topic that matches the semantic parsing result in stored actual topics; and

creating a routing rule between the dummy topic corresponding to the subscriber and the found actual topic that matches the semantic parsing result when the actual topic that matches the semantic parsing result is found in the stored actual topics.

11. The method according to claim 10 further comprising:

creating a new actual topic when the actual topic that matches the semantic parsing result is not found in the stored actual topics; and

creating a routing rule between the dummy topic corresponding to the subscriber and the new actual topic.

12. A message publishing apparatus comprising:

an information processing module configured to obtain a message that a publisher has sent to a dummy topic corresponding to the publisher;

a topic module configured to search for, according to a stored routing rule, all transmission paths with the dummy topic corresponding to the publisher being a start point and the dummy topic corresponding to any one subscriber being an end point, wherein the dummy topic is configured to forward a message between the actual topic and the publisher, and the actual topic is configured to forward a message between the publisher and the subscriber; and

a transmission module configured to transmit the message or identification information corresponding to the message on a found transmission path when the topic module finds the transmission path with the dummy topic corresponding to the publisher being the start point and the dummy topic corresponding to any one subscriber being the end point, and send the message to a subscriber corresponding to an end point of the transmission path when the message or the identification information corresponding to the message is transmitted to the end point of each transmission path.

13. The apparatus according to claim 12, wherein the dummy topic is further configured to forward a message between the actual topic and the subscriber.

14. The apparatus according to claim 12, further comprising:

a semantic recognition module configured to perform semantic parsing on the message to obtain a semantic parsing result when the topic module does not find the transmission path with the dummy topic corresponding to the publisher being the start point and the dummy topic corresponding to any one subscriber being the end point, and search for, according to the semantic parsing result, an actual topic that matches the semantic parsing result in stored actual topics; and

a routing rule generating module configured to generate and store a routing rule between the dummy topic corresponding to the publisher and the found actual topic when the semantic recognition module finds the actual topic that matches the semantic parsing result.

15. The apparatus according to claim 14, wherein the topic module is configured to search for, according to a currently stored routing rule between the dummy topic and the actual topic, wherein the transmission path with the dummy topic corresponds to the publisher being the start point and the dummy topic corresponds to any one subscriber being the end point;

and

the transmission module is configured to transmit the identification information corresponding to the message on the found transmission path when the topic module finds the transmission path with the dummy topic corresponding to the publisher being the start point and the dummy topic corresponding to any one subscriber being the end point, and send the message to the subscriber corresponding to the end point of the transmission path when the message or the identification information is transmitted to the end point of each transmission path.

16. The apparatus according to claim 14, wherein the topic module is further configured to create a new actual topic when the actual topic that matches the semantic parsing result is not found, and wherein the routing rule generating module is further configured to store a routing rule between the dummy topic corresponding to the publisher and the newly-created actual topic.

17. The apparatus according to claim 12, wherein the information processing module is further configured to obtain a control message sent by the publisher, wherein the control message is used to update the stored routing rule between the dummy topic and the actual topic, and wherein the routing rule generating module is further configured to modify a currently stored routing rule between a dummy topic and an actual topic according to the control message, and store the modified routing rule.

21. The apparatus according to claim 16, wherein the first topic submodule is further configured to:

perform semantic parsing on the obtained message when the obtained message is not a control message;

search for, according to a semantic parsing result, an actual topic that matches the semantic parsing result in stored actual topics; and

use the found actual topic as the target actual topic when the actual topic that matches the semantic parsing result is found.

22. The apparatus according to claim 21, wherein the creating module is further configured to:

create a new actual topic as the target actual topic when the first topic submodule does not find the actual topic that matches the semantic parsing result in the stored actual topics; and

create a routing rule between the dummy topic corresponding to the subscriber and the new actual topic.

18. A message subscribing apparatus, comprising:

an obtaining module configured to obtain a message that a subscriber has sent to a dummy topic corresponding to the subscriber;

a creating module configured to create, according to the obtained message that is sent by the subscriber, a routing rule between the dummy topic corresponding to the subscriber and a target actual topic, wherein the target actual topic is an actual topic that is currently subscribed to by the subscriber, and wherein the dummy topic is configured to forward a message between the actual topic and a publisher.

19. The apparatus according to claim 18, wherein the dummy topic is configured to forward a message between the actual topic and the subscriber.

20. The apparatus according to claim 18, wherein the creating module comprises:

a first topic submodule configured to determine, according to a control message, an actual topic subscribed to by the subscriber when the obtained message is the control message, and use the actual topic subscribed to by the subscriber as the target actual topic, wherein the control message comprises a message of the actual topic subscribed to by the subscriber; and

a routing rule generating module configured to update the routing rule between the dummy topic corresponding to the subscriber and the target actual topic.