CN105722040B - Method, device and system for transmitting business messages - Google Patents

Abstract

The invention discloses a service message transmission method, device and system, relates to the technical field of communication, and can reduce communication overhead between an M2M server and an MQTT server. The method includes: when the M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to the first resource stored in the M2M server, the M2M server determines the first common topic generated for the first resource, And send a first MQTT message to the MQTT server once, the first MQTT message includes the first service message and the first common topic, and the first service message includes the same content sent to the at least two M2M terminals. The method is applied to an M2M system.

Description

Method, device and system for transmitting business messages

technical field

The present invention relates to the technical field of communication, in particular to a method, device and system for transmitting business messages.

Background technique

With the widespread application of machine-to-machine (English: Machine-to-Machine, abbreviation: M2M) communication in communication technology, the International Organization for Standardization in the Internet of Things has defined a message sequence telemetry transport (English: message queuetelemetry transport, abbreviation: MQTT) protocol for transmitting service messages in the M2M system. The MQTT protocol supports a topic subscription (subscribe)/publish (English: publish) mechanism, that is, the sender can publish the service message to be transmitted on an MQTT message, and the MQTT message contains a topic. When the receiving end subscribes to the topic, the receiving end can receive the MQTT message containing the topic, so that the sending end and the receiving end can use this topic subscription/publishing mechanism to complete the transmission of the business message.

Currently, in the MQTT protocol, the receiving end can configure the name of the topic to be subscribed according to the resource identifier of the receiving end, and subscribe to the topic with the MQTT server (English: MQTT server). When the sending end needs to send a business message to the receiving end, the sending end can configure the resource identifier of the receiving end (that is, the destination address of the business message) in the name of the topic to be published as the topic contained in the MQTT message carrying the business message, And send the MQTT message to the MQTT server, so that the MQTT server forwards the MQTT message to the receiving end that has subscribed to the topic according to the topic in the MQTT message. After receiving the MQTT message, the receiving end can perform corresponding operations on the resources indicated by the topic contained in the MQTT message according to the service message carried in the MQTT message. In the MQTT protocol, the destination address of the business message is configured in the name of the topic contained in the MQTT message, so if the destination address of the business message to be sent by the sender is different, the topic in the MQTT message to be published by the sender will be different . Wherein, the sending end may be an M2M terminal, and the receiving end may be an M2M server; or the sending end may be an M2M server, and the receiving end may be an M2M terminal.

In an M2M system, an M2M server may send a service message with the same content to multiple M2M terminals, such as a group member access message in group management or a subscription notification message in subscription notification management. At this time, according to the above topic subscription/publishing mechanism, since the resource identifiers of multiple M2M terminals are different, that is, the destination addresses of the service messages are all different, therefore, the M2M server needs to publish multiple The MQTT message of the topic, thus increasing the communication overhead between the M2M server and the MQTT server.

Contents of the invention

The present invention provides a service message transmission method, device and system, which can reduce communication overhead between an M2M server and an MQTT server.

To achieve the above object, the present invention adopts the following technical solutions:

In a first aspect, the present invention provides a method for transmitting service messages, including:

The machine-to-machine M2M terminal receives the first MQTT message sent by the message sequence telemetry transmission MQTT server, and the first MQTT message includes the first service message and the first common topic;

The M2M terminal searches for the resource identifier stored in the M2M terminal corresponding to the first public topic according to the saved mapping relationship between the first public topic and the identifier of the resource stored in the M2M terminal. The identity of the resource;

The M2M terminal performs an operation related to the first service message on the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal.

In a first possible implementation manner of the first aspect, before the M2M terminal receives the first MQTT message sent by the MQTT server, the method further includes:

The M2M terminal receives a second MQTT message sent by the MQTT server, the second MQTT message includes a second service message and a first topic, the second service message includes the first common topic, and the The first topic includes the identifier of the resource stored in the M2M terminal;

The M2M terminal saves the mapping relationship between the first common theme and the identifier of the resource stored in the M2M terminal;

The M2M terminal sends a first subscription topic message to the MQTT server, and the first subscription topic message includes the first public topic and the identifier of the M2M terminal.

With reference to the first possible implementation of the first aspect, in a second possible implementation, before the M2M terminal receives the second MQTT message sent by the MQTT server, the method further includes:

The M2M terminal sends a second subscription topic message to the MQTT server, where the second subscription topic message includes the first topic that the M2M terminal needs to subscribe to.

In a second aspect, the present invention provides a method for transmitting service messages, including:

When the machine-to-machine M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to the first resources stored in the M2M server,

The M2M server determines a first common theme generated for the first resource;

The M2M server sends a first MQTT message to the message sequence telemetry transmission MQTT server once, the first MQTT message includes the first service message and the first public topic, and the first service message includes the message sent to Same content of the at least two M2M terminals.

In a first possible implementation manner of the second aspect, before the M2M server determines the first common topic generated for the first resource, the method further includes:

generating, by the M2M server, the first common theme for the first resource;

The M2M server uses the identifier of the second resource stored in each of the at least two M2M terminals as the content contained in the first topic that the M2M terminal has subscribed to;

The M2M server sends a second MQTT message to each of the at least two M2M terminals through the MQTT server, and the second MQTT message includes a second service message and the first topic, so The second service message includes the first public topic.

In combination with the first possible implementation of the second aspect, in the second possible implementation,

When the first resource is a group resource, the identifier of the second resource is an identifier of a member resource in the group resource, and the M2M server generates the first public theme specific information for the first resource for:

After receiving the creation request message of the group resource, the M2M server generates the first group resource ID for the group resource according to the identifier of the group resource allocated to the group resource. A public topic, the first public topic of the group resource includes the identification of the group resource;

The M2M server uses the identifier of the second resource stored in each of the at least two M2M terminals as the first topic that the M2M terminal has subscribed to. The content contained is specifically:

The M2M server uses the identifier of the member resource as the content included in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to;

Wherein, the second service message is a notification message sent by the M2M server to the M2M terminal corresponding to the identifier of the member resource.

With reference to the first possible implementation manner of the second aspect, in a third possible implementation manner, when the first resource is a group resource, the identifier of the second resource is the The identifier of the member resource, the M2M server generating the first common topic for the first resource is specifically:

After the M2M server receives the access request message for the member resource of the group resource, the M2M server, according to the group resource included in the access request message for the member resource of the group resource, The identification of determines that there is no first public topic corresponding to the group resource;

The M2M server generates a first common topic of the group resource for the group resource according to the identifier of the group resource, and the first common topic of the group resource includes the identifier of the group resource ;

The M2M server uses the identifier of the second resource stored in each of the at least two M2M terminals as the first topic that the M2M terminal has subscribed to. The content contained is specifically:

The M2M server uses the identifier of the member resource as the content included in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to;

Wherein, the second service message is a first access request message generated by the M2M server according to the access request message to the member resource of the group resource, and the first access request message is sent by the M2M server An access request message to the M2M terminal corresponding to the identifier of the member resource.

With reference to the first possible implementation manner of the second aspect, in a fourth possible implementation manner, when the first resource is a subscription resource, the M2M server generates the first common Specifically the topics are:

When the M2M server determines that the subscription resource changes, the M2M server determines according to the identifier of the subscription resource that there is no first public topic corresponding to the subscription resource;

The M2M server generates a first public topic of the subscription resource for the subscription resource according to the identifier of the subscription resource, and the first public topic of the subscription resource includes the identifier of the subscription resource;

The M2M server uses the identifier of the second resource stored in each of the at least two M2M terminals as the first topic that the M2M terminal has subscribed to. The content contained is specifically:

The M2M server uses the identifier of the second resource stored in each M2M terminal subscribing to the subscription resource as the content contained in the first topic that the M2M terminal has subscribed to;

Wherein, the second service message is a subscription notification message sent by the M2M server to each M2M terminal subscribing to the subscription resource.

In combination with the first possible implementation of the second aspect, in a fifth possible implementation,

When the first resource is a subscription resource, the M2M server generating the first common topic for the first resource is specifically:

When the M2M server receives the subscription creation request message for the subscription resource, the subscription creation request message for the subscription resource includes the identifier of the subscription resource and the The identifier of the second resource of the subscription resource, the M2M server generates the first public topic of the subscription resource for the subscription resource according to the identifier of the subscription resource, and the first public topic of the subscription resource includes the subscription resource logo;

The M2M server uses the identifier of the second resource stored in each of the at least two M2M terminals as the first topic that the M2M terminal has subscribed to. The content contained is specifically:

The M2M server uses the identifier of the second resource stored in each M2M terminal subscribing to the subscription resource as the content contained in the first topic that the M2M terminal has subscribed to;

Wherein, the second service message is a subscription creation response message generated by the M2M server according to the subscription creation request message for the subscription resource, and the subscription creation response message is that the M2M server needs to send to each subscription A response message of the M2M terminal subscribing to the resource.

In a third aspect, the present invention provides a machine-to-machine M2M terminal, including:

A receiving unit, configured to receive a first MQTT message sent by a message sequence telemetry transmission MQTT server, where the first MQTT message includes a first business message and a first common topic;

A search unit, configured to search for the information corresponding to the first public topic received by the receiving unit according to the mapping relationship between the first public topic stored in the storage unit and the identifiers of resources stored in the storage unit an identification of the resource stored in the storage unit;

an executing unit, configured to execute the first resource stored in the storage unit indicated by the identifier of the resource stored in the storage unit searched by the search unit and the first resource received by the receiving unit Operations related to business messages.

In a first possible implementation manner of the third aspect, the M2M terminal further includes a sending unit,

The receiving unit is further configured to receive a second MQTT message sent by the MQTT server before receiving the first MQTT message sent by the MQTT server, and the second MQTT message includes a second business message and a first topic , the second service message includes the first public topic, and the first topic includes the identifier of the resource stored in the storage unit;

The storage unit is configured to save the mapping relationship between the first public theme received by the receiving unit and the identifier of the resource stored in the storage unit;

The sending unit is configured to send a message of a first subscribed topic to the MQTT server, where the message of the first subscribed topic includes the first public topic received by the receiving unit and the identifier of the M2M terminal.

In combination with the first possible implementation of the third aspect, in the second possible implementation,

The sending unit is further configured to send a message of a second subscription topic to the MQTT server before the receiving unit receives the second MQTT message sent by the MQTT server, and the message of the second subscription topic includes a subscription required The first topic of .

In a fourth aspect, the present invention provides an M2M server, including:

A determining unit, configured to determine a first common topic generated for the first resource when a first service message with the same content needs to be sent to at least two M2M terminals corresponding to the first resource stored in the storage unit;

a sending unit, configured to send a first MQTT message to a message sequence telemetry transmission MQTT server once, where the first MQTT message includes the first business message and the first common topic determined by the determining unit, and the first A service message includes the same content sent to the at least two M2M terminals.

In a first possible implementation manner of the fourth aspect, the M2M server further includes:

