CN118890389A - An instant messaging method, server, client and system based on MQTT protocol - Google Patents
An instant messaging method, server, client and system based on MQTT protocol Download PDFInfo
- Publication number
- CN118890389A CN118890389A CN202411358838.8A CN202411358838A CN118890389A CN 118890389 A CN118890389 A CN 118890389A CN 202411358838 A CN202411358838 A CN 202411358838A CN 118890389 A CN118890389 A CN 118890389A
- Authority
- CN
- China
- Prior art keywords
- packet
- puback
- confirmation message
- message
- server
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
- 238000000034 method Methods 0.000 title claims abstract description 42
- 238000012790 confirmation Methods 0.000 claims abstract description 134
- 238000012545 processing Methods 0.000 claims description 36
- 238000012217 deletion Methods 0.000 claims description 6
- 230000037430 deletion Effects 0.000 claims description 6
- 230000004044 response Effects 0.000 claims description 4
- 238000010586 diagram Methods 0.000 description 9
- 238000004590 computer program Methods 0.000 description 8
- 230000008569 process Effects 0.000 description 8
- 238000012546 transfer Methods 0.000 description 4
- 230000005540 biological transmission Effects 0.000 description 3
- 230000006870 function Effects 0.000 description 3
- 238000012986 modification Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 230000008520 organization Effects 0.000 description 3
- 101100233916 Saccharomyces cerevisiae (strain ATCC 204508 / S288c) KAR5 gene Proteins 0.000 description 2
- 230000003993 interaction Effects 0.000 description 2
- 101001121408 Homo sapiens L-amino-acid oxidase Proteins 0.000 description 1
- 102100026388 L-amino-acid oxidase Human genes 0.000 description 1
- 101100012902 Saccharomyces cerevisiae (strain ATCC 204508 / S288c) FIG2 gene Proteins 0.000 description 1
- 230000009471 action Effects 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000004891 communication Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 238000002955 isolation Methods 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/55—Push-based network services
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L51/00—User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
- H04L51/04—Real-time or near real-time messaging, e.g. instant messaging [IM]
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
Description
技术领域Technical Field
本发明涉及卫星观测技术领域,尤其涉及一种基于MQTT协议的即时通讯方法、服务器、客户端及系统。The present invention relates to the field of satellite observation technology, and in particular to an instant messaging method, server, client and system based on the MQTT protocol.
背景技术Background Art
消息队列遥测传输(Message Queuing Telemetry Transport,MQTT)是国际标准化组织在标准ISO/IEC PRF 20922的基础上,基于发布(Publish)/订阅(Subscribe)范式的消息协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。基于这些优势,MQTT协议也可以应用于多个客户端的即时通讯中。但是,在即时通讯应用过程中,由于存在多个客户端与服务器交互,时通讯客户端发布消息(PUBLISH),即时通讯服务端只能确认接收到消息(PUBACK),该确认消息没有标识(确认消息ID),如果需要返回确认消息ID,需要服务端PUBLISH发布带ID的消息,客户端PUBACK确认收到消息,才可以完成客户端和服务端发送消息并记录ID的操作,增加了服务器和客户端的消息发送量和处理量,客户端和服务端对消息管理十分不便。Message Queuing Telemetry Transport (MQTT) is a message protocol based on the Publish/Subscribe paradigm and developed by the International Organization for Standardization based on the ISO/IEC PRF 20922 standard. The MQTT protocol is lightweight, simple, open, and easy to implement, which makes it widely applicable. Based on these advantages, the MQTT protocol can also be applied to instant messaging of multiple clients. However, in the process of instant messaging applications, due to the interaction between multiple clients and servers, when the instant messaging client publishes a message (PUBLISH), the instant messaging server can only confirm the receipt of the message (PUBACK), and the confirmation message has no identification (confirmation message ID). If the confirmation message ID needs to be returned, the server needs to publish a message with an ID through PUBLISH, and the client needs to confirm the receipt of the message through PUBACK, so that the client and server can complete the operation of sending messages and recording IDs, which increases the message sending and processing volume of the server and client, and is very inconvenient for the client and server to manage messages.
发明内容Summary of the invention
为了解决现有技术中存在的上述问题,本发明提供了一种基于MQTT协议的即时通讯方法、服务器、客户端及系统。本发明要解决的技术问题通过以下技术方案实现:In order to solve the above problems existing in the prior art, the present invention provides an instant messaging method, server, client and system based on the MQTT protocol. The technical problem to be solved by the present invention is achieved through the following technical solutions:
本发明实施例第一方面提供一种基于MQTT协议的即时通讯方法,应用于服务器,包括以下步骤:A first aspect of an embodiment of the present invention provides an instant messaging method based on the MQTT protocol, which is applied to a server and includes the following steps:
接收客户端发送的消息数据PUBLISH包;Receive the message data PUBLISH package sent by the client;
向所述客户端发送确认消息PUBACK包;其中,所述确认消息PUBACK包包括有效负载,所述有效负载包括至少8个字节的确认消息PUBACK包的标识。Sending a confirmation message PUBACK packet to the client; wherein the confirmation message PUBACK packet includes a valid load, and the valid load includes an identification of the confirmation message PUBACK packet of at least 8 bytes.
本发明实施例第二方面提供一种基于MQTT协议的即时通讯方法,应用于客户端,包括以下步骤:A second aspect of an embodiment of the present invention provides an instant messaging method based on the MQTT protocol, which is applied to a client and includes the following steps:
接收服务器发送的确认消息PUBACK包;其中,所述确认消息PUBACK包包括有效负载,所述有效负载包括至少8个字节的确认消息PUBACK包的标识;Receive a confirmation message PUBACK packet sent by the server; wherein the confirmation message PUBACK packet includes a valid load, and the valid load includes an identifier of the confirmation message PUBACK packet of at least 8 bytes;
解析所述确认消息PUBACK包;Parsing the confirmation message PUBACK packet;
判断所述确认消息PUBACK包的剩余字节长度是否大于或等于预设字节长度;其中,所述预设字节长度大于或等于10个字节;Determine whether the remaining byte length of the confirmation message PUBACK packet is greater than or equal to a preset byte length; wherein the preset byte length is greater than or equal to 10 bytes;
若大于或等于所述预设字节长度,则根据所述确认消息PUBACK包和所述有效负载,构建自身的消息数据与所述确认消息PUBACK包的标识的对应关系。If it is greater than or equal to the preset byte length, a correspondence between its own message data and the identifier of the confirmation message PUBACK packet is constructed according to the confirmation message PUBACK packet and the effective load.
在本发明的一个实施例中,所述根据所述确认消息PUBACK包和所述有效负载,构建自身的消息数据与所述确认消息PUBACK包的标识的对应关系,包括:In one embodiment of the present invention, constructing a correspondence between its own message data and an identifier of the confirmation message PUBACK packet according to the confirmation message PUBACK packet and the effective load includes:
读取所述确认消息PUBACK包的可变报文头,获取消息数据PUBLISH包的标识;Read the variable message header of the confirmation message PUBACK packet to obtain the identifier of the message data PUBLISH packet;
读取所述确认消息PUBACK包的有效负载,获取所述确认消息PUBACK包的标识;Read the payload of the confirmation message PUBACK packet to obtain the identifier of the confirmation message PUBACK packet;
根据所述消息数据PUBLISH包的标识确定自身的消息数据;Determine its own message data according to the identifier of the message data PUBLISH package;
构建所述自身的消息数据与所述确认消息PUBACK包的标识的对应关系。Construct a correspondence between the message data of the device itself and the identifier of the confirmation message PUBACK packet.
在本发明的一个实施例中,所述方法还包括:当所述确认消息PUBACK包的剩余字节长度小于预设字节长度时,删除所述确认消息PUBACK包,并将确认消息PUBACK包中可变报头对应的消息数据标记为发送失败。In one embodiment of the present invention, the method further includes: when the remaining byte length of the confirmation message PUBACK packet is less than a preset byte length, deleting the confirmation message PUBACK packet, and marking the message data corresponding to the variable header in the confirmation message PUBACK packet as sending failure.
在本发明的一个实施例中,所述方法还包括:In one embodiment of the present invention, the method further comprises:
响应于对消息数据的处理操作,向所述服务器发送处理消息PUBLISH包;其中,所述处理消息PUBLISH包中的主题名指示处理操作,所述处理消息PUBLISH包的有效负载中包括所述消息数据对应的确认消息PUBACK包的标识;所述处理操作包括撤回操作或删除操作。In response to a processing operation on the message data, a processing message PUBLISH package is sent to the server; wherein the subject name in the processing message PUBLISH package indicates the processing operation, and the payload of the processing message PUBLISH package includes an identifier of a confirmation message PUBACK package corresponding to the message data; the processing operation includes a withdrawal operation or a deletion operation.
在本发明的一个实施例中,所述主题名为3至5个字节;In one embodiment of the present invention, the subject name is 3 to 5 bytes;
所述处理消息PUBLISH包中的有效负载为至少8个字节。The payload in the PUBLISH packet of the processing message is at least 8 bytes.
在本发明的一个实施例中,所述方法还包括:In one embodiment of the present invention, the method further comprises:
通过HTTP协议向服务器发送文件数据;Send file data to the server via HTTP protocol;
向服务器发送文件数据PUBLISH包;其中,所述文件数据PUBLISH包中的有效负载包括服务器返回的所述文件数据的HTTP链接。A file data PUBLISH packet is sent to a server; wherein the effective load in the file data PUBLISH packet includes an HTTP link of the file data returned by the server.
本发明实施例的第三方面提供一种基于MQTT协议的即时通讯服务器,包括:A third aspect of an embodiment of the present invention provides an instant messaging server based on the MQTT protocol, comprising:
第一接收模块,用于接收客户端发送的消息数据PUBLISH包;The first receiving module is used to receive the message data PUBLISH package sent by the client;
发送模块,用于向所述客户端发送确认消息PUBACK包;其中,所述确认消息PUBACK包包括有效负载,所述有效负载包括至少8个字节的确认消息PUBACK包的标识。A sending module is used to send a confirmation message PUBACK packet to the client; wherein the confirmation message PUBACK packet includes a valid load, and the valid load includes an identification of the confirmation message PUBACK packet of at least 8 bytes.
本发明实施例的第四方面提供一种基于MQTT协议的即时通讯客户端,包括:A fourth aspect of an embodiment of the present invention provides an instant messaging client based on the MQTT protocol, comprising:
第二接收模块,用于接收服务器发送的确认消息PUBACK包;其中,所述确认消息PUBACK包包括有效负载,所述有效负载包括至少8个字节的确认消息PUBACK包的标识;A second receiving module is used to receive a confirmation message PUBACK packet sent by the server; wherein the confirmation message PUBACK packet includes a valid load, and the valid load includes an identifier of the confirmation message PUBACK packet of at least 8 bytes;
解析模块,用于解析所述确认消息PUBACK包;A parsing module, used for parsing the confirmation message PUBACK packet;
判断模块,用于判断所述确认消息PUBACK包的剩余字节长度是否大于或等于预设字节长度;其中,所述预设字节长度大于或等于10个字节;A judging module, used to judge whether the remaining byte length of the confirmation message PUBACK packet is greater than or equal to a preset byte length; wherein the preset byte length is greater than or equal to 10 bytes;
确定模块,用于若大于或等于所述预设字节长度,则根据所述确认消息PUBACK包和所述有效负载,构建自身的消息数据与所述确认消息PUBACK包的标识的对应关系。The determination module is used to construct a corresponding relationship between its own message data and the identifier of the confirmation message PUBACK packet according to the confirmation message PUBACK packet and the effective load if it is greater than or equal to the preset byte length.
本发明实施例的第五方面提供一种基于MQTT协议的即时通讯系统,包括:本发明实施例第三方面的服务器和本发明实施例第四方面的客户端。A fifth aspect of the embodiments of the present invention provides an instant messaging system based on the MQTT protocol, comprising: a server according to the third aspect of the embodiments of the present invention and a client according to the fourth aspect of the embodiments of the present invention.
本发明的有益效果:Beneficial effects of the present invention:
本发明通过确认消息PUBACK包中的有效负载携带确认消息PUBACK包的标识,服务器和客户端均可以获取该标识,并通过该标识可以对服务器返回至客户端的消息在本端进行管理,无需增加消息的发送量就能够实现多个客户端和服务器分别便捷地对服务器返回的消息进行管理,提高了即时通讯消息管理的便捷性。The present invention carries the identifier of the confirmation message PUBACK packet through the effective load in the confirmation message PUBACK packet. Both the server and the client can obtain the identifier, and the messages returned by the server to the client can be managed on the local side through the identifier. Without increasing the amount of message sending, multiple clients and servers can each conveniently manage the messages returned by the server, thereby improving the convenience of instant messaging message management.
本发明的其它特征和优点将在随后的说明书中阐述,并且,部分地从说明书中变得显而易见,或者通过实施本发明而了解。本发明的目的和其他优点可通过在所写的说明书、权利要求书、以及附图中所特别指出的结构来实现和获得。Other features and advantages of the present invention will be described in the following description, and partly become apparent from the description, or understood by practicing the present invention. The purpose and other advantages of the present invention can be realized and obtained by the structures particularly pointed out in the written description, claims, and drawings.
下面通过附图和实施例,对本发明的技术方案做进一步的详细描述。The technical solution of the present invention is further described in detail below through the accompanying drawings and embodiments.
附图说明BRIEF DESCRIPTION OF THE DRAWINGS
附图用来提供对本发明的进一步理解,并且构成说明书的一部分,与本发明的实施例一起用于解释本发明,并不构成对本发明的限制。在附图中:The accompanying drawings are used to provide a further understanding of the present invention and constitute a part of the specification. Together with the embodiments of the present invention, they are used to explain the present invention and do not constitute a limitation of the present invention. In the accompanying drawings:
图1为本发明实施例提供的一种基于MQTT协议的即时通讯方法的流程示意图;FIG1 is a flow chart of an instant messaging method based on the MQTT protocol provided by an embodiment of the present invention;
图2为本发明实施例提供的另一种基于MQTT协议的即时通讯方法的流程示意图;FIG2 is a schematic diagram of a flow chart of another instant messaging method based on the MQTT protocol provided by an embodiment of the present invention;
图3为本发明实施例提供的一种基于MQTT协议的即时通讯服务器的框图;FIG3 is a block diagram of an instant messaging server based on the MQTT protocol provided in an embodiment of the present invention;
图4为本发明实施例提供的一种基于MQTT协议的即时通讯客户端的框图。FIG. 4 is a block diagram of an instant messaging client based on the MQTT protocol provided in an embodiment of the present invention.
具体实施方式DETAILED DESCRIPTION
下面结合具体实施例对本发明做进一步详细的描述,但本发明的实施方式不限于此。The present invention is further described in detail below with reference to specific embodiments, but the embodiments of the present invention are not limited thereto.
本发明旨在提供安全、高效、实时的通讯服务。通过使用即时通讯系统,组织内部可以快速传递信息、提高协同办公能力,为组织的决策和行动提供有力支持。The present invention aims to provide a safe, efficient and real-time communication service. By using the instant messaging system, information can be quickly transmitted within the organization, the collaborative office capability can be improved, and strong support can be provided for the decision-making and action of the organization.
如图1所示,本发明实施例第一方面提供一种基于MQTT协议的即时通讯方法,应用于服务器,包括以下步骤:As shown in FIG. 1 , a first aspect of an embodiment of the present invention provides an instant messaging method based on the MQTT protocol, which is applied to a server and includes the following steps:
步骤11,接收客户端发送的消息数据PUBLISH包。Step 11: Receive the message data PUBLISH package sent by the client.
步骤12,向客户端发送确认消息PUBACK包。Step 12: Send a confirmation message PUBACK packet to the client.
其中,确认消息PUBACK包包括有效负载,有效负载包括至少8个字节的确认消息PUBACK包的标识。The confirmation message PUBACK packet includes a valid load, and the valid load includes an identifier of the confirmation message PUBACK packet of at least 8 bytes.
本实施例中,消息级别是QoS=1。MQTT消息队列的服务质量(Quality of Service,QoS)代表消息传输的服务质量,QoS=1代表消息至少达到一次,这一级别会确保消息到达,但消息可能会重复。即时通讯客户端PUBLISH发布消息,即时通讯服务端PUBACK确认收到消息,并通过PUBACK报文的Payload给客户端返回服务端的确认消息PUBACK包的标识,也即是确认消息PUBACK包的ID,Payload为有效负载。In this embodiment, the message level is QoS=1. The Quality of Service (QoS) of the MQTT message queue represents the service quality of message transmission. QoS=1 means that the message arrives at least once. This level ensures that the message arrives, but the message may be repeated. The instant messaging client PUBLISH publishes the message, and the instant messaging server PUBACK confirms the receipt of the message, and returns the server's confirmation message PUBACK packet identifier to the client through the Payload of the PUBACK message, which is the ID of the confirmation message PUBACK packet. Payload is the effective load.
需要说明的是,PUBACK包用于服务器向客户端反馈确认客户端发送的消息已经收到,PUBACK包和PUBLISH包为报文数据包。现有技术中服务器返回的PUBACK包中没有Payload,也没有PUBACK包的ID。应用在即时通讯时,多个客户端均需要给服务器发送消息,服务器需要反馈,而每个客户端对PUBLISH包的标识存在相同的情况,服务器在返回PUBACK包时无法进行管理。本实施例的确认消息PUBACK包在现有技术基础上中增加了Payload,且Payload中至少包括确认消息PUBACK包的ID,服务器可以获取确认消息PUBACK包的标识,以便于对确认消息进行管理。It should be noted that the PUBACK packet is used by the server to feedback to the client to confirm that the message sent by the client has been received. The PUBACK packet and the PUBLISH packet are message data packets. In the prior art, there is no Payload and no PUBACK packet ID in the PUBACK packet returned by the server. When used in instant messaging, multiple clients need to send messages to the server, and the server needs feedback. However, each client has the same identification for the PUBLISH packet, and the server cannot manage it when returning the PUBACK packet. The confirmation message PUBACK packet of this embodiment adds a Payload to the prior art, and the Payload at least includes the ID of the confirmation message PUBACK packet. The server can obtain the identification of the confirmation message PUBACK packet to facilitate the management of the confirmation message.
如图2所示,本发明实施例第二方面提供一种基于MQTT协议的即时通讯方法,应用于客户端,包括以下步骤:As shown in FIG. 2 , a second aspect of an embodiment of the present invention provides an instant messaging method based on the MQTT protocol, which is applied to a client and includes the following steps:
步骤21,接收服务器发送的确认消息PUBACK包。Step 21: Receive a confirmation message PUBACK packet sent by the server.
本步骤中,客户端发送的消息数据PUBLISH包给服务器,服务器返回至客户端确认消息PUBACK包。In this step, the client sends a message data PUBLISH packet to the server, and the server returns a confirmation message PUBACK packet to the client.
其中,确认消息PUBACK包包括有效负载,有效负载包括至少8个字节的确认消息PUBACK包的标识。The confirmation message PUBACK packet includes a valid load, and the valid load includes an identifier of the confirmation message PUBACK packet of at least 8 bytes.
步骤22,解析确认消息PUBACK包。Step 22, parse the confirmation message PUBACK packet.
步骤23,判断确认消息PUBACK包的剩余字节长度是否大于或等于预设字节长度。Step 23, determining whether the remaining byte length of the confirmation message PUBACK packet is greater than or equal to a preset byte length.
其中,预设字节长度大于或等于10个字节。Among them, the preset byte length is greater than or equal to 10 bytes.
步骤24,若大于或等于预设字节长度,则根据确认消息PUBACK包和有效负载,构建自身的消息数据与确认消息PUBACK包的标识的对应关系。Step 24: If it is greater than or equal to the preset byte length, then a corresponding relationship between its own message data and the identifier of the confirmation message PUBACK packet is constructed according to the confirmation message PUBACK packet and the effective load.
本实施例中,由于确认消息PUBACK包中包含了Payload,客户端在解析时需要判断确认消息PUBACK包的剩余解析字节长度是否有效,若有效,则说明该PUBACK包是有效可用的,若无效,则该PUBACK包无效不可用。在确认PUBACK包有效后,则在客户端本地建立服务器返回的消息与本地的消息数据的对应关系,以便于后续对所有消息进行管理。In this embodiment, since the confirmation message PUBACK packet contains the Payload, the client needs to determine whether the remaining parsed byte length of the confirmation message PUBACK packet is valid when parsing. If it is valid, it means that the PUBACK packet is valid and usable. If it is invalid, the PUBACK packet is invalid and unusable. After confirming that the PUBACK packet is valid, a corresponding relationship between the message returned by the server and the local message data is established locally on the client to facilitate the subsequent management of all messages.
这里,结合本发明实施例第一方面和第二方面提供的方法,对本发明服务器和客户端交互的即时通讯方法进行详细说明,本发明实施例第三方面提供一种基于MQTT协议的即时通讯方法,包括以下步骤:(与上述的本发明实施例第一方面和第二方面相同的内容这里不再赘述)Here, in combination with the methods provided in the first and second aspects of the embodiments of the present invention, the instant messaging method for interaction between the server and the client of the present invention is described in detail. The third aspect of the embodiment of the present invention provides an instant messaging method based on the MQTT protocol, comprising the following steps: (the same contents as those in the first and second aspects of the embodiments of the present invention are not repeated here)
步骤31,客户端向服务器发送消息数据PUBLISH包。Step 31: The client sends a message data PUBLISH packet to the server.
步骤32,服务器接收客户端发送的消息数据PUBLISH包。Step 32: The server receives the message data PUBLISH packet sent by the client.
步骤33,服务器向客户端发送确认消息PUBACK包。Step 33: The server sends a confirmation message PUBACK packet to the client.
其中,确认消息PUBACK包包括有效负载,有效负载包括至少8个字节的确认消息PUBACK包的标识。这里,有效负载还可以携带其他信息,也即是确认消息PUBACK包的有效负载Payload可以为确认消息PUBACK包的标识和其他信息构成,此时,Payload的字节大于8个,其中,确认消息PUBACK包的标识至少占8个字节。The confirmation message PUBACK packet includes a payload, and the payload includes an identification of the confirmation message PUBACK packet of at least 8 bytes. Here, the payload can also carry other information, that is, the payload of the confirmation message PUBACK packet can be composed of the identification of the confirmation message PUBACK packet and other information. At this time, the bytes of the Payload are greater than 8, and the identification of the confirmation message PUBACK packet occupies at least 8 bytes.
在一种可行的实施方式中,确认消息PUBACK包的标识使用long类型共8字节占用64个比特位,其中43位是时间戳,6位是节点编号,15位是序列号,服务器生成的该标识保证递增且唯一。示例的,确认消息PUBACK包的报文数据如下表1所示:In a feasible implementation, the identifier of the confirmation message PUBACK packet uses the long type, a total of 8 bytes, and occupies 64 bits, of which 43 bits are timestamps, 6 bits are node numbers, and 15 bits are sequence numbers. The identifier generated by the server is guaranteed to be incremental and unique. For example, the message data of the confirmation message PUBACK packet is shown in Table 1 below:
表1Table 1
其中,MSB和LSB表示消息数据PUBLISH包的标识,Byte表示字节,Bit表示比特。Among them, MSB and LSB represent the identifier of the message data PUBLISH packet, Byte represents byte, and Bit represents bit.
步骤34,客户端接收服务器发送的确认消息PUBACK包。Step 34: The client receives a confirmation message PUBACK packet sent by the server.
步骤35,客户端解析确认消息PUBACK包。Step 35: The client parses the confirmation message PUBACK packet.
步骤36,客户端判断确认消息PUBACK包的剩余字节长度是否大于或等于预设字节长度。Step 36: The client determines whether the remaining byte length of the confirmation message PUBACK packet is greater than or equal to the preset byte length.
其中,预设字节长度大于或等于10个字节。剩余字节长度也即是表1中的剩余长度后续的字节。The preset byte length is greater than or equal to 10 bytes. The remaining byte length is the bytes following the remaining length in Table 1.
当客户端解析至剩余字节长度处的报文时,判断报文中的剩余字节长度的数值是否大于或等于10个字节。示例的,如表1中,预设字节长度为10,解析至剩余长度处的报文时,判断这里的数值是否等于10。When the client parses the message at the remaining byte length, it is determined whether the value of the remaining byte length in the message is greater than or equal to 10 bytes. For example, as shown in Table 1, the preset byte length is 10, and when the message is parsed to the remaining length, it is determined whether the value here is equal to 10.
步骤37,若大于或等于预设字节长度,则客户端根据确认消息PUBACK包和有效负载,构建自身的消息数据与确认消息PUBACK包的标识的对应关系。步骤37的具体步骤包括:步骤371-步骤374:Step 37: If the length is greater than or equal to the preset byte length, the client constructs a corresponding relationship between its own message data and the identifier of the confirmation message PUBACK packet according to the confirmation message PUBACK packet and the effective load. The specific steps of step 37 include: Step 371-Step 374:
步骤371,若大于或等于预设字节长度,客户端读取确认消息PUBACK包的可变报文头,获取消息数据PUBLISH包的标识。Step 371: If it is greater than or equal to the preset byte length, the client reads the variable message header of the confirmation message PUBACK packet to obtain the identifier of the message data PUBLISH packet.
步骤372,客户端读取确认消息PUBACK包的有效负载Payload,获取确认消息PUBACK包的标识。步骤371和步骤372是对同一个确认消息PUBACK包进行解析,则解析得到的消息数据PUBLISH包的标识和确认消息PUBACK包的标识相对应。Step 372, the client reads the payload of the confirmation message PUBACK packet and obtains the identifier of the confirmation message PUBACK packet. Steps 371 and 372 parse the same confirmation message PUBACK packet, and the identifier of the message data PUBLISH packet obtained by parsing corresponds to the identifier of the confirmation message PUBACK packet.
步骤373,客户端根据消息数据PUBLISH包的标识确定自身的消息数据。本步骤中,客户端根据确认消息PUBACK包中的消息数据PUBLISH包的标识能够查找到该标识对应的本地的消息数据。Step 373, the client determines its own message data according to the identifier of the message data PUBLISH package. In this step, the client can find the local message data corresponding to the identifier according to the identifier of the message data PUBLISH package in the confirmation message PUBACK package.
步骤374,客户端构建自身的消息数据与对应的确认消息PUBACK包的标识的对应关系。本步骤中,将查找到的自身的消息数据和对应的确认消息PUBACK包的标识的对应关系进行存储,以便于后续对返回的确认消息PUBACK包的标识对应的自身的消息数据进行相关处理。Step 374, the client constructs a correspondence between its own message data and the identifier of the corresponding confirmation message PUBACK packet. In this step, the correspondence between the found own message data and the identifier of the corresponding confirmation message PUBACK packet is stored, so as to facilitate the subsequent relevant processing of the own message data corresponding to the identifier of the returned confirmation message PUBACK packet.
步骤38,当确认消息PUBACK包的剩余字节长度小于预设字节长度时,删除确认消息PUBACK包,并将读取的确认消息PUBACK包中可变报头对应的消息数据标记为发送失败。Step 38: When the remaining byte length of the confirmation message PUBACK packet is less than the preset byte length, the confirmation message PUBACK packet is deleted, and the message data corresponding to the variable header in the read confirmation message PUBACK packet is marked as sending failure.
在一种可行的实施方式中,在上述实施例的基础上,自身的消息数据与确认消息PUBACK包的标识的对应关系已经建立,当客户端要对消息数据PUBLISH包对应的消息数据进行撤回或者删除操作时,包括以下步骤:In a feasible implementation manner, based on the above embodiment, the correspondence between the own message data and the identifier of the confirmation message PUBACK packet has been established. When the client wants to withdraw or delete the message data corresponding to the message data PUBLISH packet, the following steps are included:
步骤A1,客户端响应于对消息数据的处理操作,向服务器发送处理消息PUBLISH包。Step A1: In response to a processing operation on message data, the client sends a processing message PUBLISH packet to the server.
其中,处理消息PUBLISH包中的主题名指示处理操作,有效负载中包括消息数据对应的确认消息PUBACK包的标识;处理操作包括撤回操作或删除操作。The subject name in the processing message PUBLISH packet indicates the processing operation, and the effective load includes the identifier of the confirmation message PUBACK packet corresponding to the message data; the processing operation includes a withdrawal operation or a deletion operation.
本步骤中,用户在客户端进行撤回或删除的处理操作后,客户端向服务器发送处理消息PUBLISH包。这里,在传统的PUBLISH包的基础上,将PUBLISH包的主题名赋予新的值,能够指示撤回或删除操作,且在PUBLISH包的Payload中带上对应的确认消息PUBACK包的标识(上述实施例中已经建立了对应关系),这样一来,服务器接收到处理消息PUBLISH包并读取,则服务器能够唯一确定是对哪个确认消息PUBACK包中的消息进行撤回或删除处理。In this step, after the user performs the withdrawal or deletion processing operation on the client, the client sends a processing message PUBLISH package to the server. Here, on the basis of the traditional PUBLISH package, the subject name of the PUBLISH package is given a new value, which can indicate the withdrawal or deletion operation, and the corresponding confirmation message PUBACK package identifier is carried in the Payload of the PUBLISH package (the corresponding relationship has been established in the above embodiment). In this way, when the server receives and reads the processing message PUBLISH package, the server can uniquely determine which confirmation message PUBACK package is to be withdrawn or deleted.
优选地,主题名为3至5个字节;处理消息PUBLISH包中的有效负载为至少8个字节。Preferably, the subject name is 3 to 5 bytes; the payload in the PUBLISH packet of the processing message is at least 8 bytes.
在一种可行的实现方式中,在即时通信过程中,客户端和服务器双方可以传输文字,图片、视频等信息。文字可以在PUBLISH报文中的Payload中携带。图片或视频等形成文件,文件通过HTTP协议(Hypertext Transfer Protocol,超文本传输协议)或者超文本传输安全协议传输,文件的链接在PUBLISH报文中的Payload中携带。具体包括以下步骤:In a feasible implementation, during the instant messaging process, the client and the server can transmit text, pictures, videos and other information. The text can be carried in the Payload of the PUBLISH message. The pictures or videos form files, which are transmitted via the HTTP protocol (Hypertext Transfer Protocol) or the Hypertext Transfer Protocol Secure, and the links to the files are carried in the Payload of the PUBLISH message. Specifically, the following steps are included:
步骤B1,客户端通过HTTP协议(或超文本传输安全协议)向服务器发送文件数据。其中,文件数据包括图片、视频、音频等较大的文件。Step B1, the client sends file data to the server via HTTP protocol (or Hypertext Transfer Protocol Secure), wherein the file data includes relatively large files such as pictures, videos, and audios.
步骤B2,服务器接收文件数据并生成链接,然后将文件数据的链接通过HTTP协议(或超文本传输安全协议)发送至客户端;Step B2, the server receives the file data and generates a link, and then sends the link of the file data to the client via HTTP protocol (or Hypertext Transfer Protocol Secure);
步骤B3,客户端向服务器发送文件数据PUBLISH包。Step B3: The client sends a file data PUBLISH packet to the server.
其中,文件数据PUBLISH包中的有效负载包括文件数据的HTTP链接。The payload in the file data PUBLISH packet includes an HTTP link of the file data.
本实施例中,在传输较大的文件数据时,通过HTTP协议和MQTT协议双协议进行分别传输,HTTP协议传输文件数据,和MQTT协议传输文件数据的链接消息,文件数据传输不易丢失。同时,文件数据若损坏也不会影响带有链接的MQTT消息的发送,通过HTTP协议发送的文件数据不会占用MQTT协议其他消息的资源,形成资源的隔离。In this embodiment, when transmitting large file data, the HTTP protocol and the MQTT protocol are used for transmission respectively. The HTTP protocol transmits the file data, and the MQTT protocol transmits the link message of the file data, so that the file data transmission is not easy to be lost. At the same time, if the file data is damaged, it will not affect the sending of the MQTT message with the link. The file data sent through the HTTP protocol will not occupy the resources of other messages of the MQTT protocol, forming resource isolation.
这里,服务器接收到文件数据PUBLISH包后将该消息以PUBLISH包的形式发送至其他客户端,也可以理解为服务器将文件数据PUBLISH包转发。Here, after receiving the file data PUBLISH package, the server sends the message to other clients in the form of a PUBLISH package, which can also be understood as the server forwarding the file data PUBLISH package.
如图3所示,本发明实施例第四方面提供一种基于MQTT协议的即时通讯服务器,包括:As shown in FIG3 , a fourth aspect of an embodiment of the present invention provides an instant messaging server based on the MQTT protocol, including:
第一接收模块41,用于接收客户端发送的消息数据PUBLISH包;The first receiving module 41 is used to receive a message data PUBLISH packet sent by a client;
发送模块42,用于向客户端发送确认消息PUBACK包;其中,确认消息PUBACK包包括有效负载,有效负载包括至少8个字节的确认消息PUBACK包的标识。The sending module 42 is used to send a confirmation message PUBACK packet to the client; wherein the confirmation message PUBACK packet includes a valid load, and the valid load includes an identification of the confirmation message PUBACK packet of at least 8 bytes.
如图4所示,本发明实施例第五方面提供一种基于MQTT协议的即时通讯客户端,包括:As shown in FIG. 4 , a fifth aspect of an embodiment of the present invention provides an instant messaging client based on the MQTT protocol, including:
第二接收模块51,用于接收服务器发送的确认消息PUBACK包;其中,确认消息PUBACK包包括有效负载,有效负载包括至少8个字节的确认消息PUBACK包的标识;The second receiving module 51 is used to receive a confirmation message PUBACK packet sent by the server; wherein the confirmation message PUBACK packet includes a valid load, and the valid load includes an identification of the confirmation message PUBACK packet of at least 8 bytes;
解析模块52,用于解析确认消息PUBACK包;A parsing module 52, configured to parse a confirmation message PUBACK packet;
判断模块53,用于判断确认消息PUBACK包的剩余字节长度是否大于或等于预设字节长度;其中,预设字节长度大于或等于10个字节;The judging module 53 is used to judge whether the remaining byte length of the confirmation message PUBACK packet is greater than or equal to a preset byte length; wherein the preset byte length is greater than or equal to 10 bytes;
确定模块54,用于若大于或等于预设字节长度,则根据确认消息PUBACK包和有效负载,构建自身的消息数据与确认消息PUBACK包的标识的对应关系。The determination module 54 is used to construct a corresponding relationship between its own message data and the identifier of the confirmation message PUBACK packet according to the confirmation message PUBACK packet and the effective load if it is greater than or equal to the preset byte length.
在本发明的一个实施例中,根据确认消息PUBACK包和有效负载,构建自身的消息数据与确认消息PUBACK包的标识的对应关系,包括:In one embodiment of the present invention, constructing a correspondence between its own message data and the identifier of the confirmation message PUBACK packet according to the confirmation message PUBACK packet and the effective load includes:
读取确认消息PUBACK包的可变报文头,获取消息数据PUBLISH包的标识;Read the variable message header of the confirmation message PUBACK packet to obtain the identifier of the message data PUBLISH packet;
读取确认消息PUBACK包的有效负载,获取确认消息PUBACK包的标识;Read the payload of the confirmation message PUBACK packet and obtain the identifier of the confirmation message PUBACK packet;
根据消息数据PUBLISH包的标识确定自身的消息数据;Determine its own message data according to the identifier of the message data PUBLISH package;
构建自身的消息数据与确认消息PUBACK包的标识的对应关系。Construct the correspondence between its own message data and the identifier of the confirmation message PUBACK packet.
在本发明的一个实施例中,还包括:当确认消息PUBACK包的剩余字节长度小于预设字节长度时,删除确认消息PUBACK包,并将确认消息PUBACK包中可变报头对应的消息数据标记为发送失败。In one embodiment of the present invention, it also includes: when the remaining byte length of the confirmation message PUBACK packet is less than the preset byte length, deleting the confirmation message PUBACK packet, and marking the message data corresponding to the variable header in the confirmation message PUBACK packet as sending failure.
在本发明的一个实施例中,还包括:In one embodiment of the present invention, it also includes:
响应于对消息数据的处理操作,向服务器发送处理消息PUBLISH包;其中,处理消息PUBLISH包中的主题名指示处理操作,有效负载中包括消息数据对应的确认消息PUBACK包的标识;处理操作包括撤回操作或删除操作。In response to a processing operation on the message data, a processing message PUBLISH package is sent to the server; wherein the subject name in the processing message PUBLISH package indicates the processing operation, and the payload includes an identifier of a confirmation message PUBACK package corresponding to the message data; the processing operation includes a withdrawal operation or a deletion operation.
在本发明的一个实施例中,主题名为3至5个字节;处理消息PUBLISH包中的有效负载为至少8个字节。In one embodiment of the present invention, the subject name is 3 to 5 bytes; the payload in the processing message PUBLISH packet is at least 8 bytes.
在本发明的一个实施例中,通过HTTP协议向服务器发送文件数据;In one embodiment of the present invention, the file data is sent to the server via the HTTP protocol;
向服务器发送文件数据PUBLISH包;其中,文件数据PUBLISH包中的有效负载包括服务器返回的文件数据的HTTP链接。A file data PUBLISH packet is sent to the server; wherein the effective load in the file data PUBLISH packet includes an HTTP link of the file data returned by the server.
本发明实施例第六方面提供一种基于MQTT协议的即时通讯系统,包括本发明上述实施例中的服务器和客户端。A sixth aspect of an embodiment of the present invention provides an instant messaging system based on the MQTT protocol, including the server and client in the above embodiment of the present invention.
本发明实施例的第七方面提供一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,处理器执行程序时实现本发明上述实施例的提供的一种基于MQTT协议的即时通讯方法。A seventh aspect of an embodiment of the present invention provides an electronic device, including a memory, a processor, and a computer program stored in the memory and executable on the processor. When the processor executes the program, an instant messaging method based on the MQTT protocol provided in the above embodiment of the present invention is implemented.
本发明实施例第八方面还提供一种计算机可读存储介质,其上存储有计算机程序,计算机程序被处理器执行时实现本发明上述实施例的提供的一种基于MQTT协议的即时通讯方法的步骤。An eighth aspect of an embodiment of the present invention further provides a computer-readable storage medium having a computer program stored thereon. When the computer program is executed by a processor, the steps of an instant messaging method based on the MQTT protocol provided in the above embodiment of the present invention are implemented.
其中,存储器可以包括随机存取存储器(Random Access Memory,RAM),也可以包括非易失性存储器(Non-Volatile Memory,NVM),例如至少一个磁盘存储器。可选的,存储器还可以是至少一个位于远离前述处理器的存储装置。The memory may include a random access memory (RAM) or a non-volatile memory (NVM), such as at least one disk memory. Optionally, the memory may also be at least one storage device located away from the aforementioned processor.
上述的处理器可以是通用处理器,包括中央处理器(Central Processing Unit,CPU)、网络处理器(Network Processor,NP)等;还可以是数字信号处理器(Digital SignalProcessing,DSP)、专用集成电路(Application Specific Integrated Circuit,ASIC)、现场可编程门阵列(Field-Programmable Gate Array,FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件系统。The above-mentioned processor can be a general-purpose processor, including a central processing unit (CPU), a network processor (NP), etc.; it can also be a digital signal processor (DSP), an application specific integrated circuit (ASIC), a field programmable gate array (FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware systems.
本发明实施例提供的方法可以应用于电子设备。具体的,该电子设备可以为:台式计算机、便携式计算机、智能移动终端、服务器等。在此不作限定,任何可以实现本发明的电子设备,均属于本发明的保护范围。The method provided in the embodiment of the present invention can be applied to electronic devices. Specifically, the electronic device can be: a desktop computer, a portable computer, an intelligent mobile terminal, a server, etc. This is not limited here, and any electronic device that can implement the present invention belongs to the protection scope of the present invention.
对于系统/电子设备实施例而言,由于其基本相似于方法实施例,所以描述的比较简单,相关之处参见方法实施例的部分说明即可。As for the system/electronic device embodiment, since it is basically similar to the method embodiment, the description is relatively simple, and the relevant parts can be referred to the partial description of the method embodiment.
本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的系统。The present invention is described with reference to the flowcharts and/or block diagrams of the methods, devices (systems), and computer program products according to the embodiments of the present invention. It should be understood that each process and/or box in the flowchart and/or block diagram, as well as the combination of the processes and/or boxes in the flowchart and/or block diagram, can be implemented by computer program instructions. These computer program instructions can be provided to a processor of a general-purpose computer, a special-purpose computer, an embedded processor, or other programmable data processing device to produce a machine, so that the instructions executed by the processor of the computer or other programmable data processing device produce a system for implementing the functions specified in one or more processes in the flowchart and/or one or more boxes in the block diagram.
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing device to work in a specific manner, so that the instructions stored in the computer-readable memory produce a manufactured product including an instruction device that implements the functions specified in one or more processes in the flowchart and/or one or more boxes in the block diagram.
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。These computer program instructions may also be loaded onto a computer or other programmable data processing device so that a series of operational steps are executed on the computer or other programmable device to produce a computer-implemented process, whereby the instructions executed on the computer or other programmable device provide steps for implementing the functions specified in one or more processes in the flowchart and/or one or more boxes in the block diagram.
显然,本领域的技术人员可以对本发明进行各种改动和变型而不脱离本发明的精神和范围。这样,倘若本发明的这些修改和变型属于本发明权利要求及其等同技术的范围之内,则本发明也意图包含这些改动和变型在内。Obviously, those skilled in the art can make various changes and modifications to the present invention without departing from the spirit and scope of the present invention. Thus, if these modifications and variations of the present invention fall within the scope of the claims of the present invention and their equivalents, the present invention is also intended to include these modifications and variations.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202411358838.8A CN118890389B (en) | 2024-09-27 | 2024-09-27 | Instant messaging method, server, client and system based on MQTT protocol |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202411358838.8A CN118890389B (en) | 2024-09-27 | 2024-09-27 | Instant messaging method, server, client and system based on MQTT protocol |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN118890389A true CN118890389A (en) | 2024-11-01 |
| CN118890389B CN118890389B (en) | 2024-12-06 |
Family
ID=93235345
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202411358838.8A Active CN118890389B (en) | 2024-09-27 | 2024-09-27 | Instant messaging method, server, client and system based on MQTT protocol |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN118890389B (en) |
Citations (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2001111566A (en) * | 1999-10-08 | 2001-04-20 | Nec Corp | Serial communication method according to atm system |
| US6975651B1 (en) * | 1999-01-20 | 2005-12-13 | Fujitsu Limited | Cell processing apparatus, ATM exchange and cell discarding method |
| CN107786423A (en) * | 2016-08-29 | 2018-03-09 | 北京融聚世界网络科技有限公司 | A kind of method and system of instant messaging |
| CN109327527A (en) * | 2018-10-30 | 2019-02-12 | 北京摩拜科技有限公司 | Control method for vehicle, server, client, vehicle and Vehicular system |
| KR20190057818A (en) * | 2017-11-20 | 2019-05-29 | 광운대학교 산학협력단 | Priority-based MQTT System and method to provide Differentiated IoT Services |
| CN113141544A (en) * | 2021-04-09 | 2021-07-20 | 广东电网有限责任公司计量中心 | Communication method, system and storage medium of metering automation system |
| CN116887351A (en) * | 2023-07-24 | 2023-10-13 | 东软睿驰汽车技术(大连)有限公司 | Internet of vehicles data communication method, device, equipment and medium |
| CN117880232A (en) * | 2024-01-09 | 2024-04-12 | 浪潮软件股份有限公司 | Real-time high concurrency instant messaging method, device and medium based on MQTT protocol |
| CN118158299A (en) * | 2024-03-07 | 2024-06-07 | 国网江苏省电力有限公司信息通信分公司 | A data conversion method, device, equipment and medium |
-
2024
- 2024-09-27 CN CN202411358838.8A patent/CN118890389B/en active Active
Patent Citations (9)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US6975651B1 (en) * | 1999-01-20 | 2005-12-13 | Fujitsu Limited | Cell processing apparatus, ATM exchange and cell discarding method |
| JP2001111566A (en) * | 1999-10-08 | 2001-04-20 | Nec Corp | Serial communication method according to atm system |
| CN107786423A (en) * | 2016-08-29 | 2018-03-09 | 北京融聚世界网络科技有限公司 | A kind of method and system of instant messaging |
| KR20190057818A (en) * | 2017-11-20 | 2019-05-29 | 광운대학교 산학협력단 | Priority-based MQTT System and method to provide Differentiated IoT Services |
| CN109327527A (en) * | 2018-10-30 | 2019-02-12 | 北京摩拜科技有限公司 | Control method for vehicle, server, client, vehicle and Vehicular system |
| CN113141544A (en) * | 2021-04-09 | 2021-07-20 | 广东电网有限责任公司计量中心 | Communication method, system and storage medium of metering automation system |
| CN116887351A (en) * | 2023-07-24 | 2023-10-13 | 东软睿驰汽车技术(大连)有限公司 | Internet of vehicles data communication method, device, equipment and medium |
| CN117880232A (en) * | 2024-01-09 | 2024-04-12 | 浪潮软件股份有限公司 | Real-time high concurrency instant messaging method, device and medium based on MQTT protocol |
| CN118158299A (en) * | 2024-03-07 | 2024-06-07 | 国网江苏省电力有限公司信息通信分公司 | A data conversion method, device, equipment and medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN118890389B (en) | 2024-12-06 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN102685203B (en) | Method and device for data resource transmission | |
| CN107925674B (en) | Method and apparatus for pushing data in a content-centric network (CCN) | |
| CN111083161A (en) | Data transmission processing method and device and Internet of things equipment | |
| WO2018084947A1 (en) | Network management interface | |
| CN111901230B (en) | Internet of things gateway and system supporting equipment access verification and equipment access verification method | |
| US20050187979A1 (en) | System and method for message-level connection management | |
| WO2014067311A1 (en) | Resource subscription method and device | |
| JP2016025658A (en) | Interest return control message | |
| CN110062004A (en) | A kind of message handling system and method based on Internet of Things fidonetFido | |
| CN108809549A (en) | A kind of method and apparatus of transmission data | |
| CN113055193B (en) | A data multicast transmission method, device, equipment and storage medium | |
| US8200278B2 (en) | Adding SMS as a transport type for an enterprise service bus | |
| US7689648B2 (en) | Dynamic peer network extension bridge | |
| CN118890389A (en) | An instant messaging method, server, client and system based on MQTT protocol | |
| EP3002910B1 (en) | Connecting computer management systems via cellular digital telecommunication networks | |
| CN102263796B (en) | Data transmission method based on simple network management protocol | |
| CN115412308A (en) | Message processing method, device and electronic equipment | |
| CN109688204B (en) | File downloading method, node and terminal based on NDN (named data networking) | |
| US11588925B2 (en) | Method for transferring large amounts of data through a telematic network in an efficient and reliable manner at a high-speed | |
| CN116112261B (en) | Network gate penetration method, system, MQTT client, MQTT server and electronic device | |
| CN118612223B (en) | Data processing method, device, system, computer equipment and storage medium | |
| Alliance | Internet of Things Protocol Comparison | |
| CN111917808B (en) | Load control method, service provider NF and service user NF | |
| CN115967754A (en) | A method, device, equipment and storage medium for acquiring industrial data | |
| KR20180081331A (en) | Constrained application protocol compression communication system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |