Message publishing and subscribing method and apparatus

• US 9,110,884 B2
• Filed: 09/18/2014
• Issued: 08/18/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
• Primary Examiner(s): Cao, Phuong Thao
• Application Number:
  US14/489,743
• Publication Number:
  US 20150006555A1
• Time in Patent Office: 334 Days
• Field of Search: 707/755, 709/206, 709/238
• US Class Current: 1/1
• 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, implemented by a message broker, on a computing device, that comprises at least one actual topic, comprising:

separately allocating, by the message broker, a dummy topic for each publisher and subscriber, wherein the dummy topic has functions of searching for a next-hop actual topic, wherein each actual topic has a logical connection with at least one dummy topic or at least one actual topic;

receiving, by using the dummy topic corresponding to a first publisher, a message from the first publisher;

searching for, according to a routing rule between the dummy topic corresponding to the first publisher and the at least one actual topic, the next-hop actual topic of the dummy topic corresponding to the first publisher;

determining, according to a routing rule of the next-hop actual topic, a next-hop topic of the next-hop actual topic;

transmitting the message to a subscriber corresponding to the dummy topic when the next-hop topic is the dummy topic; and

repeating the determining step when the next-hop topic is an actual topic.

2. The method according to claim 1, further comprising:

performing semantic parsing on the message to obtain a semantic parsing result;

searching for, according to the semantic parsing result, an actual topic that matches the semantic parsing result in the at least one actual topic comprised in the message broker; and

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

3. The method according to claim 2, 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.

4. The method according to claim 1, further comprising:

obtaining a control message sent by the first publisher;

modifying a current routing rule between the dummy topic corresponding to the first publisher and the at least one actual topic comprised in the message broker according to the control message; and

storing the modified routing rule.

5. The method according to claim 4, wherein the control message comprises a Forward instruction, a Copy instruction, a Subscription instruction, and a Proxy instruction.

6. A computing device, comprising:

at least one actual topic;

a memory configured to store computer program instructions; and

a processor configured to execute the computer program instructions stored in the memory to perform the steps of;

allocating a dummy topic for each publisher and subscriber, wherein the dummy topic has functions of searching for a next-hop actual topic and message forwarding, wherein each actual topic has a logical connection with at least one dummy topic or at least one actual topic;

receiving, by using the dummy topic corresponding to a first publisher, a message from the first publisher;

searching for, according to a routing rule between the dummy topic corresponding to the first publisher and the at least one actual topic, a next-hop actual topic of the dummy topic corresponding to the first publisher;

determining, according to a routing rule of the next-hop actual topic, a next-hop topic of the next-hop actual topic;

transmitting the message to a subscriber corresponding to the dummy topic when the next-hop topic is the dummy topic; and

repeating the determining step when the next-hop topic is an actual topic.

7. The computing device according to claim 6, wherein the processor is further configured to perform the steps of:

performing semantic parsing on the message to obtain a semantic parsing result;

searching for, according to the semantic parsing result, an actual topic that matches the semantic parsing result in the at least one actual topic comprised in the message broker; and

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

8. The computing device according to claim 7, wherein the processor is further configured to perform the steps of:

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.

9. The computing device according to claim 6, wherein the processor is further configured to perform the steps of:

obtaining a control message sent by the first publisher;

modifying a current routing rule between the dummy topic corresponding to the first publisher and the at least one actual topic comprised in the message broker according to the control message; and

storing the modified routing rule.

10. The computing device according to claim 9, wherein the control message comprises a Forward instruction, a Copy instruction, a Subscription instruction, and a Proxy instruction.