a generating unit, configured to generate the first common theme for the first resource before the determining unit determines the first common theme generated for the first resource, and generate the first common theme for each of the at least two M2M terminals The identifier of the second resource stored in an M2M terminal is used as the content contained in the first topic that the M2M terminal has subscribed to;

The sending unit is further configured to send a second MQTT message to each of the at least two M2M terminals through the MQTT server, and the second MQTT message includes a second service message and the generated The first topic generated by the generating unit, and the second service message includes the first public topic generated by the generating unit.

In combination with the first possible implementation of the fourth aspect, in the second possible implementation,

When the first resource is a group resource, the identifier of the second resource is an identifier of a member resource in the group resource,

The generating unit is specifically configured to, after receiving the creation request message of the group resource, generate the group resource for the group resource according to the identifier of the group resource allocated for the group resource The first common theme of the resource, and the identifier of the member resource is used as the content contained in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to, and the first common theme of the group resource contains an identification of the group resource;

Wherein, the second service message is a notification message to the M2M terminal corresponding to the identifier of the member resource.

With reference to the first possible implementation manner of the fourth aspect, in a third possible implementation manner, when the first resource is a group resource, the identifier of the second resource is the an identifier of a member resource, the generation unit specifically includes a determination module and a generation module,

The determining module is configured to, after receiving an access request message for a member resource of the group resource, according to the information of the group resource included in the access request message for a member resource of the group resource identifying a first common topic that is determined not to correspond to the group resource;

The generating module is configured to, when the determining module determines that there is no first common topic corresponding to the group resource, generate the group resource for the group resource according to the identifier of the group resource The first common topic, and the identifier of the member resource is used as the content contained in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to, and the first common topic of the group resource contains the The identification of the group resource;

Wherein, the second service message is a first access request message generated according to the access request message to the member resource of the group resource, and the first access request message is an identifier sent to the member resource The corresponding access request message of the M2M terminal.

With reference to the first possible implementation of the fourth aspect, in a fourth possible implementation, when the first resource is a subscription resource, the generation unit specifically includes a determination module and a generation module,

The determination module is configured to determine, according to the identifier of the subscription resource, that there is no first public topic corresponding to the subscription resource when it is determined that the subscription resource has changed;

The generation module is configured to generate the first public topic of the subscription resource for the subscription resource according to the identifier of the subscription resource when the determination module determines that there is no first public topic corresponding to the subscription resource , and use the identifier of the second resource stored in each M2M terminal subscribing to the subscription resource as the content contained in the first topic that the M2M terminal has subscribed to, and the first public topic of the subscription resource includes the subscription the identification of the resource;

Wherein, the second service message is a subscription notification message for each M2M terminal subscribing to the subscription resource.

In combination with the first possible implementation of the fourth aspect, in the fifth possible implementation,

When the first resource is a subscription resource,

The generating unit is specifically configured to, when receiving the subscription creation request message for the subscription resource, generate the first public topic of the subscription resource for the subscription resource according to the identifier of the subscription resource, and An identifier of a second resource stored in an M2M terminal that subscribes to the subscription resource, as the content contained in the first topic that the M2M terminal has subscribed to, and the subscription creation request message for the subscription resource includes the subscription resource and the identifier of the second resource stored in the M2M terminal subscribing to the subscription resource, where the first public subject of the subscription resource includes the identifier of the subscription resource;

Wherein, the second service message is a subscription creation response message generated according to the subscription creation request message for the subscription resource, and the subscription creation response message is a message that needs to be sent to each M2M terminal that subscribes to the subscription resource Respond to the message.

In the fifth aspect, the present invention provides a service message transmission system, including:

At least two machine-to-machine M2M terminals as described in the third aspect or any possible implementation of the third aspect, and M2M terminals as described in the fourth aspect or any possible implementation of the fourth aspect server, and the message sequence telemetry transport MQTT server.

The present invention provides a service message transmission method, device and system. When an M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to a first resource stored in the M2M server, the M2M server determines Generate a first common topic for the first resource, and send a first MQTT message to the MQTT server, the first MQTT message includes the first business message and the first public topic, and the first business message includes sending Given the same content of the at least two M2M terminals, each M2M terminal in the at least two M2M terminals can receive the first MQTT message sent by the MQTT server, and according to the stored first common theme and the M2M terminal The mapping relationship between the identifiers of the second resources stored in , look up the identifiers of the second resources corresponding to the first public subject, and the execution of the second resource indicated by the identifiers of the second resources is related to the first business message operation. Through this method, when the M2M server needs to send the first service message with the same content to the at least two M2M terminals, the M2M server only needs to send the first MQTT message to the MQTT server once, unlike the M2M server in the prior art that needs to send the first MQTT message to the MQTT server. Compared with sending MQTT messages containing different topics, the service message transmission method provided by the present invention can reduce the communication overhead between the M2M server and the MQTT server.

Description of drawings

FIG. 1 is a flow chart 1 of a method for transmitting a service message provided by an embodiment of the present invention;

FIG. 2 is a second flow chart of a method for transmitting service messages provided by an embodiment of the present invention;

FIG. 3 is an interaction diagram 1 of a service message transmission method provided by an embodiment of the present invention;

FIG. 4 is a schematic diagram of using the first common subject of a group resource as a sub-resource of the group resource provided by an embodiment of the present invention;

Fig. 5 is an interaction diagram 2 of a method for transmitting service messages provided by an embodiment of the present invention;

FIG. 6 is an interaction diagram 3 of a method for transmitting service messages provided by an embodiment of the present invention;

FIG. 7 is an interaction diagram 4 of a method for transmitting service messages provided by an embodiment of the present invention;

FIG. 8 is an interaction diagram five of a method for transmitting service messages provided by an embodiment of the present invention;

FIG. 9 is a first structural schematic diagram of an M2M terminal provided by an embodiment of the present invention;

FIG. 10 is a second structural schematic diagram of an M2M terminal provided by an embodiment of the present invention;

FIG. 11 is a first structural diagram of an M2M server provided by an embodiment of the present invention;

FIG. 12 is a second structural diagram of an M2M server provided by an embodiment of the present invention;

FIG. 13 is a schematic structural diagram III of an M2M server provided by an embodiment of the present invention;

FIG. 14 is a schematic diagram of a hardware structure of an M2M terminal provided by an embodiment of the present invention;

FIG. 15 is a schematic diagram of a hardware structure of an M2M server provided by an embodiment of the present invention;

Fig. 16 is a block diagram of a service message transmission system provided by an embodiment of the present invention.

Detailed ways

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some of the embodiments of the present invention, not all of them.

In the embodiment of the present invention, the M2M server may be a server applied in various management systems, and the M2M terminal may be an application and a terminal in various application scenarios. For example, in the vehicle monitoring and management system, the M2M server is the vehicle monitoring and management server, and the M2M terminal is the vehicle terminal; in the power meter reading system, the M2M server is the power meter reading server, and the M2M terminal is each smart meter; , the M2M server is an intelligent traffic server, and the M2M terminal is a microcontroller at each traffic intersection. None are limited in the present invention.

In order to better illustrate the transmission method of the business message provided by the embodiment of the present invention, a possible application scenario is taken as an example below to identify the business message, resource, topic and resource involved in the following embodiments of the present invention, and their The relationship between them is illustrated as an example. It is assumed that the application scenario provided by the embodiment of the present invention is an intelligent transportation system. In the intelligent transportation system, the M2M server is the intelligent transportation server, the M2M terminal is the microcontroller of each traffic intersection, and the intelligent transportation server is the microcontroller of each traffic intersection. The controller provides the service.

The microcontroller of each traffic intersection stores relevant data of the traffic intersection where it is located, for example, may include location information of the traffic intersection where the microcontroller is located, traffic video and violation records, and the like. Then the location information, the traffic video and the violation record constitute resources of the microcontroller, and the location information, the traffic video and the violation record are respectively sub-resources of the microcontroller.

The intelligent traffic server saves the attribute of the microcontroller of each traffic intersection and the attribute of the intelligent traffic server that it provides services, and the attribute of the microcontroller of each traffic intersection and the attribute of the intelligent traffic server constitute the intelligent traffic server resources (the resources of the intelligent traffic server can be understood as a group resource), the attributes of the micro-controller of each traffic intersection and the attributes of the intelligent traffic server are respectively sub-resources of the intelligent traffic server.

If the resource identifier of a microcontroller (for example, the domain name of the microcontroller) can be expressed as "m.example.com", then the identifiers of each sub-resource of the microcontroller can be expressed as: the geographic location information The identifier of the traffic video can be expressed as "m.example.com/address", the identifier of the traffic video can be expressed as "m.example.com/video", and the identifier of the violation record can be expressed as "m.example.com/record" .

When the intelligent transportation server needs to access a certain sub-resource of the certain microcontroller (a certain sub-resource of the certain microcontroller can be understood as a certain member resource of the group resource), for example, the intelligent transportation server requests When a certain microcontroller clears the violation record saved by the microcontroller, the topic subscription/publishing mechanism in the root M2M system, the intelligent traffic server will use the identifier of the violation record of the microcontroller (ie, the identifier of the member resource) "m .example.com/record", generate the topic "/oneM2M/m.example.com/record/req" containing the identification of the violation record, and send a business message (the business message is used to instruct the microcontroller to clear the microcontroller The violation record saved by the controller) and the topic are carried on the MQTT message and sent to the MQTT server. The MQTT server forwards the MQTT message to the microcontroller that has subscribed to the topic, and after receiving the MQTT message, the microcontroller clears the violation record saved by the microcontroller according to the business message contained in the MQTT message.

It should be noted that, the above descriptions of service messages, resources, topics and resource identifiers involved in the following embodiments of the present invention, and the relationships among them are only exemplary. In other possible application scenarios, for example, in application scenarios such as a vehicle monitoring management system and a power meter reading system, the resources stored in the M2M terminal are different from the resources stored in the M2M server. And in the intelligent transportation system, the resources of the micro-controller and the intelligent transportation server at each traffic intersection may include but not limited to the resources listed above, which are not limited in the embodiment of the present invention.

An embodiment of the present invention provides a method for transmitting a service message. As shown in FIG. 1, the method may include:

S101. The M2M terminal receives a first MQTT message sent by an MQTT server, where the first MQTT message includes a first service message and a first common topic.

It should be noted that, before the M2M terminal receives the first MQTT message containing the first common topic, the M2M terminal has already subscribed to the content of the first public topic to the MQTT server, therefore, the M2M terminal can receive the message containing the first public topic The first MQTT message.

S102. The M2M terminal searches for an identifier of a resource stored in the M2M terminal corresponding to the first common theme according to the stored mapping relationship between the first common theme and the identifier of the resource stored in the M2M terminal.

Wherein, one resource may be stored in the M2M terminal, and multiple resources may also be stored. The identifier of the resource stored in the M2M terminal may be an identifier that can uniquely characterize the resource stored in the M2M terminal, specifically, it may be a universal resource identifier (English: uniform resource identifier, abbreviation: URI) of the resource stored in the M2M terminal .

