Message processing method, device and system for internet of things

Patent metadata

Field	Value
Publication number	US-9832275-B2
Application number	US-201314410850-A
Country	US
Kind code	B2
Filing date	Jul 4, 2013
Priority date	Jul 4, 2012
Publication date	Nov 28, 2017
Grant date	Nov 28, 2017

Abstract

A message processing method, device and system for Internet of Things are described. The method includes that: a gateway of the Internet of Things receives one or more operation messages transmitted by a plurality of transmitters for one or more operations of a terminal; and the gateway of the Internet of Things caches and pre-processes the received one or more operation messages in a message queue, and according to a processing result, sends at least one operation message in the message queue to a terminal. By the disclosure, the problems existing in the process of executing interactive operations on the terminal in the related art are solved, the energy consumption generated when the terminal executes the operation messages is saved, and the resource loss of the Internet of Things is reduced.

First claim

What is claimed is:

1. A message processing method for Internet of Things, comprising:
receiving, by a gateway of Internet of Things, one or more operation messages transmitted by a plurality of transmitters for one or more operations of a terminal; and
caching and pre-processing, by the gateway of the Internet of Things, the received one or more operation messages in a message queue, and according to a processing result, sending at least one operation message in the message queue to the terminal,
wherein pre-processing, by the gateway of the Internet of Things, the received one or more operation messages in a message queue comprises at least one of the following:
adjusting, by the gateway of the Internet of Things, a message sequence of the received one or more operation messages in the message queue corresponding to the terminal according to a configured policy; and
merging, by the gateway of the Internet of Things, operation messages indicative of a same operation in the received one or more operation messages and/or operation messages indicative of the same operation in the message queue corresponding to the terminal,
wherein the message queue corresponding to the terminal comprises a first queue and a second queue, the first queue is configured to store operation messages of the terminal, the second queue is configured to store a sending sequence of the operation messages of the terminal, the sending sequence comprises address information corresponding to the operation messages in the first queue and an access address of a status of the terminal;
correspondingly, sending at least one operation message in the message queue to the terminal according to the processing result comprises:
reading, by the gateway of the Internet of Things, status information of the terminal according to the access address in the second queue;
reading, by the gateway of the Internet of Things, at least one operation message of the terminal stored in the first queue according to the address information of the operation messages in the second queue; and

sending, by the gateway of the Internet of Things, the at least one operation message which is read to the terminal according to the status information of the terminal and the processing result.

2. The message processing method according to claim 1 , wherein adjusting the message sequence of the received one or more operation messages in the message queue corresponding to the terminal comprises:
when there is a conflict between the received one or more operation messages and one or more operation messages in the message queue, and operation messages in conflict have different priority, adjusting, by the gateway of the Internet of Things, a sending sequence of operation messages in the message queue according to the configured policy and executing operation messages having high priority prior to operation messages having low priority in the operation messages in conflict; and/or
when there is a conflict between the received one or more operation messages and one or more operation messages in the message queue, and operation messages in conflict have same priority, rearranging, by the gateway of the Internet of Things, a sending sequence of the operation messages in conflict according to the configured policy.

3. The message processing method according to claim 1 , wherein merging, by the gateway of the Internet of Things, the operation messages indicative of a same operation in the received one or more operation messages and/or the operation messages indicative of the same operation in the message queue corresponding to the terminal comprises:
when the received one or more operation messages indicate a same operation as one or more operation messages in the message queue, and operation messages indicative of the same operation have different priority, merging, by the gateway of the Internet of Things, the operation messages indicative of the same operation into a corresponding position of an operation message having highest priority in the operation messages indicative of the same operation and executing the merged operation messages according to the configured policy; and/or
when the received one or more operation messages indicate a same operation as one or more operation messages in the message queue, and operation messages indicative of the same operation have same priority, merging, by the gateway of the Internet of Things, the operation messages indicative of the same operation into a position where the operation messages indicative of the same operation already existing in the message queue of the terminal are located and executing the merged operation messages; and/or
when the received one or more operation messages indicate a same operation, merging, by the gateway of the Internet of Things, the operation messages indicative of the same operation into a corresponding position of an operation message having highest priority in the received one or more operation messages according to the configured policy.

4. The message processing method according to claim 1 , wherein sending, by the gateway of the Internet of Things, the at least one operation message which is read to the terminal according to the status information of the terminal and the processing result comprises:
when the status information of the terminal indicates a sleeping or shutdown status, inserting, by the gateway of the Internet of Things, a wakeup or startup message before sending the at least one operation message which is read according to the processing result; or
when the status information of the terminal indicates an executing status, and priority of the at least one operation message to be transmitted which has been processed in the message queue is higher than an operation that the terminal is executing, inserting, by the gateway of the Internet of Things, a current operation termination message before sending the at least one operation message that is read according to the processing result.

5. The message processing method according to claim 1 , after sending the at least one operation message in the message queue to the terminal according to the processing result, the method further comprising:
executing, by the terminal, operations according to a sequence of the at least one operation message processed in the message queue;
when an operation is executed successfully, returning, by the terminal, a success message to the gateway of the Internet of Things, wherein the success message contains status information of the terminal; or
when the operation is executed unsuccessfully, returning, by the terminal, a failure message to the gateway of the Internet of Things, wherein the failure message contains status information of the terminal and a cause of failure.

6. The message processing method according to claim 5 , further comprising:
receiving, by the gateway of the Internet of Things, a response message returned by the terminal;
when the response message is the success message or failure message, transmitting, by the gateway of the Internet of Things, the response message to one or more transmitters of one or more operation messages corresponding to the response message, and deleting the operation message corresponding to the response message from the message queue corresponding to the terminal; or
when the response message indicates that an operation is being executed, labelling, by the gateway of the Internet of Things, the status information of the terminal as an executing status.

7. A message processing device for Internet of Things, located in a gateway of the Internet of Things, comprising:
a processor;
a receiving module, configured to receive one or more operation messages transmitted by a plurality of transmitters for one or more operations

Assignees

• Zte Corp
• Xian Zhongxing New Software Co Ltd

Inventors

• Li Qiuting

Classifications

• H04L67/02

  based on web technology, e.g. hypertext transfer protocol [HTTP] · CPC title

• H04L67/2842

  Electricity · mapped topic

• H04L67/2833

  Electricity · mapped topic

• H04L51/18 Primary

  Commands or executable codes · CPC title

• H04L67/28 Primary

  Electricity · mapped topic