Communication method and communication apparatus for message queue telemetry transport

Patent metadata

Field	Value
Publication number	US-11411897-B2
Application number	US-202016928204-A
Country	US
Kind code	B2
Filing date	Jul 14, 2020
Priority date	Jan 16, 2018
Publication date	Aug 9, 2022
Grant date	Aug 9, 2022

Abstract

This application provides a communication method that includes grouping a plurality of clients to obtain at least two device groups, where each of the at least two device groups includes at least two clients. The method further includes receiving a publish request sent by a first client, where the publish request includes first data that corresponds to a first topic. The publish request is used to request a message queue telemetry transport (MQTT) server to publish the first data. After it is determined that a first device group to which the first client belongs from the at least two device groups, a publish message that includes the first data is sent to a second client in the first device group.

First claim

What is claimed is:

1. A communication method, wherein the method is applied to a message queue telemetry transport (MQTT) server, and the method comprises:
grouping a plurality of clients to obtain at least two device groups, wherein each of the at least two device groups comprises at least two clients, including
determining a grouping condition, wherein the grouping condition is specified by a preset grouping rule and comprises a condition that identity identifiers of clients grouped into a same device group need to satisfy, and one identity identifier can uniquely indicate one client, and
grouping the plurality of clients based on the identity identifiers of the plurality of clients and the grouping condition;
receiving a publish request sent by a first client, wherein the publish request comprises first data, the first data corresponds to a first topic, and the publish request is used to request the MQTT server to publish the first data; and selecting, using an identity identifier of the first client, a first device group to which the first client belongs, wherein the first device group is either device group in the at least two device groups, and
sending a publish message to a second client in the first device group, wherein the publish message comprises the first data.

2. The method according to claim 1 , wherein before the receiving a publish request sent by a first client, the method further comprises:
receiving a subscribe request sent by the second client, wherein the subscribe request carries indication information of the first topic, and the subscribe request is used to request the MQTT server to send data corresponding to the first topic to the second client.

3. The method according to claim 1 , wherein before the grouping the plurality of clients based on the identity identifiers of the plurality of clients and the grouping condition, the method further comprises:
receiving identification information of each client in the plurality of clients sent by the client, wherein the identification information of the client is used to indicate the identity identifier of the client.

4. The method according to claim 1 , wherein the determining a first device group to which the first client belongs comprises:
determining the first device group based on the identity identifier of the first client and the grouping condition.

5. The method according to claim 1 , wherein before the grouping a plurality of clients, the method comprises:
determining that each client in the plurality of clients allows being grouped into a device group.

6. The method according to claim 5 , wherein the determining that each client in the plurality of clients allows being grouped into a device group comprises:
receiving a grouping flag sent by each client in the plurality of clients, wherein each grouping flag is used to indicate whether a corresponding client allows being grouped into a device group.

7. The method according to claim 6 , wherein the grouping flag is carried in a connection request message, wherein the connection request message is used to request to establish a connection with the MQTT server.

8. A communications apparatus, wherein the apparatus is applied to a message queue telemetry transport (MQTT) server comprising:
a memory and one or more processors, the one or more processors including:
a grouping unit, configured to group a plurality of clients, to obtain at least two device groups, wherein each of the at least two device groups comprises at least two clients, the grouping unit being further configured to
determine a grouping condition, wherein the grouping condition is specified by a preset grouping rule and comprises a condition that identity identifiers of clients grouped into a same device group need to satisfy, and one identity identifier can uniquely indicate one client, and
group the plurality of clients based on the identity identifiers of the plurality of clients and the grouping condition;
a receiving unit, configured to receive a publish request sent by a first client, wherein the publish request comprises first data, the first data corresponds to a first topic, and the publish request is used to request the MQTT server to publish the first data;
a determining unit, configured to use an identity identifier of the first client to select a first device group to which the first client belongs, wherein the first device group is either device group in the at least two device groups; and
a sending unit, configured to send a publish message to a second client in the first device group, wherein the publish message comprises the first data.

9. The apparatus according to claim 8 , wherein the receiving unit is further configured to receive a subscribe request sent by the second client, wherein the subscribe request carries indication information of the first topic, and the subscribe request is used to request the MQTT server to send data corresponding to the first topic to the second client.

10. The apparatus according to claim 8 , wherein the receiving unit is further configured to: before grouping the plurality of clients based on the identity identifiers of the plurality of clients and the grouping condition, receive identification information of each client in the plurality of clients sent by the client, wherein the identification information of the client is used to indicate the identity identifier of the client.

11. The apparatus according to claim 8 , wherein the determining unit is configured to select the first device group based on the identity identifier of the first client and the grouping condition.

12. The apparatus according to claim 8 , wherein the determining unit is further configured to: before the MQTT server groups the plurality of clients, determine that each client in the plurality of clients allows being grouped into a device group.

13. The apparatus according to claim 12 , wherein that the determining unit determines that each client in the plurality of clients allows being grouped into a device group comprises:
receiving, by the receiving unit, a grouping flag sent by each client in the plurality of client, wherein each grouping flag is used to indicate whether a corresponding client allows being grouped into a device group.

14. The apparatus according to claim 13 , wherein the grouping flag is carried in a connection request message, wherein the connection request message is used to request to establish a connection with the MQTT server.

Assignees

• Huawei Tech Co Ltd

Inventors

• Cui Gaosheng
• Cheng Baochuan
• Lin Le

Classifications

• H04L51/04 Primary

  Real-time or near real-time messaging, e.g. instant messaging [IM] · CPC title

• H04L51/046 Primary

  Interoperability with other network applications or services · CPC title

• H04L67/12

  specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks · CPC title

• H04L67/55

  Push-based network services · CPC title

• H04L67/42

  Electricity · mapped topic