It should be noted that the mapping relationship between the first common topic and the identifier of the resource stored in the M2M terminal is saved in the M2M terminal when the M2M terminal subscribes to the first common topic with the MQTT server. Exemplarily, the mapping relationship between the first common subject and the identifier of the resource stored in the M2M terminal may be as shown in Table 1. Wherein, the first public topic may be "/oneM2M/g/g.example.com/req", and the identifier of the resource stored in the M2M terminal (that is, the destination address of the first service message) may be "m1. example.com/container1".

Table 1

public topic Identification of resources stored in the M2M terminal /oneM2M/g/g.example.com/req m1.example.com/container1

S103. The M2M terminal performs an operation related to the first service message on the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal.

In the embodiment of the present invention, the specific manner in which the M2M terminal performs operations related to the first service message on the resources stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal, in different application scenarios The specific methods used are also different.

Exemplarily, when the method provided by the embodiment of the present invention is applied to group management, the M2M terminal executes the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal with the first service A specific manner of message-related operations may be that the M2M terminal executes the operation indicated by the content of the first service message on the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal. For example, assuming that the M2M terminal is a microcontroller at a traffic intersection in an intelligent transportation system, and the content of the first service message contained in the first MQTT message received by the microcontroller is "delete instruction", the microcontroller According to the content of the first service message, the resource stored in the microcontroller indicated by the identifier of the resource stored in the microcontroller is deleted.

When the method provided by the embodiment of the present invention is applied to subscription notification management, the M2M terminal performs an operation related to the first service message on the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal The specific manner may be that the M2M terminal obtains the indication information corresponding to the content of the first service message according to the corresponding relationship between the content of the first service message and the indication information preset in the M2M terminal, and The resource stored in the M2M terminal indicated by the identifier of the resource stored in , executes the operation indicated by the indication information. For example, assuming that the M2M terminal is a microcontroller controlling an air conditioner, and the content of the first service message is "the current temperature is less than 5 degrees", the instruction information corresponding to the content of the first service message preset in the microcontroller is "start the air conditioner", after the microcontroller receives the first service message, according to the corresponding relationship between the content of the first service message and the indication information preset in the M2M terminal, obtain the "current temperature is less than 5 degrees" Corresponding instruction information "Start the air conditioner", and start the air conditioner according to the instruction information.

An embodiment of the present invention provides a method for transmitting service messages. The M2M terminal receives the first MQTT message sent by the MQTT server, and according to the saved mapping between the first public theme and the identifier of the resource stored in the M2M terminal relationship, look up the identifier of the resource stored in the M2M terminal corresponding to the first common theme, and execute the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal with the first service For message-related operations, the first MQTT message includes the first service message and the first public topic. Through this method, when the M2M server needs to send the first service message with the same content to at least two M2M terminals corresponding to the resources stored in the M2M server, the MQTT server only needs to send the first MQTT message to the MQTT server once, because the At least two M2M terminals have subscribed to the first common topic, so the MQTT server will forward the first MQTT message to the at least two M2M terminals, and each M2M terminal in the at least two M2M terminals can A mapping relationship between a common topic and the identifier of the resource stored in each M2M terminal executes an operation related to the first service message. Compared with the prior art where the M2M server needs to send multiple MQTT messages containing different topics to the MQTT server, the service message transmission method provided by the embodiment of the present invention can reduce the communication overhead between the M2M server and the MQTT server.

An embodiment of the present invention provides a method for transmitting a service message. As shown in FIG. 2, the method may include:

S201. When the M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to a first resource stored in the M2M server, the M2M server determines a first common topic generated for the first resource.

Wherein, the first resource is a resource stored in the M2M server.

It should be noted that, the M2M server may determine that the first service message with the same content needs to be sent to at least two M2M terminals corresponding to the first resource according to a change situation of the first resource stored in the M2M server. For example, when the method provided by the embodiment of the present invention is applied to subscription notification management, the first resource is a subscription resource stored in the M2M server, and a sub-resource of the subscription resource is used to describe the M2M terminal subscribing to the subscription resource If the identifier of the second resource is the identifier of the second resource, the M2M terminal corresponding to the identifier of the second resource of the M2M terminal subscribing to the subscription resource is the M2M terminal corresponding to the subscription resource. Wherein, the second resource refers to a resource stored in the M2M terminal.

When the subscription resource changes, the M2M server compares the change of the subscription resource with the notification filter criteria (English: notice filter criteria) of each M2M terminal subscribing to the subscription resource. The notification filter condition of at least two M2M terminals among all M2M terminals subscribing to the resource, the M2M server determines that a notification message including the change of the subscription resource needs to be sent to each of the at least two M2M terminals. At this time, the notification message is the first service message, and the content of the notification message sent by the M2M server to each of the at least two M2M terminals is the change of the subscription resource, that is, the M2M server determines that the At least two M2M terminals send the first service message with the same content. Wherein, the notification filter condition of each M2M terminal subscribing to the subscription resource is sent to the M2M server when the M2M terminal requests the M2M server to create a subscription notification.

The M2M server may also determine that at least two M2M terminals corresponding to the first resource stored in the M2M server need to send the same content according to the received message sent by the common service entity (English: common service entity, abbreviation: CSE). First business news. Wherein, the service public entity may be an M2M server or an M2M terminal, which is not limited in the present invention.

For example, when the method provided by the embodiment of the present invention is applied to group management, the first resource is a certain group resource, and a sub-resource of the group resource is used to describe the member resources that form the group resource , the M2M terminal corresponding to the identifiers of the member resources forming the group resource is the M2M terminal corresponding to the group resource.

When a CSE accesses a member resource of the group resource, the CSE will send an access request message to the M2M server for the member resource of the group resource, and the M2M server receives the access request message for the member resource of the group resource Afterwards, the M2M server determines to send the first access request message to all M2M terminals corresponding to the identifiers of the member resources of the group resource. At this time, the first service message is the first access request message. Wherein, the content of the first access request message sent by the M2M server to each M2M terminal corresponding to the identifier of the member resource of the group resource is the content of the access request message of the member resource of the group resource, namely The M2M server sends the first service message with the same content to all M2M terminals corresponding to the identifiers of the member resources of the group resource. Exemplarily, the content in the access request message of the member resource of the group resource may be "read indication", which is used to instruct the M2M terminal to report the member resource corresponding to the M2M terminal; or the member resource of the group resource The content in the resource access request message may be a "deletion instruction", which is used to instruct the M2M terminal to delete the member resource corresponding to the M2M terminal.

When the M2M server determines that the first service message with the same content needs to be sent to at least two M2M terminals corresponding to the first resource stored in the M2M server, the M2M server determines the first common topic generated for the first resource.

Further, there are multiple ways for the M2M server to determine the first common theme generated for the first resource. Exemplarily, the manner in which the M2M server determines the first common theme generated for the first resource may include, if the M2M server judges that a certain sub-resource of the first resource is a theme containing the identifier of the first resource, then the M2M server It may be determined that the topic is the first public topic generated by the MQTT server for the first resource. Alternatively, if the M2M server judges that a certain attribute of the first resource is a topic including the identifier of the first resource, the M2M server may determine that the topic is the first public topic generated by the MQTT server for the first resource.

Specifically, the manner in which the M2M server generates a common theme for the first resource will be described in detail in the following embodiments.

S202. The M2M server sends a first MQTT message to the MQTT server once, the first MQTT message includes the first service message and the first common topic, and the first service message includes information sent to the at least two M2M terminals same content.

It should be noted that, before the M2M server sends the first MQTT message to the MQTT server, the at least two M2M terminals have already subscribed to the first common topic from the MQTT server. Therefore, after the M2M server sends the first MQTT message including the first service message and the first common topic to the MQTT server, the MQTT server will respectively forward the first MQTT message to the at least two M2M terminals. Compared with the M2M server in the prior art sending the first service message to the MQTT server on at least two MQTT messages containing different topics, in the service message transmission method provided by the embodiment of the present invention, the M2M server only needs to send the first service message to the MQTT server. The MQTT server only needs to send the first MQTT message once.

An embodiment of the present invention provides a service message transmission method. When an M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to the first resources stored in the M2M server, the M2M server determines the The first public topic generated by the first resource, and the first MQTT message is sent to the MQTT server once, the first MQTT message includes the first business message and the first public topic, and the first business message includes sending to at least two terminals of the same content. Compared with the prior art where the M2M server needs to issue multiple MQTT messages containing different topics to the MQTT server, the service message transmission method provided by the embodiment of the present invention can reduce the communication overhead between the M2M server and the MQTT server.

It should be noted that, in a service message transmission method provided by an embodiment of the present invention, the M2M server generates a first public topic for the first resource stored in the M2M server, and the M2M terminal has subscribed to the first public topic In the case of , the M2M server can execute the method shown in FIG. 2 above, and the M2M terminal can execute the method shown in FIG. 1 above.

Therefore, further, before the M2M server executes the method shown in FIG. 2 above, and before the M2M terminal executes the method shown in FIG. 1 above, a service message transmission method provided by an embodiment of the present invention may further include A process in which the M2M server generates a first common theme for the first resource stored in the M2M server, and the M2M terminal subscribes to the first common theme. Specifically, as shown in FIG. 3, the M2M server generates a first common theme for the first resource stored in the M2M server, and the method for the M2M terminal to subscribe to the first common theme may include:

S301, the M2M server and at least two M2M terminals respectively establish connections with the MQTT server.

Specifically, the manner in which the M2M server and the at least two M2M terminals respectively establish connections with the MQTT server may be that the M2M server and the at least two M2M terminals respectively send an MQTT connection message (English: MQTTconnect) to the MQTT server to establish a connection with the MQTT server. connect. After the M2M server and the at least two M2M terminals respectively establish connections with the MQTT server, both the M2M server and the at least two M2M terminals can communicate with the MQTT server.

S302. The M2M server and the at least two M2M terminals respectively subscribe to related topics from the MQTT server.

Wherein, the related topics of the M2M server are all topics that the M2M server needs to subscribe to, including all the identifiers of all first resources stored in the M2M server, and the related topics of each M2M terminal in the at least two M2M terminals are the topics that the M2M terminal needs to subscribe to. Subscribed, including all topics of identifiers of all second resources stored in the M2M terminal.

Specifically, the M2M server and each of the at least two M2M terminals may subscribe to related topics by sending a message of the second subscription topic to the MQTT server.

Exemplarily, take an M2M terminal subscribing to a related topic from an MQTT server as an example. When the M2M terminal subscribes to the MQTT server for the first topic corresponding to the second resource stored in the M2M terminal, the M2M terminal uses the identifier of the second resource as the content contained in the first topic corresponding to the second resource , and send the first topic and the identifier of the M2M terminal to the MQTT server in a second subscription topic message, thereby subscribing to the first topic corresponding to the second resource, that is, the M2M terminal sends a message containing The M2M terminal needs to subscribe to the message of the second subscription topic of the first topic, and subscribes to the first topic.

S303. The MQTT server saves the related topics of the M2M server and the related topics of the at least two M2M terminals respectively.

Specifically, the MQTT server respectively saves the corresponding relationship between the identifier of each first resource stored in the M2M server and the topic containing the identifier of the first resource, and the MQTT server respectively saves the corresponding relationship between each M2M terminal in the at least two M2M terminals. The corresponding relationship between the identifier of the terminal and the first topic including the identifier of the second resource stored in the M2M terminal.

S304. The M2M server generates a first common theme for the first resource stored in the M2M server.

Specifically, when the service message transmission method provided by the embodiment of the present invention is applied in different application scenarios, the process for the M2M server to generate the first common theme for the first resource in the M2M server is also different. Therefore, the M2M server is The specific process for the first resource in the M2M server to generate the first common theme will be described in detail in the following exemplary application scenarios, and will not be repeated here.

It should be noted that the first common theme generated by the M2M server for the first resource in the M2M server must be unique, that is, the first common theme generated by the M2M server for the first resource in the M2M server is the same as that generated by the M2M server for the first resource in the M2M server. All other topics generated before the first resource in generate the first common topic are different.

Further, the way to ensure the uniqueness of the first public topic may be that the M2M server may use the identifiers of each resource (including the identifier of each group resource, the identifier of each second resource stored in the M2M terminal, and the identifier of each subscribed resource etc.) to generate the first common theme, since the identification of each resource is different, so the method of generating the first common theme according to the identification of the resource can also guarantee the uniqueness of the first common theme.

Further, after the M2M server generates the first common theme for the first resource, the M2M server needs to use the first common theme as a sub-resource of the first resource, or the M2M server needs to use the first common theme as a sub-resource of the first resource. Attributes.

Exemplarily, as shown in FIG. 4 , when the first resource is a group resource, the M2M server will generate a first common theme for the group resource as a schematic diagram of a sub-resource of the group resource. Wherein, the group resource includes multiple sub-resources. For example, sub-resource 1 is used to describe the identification of each member resource in the group resource; sub-resource 2 is used to indicate the distribution request (English: fan out point) resource identification of member resources of all group resources, etc. After the M2M server generates the first common theme for the group resource, the M2M server adds the first common theme as a sub-resource of the group resource (sub-resource n shown in FIG. 4 ) to the group resource , so that the first public theme generated for the group resource is used as a sub-resource of the group resource.

S305. The M2M server takes the identifier of the second resource stored in each of the at least two M2M terminals as content included in the first topic that the M2M terminal has subscribed to.

Wherein, each of the at least two M2M terminals has subscribed to the first topic when subscribing to the relevant topic from the MQTT server in S302 above. The M2M server takes the identifier of the second resource stored in each of the at least two M2M terminals as the content contained in the first topic that the M2M terminal has subscribed to, that is, the M2M server The identifier of the second resource stored in each M2M terminal (that is, the multiple destination addresses of the second service message sent by the M2M server), generating a first topic containing the identifier of the second resource stored in the M2M terminal for the M2M terminal .

Further, the specific manner in which the M2M server uses the identifier of the second resource stored in each of the at least two M2M terminals as the content contained in the first topic that the M2M terminal has subscribed to is different from that of the M2M server in the prior art. The manner in which the identifier of the second resource stored in each of the at least two M2M terminals is used as the content included in the first topic that the M2M terminal has subscribed to is the same, and will not be repeated here.

S306. The M2M server sends a second MQTT message to each of the at least two M2M terminals through the MQTT server. The second MQTT message includes the second service message and the first topic, and the second service message carries the first public subject.

Specifically, the M2M server sends a second MQTT message including a second service message and a topic to each of the at least two M2M terminals through the MQTT server, and the topic is generated by the M2M server for the M2M terminal and includes the M2M The first subject of the identifier of the second resource stored in the terminal.

Wherein, the manner of carrying the first common subject in the second service message may be that the M2M server adds the first common subject as an attribute of the second service message to the second service message, so that the second service Messages carry this first common topic. The M2M server carries the first common topic in a second service message and sends it to each of the at least two M2M terminals, so that each of the at least two M2M terminals receives the second service message Then, according to the first public topic carried in the second service message, subscribe to the first public topic with the MQTT server.

Further, since each of the at least two M2M terminals has subscribed to the first topic from the MQTT server, the MQTT server can forward the second MQTT message containing the first topic to the M2M terminal.

S307. Each M2M terminal of the at least two M2M terminals receives a second MQTT message sent by the MQTT server, the second MQTT message includes a second service message and a first topic, and the second service message includes a first public topic, The first theme includes the identifier of the second resource stored in the M2M terminal.

Further, after each M2M terminal of the at least two M2M terminals receives the second MQTT message sent by the MQTT server, the M2M terminal judges whether the public topic it has subscribed to contains the first public message contained in the second service message. theme. Specifically, the M2M terminal may compare the topic contained in the second service message with the public topic saved by the M2M terminal to determine whether the topic contained in the second service message is included in the public topic subscribed by the M2M terminal to the MQTT server. . The topic included in the second service message is the first public topic.

If the M2M terminal does not have the first common topic contained in the second service message in the public topics subscribed to by the MQTT server, the M2M terminal executes S308, S309 or S310.

S308. Each M2M terminal of the at least two M2M terminals saves the mapping relationship between the first common theme and the identifier of the second resource contained in the first theme and stored in the M2M terminal.

The manner in which each of the at least two M2M terminals saves the mapping relationship between the first common theme and the identifier of the second resource stored in the M2M terminal included in the first theme may specifically be Refer to related descriptions in the embodiment shown in FIG. 1 , and details are not repeated here.

S309. Each M2M terminal of the at least two M2M terminals sends a first subscription topic message to the MQTT server, where the first subscription topic message includes the first public topic and the identifier of the M2M terminal.

Specifically, each M2M terminal of the at least two M2M terminals generates a message for subscribing to the MQTT server for the first subscription topic of the first public topic, and the message of the first subscription topic includes the first public topic and the The identifier of the M2M terminal. Each M2M terminal of the at least two M2M terminals sends a message of the first subscription topic to the MQTT server, and after the MQTT server receives the message of the first subscription topic sent by each M2M terminal of the at least two M2M terminals, The corresponding relationship between the first common topic and the identifier of the M2M terminal is stored, that is, each of the at least two M2M terminals has subscribed to the first common topic with the MQTT server. Therefore, when the MQTT server receives the first MQTT message containing the first common topic sent by the M2M server, the MQTT server can, according to the stored correspondence between the first common topic and the identity of the M2M terminal, send the first public topic to the M2M terminal. An MQTT message is forwarded to the M2M terminal corresponding to the identifier of the M2M terminal that has subscribed to the first common topic. That is, the MQTT server can forward the first MQTT message including the first common topic to the M2M terminals that have subscribed to the first common topic.

S310. Each M2M terminal of the at least two M2M terminals performs an operation related to the second service message on the second resource indicated by the identifier of the second resource contained in the first theme and stored in the M2M terminal.

It should be noted that the above S308, S309, and S310 may be executed simultaneously or sequentially. If the above S308, S309, and S310 are executed sequentially, the execution sequence can be randomly sorted, which is not limited in this embodiment of the present invention.

Through the above method in S301-S310, the M2M server generates the first common theme for the first resource stored in the M2M server, and sends the second topic to the M2M terminal (ie each of the at least two M2M terminals) through the MQTT server. Two MQTT messages, the second MQTT message includes the first topic of the M2M terminal and a second service message, and the second service message includes the first common topic. After receiving the second MQTT message, the M2M terminal saves the mapping relationship between the first common topic contained in the second service message and the identifier of the second resource stored in the M2M terminal contained in the first topic. , and subscribe the first public topic to the MQTT server.

Therefore, when the M2M server needs to send the first service message with the same content to at least two M2M terminals corresponding to the first resources stored in the M2M server, the M2M server can send The MQTT server sends a first MQTT message once, and the first MQTT message includes the first service message and the first public topic. On the other hand, since the M2M terminal has subscribed to the content of the first public topic, the MQTT server can forward the first MQTT message to the M2M terminal, and the M2M terminal can receive the the first MQTT message, and perform operations related to the first service message included in the first MQTT message.

In order to better illustrate a method for transmitting a service message provided by an embodiment of the present invention, two possible application scenarios will be listed below for exemplary description.

A possible application scenario is that when the service message transmission method provided by the embodiment of the present invention is applied to group management, the first resource is a group resource, and the identifier of the second resource is the ID of a member resource in the group resource. mark, the M2M server may execute the method shown in Figure 3 through two possible implementation modes (mode 1 and mode 2).

Way 1: When the M2M server creates a group resource, the M2M server generates a first common topic for the group resource.

As shown in Figure 5, the above S304 may specifically be:

S304a. After receiving the creation request message of the group resource, the M2M server generates the first public theme of the group resource for the group resource according to the identifier of the group resource allocated for the group resource, and the group resource The first public topic contains the identity of the group resource.

When the originator (English: originator) needs to request the M2M server to create a group resource, the originator may send a group creation request message to the M2M server through the MQTT server. Wherein, the initiator may be a CSE that sends a group creation request message to the M2M server.

After the M2M server receives the group creation request message, the M2M server creates a group resource according to the group creation request message, assigns the group resource identifier to the group resource, and generates the group resource for the group resource. The resource's first public theme. Wherein, the first common topic of the group resource includes the identification of the group resource.

For example, assuming that the identifier assigned by the M2M server to the group resource is "g.example.com/group", the M2M server can configure the topic name of the first public topic as "g.example.com/group" according to the identifier of the group resource. /oneM2M/group/g.example.com/req", that is, the M2M server generates for the group resource the first public topic "/oneM2M/group/g.example.com/req" including the identifier of the group resource. Since the identifier of the group resource is unique, the first public topic generated by the M2M server for the group resource is also unique according to the identifier of the group resource, that is, the first public topic is unique.

Further, in the first manner, as shown in FIG. 5 , the second service message in S306 is a notification message sent by the M2M server to the M2M terminal corresponding to the identifier of the member resource. Wherein, the above-mentioned S305-S306 may specifically be:

S305a. The M2M server uses the identifier of the member resource as the content included in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to.

S306a. The M2M server sends a second MQTT message to each of the at least two M2M terminals through the MQTT server. The second MQTT message includes a notification message and a first topic, and the notification message carries the first message of the group resource. public subject.

Wherein, identifiers of multiple member resources in the group resource may correspond to one M2M terminal, or may respectively correspond to multiple M2M terminals.

For example, assume that the member resources of the group resource are member resource 1, member resource 2 and member resource 3 respectively, wherein the M2M terminal corresponding to the identifier of member resource 1 is M2M terminal 1, and the identifier of member resource 2 and member resource 3 corresponds to The M2M terminals are all M2M terminals 2 . Then when the M2M server is creating a group resource formed by member resource 1, member resource 2 and member resource 3, the M2M server will use the identifier of member resource 1 as the first topic subscribed by M2M terminal 1 (hereinafter referred to as the first topic 1), the M2M server uses the identifier of the member resource 2 as the first topic that the M2M terminal 2 has subscribed to (hereinafter referred to as the first topic 2), and the M2M server uses the identifier of the member resource 3 as the first topic that the M2M terminal 3 has subscribed to ( Hereinafter referred to as the first topic 3), that is, the M2M server generates the first topic 1 containing the identification of the member resource 1 for the M2M terminal 1, and the M2M server generates the first topic 2 containing the identification of the member resource 2 and the first topic 2 containing the identification of the member resource 2 for the M2M terminal 2. The first topic 3 identified by the resource 3. The M2M server sends a second MQTT message including the first topic 1 to the M2M terminal 1 corresponding to the identifier of the member resource 1 through the MQTT server, and the M2M server sends a second MQTT message including the first topic 1 to the M2M terminal 2 corresponding to the identifier of the member resource 2 through the MQTT server. The second MQTT message of the topic 2, and the M2M server sends a second MQTT message including the first topic 3 to the M2M terminal 2 corresponding to the identifier of the member resource 3 through the MQTT server.

Way 2: When the M2M server receives an access request message for a member resource of the group resource, the M2M server generates a first common topic for the group resource.

As shown in Figure 6, the above S304 may specifically include:

S304b. After the M2M server receives the access request message for the member resource of the group resource, the M2M server determines that there is no connection with the group resource according to the identifier of the group resource included in the access request message for the member resource of the group resource. The corresponding first public topic.

Wherein, the access request message of a member resource of the group resource may be sent by an M2M terminal corresponding to the group resource to the M2M server, or may be sent by a CSE other than the group resource.

Specifically, if the M2M server determines according to the identifier of the group resource that none of the subresources of the group resource is a topic containing the identifier of the group resource, then the M2M server determines that there is no first public topic corresponding to the group resource . Or, if the M2M server determines according to the identifier of the group resource that none of the attributes of the group resource is a topic including the identifier of the group resource, the M2M server determines that there is no first public topic corresponding to the group resource.

S304c. The M2M server generates a first common theme of the group resource for the group resource according to the identifier of the group resource, where the first common theme of the group resource includes the identifier of the group resource.

Specifically, the manner in which the M2M server generates the first common theme of the group resource for the group resource according to the identifier of the group resource may refer to the relevant description in S304a above, and details will not be repeated here.

Further, as shown in FIG. 6, in mode 2, the second service message in S306 above is the first access request message generated by the M2M server according to the access request message of the member resource of the group resource, and the first access The request message is an access request message sent by the M2M server to the M2M terminal corresponding to the identifier of the member resource. Wherein, the above-mentioned S305-S306 may specifically be:

S305a. The M2M server uses the identifier of the member resource as the content included in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to.

S306b. The M2M server sends a second MQTT message to each of the at least two M2M terminals through the MQTT server. The second MQTT message includes the first access request message and the first topic, and the first access request message carries the The first public topic of the group resource.

Specifically, the specific implementation manner of the above-mentioned S306b is similar to the specific implementation manner of the above-mentioned S306a, and will not be repeated here.

Another possible application scenario is that when the service message transmission method provided by the embodiment of the present invention is applied to subscription notification management, the first resource is a subscription resource, and the M2M server may use two possible implementation methods (mode 3 and way 4) execute the method as shown in FIG. 3 .

Mode 3: When the M2M server sends a subscription notification message, the M2M server generates the first common topic of the subscribed resource for the subscribed resource.

As shown in Figure 7, the above S304 specifically includes:

S304d. When the M2M server determines that the subscription resource changes, the M2M server determines that there is no first public topic corresponding to the subscription resource according to the identifier of the subscription resource.

Specifically, the M2M server determines according to the identifier of the subscription resource that no sub-resource of the subscription resource is a topic including the identifier of the subscription resource, and then the M2M server determines that there is no first common topic corresponding to the subscription resource. Alternatively, the M2M server determines according to the identifier of the subscription resource that none of the attributes of the subscription resource is a topic including the identifier of the subscription resource, and then the M2M server determines that there is no first public topic corresponding to the subscription resource.

S304e. The M2M server generates a first public topic of the subscription resource for the subscription resource according to the identifier of the subscription resource, and the first public topic of the subscription resource includes the identifier of the subscription resource.

Further, in mode 3, when at least two M2M terminals subscribe to the subscription resource of the M2M server, if the change of the subscription resource satisfies the notification filter condition of the at least two M2M terminals, the M2M server will generate a subscription Notify the message, and determine whether there is a first public topic associated with the subscription resource in the public topics. If the first public topic does not exist in the public topics, the M2M server will generate the first public topic including the subscription resource identifier and number according to the identifier of the subscription resource (specifically, the identifier and number of the subscription resource). Wherein, the notification filtering condition of the M2M terminal is that the M2M terminal sends to the M2M server when the M2M terminal requests the M2M server to create a subscription notification.

In particular, the notification filter condition of the M2M terminal can be understood as a condition for the M2M server to send a subscription notification message to the M2M terminal.

Exemplarily, it is assumed that the subscription resource subscribed by the M2M terminal to the M2M server is a temperature resource stored in the M2M server, and the notification filter condition of the M2M terminal is: when the temperature is higher than 5° and lower than 15°, the M2M server sends the The M2M terminal sends a subscription notification message. When the M2M server detects that the temperature resource stored in the M2M server changes, the M2M server judges whether the change of the temperature resource satisfies the notification filter condition, that is, the M2M server judges whether the current temperature is higher than 5 degrees and lower than 15 degrees . If the M2M server judges that the change of the temperature resource satisfies the notification filtering condition of the M2M terminal, the M2M server generates a subscription notification message and sends the subscription notification message to the M2M terminal.

Further, in mode 3, as shown in FIG. 7 , the second service message in S306 is a subscription notification message sent by the M2M server to each M2M terminal subscribing to the subscription resource. Wherein, the above-mentioned S305-S306 may specifically be:

S305b. The M2M server uses the identifier of the second resource stored in each M2M terminal subscribing to the subscription resource as the content included in the first topic that the M2M terminal has subscribed to.

S306c. The M2M server sends a second MQTT message to each of the at least two M2M terminals through the MQTT server. The second MQTT message includes a subscription notification message and a first topic, and the subscription notification message carries the subscription resource number. a public theme.

Way 4: When the M2M server creates a subscription notification, the M2M server generates a first common topic for the subscription resource in the M2M server.

As shown in Figure 8, the above S304 is specifically:

S304f. When the M2M server receives the subscription creation request message for the subscription resource, the subscription creation request message for the subscription resource includes the identifier of the subscription resource and the ID of the second resource stored in the M2M terminal subscribing to the subscription resource. An identifier, the M2M server generates a first public topic of the subscription resource for the subscription resource according to the identifier of the subscription resource, and the first public topic of the subscription resource includes the identifier of the subscription resource.

In this embodiment of the present invention, when each of the at least two M2M terminals requests the M2M server to create a subscription notification for the subscription resource, each of the at least two M2M terminals sends a subscription creation request to the M2M server information. Wherein, the subscription creation request message sent by each of the at least two M2M terminals may also include the notification filter condition of the M2M terminal, the identifier of the subscription resource requested by the M2M terminal, and the information stored in the M2M terminal. The identifier of the second resource. The identifier of the second resource stored in the M2M terminal is used for determining the destination address of the subscription notification message after the M2M server generates the subscription notification message.

It should be noted that in mode 4, since the notification filtering conditions of the at least two M2M terminals may be the same or different, the first common topic generated by the M2M server according to the identifier of the subscription resource may be only one, or there may be Multiple. Specifically, when the notification filtering conditions of the at least two M2M terminals are the same, the M2M server generates only one first common topic according to the identifier of the subscription resource; when the notification filtering conditions of the at least two M2M terminals are different, the M2M server There are multiple first public topics generated according to the identifier of the subscription resource.

Further, when the M2M server receives the subscription creation request message sent by the first M2M terminal among the at least two M2M terminals, the M2M server assigns a number to the identifier of the subscription resource of the first M2M terminal, for example, the number is 1 , the M2M server generates the first public topic of the subscription resource corresponding to the first M2M terminal according to the identifier of the subscription resource and the number 1.

When the M2M server receives the subscription creation request message sent by the second M2M terminal among the at least two M2M terminals, if the M2M server determines that the notification filter condition of the second M2M terminal is different from the notification filter condition of the first M2M terminal If the conditions are the same, the M2M server may assign the first public theme generated by the first M2M terminal to the second M2M terminal. If the M2M server determines that the notification filter condition of the second M2M terminal is different from the notification filter condition of the first M2M terminal, the M2M server assigns a number, for example, 2, to the identifier of the subscription resource of the second M2M terminal, And according to the identifier of the subscription resource and the number 2, a first common topic of the subscription resource corresponding to the second M2M terminal is generated.

Further, in mode 4, as shown in FIG. 8 , the second service message in S306 above is a subscription creation response message generated by the M2M server according to the subscription creation request message for the subscription resource, and the subscription creation response message is an M2M The server needs to send a response message to each M2M terminal subscribing to the subscription resource. Wherein, the above-mentioned S305-S306 may specifically be:

S305c. The M2M server uses the identifier of the second resource stored in each M2M terminal subscribing to the subscription resource as the content included in the first topic that the M2M terminal has subscribed to.

S306d, the M2M server sends a second MQTT message to each of the at least two M2M terminals through the MQTT server, the second MQTT message includes a subscription creation response message and the first topic, and the subscription creation response message carries the subscription resource The first public topic of .

An embodiment of the present invention provides a service message transmission method. An M2M server determines to send a first service message with the same content to at least two M2M terminals corresponding to a first resource stored in the M2M server, and determines to generate a service message for the first resource. The first public topic of the first MQTT message is sent to the MQTT server once, the first MQTT message includes the first business message and the first public topic, and the first business message includes the same content sent to at least two terminals. Compared with the prior art where the M2M server needs to issue multiple MQTT messages containing different topics to the MQTT server, the service message transmission method provided by the embodiment of the present invention can reduce the communication overhead between the M2M server and the MQTT server.

As shown in FIG. 9, an embodiment of the present invention provides an M2M terminal, and the M2M terminal may include:

The receiving unit 10 is configured to receive a first MQTT message sent by an MQTT server, where the first MQTT message includes a first service message and a first public topic.

The search unit 11 is configured to search for the first public topic received by the receiving unit 10 according to the mapping relationship between the first public theme stored in the storage unit 12 and the identifier of the resource stored in the storage unit 12. The identifier of the resource stored in the storage unit 12 corresponding to the public topic.

The executing unit 13 is configured to execute the resource stored in the storage unit 12 indicated by the identifier of the resource stored in the storage unit 12 searched by the search unit 10 and received by the receiving unit 10 Operations related to the first service message.

Optionally, referring to FIG. 9 , as shown in FIG. 10 , the M2M terminal further includes a sending unit 14 .

The receiving unit 10 is further configured to receive a second MQTT message sent by the MQTT server before receiving the first MQTT message sent by the MQTT server, the second MQTT message includes a second business message and a first topic, The second service message includes the first public topic, and the first topic includes the identifier of the resource stored in the storage unit 12 .

The storage unit 12 is configured to store a mapping relationship between the first public topic received by the receiving unit 10 and the identifiers of the resources stored in the storage unit 12 .

The sending unit 14 is configured to send a message of a first subscribed topic to the MQTT server, where the message of the first subscribed topic includes the first public topic received by the receiving unit 10 and the M2M terminal's logo.

Optionally, the sending unit 14 is further configured to send a message of a second subscription topic to the MQTT server before the receiving unit receives the second MQTT message sent by the MQTT server, and the second subscription topic The message includes the first topic that the M2M terminal needs to subscribe to.

In the embodiment of the present invention, the M2M terminal may be a sensor or a microcontroller.

An embodiment of the present invention provides an M2M terminal, because the M2M can receive the first MQTT message sent by the MQTT server, and according to the saved mapping relationship between the first common theme and the identifier of the resource stored in the M2M terminal, Finding the identifier of the resource stored in the M2M terminal corresponding to the first common theme, and executing the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal is related to the first service message In the operation, the first MQTT message includes the first service message and the first public topic. Therefore, when the M2M server needs to send the first service message with the same content to at least two M2M terminals corresponding to the resources stored in the M2M server, the MQTT server only needs to send the first MQTT message to the MQTT server once, because the at least Both M2M terminals have subscribed to the first common topic, so the MQTT server will forward the first MQTT message to the at least two M2M terminals, and each M2M terminal in the at least two M2M terminals can be based on the first The mapping relationship between the public topic and the identifier of the resource stored in each M2M terminal executes an operation related to the first service message, thereby reducing the communication overhead between the M2M server and the MQTT server.

As shown in FIG. 11, an embodiment of the present invention provides an M2M server, and the M2M server may include:

The determining unit 20 is configured to determine a first common topic generated for the first resource when the first service message with the same content needs to be sent to at least two M2M terminals corresponding to the first resource stored in the storage unit 22 .

The sending unit 21 is configured to send a first MQTT message to the MQTT server once, the first MQTT message includes the first business message and the first public topic determined by the determining unit 20, the first business The message includes the same content sent to the at least two M2M terminals.

Optionally, combined with Step 11, as shown in Figure 12, the M2M server further includes:

The generating unit 23 is configured to generate the first common topic for the first resource before the determining unit 20 determines the first common topic generated for the first resource, and generate the first common topic in the at least two M2M terminals The identifier of the second resource stored in each M2M terminal of , is used as the content included in the first topic that the M2M terminal has subscribed to.

Wherein, after the generating unit 23 generates the first public topic for the first resource, associate the first public topic with the first resource and store it in the storage unit 22 .

The sending unit 21 is further configured to send a second MQTT message to each of the at least two M2M terminals through the MQTT server, and the second MQTT message includes a second service message and the The first topic generated by the generating unit 23, and the second service message includes the first common topic generated by the generating unit 23.

Optionally, as shown in FIG. 12, when the first resource is a group resource, the identifier of the second resource is an identifier of a member resource in the group resource, and the generation unit 23 specifically uses After receiving the creation request message of the group resource, generating a first public theme of the group resource for the group resource according to the identifier of the group resource allocated to the group resource, and the identifier of the member resource is used as the content contained in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to, and the first common topic of the group resource includes the identifier of the group resource . Wherein, the second service message sent by the sending unit 21 is a notification message sent by the M2M server to the M2M terminal corresponding to the identifier of the member resource.

Optionally, referring to FIG. 12, as shown in FIG. 13, when the first resource is a group resource, the identifier of the second resource is an identifier of a member resource in the group resource, and the generation unit 23 specifically includes a determination module 200 and a generation module 201.

The determining module 200 is configured to, after receiving an access request message to a member resource of the group resource, according to the group resource included in the access request message to a member resource of the group resource The identifier of determines that there is no first common topic corresponding to the group resource.

The generating module 201 is configured to generate the group for the group resource according to the identifier of the group resource when the determining module 200 determines that there is no first common theme corresponding to the group resource The first common theme of the resource, and the identifier of the member resource is used as the content contained in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to, and the first common theme of the group resource contains The identifier of the group resource.

Wherein, the second service message sent by the sending unit 21 is a first access request message generated by the M2M server according to the access request message for member resources of the group resource, and the first access request message The message is an access request message sent by the M2M server to the M2M terminal corresponding to the identifier of the member resource.

Optionally, as shown in FIG. 13 , when the first resource is a subscription resource, the generating unit 23 specifically includes a determining module 200 and a generating module 201 .

The determining module 200 is configured to determine, according to the identifier of the subscribed resource, that there is no first public topic corresponding to the subscribed resource when it is determined that the subscribed resource has changed.

The generation module 201 is configured to, when the determination module 200 determines that there is no first public topic corresponding to the subscription resource, generate the first topic of the subscription resource for the subscription resource according to the identifier of the subscription resource. public topic, and use the identifier of the second resource stored in each M2M terminal that subscribes to the subscription resource as the content contained in the first topic that the M2M terminal has subscribed to, and the first public topic of the subscription resource contains all The ID of the subscription resource described above.

Wherein, the second service message sent by the sending unit 21 is a subscription notification message for each M2M terminal subscribing to the subscription resource.

Optionally, as shown in FIG. 12, when the first resource is a subscription resource, the generation unit 23 is specifically configured to, when receiving a subscription creation request message for the subscription resource, generate the first public topic of the subscription resource for the subscription resource, and use the identifier of the second resource stored in each M2M terminal subscribing to the subscription resource as the first topic that the M2M terminal has subscribed to Included content, the subscription creation request message for the subscription resource includes the identifier of the subscription resource and the identifier of the second resource stored in the M2M terminal subscribing to the subscription resource, the first public resource of the subscription resource The subject contains the identifier of the subscription resource.

Wherein, the second service message sent by the sending unit 21 is a subscription creation response message generated by the M2M server according to the subscription creation request message for the subscription resource, and the subscription creation response message is the M2M The server needs to send a response message to each M2M terminal subscribing to the subscription resource.

In the embodiment of the present invention, the M2M server may be an M2M application, and specifically may include a power meter reading server, an intelligent transportation server, a fleet management server, and the like.

An embodiment of the present invention provides an M2M server. When the M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to the first resource stored in the M2M server, the M2M server can determine that the The first public topic generated by the first resource, and the first MQTT message is sent to the MQTT server once, the first MQTT message includes the first business message and the first public topic, and the first business message includes sending to at least two terminals of the same content. Compared with the prior art where the M2M server needs to issue multiple MQTT messages containing different topics to the MQTT server, using the M2M server provided by the embodiment of the present invention can reduce the communication overhead between the M2M server and the MQTT server.

As shown in FIG. 14 , an embodiment of the present invention provides an M2M terminal, and the M2M terminal includes: a processor 30 , a memory 31 , a transceiver 32 , and a system bus 33 . Said: the processor 30 , the memory 31 and the transceiver 32 are connected through the system bus 33 to complete mutual communication.

The processor 30 may be a central processing unit (Central Processing Unit, CPU), or a specific integrated circuit (Application Specific Integrated Circuit, ASIC), or one or more integrated circuits configured to implement embodiments of the present invention .

The transceiver 32 may be a module composed of an independent receiver and an independent transmitter, or may be an integrated module of the receiver and the transmitter.

The memory 31 may include a volatile memory (English: volatile memory), such as a random-access memory (English: random-access memory, abbreviated as RAM); the memory 31 may also include a non-volatile memory (English: non-volatile memory). -volatile memory), such as read-only memory (English: read-only memory, abbreviation: ROM), flash memory (English: flash memory), hard disk (English: hard disk drive, abbreviation: HDD) or solid state drive (English: solid-state drive, abbreviation: SSD); the storage 31 may also include a combination of the above-mentioned types of storage.

When the M2M terminal is running, the processor 30, the memory 31 and the transceiver 32 may execute the method flow described in any one of FIG. 1, FIG. 3 or FIG. 5 to FIG. 8, specifically including:

The transceiver 32 is configured to receive a first MQTT message sent by an MQTT server, the first MQTT message includes a first business message and a first public topic; the processor 30 is configured to A mapping relationship between a common theme and the identifier of the resource stored in the M2M terminal, searching for the resource stored in the M2M terminal corresponding to the first common theme received by the transceiver 32 identification, and performing an operation related to the first service message on the resource stored in the M2M terminal indicated by the identification of the resource stored in the M2M terminal; the memory 31 is configured to store The code of the first MQTT message, the code of the first service message, the code of the resource stored in the M2M terminal, the code of the identification of the resource stored in the M2M terminal, and the code of the first public topic , and a software program that controls the processor 30 to complete the above process, so that the processor 30 executes the software program and calls the code of the first MQTT message, the code of the first business message, the code of the first business message, the The code of the resource stored in the M2M terminal, the code of the identifier of the resource stored in the M2M terminal, and the code of the first public subject complete the above process.

Optionally, the transceiver 32 is further configured to receive a second MQTT message sent by the MQTT server before receiving the first MQTT message sent by the MQTT server, and send a message of the first subscription topic to the MQTT server , the second MQTT message includes a second service message and a first topic, the second service message includes the first public topic, and the first topic includes the information stored in the M2M terminal A resource identifier, where the message of the first subscription topic includes the first public topic and the identifier of the M2M terminal.

The processor 30 is further configured to save a mapping relationship between the first common theme received by the transceiver and the identifier of the resource stored in the M2M terminal.

Optionally, the transceiver 32 is further configured to send a message of a second subscription topic to the MQTT server before receiving the second MQTT message sent by the MQTT server, and the message of the second subscription topic includes the The first topic that the M2M terminal needs to subscribe to.

An embodiment of the present invention provides an M2M terminal, because the M2M can receive the first MQTT message sent by the MQTT server, and according to the saved mapping relationship between the first common theme and the identifier of the resource stored in the M2M terminal, Finding the identifier of the resource corresponding to the first public topic, and performing an operation related to the first service message on the resource indicated by the resource identifier, where the first MQTT message includes the first service message and the first public topic. Therefore, when the M2M server needs to send the first service message with the same content to at least two M2M terminals corresponding to the resources stored in the M2M server, the MQTT server only needs to send the first MQTT message to the MQTT server once, because the at least Both M2M terminals have subscribed to the first common topic, so the MQTT server will forward the first MQTT message to the at least two M2M terminals, and each M2M terminal in the at least two M2M terminals can be based on the first The mapping relationship between the public subject and the identifier of the resource stored in each M2M terminal executes an operation related to the first service message. Compared with the MQTT server in the prior art that needs to send multiple MQTT messages containing different topics to the MQTT server, the M2M terminal provided by the embodiment of the present invention can reduce the communication between the M2M server and the MQTT server when communicating with the M2M server. communication overhead.

As shown in FIG. 15 , an embodiment of the present invention provides an M2M server, and the M2M server includes: a processor 40 , a memory 41 , a transceiver 42 , and a system bus 43 . Said: the processor 40 , the memory 41 and the transceiver 42 are connected through the system bus 43 to complete mutual communication.

The processor 40 may be a CPU, or an ASIC, or one or more integrated circuits configured to implement embodiments of the present invention.

The transceiver 42 may be a module composed of an independent receiver and an independent transmitter, or may be an integrated module of the receiver and the transmitter.

Described memory 41 can comprise volatile memory, such as RAM; Described memory 43 also can comprise nonvolatile memory, such as ROM, flash memory, HDD or SSD; Described memory 41 can also comprise the memory of above-mentioned kind. combination.

When the M2M server is running, the processor 40, the memory 41, and the transceiver 42 may execute the method flow described in any one of FIG. 2 to FIG. 3 or FIG. 5 to FIG. 8, specifically including:

The processor 40 is configured to determine the first service message generated for the first resource when the first service message with the same content needs to be sent to at least two M2M terminals corresponding to the first resource stored in the M2M server. Public topic; the transceiver 42 is configured to send a first MQTT message to the MQTT server once, the first MQTT message includes the first business message and the first public topic, and the first business message contains Including the same content sent to the at least two M2M terminals; the memory 41 is used to store the code of the first resource stored in the M2M server, the code of the first MQTT message, the first service message , the first public subject, and a software program that controls the processor 40 to complete the above process, so that the processor 40 executes the software program, and invokes the code of the first resource stored in the M2M server, the The code of the first MQTT message, the first service message, and the first public topic are used to complete the above process.

Optionally, the processor 40 is further configured to generate the first common theme for the first resource before determining the first common theme generated for the first resource, and combine the at least two The identifier of the second resource stored in each of the M2M terminals is used as the content included in the first topic that the M2M terminal has subscribed to.

The transceiver 42 is further configured to send a second MQTT message to each of the at least two M2M terminals through the MQTT server, and the second MQTT message includes a second service message and the The first topic, the second service message includes the first public topic.

Optionally, when the first resource is a group resource, the identifier of the second resource is an identifier of a member resource in the group resource, and the processor 40 is specifically configured to receive the After the creation request message of the group resource, according to the identifier of the group resource assigned to the group resource, generate the first common topic of the group resource for the group resource, and assign the member resource The identifier of the member resource is used as the content included in the first topic that the M2M terminal corresponding to the identifier of the member resource has subscribed to, and the first common topic of the group resource includes the identifier of the group resource. Wherein, the second service message sent by the transceiver 42 is a notification message sent by the M2M server to the M2M terminal corresponding to the identifier of the member resource.

Optionally, when the first resource is a group resource, the identifier of the second resource is an identifier of a member resource in the group resource, and the processor 40 is specifically configured to, after receiving the After receiving the access request message of the member resource of the group resource, according to the identifier of the group resource included in the access request message of the member resource of the group resource, it is determined that there is no second group resource corresponding to the group resource. A common topic, and according to the identifier of the group resource, generate the first common topic of the group resource for the group resource, and use the identifier of the member resource as corresponding to the identifier of the member resource The content contained in the first topic that the M2M terminal has subscribed to, and the first public topic of the group resource includes the identifier of the group resource.

Wherein, the second service message sent by the transceiver 42 is a first access request message generated by the M2M server according to the access request message for member resources of the group resource, and the first access request message The message is an access request message sent by the M2M server to the M2M terminal corresponding to the identifier of the member resource.

Optionally, when the first resource is a subscription resource, the processor 40 is specifically configured to determine, according to the identifier of the subscription resource, that there is no subscription resource corresponding to the subscription resource when it is determined that the subscription resource changes. The first common topic, and according to the identifier of the subscribed resource, generate the first common topic of the subscribed resource for the subscribed resource, and store the identifier of the second resource stored in each M2M terminal that subscribes to the subscribed resource , as the content included in the first topic that the M2M terminal has subscribed to, the first public topic of the subscription resource includes the identifier of the subscription resource.

Wherein, the second service message sent by the transceiver 42 is a subscription notification message for each M2M terminal subscribing to the subscription resource.

Optionally, when the first resource is a subscription resource, the processor 40 is specifically configured to: when receiving a subscription creation request message for the subscription resource, according to the identifier of the subscription resource, provide the The subscription resource generates the first public topic of the subscription resource, and uses the identifier of the second resource stored in each M2M terminal subscribing to the subscription resource as the content contained in the first topic that the M2M terminal has subscribed to, the The subscription creation request message for the subscription resource includes the identifier of the subscription resource and the identifier of the second resource stored in the M2M terminal subscribing to the subscription resource, and the first public topic of the subscription resource includes the subscription The ID of the resource.

Wherein, the second service message sent by the transceiver 42 is a subscription creation response message generated by the M2M server according to the subscription creation request message for the subscription resource, and the subscription creation response message is the M2M The server needs to send a response message to each M2M terminal subscribing to the subscription resource.

An embodiment of the present invention provides an M2M server. When the M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to the first resource stored in the M2M server, the M2M server can determine that the The first public topic generated by the first resource, and the first MQTT message is sent to the MQTT server once, the first MQTT message includes the first business message and the first public topic, and the first business message includes sending to at least two terminals of the same content. Compared with the prior art where the M2M server needs to issue multiple MQTT messages containing different topics to the MQTT server, using the M2M server provided by the embodiment of the present invention can reduce the communication overhead between the M2M server and the MQTT server.

As shown in FIG. 16, an embodiment of the present invention provides a service message transmission system. The service message transmission system may include: the M2M terminal shown in FIG. 9 or FIG. 10 above, and the M2M terminal shown in FIG. Any M2M server, and an MQTT server, wherein the MQTT server interacts with the M2M server and the M2M terminal; or the service message transmission system includes: the M2M terminal shown in FIG. 14 above, such as In the M2M server and the MQTT server shown in FIG. 15 above, the MQTT server interacts with the M2M server and the M2M terminal.

In the service message transmission system provided by the embodiment of the present invention, when the M2M server needs to send a first service message with the same content to at least two M2M terminals corresponding to the first resources stored in the M2M server, the M2M server can Determine the public topic generated for the first resource, and send a first MQTT message to the MQTT server once, the first MQTT message includes the first business message and the first public topic, and the first business message contains the message sent to Same content of the at least two M2M terminals. Each M2M terminal in the at least two M2M terminals can receive the first MQTT message sent by the MQTT server, and according to the saved mapping relationship between the first common topic and the identifier of the resource stored in the M2M terminal, Finding the identifier of the resource stored in the M2M terminal corresponding to the first common theme, and executing the resource stored in the M2M terminal indicated by the identifier of the resource stored in the M2M terminal is related to the first service message operation.

Through the service message transmission system provided by the embodiment of the present invention, when the M2M server needs to send a service message with the same content to at least two M2M terminals corresponding to the first resource stored in the M2M server, the M2M service can only send the service message to the MQTT server The first MQTT message is sent once, and each M2M terminal in the at least two M2M terminals can receive the first MQTT message and perform a corresponding operation. Compared with the prior art where the M2M server needs to send multiple MQTT messages containing different topics to the MQTT server, the service message transmission system provided by the embodiment of the present invention can reduce the communication overhead between the M2M server and the MQTT server.

Those skilled in the art can clearly understand that for the convenience and brevity of description, only the division of the above-mentioned functional modules is used as an example for illustration. In practical applications, the above-mentioned function allocation can be completed by different functional modules according to needs. The internal structure of the device is divided into different functional modules to complete all or part of the functions described above. For the specific working process of the above-described system, device, and unit, reference may be made to the corresponding process in the foregoing method embodiments, and details are not repeated here.

In the several embodiments provided in this application, it should be understood that the disclosed system, device and method can be implemented in other ways. For example, the device embodiments described above are only illustrative. For example, the division of the modules or units is only a logical function division. In actual implementation, there may be other division methods. For example, multiple units or components can be Incorporation may either be integrated into another system, or some features may be omitted, or not implemented. In another point, the mutual coupling or direct coupling or communication connection shown or discussed may be through some interfaces, and the indirect coupling or communication connection of devices or units may be in electrical, mechanical or other forms.

The units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in one place, or may be distributed to multiple network units. Part or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.

In addition, each functional unit in each embodiment of the present invention may be integrated into one processing unit, each unit may exist separately physically, or two or more units may be integrated into one unit. The above-mentioned integrated units can be implemented in the form of hardware or in the form of software functional units.

If the integrated unit is realized in the form of a software function unit and sold or used as an independent product, it can be stored in a computer-readable storage medium. Based on this understanding, the essence of the technical solution of the present invention or the part that contributes to the prior art or all or part of the technical solution can be embodied in the form of a software product, and the computer software product is stored in a storage medium , including several instructions to make a computer device (which may be a personal computer, a server, or a network device, etc.) or a processor execute all or part of the steps of the method described in each embodiment of the present invention. The aforementioned storage media include: U disk, mobile hard disk, read-only memory (English full name: Read-Only Memory, English abbreviation: ROM), random access memory (English full name: Random Access Memory, English abbreviation: RAM), magnetic Various media that can store program codes such as discs or optical discs.

The above is only a specific embodiment of the present invention, but the scope of protection of the present invention is not limited thereto. Anyone skilled in the art can easily think of changes or substitutions within the technical scope disclosed in the present invention. Should be covered within the protection scope of the present invention. Therefore, the protection scope of the present invention should be based on the protection scope of the claims.

Claims (19)

1. a kind of transmission method of service message characterized by comprising

Machine To Machine M2M terminal receives the first MQTT message that message sequence telemetering transmission MQTT server is sent, and described the It include the first service message and the first common subject matter in one MQTT message；

The M2M terminal according to the mark of first common subject matter of preservation and the resource stored in the M2M terminal it Between mapping relations, search it is corresponding with first common subject matter described in the mark of resource that is stored in the M2M terminal；

Described in mark instruction of the M2M terminal to the resource stored in the M2M terminal in the M2M terminal The resource of storage executes operation relevant to first service message.

2. the method according to claim 1, wherein the M2M terminal receives first that MQTT server is sent Before MQTT message, the method also includes:

The M2M terminal receives the 2nd MQTT message that the MQTT server is sent, comprising the in the 2nd MQTT message Two service messages and the first theme include first common subject matter in second service message, wrap in first theme Mark containing the resource stored in the M2M terminal；

The M2M terminal saves first common subject matter and described between the mark of the resource stored in the M2M terminal Mapping relations；

The M2M terminal sends the first message for subscribing to theme to the MQTT server, and described first subscribes to the message of theme In the mark comprising first common subject matter and the M2M terminal.

3. according to the method described in claim 2, it is characterized in that, the M2M terminal receives what the MQTT server was sent Before 2nd MQTT message, the method also includes:

The M2M terminal sends the second message for subscribing to theme to the MQTT server, and described second subscribes to the message of theme First theme subscribed to is needed comprising the M2M terminal.

4. a kind of transmission method of service message characterized by comprising

When Machine To Machine M2M server need to the first resource corresponding at least two that is stored in the M2M server When subscribing to the M2M terminal of the first common subject matter and sending the first service message of identical content,

The M2M server is determined as first common subject matter that the first resource generates；

The M2M server to message sequence telemetering transmission MQTT server send a first MQTT message, described first Include first service message and first common subject matter in MQTT message, includes to be sent in first service message The identical content of at least two M2M terminal.

5. according to the method described in claim 4, it is characterized in that, the M2M server is determined as the first resource generation The first common subject matter before, the method also includes:

The M2M server is that the first resource generates first common subject matter；

The M2M server is by the mark of the Secondary resource stored in each of at least two M2M terminal M2M terminal The content that the first theme having subscribed as the M2M terminal includes；

The M2M server is sent by the MQTT server to each of at least two M2M terminal M2M terminal One article of the 2nd MQTT message includes the second service message and first theme, second industry in the 2nd MQTT message It include first common subject matter in message of being engaged in.

6. according to the method described in claim 5, it is characterized in that,

When the first resource is group's resource, the member resource of the Secondary resource being identified as in group's resource Mark, the M2M server are that the first resource generates first common subject matter specifically:

The M2M server is after the request to create message for receiving group's resource, according to for group's resource allocation Group's resource mark, generate the first common subject matter of group's resource, group's money for group's resource It include the mark of group's resource in first common subject matter in source；

The M2M server is by the mark of the Secondary resource stored in each of at least two M2M terminal M2M terminal The content that the first theme having subscribed as the M2M terminal includes specifically:

The M2M server is by the mark of the member resource, as M2M terminal corresponding with the mark of the member resource The content that the first theme through subscribing to includes；

Wherein, second service message is the M2M server pair M2M terminal corresponding with the mark of the member resource Notification message.

7. according to the method described in claim 5, it is characterized in that, when the first resource be group's resource when, described second The mark for the member resource of resource being identified as in group's resource, the M2M server generate institute for the first resource State the first common subject matter specifically:

The M2M server is after receiving to the access request message of the member resource of group's resource, the M2M service The mark for group's resource that device includes in the access request message according to the member resource to group's resource is true Fixed first common subject matter not corresponding with group's resource；

The M2M server generates the first of group's resource according to the mark of group's resource for group's resource Common subject matter includes the mark of group's resource in the first common subject matter of group's resource；

The M2M server is by the mark of the Secondary resource stored in each of at least two M2M terminal M2M terminal The content that the first theme having subscribed as the M2M terminal includes specifically:

The M2M server is by the mark of the member resource, as M2M terminal corresponding with the mark of the member resource The content that the first theme through subscribing to includes；

Wherein, second service message is visit of the M2M server according to the member resource to group's resource Ask request message generate the first access request message, first access request message be the M2M server be sent to The access request message of the corresponding M2M terminal of mark of the member resource.

8. according to the method described in claim 5, it is characterized in that, the M2M takes when the first resource is to subscribe to resource Device be engaged in as first resource generation first common subject matter specifically:

When the M2M server determines that the subscription resource changes, the M2M server is according to the subscription resource Mark determines the first common subject matter not corresponding with the subscription resource；

The M2M server is according to the mark for subscribing to resource, generate the subscription resource for the subscription resource first Common subject matter, it is described subscribe to resource the first common subject matter in comprising it is described subscribe to resource mark；

The M2M server is by the mark of the Secondary resource stored in each of at least two M2M terminal M2M terminal The content that the first theme having subscribed as the M2M terminal includes specifically:

Each is subscribed to the mark of the Secondary resource stored in the M2M terminal for subscribing to resource by the M2M server, as The content that the first theme that the M2M terminal has subscribed includes；

Wherein, second service message is that the M2M server subscribes to ordering for the M2M terminal for subscribing to resource to each Read notification message.

9. according to the method described in claim 5, it is characterized in that,

When the first resource is to subscribe to resource, the M2M server is that the first resource generates the first public master Topic specifically:

It is described that the subscription is provided when the M2M server is received to the subscription request to create message for subscribing to resource Comprising being deposited in the mark for subscribing to resource and the subscription M2M terminal for subscribing to resource in the subscription request to create message in source The mark of the Secondary resource of storage, the M2M server is according to the mark for subscribing to resource, for described in subscription resource generation The first common subject matter of resource is subscribed to, includes the mark for subscribing to resource in first common subject matter for subscribing to resource；

The M2M server is by the mark of the Secondary resource stored in each of at least two M2M terminal M2M terminal The content that the first theme having subscribed as the M2M terminal includes specifically:

Each is subscribed to the mark of the Secondary resource stored in the M2M terminal for subscribing to resource by the M2M server, as The content that the first theme that the M2M terminal has subscribed includes；

Wherein, second service message is the M2M server according to the subscription request to create to the subscription resource The subscription that message generates creates response message, and the subscription creation response message is that the M2M server need to be sent to each Subscribe to the response message of the M2M terminal for subscribing to resource.

10. a kind of Machine To Machine M2M terminal characterized by comprising

Receiving unit, the first MQTT message sent for receiving message sequence telemetering transmission MQTT server, described first It include the first service message and the first common subject matter in MQTT message；

Searching unit, first common subject matter for being saved according to storage unit in money stored in the storage unit Mapping relations between the mark in source are searched corresponding with received first common subject matter of the receiving unit described in institute State the mark of the resource stored in storage unit；

Execution unit, for indicating the mark described in searching unit lookup in resource stored in the storage unit It is described resource stored in the storage unit execute it is related to received first service message of the receiving unit Operation.

11. M2M terminal according to claim 10, which is characterized in that the M2M terminal further includes transmission unit,

The receiving unit is also used to before receiving the first MQTT message that the MQTT server is sent, described in reception The 2nd MQTT message that MQTT server is sent includes the second service message and the first theme, institute in the 2nd MQTT message Stating includes first common subject matter in the second service message, is deposited in the storage unit in first theme comprising described The mark of the resource of storage；

The storage unit, for saving received first common subject matter of the receiving unit with described in the storage list Mapping relations between the mark of the resource stored in member；

The transmission unit, for sending the first message for subscribing to theme to the MQTT server, described first subscribes to theme Message in the mark comprising received first common subject matter of the receiving unit and the M2M terminal.

12. M2M terminal according to claim 11, which is characterized in that

The transmission unit, be also used to the receiving unit receive the 2nd MQTT message that the MQTT server is sent it Before, Xiang Suoshu MQTT server sends the second message for subscribing to theme, and the message of the second subscription theme includes to need to subscribe to First theme.

13. a kind of M2M server characterized by comprising

Determination unit, for public when first need to have been subscribed to corresponding with the first resource stored in storage unit at least two When the M2M terminal of theme sends the first service message of identical content altogether, it is determined as the first resource generates described first Common subject matter；

Transmission unit, for message sequence telemetering transmission MQTT server send a first MQTT message, described first First common subject matter determined in MQTT message comprising first service message and the determination unit, first industry It include the identical content for being sent at least two M2M terminal in business message.

14. M2M server according to claim 13, which is characterized in that the M2M server further include:

Generation unit is determined as before the first common subject matter that the first resource generates for the determination unit, is described First resource generates first common subject matter, and will store in each of at least two M2M terminal M2M terminal The content that the first theme that the mark of Secondary resource has subscribed as the M2M terminal includes；

The transmission unit is also used to whole to each of at least two M2M terminal M2M by the MQTT server End sends one article of the 2nd MQTT message, generates in the 2nd MQTT message comprising the second service message and the generation unit First theme, first common subject matter generated comprising the generation unit in second service message.

15. M2M server according to claim 14, which is characterized in that

When the first resource is group's resource, the member resource of the Secondary resource being identified as in group's resource Mark,

The generation unit, specifically for after the request to create message for receiving group's resource, according to for the group The mark of group's resource of resource allocation generates the first common subject matter of group's resource for group's resource, and By the mark of the member resource, the first theme being had subscribed as M2M terminal corresponding with the mark of the member resource The content for including includes the mark of group's resource in the first common subject matter of group's resource；

Wherein, second service message is the notification message to M2M terminal corresponding with the mark of the member resource.

16. M2M server according to claim 14, which is characterized in that when the first resource is group's resource, institute The mark for the member resource of Secondary resource being identified as in group's resource is stated, the generation unit specifically includes determining module And generation module,

The determining module, for after receiving to the access request message of the member resource of group's resource, according to institute State the group's resource for including in the access request message to the member resource of group's resource mark determine not with Corresponding first common subject matter of group's resource；

The generation module, for determining the first common subject matter not corresponding with group's resource when the determining module When, according to the mark of group's resource, generate the first common subject matter of group's resource for group's resource, and by institute The mark for stating member resource, the first theme having subscribed as M2M terminal corresponding with the mark of the member resource include Content, include the mark of group's resource in the first common subject matter of group's resource；

Wherein, second service message is to be generated according to the access request message of the member resource to group's resource The first access request message, first access request message is to be sent to M2M corresponding with the mark of the member resource The access request message of terminal.

17. M2M server according to claim 14, which is characterized in that when the first resource is to subscribe to resource, institute It states generation unit and specifically includes determining module and generation module,

The determining module, for being determined according to the mark for subscribing to resource when determining that the subscription resource changes First common subject matter not corresponding with the subscription resource；

The generation module, for determining the first common subject matter not corresponding with the subscription resource in the determining module When, according to the mark for subscribing to resource, first common subject matter for subscribing to resource is generated for the subscription resource, and will be every One is subscribed to the mark of Secondary resource stored in the M2M terminal for subscribing to resource, the had subscribed as the M2M terminal The content that one theme includes, it is described subscribe to resource the first common subject matter in comprising it is described subscribe to resource mark；

Wherein, second service message is the subscribing notification message that the M2M terminal for subscribing to resource is subscribed to each.

18. M2M server according to claim 14, which is characterized in that

When the first resource is to subscribe to resource,

The generation unit, specifically for when receive to it is described subscribe to resource subscription request to create message when, according to described The mark of resource is subscribed to, generates first common subject matter for subscribing to resource for the subscription resource, and each is subscribed into institute The mark of the Secondary resource stored in the M2M terminal for subscribing to resource is stated, the first theme having subscribed as the M2M terminal includes Content, it is described to it is described subscribe to resource subscriptions request to create message in comprising it is described subscribe to resource mark and subscription institute The mark of the Secondary resource stored in the M2M terminal for subscribing to resource is stated, includes institute in first common subject matter for subscribing to resource State the mark for subscribing to resource；

Wherein, second service message is according to the subscription generated to the subscription request to create message for subscribing to resource Response message is created, the creation response message of subscribing to is that need to be sent to each to subscribe to the M2M terminal for subscribing to resource Response message.

19. a kind of Transmission system of service message characterized by comprising

At least two such as described in any item Machine To Machine M2M terminals of claim 10-12, as claim 13-18 is any M2M server and message sequence telemetering described in transmit MQTT server.