CN112422565B - Message processing method, device, storage medium and electronic device - Google Patents
Message processing method, device, storage medium and electronic deviceDownload PDFInfo
- Publication number
- CN112422565B CN112422565BCN202011296407.5ACN202011296407ACN112422565BCN 112422565 BCN112422565 BCN 112422565BCN 202011296407 ACN202011296407 ACN 202011296407ACN 112422565 BCN112422565 BCN 112422565B
- Authority
- CN
- China
- Prior art keywords
- message
- substructure
- network structure
- uplink
- target network
- 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.)
- Active
Links
Images
Classifications
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/18—Multiprotocol handlers, e.g. single devices capable of handling multiple protocols
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/08—Protocols for interworking; Protocol conversion
Landscapes
- Engineering & Computer Science (AREA)
- Computer Security & Cryptography (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer And Data Communications (AREA)
Abstract
Description
Translated fromChinese技术领域technical field
本发明涉及计算机领域，具体而言，涉及一种消息处理方法、装置和存储介质及电子装置。The present invention relates to the field of computers, in particular to a message processing method, device, storage medium and electronic device.
背景技术Background technique
如今，在物联网系统中，往往需要接入成百上千种终端设备，且并非同一厂商的设备。势必会存在后台系统需要有多种协议的兼容问题。目前，普遍采用的方式是不同协议的设备会接入到不同的后台服务节点中，这样就使得后台系统不再是一个纯粹的分布式系统，服务资源得不到充分利用。即，现有技术中存在因服务节点之间不兼容，消息处理较为分散，进而导致后续的运维工作量繁重的技术问题。Today, in the IoT system, it is often necessary to access hundreds of terminal devices, and they are not from the same manufacturer. There is bound to be a background system that needs to have compatibility issues with multiple protocols. At present, the commonly used method is that devices of different protocols will be connected to different background service nodes, so that the background system is no longer a purely distributed system, and service resources cannot be fully utilized. That is, in the prior art, there is a technical problem that due to the incompatibility between service nodes, message processing is scattered, which leads to a heavy workload of subsequent operation and maintenance.
针对上述的问题，目前尚未提出有效的解决方案。For the above problems, no effective solution has been proposed yet.
发明内容Contents of the invention
本发明实施例提供了一种消息处理方法、装置和存储介质及电子装置，以至少解决消息处理的适应性差的技术问题。Embodiments of the present invention provide a message processing method, device, storage medium, and electronic device, so as to at least solve the technical problem of poor adaptability of message processing.
根据本发明实施例的一个方面，提供了一种消息处理方法，包括：接收配置有第一通信协议的第一终端发送的第一消息，其中，上述第一消息的消息格式为上述第一终端可识别的第一消息格式；将上述第一消息输入至目标服务器的目标网络结构，确定上述目标网络结构中与上述第一通信协议对应的上行子结构，其中，上述目标网络结构用于转换消息格式，上述目标网络结构包括至少两个与不同通信协议外对应的上行子结构；获取上述目标网络结构中与上述第一通信协议对应的上行子结构输出的第二消息，其中，上述第二消息的第二消息格式与上述第一通信协议相对应，上述第二消息格式为上述目标服务器可识别的消息格式。According to an aspect of an embodiment of the present invention, there is provided a message processing method, including: receiving a first message sent by a first terminal configured with a first communication protocol, wherein the message format of the first message is the first terminal An identifiable first message format; input the first message to the target network structure of the target server, and determine the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert the message Format, the target network structure includes at least two uplink substructures corresponding to different communication protocols; obtain the second message output by the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message The second message format corresponds to the above-mentioned first communication protocol, and the above-mentioned second message format is a message format recognizable by the above-mentioned target server.
根据本发明实施例的另一方面，还提供了一种消息处理装置，包括：第一接收单元，用于接收配置有第一通信协议的第一终端发送的第一消息，其中，上述第一消息的消息格式为上述第一终端可识别的第一消息格式；第一确定单元，用于将上述第一消息输入至目标服务器的目标网络结构，确定上述目标网络结构中与上述第一通信协议对应的上行子结构，其中，上述目标网络结构用于转换消息格式，上述目标网络结构包括至少两个与不同通信协议外对应的上行子结构；第一获取单元，用于获取上述目标网络结构中与上述第一通信协议对应的上行子结构输出的第二消息，其中，上述第二消息的第二消息格式与上述第一通信协议相对应，上述第二消息格式为上述目标服务器可识别的消息格式。According to another aspect of the embodiments of the present invention, there is also provided a message processing device, including: a first receiving unit, configured to receive a first message sent by a first terminal configured with a first communication protocol, wherein the first The message format of the message is a first message format recognizable by the first terminal; the first determining unit is configured to input the first message to the target network structure of the target server, and determine the first communication protocol in the target network structure A corresponding uplink substructure, wherein the above target network structure is used to convert message formats, and the above target network structure includes at least two uplink substructures corresponding to different communication protocols; the first acquisition unit is used to acquire the above target network structure The second message output by the uplink substructure corresponding to the above-mentioned first communication protocol, wherein the second message format of the above-mentioned second message corresponds to the above-mentioned first communication protocol, and the above-mentioned second message format is a message recognizable by the above-mentioned target server Format.
根据本发明实施例的又一方面，还提供了一种计算机可读的存储介质，该计算机可读的存储介质中存储有计算机程序，其中，该计算机程序被设置为运行时执行上述消息处理方法。According to still another aspect of the embodiments of the present invention, there is also provided a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, wherein the computer program is set to execute the above message processing method when running .
根据本发明实施例的又一方面，还提供了一种电子装置，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其中，上述处理器通过计算机程序执行上述的消息处理方法。According to yet another aspect of the embodiments of the present invention, there is also provided an electronic device, including a memory, a processor, and a computer program stored on the memory and operable on the processor, wherein the above-mentioned processor executes the above-mentioned Message processing method.
在本发明实施例中，接收配置有第一通信协议的第一终端发送的第一消息，其中，上述第一消息的消息格式为上述第一终端可识别的第一消息格式；将上述第一消息输入至目标服务器的目标网络结构，确定上述目标网络结构中与上述第一通信协议对应的上行子结构，其中，上述目标网络结构用于转换消息格式，上述目标网络结构包括至少两个与不同通信协议外对应的上行子结构；获取上述目标网络结构中与上述第一通信协议对应的上行子结构输出的第二消息，其中，上述第二消息的第二消息格式与上述第一通信协议相对应，上述第二消息格式为上述目标服务器可识别的消息格式，利用网络结构转换消息格式的方式，通过将输入的消息的消息格式转换为服务器可识别，且与输入的消息协议对应的消息格式，从而达到了无需配置多个只能转换单一协议消息的服务节点，即可完成消息的处理的目的，进而实现了提高消息处理的统一性的效果，进而解决了消息处理的适应性差的技术问题。In an embodiment of the present invention, a first message sent by a first terminal configured with a first communication protocol is received, wherein the message format of the first message is a first message format recognizable by the first terminal; The message is input to the target network structure of the target server, and the uplink substructure corresponding to the above-mentioned first communication protocol in the above-mentioned target network structure is determined, wherein the above-mentioned target network structure is used to convert the message format, and the above-mentioned target network structure includes at least two different An uplink substructure corresponding to a communication protocol; obtaining a second message output by an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message is the same as that of the first communication protocol Correspondingly, the above-mentioned second message format is a message format recognizable by the above-mentioned target server, and the message format of the input message is converted into a message format recognizable by the server and corresponding to the input message protocol by using the network structure to convert the message format , so as to achieve the purpose of completing message processing without configuring multiple service nodes that can only convert single-protocol messages, thereby achieving the effect of improving the uniformity of message processing, and further solving the technical problem of poor adaptability of message processing .
附图说明Description of drawings
此处所说明的附图用来提供对本发明的进一步理解，构成本申请的一部分，本发明的示意性实施例及其说明用于解释本发明，并不构成对本发明的不当限定。在附图中：The accompanying drawings described here are used to provide a further understanding of the present invention and constitute a part of the application. The schematic embodiments of the present invention and their descriptions are used to explain the present invention and do not constitute improper limitations to the present invention. In the attached picture:
图1是根据本发明实施例的一种可选的消息处理方法的应用环境的示意图；FIG. 1 is a schematic diagram of an application environment of an optional message processing method according to an embodiment of the present invention;
图2是根据本发明实施例的一种可选的消息处理方法的流程图的示意图；FIG. 2 is a schematic diagram of a flow chart of an optional message processing method according to an embodiment of the present invention;
图3是根据本发明实施例的一种可选的消息处理方法的示意图；Fig. 3 is a schematic diagram of an optional message processing method according to an embodiment of the present invention;
图4是根据本发明实施例的另一种可选的消息处理方法的示意图；Fig. 4 is a schematic diagram of another optional message processing method according to an embodiment of the present invention;
图5是根据本发明实施例的另一种可选的消息处理方法的示意图；Fig. 5 is a schematic diagram of another optional message processing method according to an embodiment of the present invention;
图6是根据本发明实施例的另一种可选的消息处理方法的示意图；Fig. 6 is a schematic diagram of another optional message processing method according to an embodiment of the present invention;
图7是根据本发明实施例的另一种可选的消息处理方法的示意图；Fig. 7 is a schematic diagram of another optional message processing method according to an embodiment of the present invention;
图8是根据本发明实施例的另一种可选的消息处理方法的示意图；Fig. 8 is a schematic diagram of another optional message processing method according to an embodiment of the present invention;
图9是根据本发明实施例的一种可选的消息处理装置的示意图；Fig. 9 is a schematic diagram of an optional message processing device according to an embodiment of the present invention;
图10是根据本发明实施例的一种可选的电子装置的结构示意图。Fig. 10 is a schematic structural diagram of an optional electronic device according to an embodiment of the present invention.
具体实施方式Detailed ways
为了使本技术领域的人员更好地理解本发明方案，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分的实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都应当属于本发明保护的范围。In order to enable those skilled in the art to better understand the solutions of the present invention, the following will clearly and completely describe the technical solutions in the embodiments of the present invention in conjunction with the drawings in the embodiments of the present invention. Obviously, the described embodiments are only It is an embodiment of a part of the present invention, but not all embodiments. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts shall fall within the protection scope of the present invention.
需要说明的是，本发明的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换，以便这里描述的本发明的实施例能够以除了在这里图示或描述的那些以外的顺序实施。此外，术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元，而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。It should be noted that the terms "first" and "second" in the description and claims of the present invention and the above drawings are used to distinguish similar objects, but not necessarily used to describe a specific sequence or sequence. It is to be understood that the data so used are interchangeable under appropriate circumstances such that the embodiments of the invention described herein can be practiced in sequences other than those illustrated or described herein. Furthermore, the terms "comprising" and "having", as well as any variations thereof, are intended to cover a non-exclusive inclusion, for example, a process, method, system, product or device comprising a sequence of steps or elements is not necessarily limited to the expressly listed instead, may include other steps or elements not explicitly listed or inherent to the process, method, product or apparatus.
根据本发明实施例的一个方面，提供了一种消息处理方法，可选地，作为一种可选的实施方式，上述消息处理方法可以但不限于应用于如图1所示的环境中。其中，可以但不限于包括用户设备102、网络110及服务器112，其中，该用户设备102上可以但不限于包括显示器108、处理器106及存储器104。可选的，用户设备102可以但不限于为物联网下的智能家居设备，例如图1中所示的智能空调。可选的，显示器108上可以但不限于显示有当前智能空调检测到的体感温度。According to an aspect of an embodiment of the present invention, a method for processing a message is provided. Optionally, as an optional implementation manner, the method for processing a message may be, but not limited to, applied to the environment shown in FIG. 1 . It may include, but is not limited to, a user equipment 102 , a network 110 and a server 112 , wherein, the user equipment 102 may include, but is not limited to, a display 108 , a processor 106 and a memory 104 . Optionally, the user equipment 102 may be, but not limited to, a smart home device under the Internet of Things, such as the smart air conditioner shown in FIG. 1 . Optionally, the display 108 may, but is not limited to, display the body temperature detected by the current smart air conditioner.
具体过程可如下步骤：The specific process can be as follows:
步骤S102，用户设备102获取安装在用户设备102上的温度传感器检测到的当前环境的体感温度，并生成第一消息，其中，用户设备102配置有第一通信协议，第一消息包括该体感温度，且第一消息与第一通信协议相对应；In step S102, the user equipment 102 obtains the perceived temperature of the current environment detected by the temperature sensor installed on the user equipment 102, and generates a first message, wherein the user equipment 102 is configured with a first communication protocol, and the first message includes the perceived temperature , and the first message corresponds to the first communication protocol;
步骤S104-S106，用户设备102通过网络110将第一消息发送给服务器112；Steps S104-S106, the user equipment 102 sends the first message to the server 112 through the network 110;
步骤S108-S112，服务器112通过处理引擎116将与第一通信协议对应的第一消息进行处理，从而生成与第一通信协议的第二消息，其中，第二消息为服务器112可识别的消息格式；服务器112在数据库114中查找与第二消息对应的预设数据，进而生成对应的业务指令，其中，业务指令用于指示调整控温，例如预设温度数值低于36度，则生成用于指示升温的业务指令；服务器112通过处理引擎116将与第一通信协议对应的业务指令进行处理，从而生成与第一通信协议对应的第三消息，其中，第三消息为第一终端102可识别的消息格式。In steps S108-S112, the server 112 processes the first message corresponding to the first communication protocol through the processing engine 116, thereby generating a second message corresponding to the first communication protocol, wherein the second message is in a message format recognizable by the server 112 ; The server 112 searches the database 114 for the preset data corresponding to the second message, and then generates a corresponding business instruction, wherein the business instruction is used to instruct to adjust the temperature control, for example, if the preset temperature value is lower than 36 degrees, then generate a A service instruction indicating temperature rise; the server 112 processes the service instruction corresponding to the first communication protocol through the processing engine 116, thereby generating a third message corresponding to the first communication protocol, wherein the third message is identifiable by the first terminal 102 message format.
步骤S114-S116，服务器112通过网络110将第三消息发送给用户设备102，用户设备102中的处理器106根据第三消息调整工作档位，例如上调控温档位，并将调整工作档位后的实时体感温度显示在显示器108中，并将第三消息存储在存储器104中。Steps S114-S116, the server 112 sends the third message to the user equipment 102 through the network 110, and the processor 106 in the user equipment 102 adjusts the working gear according to the third message, for example, increases the temperature control gear, and adjusts the working gear The final real-time body temperature is displayed on the display 108, and the third message is stored in the memory 104.
可选地，作为一种可选的实施方式，如图2所示，消息处理方法包括：Optionally, as an optional implementation manner, as shown in FIG. 2, the message processing method includes:
S202，接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；S202. Receive a first message sent by a first terminal configured with a first communication protocol, where the message format of the first message is a first message format recognizable by the first terminal;
S204，将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；S204, input the first message to the target network structure of the target server, and determine the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert the message format, and the target network structure includes at least two Uplink substructure corresponding to different communication protocols;
S206，获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式。S206. Obtain a second message output by an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message format is identifiable by the target server message format.
可选的，在本实施例中，上述消息处理方法可以但不限于应用在物联网场景下，具体的，可以但不限应用于后台服务器接收或发送配置有不同协议的终端设备。目前常见的支持多协议的接入系统，普遍采用一种协议对应一类服务节点的方式，也就是说服务端接入系统被切割成了几类独立的子系统，他们互相无法兼容，而利用上述消息处理方法，利用一种复合式的服务节点，对应多种协议的方式，而无需将服务端接入系统切割成了几类独立的子系统。Optionally, in this embodiment, the above message processing method can be applied in the Internet of Things scenario, but not limited to, specifically, it can be applied in the background server to receive or send terminal devices configured with different protocols. At present, common access systems that support multiple protocols generally adopt the method that one protocol corresponds to one type of service node, that is to say, the server access system is divided into several types of independent subsystems, which are incompatible with each other. The above message processing method utilizes a composite service node corresponding to multiple protocols without dividing the server access system into several types of independent subsystems.
可选的，在本实施例中，通信协议可以但不限于指双方实体完成通信或服务所必须遵循的规则和约定，通过通信信道和设备互连起来的多个不同地理位置的数据通信系统，要使其能协同工作实现信息交互和资源共享，它们之间必须具有共同的语言。例如，配置有第一通信协议的第一终端，无法直接与仅配置有第二通信协议的服务节点或服务器实现通信或服务。Optionally, in this embodiment, the communication protocol may, but is not limited to, refer to the rules and agreements that both entities must follow to complete communication or services, and multiple data communication systems in different geographical locations that are interconnected through communication channels and devices. To enable them to work together to achieve information exchange and resource sharing, they must have a common language. For example, a first terminal configured with the first communication protocol cannot directly communicate or serve with a service node or server configured only with the second communication protocol.
可选的，在本实施例中，消息格式可以但不限于指不同终端或服务器可识别的消息格式，例如字节消息格式、对象消息格式、业务消息格式等。消息格式的转换可以但不限于通过解码器或编码器实现，其中，解码器可以但不限于是一种能将数字数据流解码还原成模拟信号的硬件/软件设备。编码器可以但不限于将信号或数据进行编制、转换为可用以通信、传输和存储的信号形式的设备。Optionally, in this embodiment, the message format may, but is not limited to, refer to message formats recognizable by different terminals or servers, such as byte message format, object message format, service message format, and the like. The conversion of the message format can be realized by, but not limited to, a decoder or an encoder, wherein the decoder can be but not limited to a hardware/software device capable of decoding and restoring a digital data stream into an analog signal. An encoder is, but is not limited to, a device that encodes and converts signals or data into a signal form that can be used for communication, transmission, and storage.
可选的，在本实施例中，目标服务器中可以但不限于包括多个子服务器，每一个子服务器可以但不限于都包括目标网络结构。Optionally, in this embodiment, the target server may include, but is not limited to, multiple sub-servers, and each sub-server may include, but is not limited to, a target network structure.
进一步举例说明，可选的例如图3所示，目标服务器302中包括n个服务节点，且每个服务节点中都包括目标网络结构，其中，目标网络结构用于将终端发送的各种协议对应的消息的消息格式转换为目标服务器可识别的消息格式，例如终端A将通信协议A对应的消息发送至第一服务节点，进而目标服务器302获取第一服务节点输出的，目标服务器302可识别的通信协议A对应的消息。此外，在第一服务节点处于工作状态的情况下，其他终端发送的消息无需等待，目标服务节点可以但不限于将接收到的消息发送至处于空闲状态的其他服务节点，例如第二服务节点等。可选的，图3中的虚线用于表示终端发送的消息可发送至不同的服务节点进行转换。For further illustration, optionally, as shown in FIG. 3, the target server 302 includes n service nodes, and each service node includes a target network structure, where the target network structure is used to correspond to various protocols sent by the terminal The message format of the message is converted into a message format recognizable by the target server. For example, terminal A sends a message corresponding to communication protocol A to the first service node, and then the target server 302 obtains the output of the first service node, which the target server 302 can recognize. Message corresponding to communication protocol A. In addition, when the first service node is in the working state, there is no need to wait for messages sent by other terminals, and the target service node can, but not limited to, send the received message to other service nodes in an idle state, such as the second service node, etc. . Optionally, the dotted line in FIG. 3 is used to indicate that the message sent by the terminal can be sent to different service nodes for conversion.
可选的，在本实施例中，目标网络结构可以但不限用于将终端可识别但服务器不可识别的消息格式转换为服务器端可识别的消息格式，目标网络结构还可以但不限用于将服务器可识别但终端不可识别的消息格式转换为终端可识别的消息格式。例如，目标网络结构可以但不限于为基于netty网络框架搭建的网络结构，可选的，netty网络框架可以但不限于是一种异步的时间驱动的网络应用程序框架，支持快速地开发可维护的高性能的面向协议的服务器和客户端，可以但不限于适合客户端数据较大的请求/处理场景，例如web服务器等。Optionally, in this embodiment, the target network structure can be used, but not limited to, to convert a message format recognizable by the terminal but unrecognized by the server into a message format recognizable by the server. The target network structure can also be used, but not limited to, for Convert a message format that the server can understand but not the terminal to a message format that the terminal can understand. For example, the target network structure can be but not limited to a network structure based on the netty network framework. Optionally, the netty network framework can be but not limited to an asynchronous time-driven network application framework, which supports rapid development and maintainable High-performance protocol-oriented servers and clients can, but are not limited to, be suitable for request/processing scenarios with large client data, such as web servers.
进一步举例说明，可选的目标网络结构可以但不限于例如图4所示，目标网络结构包括网络层402、解码器404、消息处理器406以及编码器408，其中，网络层402可以但不限于在数据链路层提供的两个相邻端点之间的数据帧的传送功能上，进一步管理网络中的数据通信，将数据设法从源端经过若干个中间节点传送到目的端，从而向运输层提供最基本的端到端的数据传送服务，解码器404可以但不限于将字节消息转化为消息对象，而编码器408可以但不限于将消息对象转化为字节消息，消息处理器406可以但不限于通道消息对象处理，例如消息处理器406可以但不限于为handler，其中，handler主要用于异步消息的处理，当发出一个消息之后，首先进入一个消息队列，发送消息的函数即可返回，而另外一个部分在消息队列中逐一将消息取出，然后对消息进行处理，也就是发送消息和接收消息不是同步的处理，这种机制通常用来处理相对耗时较长的操作。For further illustration, an optional target network structure may be but not limited to, for example, as shown in FIG. In terms of the data frame transmission function provided by the data link layer between two adjacent endpoints, the data communication in the network is further managed, and the data is managed to be transmitted from the source end to the destination end through several intermediate nodes, thus to the transport layer To provide the most basic end-to-end data transmission service, decoder 404 can convert byte messages into message objects, but encoder 408 can convert message objects into byte messages, and message processor 406 can but It is not limited to channel message object processing. For example, the message processor 406 can be but not limited to a handler, wherein the handler is mainly used for processing asynchronous messages. When a message is sent, it first enters a message queue, and the function of sending the message can return. The other part takes out the messages one by one in the message queue, and then processes the messages, that is, sending and receiving messages are not synchronized. This mechanism is usually used to process relatively time-consuming operations.
具体的，假设目标网络结构为基于netty网络架构搭建的网络结构，进而利用netty网络架构的ChannelPipeline机制，可通过向ChannelPipeline添加ChannelHandler的方式，对netty消息进行拦截，进行自定义的逻辑处理。可选的，ChannelHandler分为两类：一类是InboundHandler，旨在处理流入消息；另一类是OutboundHandler，旨在处理流出消息。从ChannelPipeline的消息流向可以看出，消息进入后会经过一个或者多个InboundHandler，消息流出时会经过一个或多个OutboundHandler。而这里的这两类Handler就是可以添加定制化逻辑的地方。而在通常的协议消息处理中，InboundHandler对应的就是解码器404，OutboundHandler对应的就是编码器408。Specifically, assuming that the target network structure is a network structure based on the netty network architecture, and then using the ChannelPipeline mechanism of the netty network architecture, by adding a ChannelHandler to the ChannelPipeline, netty messages can be intercepted and customized logic processing can be performed. Optionally, ChannelHandler is divided into two types: one is InboundHandler, which is designed to process incoming messages; the other is OutboundHandler, which is designed to process outgoing messages. From the message flow of ChannelPipeline, it can be seen that after the message enters, it will pass through one or more InboundHandlers, and when the message flows out, it will pass through one or more OutboundHandlers. The two types of Handlers here are where you can add custom logic. In normal protocol message processing, the InboundHandler corresponds to the decoder 404 , and the OutboundHandler corresponds to the encoder 408 .
需要说明的是，接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式。It should be noted that receiving the first message sent by the first terminal configured with the first communication protocol, wherein the message format of the first message is a first message format recognizable by the first terminal; inputting the first message to the target server A target network structure, determining an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert message formats, and the target network structure includes at least two uplink substructures corresponding to different communication protocols; Obtaining a second message output by an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message format is a message recognizable by the target server Format.
进一步举例说明，可选的继续基于图4所示场景，继续以图5为例说明，包括终端502以及目标服务器中的业务处理层504，其中，业务处理层504用于将目标网络结构输出的消息转化为与目标服务器对应的业务指令。For further illustration, optionally continue to be based on the scenario shown in FIG. 4 , and continue to use FIG. 5 as an example to illustrate, including the terminal 502 and the service processing layer 504 in the target server, wherein the service processing layer 504 is used to output the target network structure The messages are converted into business instructions corresponding to the target server.
再者，可针对不同的协议编写对应的编码器408和解码器404，多种协议就在ChannelPipeline中配置多种解码器404和编码器408即可。这样就可以很方便的实现协议的兼容扩展。假设以两种协议(一种为协议A—自定义，一种为协议B--MQTT协议)为例，在netty初始化时，需要针对这两种协议编写对应的编码器和解码器并注册到通道中，例如自定义协议编码器、MQTT协议编码器，以及对应的自定义协议解码器、MQTT协议解码器，对应的自定义协议消息处理器、MQTT协议消息处理器。Furthermore, corresponding encoders 408 and decoders 404 can be written for different protocols. For multiple protocols, multiple decoders 404 and encoders 408 can be configured in the ChannelPipeline. In this way, the compatible extension of the protocol can be easily realized. Assuming two protocols (one is protocol A - custom, one is protocol B - MQTT protocol) as an example, when netty is initialized, it is necessary to write corresponding encoders and decoders for these two protocols and register them with In the channel, such as custom protocol encoder, MQTT protocol encoder, and corresponding custom protocol decoder, MQTT protocol decoder, corresponding custom protocol message processor, MQTT protocol message processor.
进一步举例说明，分别为每种协议配置一个编码器408、解码器404和消息处理器406，即可实现对多个协议的解析处理。而从消息的流向(箭头指向)来看，分为上行(终端502到目标服务器)消息和下行(目标服务器到终端502)消息。For further illustration, an encoder 408, a decoder 404, and a message processor 406 are respectively configured for each protocol, so as to realize parsing and processing of multiple protocols. From the point of view of the flow direction of the message (directed by the arrow), it can be divided into an uplink (from the terminal 502 to the target server) message and a downlink (from the target server to the terminal 502) message.
通过本申请提供的实施例，接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式，利用网络结构转换消息格式的方式，通过将输入的消息的消息格式转换为服务器可识别，且与输入的消息协议对应的消息格式，从而达到了无需配置多个只能转换单一协议消息的服务节点，即可完成消息的处理的目的，进而实现了提高消息处理的统一性的效果。According to the embodiment provided by this application, the first message sent by the first terminal configured with the first communication protocol is received, wherein the message format of the first message is a first message format recognizable by the first terminal; input the first message To the target network structure of the target server, determine the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert the message format, and the target network structure includes at least two uplink substructures corresponding to different communication protocols Substructure; obtain the second message output by the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message format is that the target server can Recognized message format, using the network structure to convert the message format, by converting the message format of the input message into a message format that the server can recognize and corresponds to the input message protocol, so that it can only convert a single message without configuring multiple The service node of the protocol message can complete the purpose of message processing, thereby achieving the effect of improving the uniformity of message processing.
作为一种可选的方案，将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，包括：As an optional solution, the first message is input to the target network structure of the target server, and the uplink substructure corresponding to the first communication protocol in the target network structure is determined, including:
S1，在将第一消息输入至目标网络结构中的第一上行子结构，且获取到第一上行子结构输出的第二消息的情况下，确定第一上行子结构与第一通信协议相对应；或，S1, when the first message is input to the first uplink substructure in the target network structure, and the second message output by the first uplink substructure is obtained, determine that the first uplink substructure corresponds to the first communication protocol ;or,
S2，在将第一消息输入至第一上行子结构，但并未获取到第一上行子结构输出的第二消息的情况下，将第一消息输入至目标网络结构的第二上行子结构；S2. When the first message is input to the first uplink substructure, but the second message output by the first uplink substructure is not obtained, input the first message to the second uplink substructure of the target network structure;
S3，在将第一消息输入至第二上行子结构，且获取到第二上行子结构输出的第二消息的情况下，确定第二上行子结构与第一通信协议相对应。S3. When the first message is input into the second uplink substructure and the second message output by the second uplink substructure is obtained, determine that the second uplink substructure corresponds to the first communication protocol.
需要说明的是，在将第一消息输入至目标网络结构中的第一上行子结构，且获取到第一上行子结构输出的第二消息的情况下，确定第一上行子结构与第一通信协议相对应；或，在将第一消息输入至第一上行子结构，但并未获取到第一上行子结构输出的第二消息的情况下，将第一消息输入至目标网络结构的第二上行子结构；在将第一消息输入至第二上行子结构，且获取到第二上行子结构输出的第二消息的情况下，确定第二上行子结构与第一通信协议相对应。It should be noted that, when the first message is input to the first uplink substructure in the target network structure, and the second message output by the first uplink substructure is obtained, it is determined that the first uplink substructure communicates with the first or, when the first message is input to the first uplink substructure, but the second message output by the first uplink substructure is not obtained, the first message is input to the second of the target network structure The uplink substructure: when the first message is input to the second uplink substructure and the second message output by the second uplink substructure is obtained, determine that the second uplink substructure corresponds to the first communication protocol.
进一步举例说明，可选的例如基于上述假设为目标网络结构配置的自定义协议编码器、MQTT协议编码器，以及对应的自定义协议解码器、MQTT协议解码器，对应的自定义协议消息处理器、MQTT协议消息处理器，针对上行消息的处理过程可以但不限例如图6所示，具体步骤如下：To further illustrate, optional, such as a custom protocol encoder, MQTT protocol encoder configured for the target network structure based on the above assumptions, and a corresponding custom protocol decoder, MQTT protocol decoder, and a corresponding custom protocol message processor , MQTT protocol message processor, the processing process for the uplink message can be but not limited to, for example, as shown in Figure 6, the specific steps are as follows:
步骤S602，接收终端发送的消息；Step S602, receiving a message sent by the terminal;
步骤S604，自定义解码器解码；Step S604, decoding with a custom decoder;
步骤S606，判断自定义解码器是否解码到正确的自定义消息，若是，则执行步骤S608，若否，则执行步骤S610；Step S606, judging whether the custom decoder has decoded the correct custom message, if so, then execute step S608, if not, then execute step S610;
步骤S608，自定义消息处理器处理解码到的自定义消息；Step S608, the custom message processor processes the decoded custom message;
步骤S610，MQTT协议解码器解码；Step S610, MQTT protocol decoder decoding;
步骤S612，判断MQTT解码器是否解码到正确的MQTT消息，若是，则执行步骤S6014，若否，则执行步骤S616；Step S612, judging whether the MQTT decoder has decoded the correct MQTT message, if yes, execute step S6014, if not, execute step S616;
步骤S614，MQTT消息处理器处理解码到的MQTT消息；Step S614, the MQTT message processor processes the decoded MQTT message;
步骤S616，确定终端发送的消息无法解析；Step S616, determining that the message sent by the terminal cannot be parsed;
步骤S618，获取编码得到的自定义消息；Step S618, obtaining the encoded custom message;
步骤S620，获取编码得到的MQTT消息。Step S620, acquire the encoded MQTT message.
通过本申请提供的实施例，在将第一消息输入至目标网络结构中的第一上行子结构，且获取到第一上行子结构输出的第二消息的情况下，确定第一上行子结构与第一通信协议相对应；或，在将第一消息输入至第一上行子结构，但并未获取到第一上行子结构输出的第二消息的情况下，将第一消息输入至目标网络结构的第二上行子结构；在将第一消息输入至第二上行子结构，且获取到第二上行子结构输出的第二消息的情况下，确定第二上行子结构与第一通信协议相对应，达到了高效且统一处理不同协议对应的上行消息的目的，实现了提高上行消息的处理效率的效果。Through the embodiments provided in this application, when the first message is input to the first uplink substructure in the target network structure, and the second message output by the first uplink substructure is obtained, the first uplink substructure and the first uplink substructure are determined to be Corresponding to the first communication protocol; or, when the first message is input to the first uplink substructure, but the second message output by the first uplink substructure is not obtained, the first message is input to the target network structure the second uplink substructure; when the first message is input to the second uplink substructure and the second message output by the second uplink substructure is obtained, it is determined that the second uplink substructure corresponds to the first communication protocol , the purpose of efficiently and uniformly processing uplink messages corresponding to different protocols is achieved, and the effect of improving the processing efficiency of uplink messages is achieved.
作为一种可选的方案，在获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息之后，包括：As an optional solution, after obtaining the second message output by the uplink substructure corresponding to the first communication protocol in the target network structure, the method includes:
S1，将第二消息输入至目标网络结构的目标处理子结构，其中，目标处理子结构与第一通信协议相对应，目标处理子结构用于将消息处理为目标服务器对应的业务消息，目标网络结构包括至少两个与不同通信协议外对应的处理子结构；S1, input the second message to the target processing substructure of the target network structure, wherein the target processing substructure corresponds to the first communication protocol, and the target processing substructure is used to process the message into a service message corresponding to the target server, and the target network The structure includes at least two processing substructures corresponding to different communication protocols;
S2，获取目标处理子结构输出的第一业务消息，其中，第一业务消息用于指示目标服务器生成第一业务指令，第一业务指令用于指示执行第一业务。S2. Obtain a first service message output by the target processing substructure, where the first service message is used to instruct the target server to generate a first service instruction, and the first service instruction is used to instruct the execution of the first service.
可选的，目标处理子结构可以但不限用于将目标服务器可识别的消息结合目标服务器预设的业务逻辑，处理为具体的业务指令或业务消息，以实现信息的处理或对终端的控制。Optionally, the target processing substructure can be used, but not limited to, to process messages identifiable by the target server in combination with the preset business logic of the target server into specific business instructions or business messages, so as to realize information processing or terminal control .
需要说明的是，将第二消息输入至目标网络结构的目标处理子结构，其中，目标处理子结构与第一通信协议相对应，目标处理子结构用于将消息处理为目标服务器对应的业务消息，目标网络结构包括至少两个与不同通信协议外对应的处理子结构；获取目标处理子结构输出的第一业务消息，其中，第一业务消息用于指示目标服务器生成第一业务指令，第一业务指令用于指示执行第一业务。It should be noted that the second message is input to the target processing substructure of the target network structure, wherein the target processing substructure corresponds to the first communication protocol, and the target processing substructure is used to process the message into a service message corresponding to the target server , the target network structure includes at least two processing substructures corresponding to different communication protocols; obtain the first service message output by the target processing substructure, wherein the first service message is used to instruct the target server to generate a first service instruction, the first The service instruction is used to instruct to execute the first service.
进一步举例说明，可选的例如图5所示，目标处理子结构可以但不限于为业务处理层504，其中，业务处理层504的业务逻辑可以但不限于在不同的场景下灵活设置，例如终端502为智能空调，在一种场景下，智能空调发送检测到的当前体感温度至目标服务器，通过目标网络结构将携带有上述当前体感温度的消息处理为目标服务器可识别到的消息，进而业务处理层504基于预设的业务逻辑，对该温度数据进行判断，例如低于目标预设阈值，则生成上调业务指令，其中，该上调业务指令用于指示智能空调上调控温档位，直至再检测到的体感温度达到目标预设阈值。For further illustration, optionally, as shown in FIG. 5, the target processing substructure can be but not limited to a business processing layer 504, wherein the business logic of the business processing layer 504 can be flexibly set in different scenarios, such as a terminal 502 is an intelligent air conditioner. In one scenario, the intelligent air conditioner sends the detected current body temperature to the target server, and processes the message carrying the above current body temperature into a message recognizable by the target server through the target network structure, and then performs business processing Layer 504 judges the temperature data based on the preset business logic. For example, if the temperature data is lower than the target preset threshold, an upward adjustment business instruction is generated, wherein the upward adjustment business instruction is used to instruct the smart air conditioner to increase the temperature adjustment level until the temperature is detected again. The perceived body temperature reaches the target preset threshold.
通过本申请提供的实施例，将第二消息输入至目标网络结构的目标处理子结构，其中，目标处理子结构与第一通信协议相对应，目标处理子结构用于将消息处理为目标服务器对应的业务消息，目标网络结构包括至少两个与不同通信协议外对应的处理子结构；获取目标处理子结构输出的第一业务消息，其中，第一业务消息用于指示目标服务器生成第一业务指令，第一业务指令用于指示执行第一业务，达到了将上述消息处理方法与具体的业务场景相结合的目的，实现了提高消息处理的兼容性的效果。Through the embodiments provided by the present application, the second message is input to the target processing substructure of the target network structure, wherein the target processing substructure corresponds to the first communication protocol, and the target processing substructure is used to process the message as corresponding to the target server The target network structure includes at least two processing substructures corresponding to different communication protocols; obtain the first service message output by the target processing substructure, wherein the first service message is used to instruct the target server to generate the first service instruction , the first service instruction is used to instruct the execution of the first service, which achieves the purpose of combining the above message processing method with a specific service scenario, and achieves the effect of improving the compatibility of message processing.
作为一种可选的方案，在获取目标处理子结构输出的第一业务消息之后，包括：As an optional solution, after obtaining the first service message output by the target processing substructure, include:
S1，将第一业务指令输入目标网络结构的第一下行子结构，其中，第一下行子结构用于将与第一通信协议对应的消息格式处理为第一消息格式，目标网络结构包括至少两个与不同通信协议外对应的下行子结构；S1. Input the first service instruction into the first downlink substructure of the target network structure, wherein the first downlink substructure is used to process the message format corresponding to the first communication protocol into the first message format, and the target network structure includes At least two downlink substructures corresponding to different communication protocols;
S2，获取第一下行子结构输出的第三消息，其中，第三消息的第一消息格式与第一通信协议相对应；S2. Obtain a third message output by the first downlink substructure, where the first message format of the third message corresponds to the first communication protocol;
S3，发送第三消息至第一终端，其中，第一终端基于第三消息执行第一业务。S3. Send a third message to the first terminal, where the first terminal executes the first service based on the third message.
需要说明的是，将第一业务指令输入目标网络结构的第一下行子结构，其中，第一下行子结构用于将与第一通信协议对应的消息格式处理为第一消息格式，目标网络结构包括至少两个与不同通信协议外对应的下行子结构；获取第一下行子结构输出的第三消息，其中，第三消息的第一消息格式与第一通信协议相对应；发送第三消息至第一终端，其中，第一终端基于第三消息执行第一业务。It should be noted that the first service instruction is input into the first downlink substructure of the target network structure, wherein the first downlink substructure is used to process the message format corresponding to the first communication protocol into the first message format, and the target The network structure includes at least two downlink substructures corresponding to different communication protocols; obtaining a third message output by the first downlink substructure, wherein the first message format of the third message corresponds to the first communication protocol; sending the third message Three messages are sent to the first terminal, wherein the first terminal executes the first service based on the third message.
进一步举例说明，可选的例如基于上述假设为目标网络结构配置的自定义协议编码器、MQTT协议编码器，以及对应的自定义协议解码器、MQTT协议解码器，对应的自定义协议消息处理器、MQTT协议消息处理器，针对下行消息的处理过程可以但不限例如图7所示，具体步骤如下：To further illustrate, optional, such as a custom protocol encoder, MQTT protocol encoder configured for the target network structure based on the above assumptions, and a corresponding custom protocol decoder, MQTT protocol decoder, and a corresponding custom protocol message processor , MQTT protocol message processor, the processing process for the downlink message can be, but not limited to, as shown in Figure 7, the specific steps are as follows:
步骤S702，接收终端发送的消息；Step S702, receiving a message sent by the terminal;
步骤S704，自定义编码器编码；Step S704, custom encoder encoding;
步骤S706，判断自定义编码器是否编码到正确的自定义消息，若是，则执行步骤S708，若否，则执行步骤S710；Step S706, judging whether the custom coder has encoded the correct custom message, if yes, execute step S708, if not, execute step S710;
步骤S708，获取编码得到的自定义消息；Step S708, obtaining the encoded custom message;
步骤S710，MQTT协议编码器编码；Step S710, MQTT protocol encoder encoding;
步骤S712，判断MQTT编码器是否编码到正确的MQTT消息，若是，则执行步骤S714，若否，则执行步骤S716；Step S712, judging whether the MQTT encoder has encoded the correct MQTT message, if so, then perform step S714, if not, then perform step S716;
步骤S714，获取编码得到的MQTT消息；Step S714, obtaining the encoded MQTT message;
步骤S716，确定终端发送的消息无法解析。In step S716, it is determined that the message sent by the terminal cannot be parsed.
需要说明的是，在确定接入消息对应的协议后，可直接为该接入消息选择对应的消息处理器以及编码器，而无需再进行判断。It should be noted that after the protocol corresponding to the access message is determined, the corresponding message processor and encoder can be directly selected for the access message without further judgment.
通过本申请提供的实施例，将第一业务指令输入目标网络结构的第一下行子结构，其中，第一下行子结构用于将与第一通信协议对应的消息格式处理为第一消息格式，目标网络结构包括至少两个与不同通信协议外对应的下行子结构；获取第一下行子结构输出的第三消息，其中，第三消息的第一消息格式与第一通信协议相对应；发送第三消息至第一终端，其中，第一终端基于第三消息执行第一业务，达到了高效且统一处理不同协议对应的下行消息的目的，实现了提高下行消息的处理效率的效果。Through the embodiment provided by this application, the first service instruction is input into the first downlink substructure of the target network structure, wherein the first downlink substructure is used to process the message format corresponding to the first communication protocol into the first message Format, the target network structure includes at least two downlink substructures corresponding to different communication protocols; obtain the third message output by the first downlink substructure, wherein the first message format of the third message corresponds to the first communication protocol ; sending the third message to the first terminal, wherein the first terminal executes the first service based on the third message, achieving the purpose of efficiently and uniformly processing downlink messages corresponding to different protocols, and achieving the effect of improving the processing efficiency of downlink messages.
作为一种可选的方案，还包括：As an option, also include:
S1，生成第二业务指令，其中，第二业务指令用于指示执行第二业务；S1. Generate a second service instruction, where the second service instruction is used to instruct execution of the second service;
S2，将第二业务指令输入至目标网络结构，确定目标网络结构中与第三通信协议对应的下行子结构；S2. Input the second service instruction into the target network structure, and determine the downlink substructure corresponding to the third communication protocol in the target network structure;
S3，获取目标网络结构中与第三通信协议对应的下行子结构输出的第四消息，其中，第四消息的第三消息格式与第三通信协议相对应，第三消息格式为第二终端可识别的消息格式，第二终端配置有第三通信协议；S3. Obtain the fourth message output by the downlink substructure corresponding to the third communication protocol in the target network structure, where the third message format of the fourth message corresponds to the third communication protocol, and the third message format is that the second terminal can The identified message format, the second terminal is configured with a third communication protocol;
S4，发送第三消息至第二终端，其中，第二终端基于第三消息执行第二业务。S4. Send a third message to the second terminal, where the second terminal executes the second service based on the third message.
需要说明的是，生成第二业务指令，其中，第二业务指令用于指示执行第二业务；将第二业务指令输入至目标网络结构，确定目标网络结构中与第三通信协议对应的下行子结构；获取目标网络结构中与第三通信协议对应的下行子结构输出的第四消息，其中，第四消息的第三消息格式与第三通信协议相对应，第三消息格式为第二终端可识别的消息格式，第二终端配置有第三通信协议；发送第三消息至第二终端，其中，第二终端基于第三消息执行第二业务。It should be noted that the second service instruction is generated, wherein the second service instruction is used to instruct the execution of the second service; the second service instruction is input into the target network structure, and the downlink sub-communication corresponding to the third communication protocol in the target network structure is determined. structure; obtain the fourth message output by the downlink substructure corresponding to the third communication protocol in the target network structure, wherein the third message format of the fourth message corresponds to the third communication protocol, and the third message format is that the second terminal can The identified message format, the second terminal is configured with a third communication protocol; and the third message is sent to the second terminal, wherein the second terminal executes the second service based on the third message.
进一步举例说明，可选的例如图3所示，配置有不同通信协议的多个终端，可以但不限于选择在一个服务节点处实现接入消息的处理，在一种场景下，第一服务节点可以但不限于同时处理终端A、终端B等多个终端接入的消息，并同时或按照接入顺序处理。To further illustrate, optionally, as shown in Figure 3, multiple terminals configured with different communication protocols may, but not limited to, choose to process access messages at one service node. In one scenario, the first service node It is possible, but not limited to, to process messages accessed by multiple terminals such as terminal A and terminal B at the same time, and process them simultaneously or according to the access sequence.
通过本申请提供的实施例，生成第二业务指令，其中，第二业务指令用于指示执行第二业务；将第二业务指令输入至目标网络结构，确定目标网络结构中与第三通信协议对应的下行子结构；获取目标网络结构中与第三通信协议对应的下行子结构输出的第四消息，其中，第四消息的第三消息格式与第三通信协议相对应，第三消息格式为第二终端可识别的消息格式，第二终端配置有第三通信协议；发送第三消息至第二终端，其中，第二终端基于第三消息执行第二业务，达到了一个服务节点可处理多个通信协议的目的，实现了提高消息处理的效率的效果。Through the embodiments provided in this application, a second service instruction is generated, wherein the second service instruction is used to instruct the execution of the second service; input the second service instruction into the target network structure, and determine that the target network structure corresponds to the third communication protocol the downlink substructure; obtain the fourth message output by the downlink substructure corresponding to the third communication protocol in the target network structure, wherein the third message format of the fourth message corresponds to the third communication protocol, and the third message format is the first The message format recognizable by the two terminals, the second terminal is configured with a third communication protocol; the third message is sent to the second terminal, wherein, the second terminal executes the second service based on the third message, so that one service node can handle multiple The purpose of the communication protocol is to achieve the effect of improving the efficiency of message processing.
作为一种可选的方案，将第二业务指令输入至目标服务器的目标网络结构，确定目标网络结构中与第二通信协议对应的下行子结构，包括：As an optional solution, the second service instruction is input to the target network structure of the target server, and the downlink substructure corresponding to the second communication protocol in the target network structure is determined, including:
S1，在将第二业务指令输入至目标网络结构中的第二下行子结构，且获取到第二下行子结构输出的第三消息的情况下，确定第二下行子结构与第三通信协议相对应；或，S1. When the second service instruction is input to the second downlink substructure in the target network structure, and the third message output by the second downlink substructure is obtained, determine that the second downlink substructure is consistent with the third communication protocol corresponding; or,
S2，在将第二业务指令输入至第二下行子结构，但并未获取到第二下行子结构输出的第三消息的情况下，将第一消息输入至目标网络结构的第三下行子结构；S2. Input the first message to the third downlink substructure of the target network structure when the second service instruction is input to the second downlink substructure but the third message output by the second downlink substructure is not obtained. ;
S3，在将第二业务指令输入至第三下行子结构，且获取到第三下行子结构输出的第三消息的情况下，确定第三下行子结构与第三通信协议相对应。S3. When the second service instruction is input into the third downlink substructure and the third message output by the third downlink substructure is acquired, determine that the third downlink substructure corresponds to the third communication protocol.
可选的。optional.
需要说明的是，在将第二业务指令输入至目标网络结构中的第二下行子结构，且获取到第二下行子结构输出的第三消息的情况下，确定第二下行子结构与第三通信协议相对应；或，在将第二业务指令输入至第二下行子结构，但并未获取到第二下行子结构输出的第三消息的情况下，将第一消息输入至目标网络结构的第三下行子结构；在将第二业务指令输入至第三下行子结构，且获取到第三下行子结构输出的第三消息的情况下，确定第三下行子结构与第三通信协议相对应。It should be noted that, when the second service instruction is input to the second downlink substructure in the target network structure, and the third message output by the second downlink substructure is obtained, it is determined that the second downlink substructure and the third Corresponding to the communication protocol; or, when the second service instruction is input to the second downlink substructure, but the third message output by the second downlink substructure is not obtained, the first message is input to the target network structure The third downlink substructure; when the second service instruction is input into the third downlink substructure and the third message output by the third downlink substructure is obtained, determine that the third downlink substructure corresponds to the third communication protocol .
进一步举例说明，可选的继续基于图5所示场景，例如图8所示，目标服务器可以但不限于主动发起指令或消息至终端802，例如目标服务器发起业务指令，并经由目标网络结构处理为终端802可识别且与终端802配置的网络协议相对应的指令/消息，用于指示终端802执行某业务操作。For further illustration, the optional scenario shown in FIG. 5 can be continued. For example, as shown in FIG. 8, the target server may, but is not limited to, actively initiate instructions or messages to the terminal 802, for example, the target server initiates a business instruction, and processes it via the target network structure as An instruction/message identifiable by the terminal 802 and corresponding to a network protocol configured by the terminal 802 is used to instruct the terminal 802 to perform a certain service operation.
通过本申请提供的实施例，在将第二业务指令输入至目标网络结构中的第二下行子结构，且获取到第二下行子结构输出的第三消息的情况下，确定第二下行子结构与第三通信协议相对应；或，在将第二业务指令输入至第二下行子结构，但并未获取到第二下行子结构输出的第三消息的情况下，将第一消息输入至目标网络结构的第三下行子结构；在将第二业务指令输入至第三下行子结构，且获取到第三下行子结构输出的第三消息的情况下，确定第三下行子结构与第三通信协议相对应，达到了降低消息处理的单一性的目的，实现了提高消息处理的全面性的效果。Through the embodiment provided by this application, when the second service instruction is input to the second downlink substructure in the target network structure, and the third message output by the second downlink substructure is obtained, the second downlink substructure is determined Corresponding to the third communication protocol; or, when the second service instruction is input to the second downlink substructure, but the third message output by the second downlink substructure is not obtained, input the first message to the target The third downlink substructure of the network structure; when the second service instruction is input to the third downlink substructure, and the third message output by the third downlink substructure is obtained, it is determined that the third downlink substructure communicates with the third Corresponding to the protocol, the purpose of reducing the singleness of message processing is achieved, and the effect of improving the comprehensiveness of message processing is achieved.
需要说明的是，对于前述的各方法实施例，为了简单描述，故将其都表述为一系列的动作组合，但是本领域技术人员应该知悉，本发明并不受所描述的动作顺序的限制，因为依据本发明，某些步骤可以采用其他顺序或者同时进行。其次，本领域技术人员也应该知悉，说明书中所描述的实施例均属于优选实施例，所涉及的动作和模块并不一定是本发明所必须的。It should be noted that for the foregoing method embodiments, for the sake of simple description, they are expressed as a series of action combinations, but those skilled in the art should know that the present invention is not limited by the described action sequence. Because of the present invention, certain steps may be performed in other orders or simultaneously. Secondly, those skilled in the art should also know that the embodiments described in the specification belong to preferred embodiments, and the actions and modules involved are not necessarily required by the present invention.
根据本发明实施例的另一个方面，还提供了一种用于实施上述消息处理方法的消息处理装置。如图9所示，该装置包括：According to another aspect of the embodiments of the present invention, a message processing device for implementing the above message processing method is also provided. As shown in Figure 9, the device includes:
第一接收单元902，用于接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；The first receiving unit 902 is configured to receive a first message sent by a first terminal configured with a first communication protocol, where the message format of the first message is a first message format recognizable by the first terminal;
第一确定单元904，用于将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；The first determining unit 904 is configured to input the first message to the target network structure of the target server, and determine the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert the message format, and the target network The structure includes at least two uplink substructures corresponding to different communication protocols;
第一获取单元906，用于获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式。The first obtaining unit 906 is configured to obtain the second message output by the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message The format is a message format recognized by the target server.
可选的，在本实施例中，上述消息处理装置可以但不限于应用在物联网场景下，具体的，可以但不限应用于后台服务器接收或发送配置有不同协议的终端设备。目前常见的支持多协议的接入系统，普遍采用一种协议对应一类服务节点的方式，也就是说服务端接入系统被切割成了几类独立的子系统，他们互相无法兼容，而利用上述消息处理方法，利用一种复合式的服务节点，对应多种协议的方式，而无需将服务端接入系统切割成了几类独立的子系统。Optionally, in this embodiment, the above-mentioned message processing apparatus can be applied in an Internet of Things scenario, but not limited to, specifically, it can be applied in a background server to receive or send terminal devices configured with different protocols. At present, common access systems that support multiple protocols generally adopt the method that one protocol corresponds to one type of service node, that is to say, the server access system is divided into several types of independent subsystems, which are incompatible with each other. The above message processing method utilizes a composite service node corresponding to multiple protocols without dividing the server access system into several types of independent subsystems.
可选的，在本实施例中，通信协议可以但不限于指双方实体完成通信或服务所必须遵循的规则和约定，通过通信信道和设备互连起来的多个不同地理位置的数据通信系统，要使其能协同工作实现信息交互和资源共享，它们之间必须具有共同的语言。例如，配置有第一通信协议的第一终端，无法直接与仅配置有第二通信协议的服务节点或服务器实现通信或服务。Optionally, in this embodiment, the communication protocol may, but is not limited to, refer to the rules and agreements that both entities must follow to complete communication or services, and multiple data communication systems in different geographical locations that are interconnected through communication channels and devices. To enable them to work together to achieve information exchange and resource sharing, they must have a common language. For example, a first terminal configured with the first communication protocol cannot directly communicate or serve with a service node or server configured only with the second communication protocol.
可选的，在本实施例中，消息格式可以但不限于指不同终端或服务器可识别的消息格式，例如字节消息格式、对象消息格式、业务消息格式等。消息格式的转换可以但不限于通过解码器或编码器实现，其中，解码器可以但不限于是一种能将数字数据流解码还原成模拟信号的硬件/软件设备。编码器可以但不限于将信号或数据进行编制、转换为可用以通信、传输和存储的信号形式的设备。Optionally, in this embodiment, the message format may, but is not limited to, refer to message formats recognizable by different terminals or servers, such as byte message format, object message format, service message format, and the like. The conversion of the message format can be realized by, but not limited to, a decoder or an encoder, wherein the decoder can be but not limited to a hardware/software device capable of decoding and restoring a digital data stream into an analog signal. An encoder is, but is not limited to, a device that encodes and converts signals or data into a signal form that can be used for communication, transmission, and storage.
可选的，在本实施例中，目标服务器中可以但不限于包括多个子服务器，每一个子服务器可以但不限于都包括目标网络结构。Optionally, in this embodiment, the target server may include, but is not limited to, multiple sub-servers, and each sub-server may include, but is not limited to, a target network structure.
需要说明的是，接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式。It should be noted that receiving the first message sent by the first terminal configured with the first communication protocol, wherein the message format of the first message is a first message format recognizable by the first terminal; inputting the first message to the target server A target network structure, determining an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert message formats, and the target network structure includes at least two uplink substructures corresponding to different communication protocols; Obtaining a second message output by an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message format is a message recognizable by the target server Format.
具体实施例可以参考上述消息处理方法中所示示例，本示例中在此不再赘述。For a specific embodiment, reference may be made to the example shown in the above message processing method, and details will not be repeated in this example.
通过本申请提供的实施例，接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式，利用网络结构转换消息格式的方式，通过将输入的消息的消息格式转换为服务器可识别，且与输入的消息协议对应的消息格式，从而达到了无需配置多个只能转换单一协议消息的服务节点，即可完成消息的处理的目的，进而实现了提高消息处理的统一性的效果。According to the embodiment provided by this application, the first message sent by the first terminal configured with the first communication protocol is received, wherein the message format of the first message is a first message format recognizable by the first terminal; input the first message To the target network structure of the target server, determine the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert the message format, and the target network structure includes at least two uplink substructures corresponding to different communication protocols Substructure; obtain the second message output by the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message format is that the target server can Recognized message format, using the network structure to convert the message format, by converting the message format of the input message into a message format that the server can recognize and corresponds to the input message protocol, so that it can only convert a single message without configuring multiple The service node of the protocol message can complete the purpose of message processing, thereby achieving the effect of improving the uniformity of message processing.
作为一种可选的方案，第一确定单元904，包括：As an optional solution, the first determining unit 904 includes:
第一确定模块，用于在将第一消息输入至目标网络结构中的第一上行子结构，且获取到第一上行子结构输出的第二消息的情况下，确定第一上行子结构与第一通信协议相对应；或，The first determination module is configured to determine the relationship between the first uplink substructure and the first uplink substructure when the first message is input to the first uplink substructure in the target network structure and the second message output by the first uplink substructure is obtained. corresponding to a communication protocol; or,
第二确定模块，用于在将第一消息输入至第一上行子结构，但并未获取到第一上行子结构输出的第二消息的情况下，将第一消息输入至目标网络结构的第二上行子结构；The second determination module is configured to input the first message to the first uplink substructure of the target network structure when the first message is input to the first uplink substructure, but the second message output by the first uplink substructure is not obtained. Two uplink substructures;
第三确定模块，用于在将第一消息输入至第二上行子结构，且获取到第二上行子结构输出的第二消息的情况下，确定第二上行子结构与第一通信协议相对应。The third determination module is configured to determine that the second uplink substructure corresponds to the first communication protocol when the first message is input to the second uplink substructure and the second message output by the second uplink substructure is obtained. .
具体实施例可以参考上述消息处理方法中所示示例，本示例中在此不再赘述。For a specific embodiment, reference may be made to the example shown in the above message processing method, and details will not be repeated in this example.
作为一种可选的方案，包括：As an option, include:
输入单元，用于在获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息之后，将第二消息输入至目标网络结构的目标处理子结构，其中，目标处理子结构与第一通信协议相对应，目标处理子结构用于将消息处理为目标服务器对应的业务消息，目标网络结构包括至少两个与不同通信协议外对应的处理子结构；The input unit is configured to input the second message to the target processing substructure of the target network structure after acquiring the second message output by the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target processing substructure is the same as Corresponding to the first communication protocol, the target processing substructure is used to process the message into a service message corresponding to the target server, and the target network structure includes at least two processing substructures corresponding to different communication protocols;
第二获取单元，用于在获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息之后，获取目标处理子结构输出的第一业务消息，其中，第一业务消息用于指示目标服务器生成第一业务指令，第一业务指令用于指示执行第一业务。The second acquiring unit is configured to acquire the first service message output by the target processing substructure after acquiring the second message output by the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the first service message is used for Instructing the target server to generate a first service instruction, where the first service instruction is used to instruct the execution of the first service.
具体实施例可以参考上述消息处理方法中所示示例，本示例中在此不再赘述。For a specific embodiment, reference may be made to the example shown in the above message processing method, and details will not be repeated in this example.
作为一种可选的方案，包括：As an option, include:
处理单元，用于在获取目标处理子结构输出的第一业务消息之后，将第一业务指令输入目标网络结构的第一下行子结构，其中，第一下行子结构用于将与第一通信协议对应的消息格式处理为第一消息格式，目标网络结构包括至少两个与不同通信协议外对应的下行子结构；The processing unit is configured to, after acquiring the first service message output by the target processing substructure, input the first service instruction into the first downlink substructure of the target network structure, wherein the first downlink substructure is used to communicate with the first The message format corresponding to the communication protocol is processed as the first message format, and the target network structure includes at least two downlink substructures corresponding to different communication protocols;
第三获取单元，用于在获取目标处理子结构输出的第一业务消息之后，获取第一下行子结构输出的第三消息，其中，第三消息的第一消息格式与第一通信协议相对应；The third acquiring unit is configured to acquire a third message output by the first downlink substructure after acquiring the first service message output by the target processing substructure, wherein the first message format of the third message is consistent with the first communication protocol correspond;
第一发送单元，用于在获取目标处理子结构输出的第一业务消息之后，发送第三消息至第一终端，其中，第一终端基于第三消息执行第一业务。The first sending unit is configured to send a third message to the first terminal after acquiring the first service message output by the target processing substructure, wherein the first terminal executes the first service based on the third message.
具体实施例可以参考上述消息处理方法中所示示例，本示例中在此不再赘述。For a specific embodiment, reference may be made to the example shown in the above message processing method, and details will not be repeated in this example.
作为一种可选的方案，还包括：As an option, also include:
生成单元，用于生成第二业务指令，其中，第二业务指令用于指示执行第二业务；a generating unit, configured to generate a second service instruction, where the second service instruction is used to instruct the execution of a second service;
第二确定单元，用于将第二业务指令输入至目标网络结构，确定目标网络结构中与第三通信协议对应的下行子结构；The second determination unit is configured to input the second service instruction into the target network structure, and determine the downlink substructure corresponding to the third communication protocol in the target network structure;
第四获取单元，用于获取目标网络结构中与第三通信协议对应的下行子结构输出的第四消息，其中，第四消息的第三消息格式与第三通信协议相对应，第三消息格式为第二终端可识别的消息格式，第二终端配置有第三通信协议；The fourth obtaining unit is configured to obtain a fourth message output by the downlink substructure corresponding to the third communication protocol in the target network structure, wherein the third message format of the fourth message corresponds to the third communication protocol, and the third message format It is a message format recognizable by the second terminal, and the second terminal is configured with a third communication protocol;
第二发送单元，用于发送第三消息至第二终端，其中，第二终端基于第三消息执行第二业务。The second sending unit is configured to send the third message to the second terminal, where the second terminal executes the second service based on the third message.
具体实施例可以参考上述消息处理方法中所示示例，本示例中在此不再赘述。For a specific embodiment, reference may be made to the example shown in the above message processing method, and details will not be repeated in this example.
作为一种可选的方案，第二确定单元，包括：As an optional solution, the second determination unit includes:
第四确定模块，用于在将第二业务指令输入至目标网络结构中的第二下行子结构，且获取到第二下行子结构输出的第三消息的情况下，确定第二下行子结构与第三通信协议相对应；或，The fourth determination module is configured to determine the relationship between the second downlink substructure and corresponding to the third communication protocol; or,
第五确定模块，用于在将第二业务指令输入至第二下行子结构，但并未获取到第二下行子结构输出的第三消息的情况下，将第一消息输入至目标网络结构的第三下行子结构；The fifth determination module is configured to input the first message to the target network structure when the second service instruction is input to the second downlink substructure, but the third message output by the second downlink substructure is not obtained. The third downlink substructure;
第六确定模块，用于在将第二业务指令输入至第三下行子结构，且获取到第三下行子结构输出的第三消息的情况下，确定第三下行子结构与第三通信协议相对应。The sixth determination module is configured to determine that the third downlink substructure is compatible with the third communication protocol when the second service instruction is input into the third downlink substructure and the third message output by the third downlink substructure is obtained. correspond.
具体实施例可以参考上述消息处理方法中所示示例，本示例中在此不再赘述。For a specific embodiment, reference may be made to the example shown in the above message processing method, and details will not be repeated in this example.
根据本发明实施例的又一个方面，还提供了一种用于实施上述消息处理方法的电子装置，如图10所示，该电子装置包括存储器1002和处理器1004，该存储器1002中存储有计算机程序，该处理器1004被设置为通过计算机程序执行上述任一项方法实施例中的步骤。According to yet another aspect of the embodiments of the present invention, there is also provided an electronic device for implementing the above message processing method. As shown in FIG. 10, the electronic device includes a
可选地，在本实施例中，上述电子装置可以位于计算机网络的多个网络设备中的至少一个网络设备。Optionally, in this embodiment, the foregoing electronic device may be located in at least one network device among multiple network devices of the computer network.
可选地，在本实施例中，上述处理器可以被设置为通过计算机程序执行以下步骤：Optionally, in this embodiment, the above-mentioned processor may be configured to execute the following steps through a computer program:
S1，接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；S1. Receive a first message sent by a first terminal configured with a first communication protocol, where the message format of the first message is a first message format recognizable by the first terminal;
S2，将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；S2. Input the first message to the target network structure of the target server, and determine the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert the message format, and the target network structure includes at least two and Uplink substructures corresponding to different communication protocols;
S3，获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式。S3. Obtain a second message output by an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message format is identifiable by the target server message format.
可选地，本领域普通技术人员可以理解，图10所示的结构仅为示意，电子装置也可以是智能手机(如Android手机、iOS手机等)、平板电脑、掌上电脑以及移动互联网设备(Mobile Internet Devices，MID)、PAD等终端设备。图10其并不对上述电子装置的结构造成限定。例如，电子装置还可包括比图10中所示更多或者更少的组件(如网络接口等)，或者具有与图10所示不同的配置。Optionally, those of ordinary skill in the art can understand that the structure shown in FIG. Internet Devices, MID), PAD and other terminal equipment. FIG. 10 does not limit the structure of the above-mentioned electronic device. For example, the electronic device may also include more or less components than those shown in FIG. 10 (such as a network interface, etc.), or have a different configuration from that shown in FIG. 10 .
其中，存储器1002可用于存储软件程序以及模块，如本发明实施例中的消息处理方法和装置对应的程序指令/模块，处理器1004通过运行存储在存储器1002内的软件程序以及模块，从而执行各种功能应用以及数据处理，即实现上述的消息处理方法。存储器1002可包括高速随机存储器，还可以包括非易失性存储器，如一个或者多个磁性存储装置、闪存、或者其他非易失性固态存储器。在一些实例中，存储器1002可进一步包括相对于处理器1004远程设置的存储器，这些远程存储器可以通过网络连接至终端。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。其中，存储器1002具体可以但不限于用于存储第一消息格式、第一消息、第二消息格式以及第二消息等信息。作为一种示例，如图10所示，上述存储器1002中可以但不限于包括上述消息处理装置中的第一接收单元902、第一确定单元904及第一获取单元906。此外，还可以包括但不限于上述消息处理装置中的其他模块单元，本示例中不再赘述。Wherein, the
可选地，上述的传输装置1006用于经由一个网络接收或者发送数据。上述的网络具体实例可包括有线网络及无线网络。在一个实例中，传输装置1006包括一个网络适配器(Network Interface Controller，NIC)，其可通过网线与其他网络设备与路由器相连从而可与互联网或局域网进行通讯。在一个实例中，传输装置1006为射频(Radio Frequency，RF)模块，其用于通过无线方式与互联网进行通讯。Optionally, the above-mentioned
此外，上述电子装置还包括：显示器1008，用于显示上述第一消息格式、第一消息、第二消息格式以及第二消息等信息；和连接总线1010，用于连接上述电子装置中的各个模块部件。In addition, the above-mentioned electronic device also includes: a
根据本发明的实施例的又一方面，还提供了一种计算机可读的存储介质，该计算机可读的存储介质中存储有计算机程序，其中，该计算机程序被设置为运行时执行上述任一项方法实施例中的步骤。According to yet another aspect of the embodiments of the present invention, there is also provided a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, wherein the computer program is configured to execute any one of the above-mentioned The steps in the method embodiment.
可选地，在本实施例中，上述计算机可读的存储介质可以被设置为存储用于执行以下步骤的计算机程序：Optionally, in this embodiment, the above-mentioned computer-readable storage medium may be configured to store a computer program for performing the following steps:
S1，接收配置有第一通信协议的第一终端发送的第一消息，其中，第一消息的消息格式为第一终端可识别的第一消息格式；S1. Receive a first message sent by a first terminal configured with a first communication protocol, where the message format of the first message is a first message format recognizable by the first terminal;
S2，将第一消息输入至目标服务器的目标网络结构，确定目标网络结构中与第一通信协议对应的上行子结构，其中，目标网络结构用于转换消息格式，目标网络结构包括至少两个与不同通信协议外对应的上行子结构；S2. Input the first message to the target network structure of the target server, and determine the uplink substructure corresponding to the first communication protocol in the target network structure, wherein the target network structure is used to convert the message format, and the target network structure includes at least two and Uplink substructures corresponding to different communication protocols;
S3，获取目标网络结构中与第一通信协议对应的上行子结构输出的第二消息，其中，第二消息的第二消息格式与第一通信协议相对应，第二消息格式为目标服务器可识别的消息格式。S3. Obtain a second message output by an uplink substructure corresponding to the first communication protocol in the target network structure, wherein the second message format of the second message corresponds to the first communication protocol, and the second message format is identifiable by the target server message format.
可选地，在本实施例中，本领域普通技术人员可以理解上述实施例的各种方法中的全部或部分步骤是可以通过程序来指令终端设备相关的硬件来完成，该程序可以存储于一计算机可读存储介质中，存储介质可以包括：闪存盘、只读存储器(Read-Only Memory，ROM)、随机存取器(Random Access Memory，RAM)、磁盘或光盘等。Optionally, in this embodiment, those skilled in the art can understand that all or part of the steps in the various methods of the above embodiments can be completed by instructing hardware related to the terminal device through a program, and the program can be stored in a In the computer-readable storage medium, the storage medium may include: a flash disk, a read-only memory (Read-Only Memory, ROM), a random access device (Random Access Memory, RAM), a magnetic disk or an optical disk, and the like.
上述本发明实施例序号仅仅为了描述，不代表实施例的优劣。The serial numbers of the above embodiments of the present invention are for description only, and do not represent the advantages and disadvantages of the embodiments.
上述实施例中的集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在上述计算机可读取的存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在存储介质中，包括若干指令用以使得一台或多台计算机设备(可为个人计算机、服务器或者网络设备等)执行本发明各个实施例方法的全部或部分步骤。If the integrated units in the above embodiments are realized in the form of software function units and sold or used as independent products, they can be stored in the above 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. Several instructions are included to enable one or more computer devices (which may be personal computers, servers or network devices, etc.) to execute all or part of the steps of the methods in various embodiments of the present invention.
在本发明的上述实施例中，对各个实施例的描述都各有侧重，某个实施例中没有详述的部分，可以参见其他实施例的相关描述。In the above-mentioned embodiments of the present invention, the descriptions of each embodiment have their own emphases, and for parts not described in detail in a certain embodiment, reference may be made to relevant descriptions of other embodiments.
在本申请所提供的几个实施例中，应该理解到，所揭露的客户端，可通过其它的方式实现。其中，以上所描述的装置实施例仅仅是示意性的，例如单元的划分，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式，例如多个单元或组件可以结合或者可以集成到另一个系统，或一些特征可以忽略，或不执行。另一点，所显示或讨论的相互之间的耦合或直接耦合或通信连接可以是通过一些接口，单元或模块的间接耦合或通信连接，可以是电性或其它的形式。In the several embodiments provided in this application, it should be understood that the disclosed client can be implemented in other ways. Wherein, the device embodiments described above are only illustrative, such as the division of units, which is only a logical function division, and there may be other division methods in actual implementation, for example, multiple units or components can be combined or integrated into Another system, or some features may be ignored, 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 units or modules may be in electrical or other forms.
作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部单元来实现本实施例方案的目的。A unit described as a separate component may or may not be physically separated, and a component displayed as a unit may or may not be a physical unit, that is, it 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.
以上所述仅是本发明的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也应视为本发明的保护范围。The above is only a preferred embodiment of the present invention, it should be pointed out that, for those of ordinary skill in the art, without departing from the principle of the present invention, some improvements and modifications can also be made, and these improvements and modifications can also be made. It should be regarded as the protection scope of the present invention.
Claims (8)
Translated fromChinesePriority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011296407.5ACN112422565B (en) | 2020-11-18 | 2020-11-18 | Message processing method, device, storage medium and electronic device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011296407.5ACN112422565B (en) | 2020-11-18 | 2020-11-18 | Message processing method, device, storage medium and electronic device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112422565A CN112422565A (en) | 2021-02-26 |
| CN112422565Btrue CN112422565B (en) | 2023-02-03 |
Family
ID=74773701
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011296407.5AActiveCN112422565B (en) | 2020-11-18 | 2020-11-18 | Message processing method, device, storage medium and electronic device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112422565B (en) |
Families Citing this family (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115208964B (en)* | 2021-04-09 | 2025-09-12 | 华为技术有限公司 | Collective communication method and communication device |
| CN114257623B (en)* | 2022-03-02 | 2024-06-04 | 中节能晶和科技有限公司 | Internet of things equipment communication method based on stream processing |
| CN115412329B (en)* | 2022-08-24 | 2024-09-17 | 深圳市凯迪仕智能科技有限公司 | Information processing method and related device for Internet of things |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105634925A (en)* | 2016-01-20 | 2016-06-01 | 北京乐动卓越科技有限公司 | Extensible communication method and system between users |
| CN111064716A (en)* | 2019-12-05 | 2020-04-24 | 深圳猛犸电动科技有限公司 | Message conversion method, device, storage medium and server |
Family Cites Families (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP5686186B2 (en)* | 2011-05-19 | 2015-03-18 | 富士通株式会社 | Gateway device, gateway device communication method, node device, node device communication method, and communication system |
| CN105072507B (en)* | 2015-07-24 | 2019-01-25 | 南京信通科技有限责任公司 | A kind of transmission method and system of multi-medium data |
| CN105915500A (en)* | 2015-12-22 | 2016-08-31 | 美的集团股份有限公司 | Method, protocol conversion service end and Internet of things terminal for conversion of different Internet of things protocols |
| CN106453342A (en)* | 2016-10-21 | 2017-02-22 | 过冬 | Terminal access method of Internet of Things |
| CN110515894B (en)* | 2019-08-02 | 2023-07-21 | 济南浪潮数据技术有限公司 | Data format conversion method, device, equipment and readable storage medium |
| CN111049854B (en)* | 2019-12-25 | 2021-12-14 | 微民保险代理有限公司 | Service request transmission method and device |
| CN111641583B (en)* | 2020-04-07 | 2021-09-03 | 北京邮电大学 | Internet of things resource access system and resource access method |
| CN111600909B (en)* | 2020-06-24 | 2023-06-23 | 腾讯科技（深圳）有限公司 | Data processing method, device, protocol conversion equipment and storage medium |
- 2020
- 2020-11-18CNCN202011296407.5Apatent/CN112422565B/enactiveActive
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105634925A (en)* | 2016-01-20 | 2016-06-01 | 北京乐动卓越科技有限公司 | Extensible communication method and system between users |
| CN111064716A (en)* | 2019-12-05 | 2020-04-24 | 深圳猛犸电动科技有限公司 | Message conversion method, device, storage medium and server |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112422565A (en) | 2021-02-26 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112422565B (en) | Message processing method, device, storage medium and electronic device | |
| CN103647853B (en) | One kind sends ARP file transmitting methods, VTEP and VxLAN controllers in VxLAN | |
| CN103650458B (en) | Media stream transmission method, device and system | |
| CN108449418A (en) | A hybrid cloud platform management system and method | |
| US10609125B2 (en) | Method and system for transmitting communication data | |
| CN110290127A (en) | A message conversion method and message conversion system | |
| CN104935499A (en) | Message format conversion method and equipment | |
| CN109889521A (en) | Memory, communication channel multiplexing implementation method, device and device | |
| CN112968919B (en) | Data processing method, device, equipment and storage medium | |
| CN108023736A (en) | Communication means, server device, client device, apparatus and system | |
| CN104683312A (en) | Method and device for media multiplexing negotiation | |
| CN116935864A (en) | A semantic communication method, device and system | |
| EP3032801A1 (en) | Method and device for generating forwarding information | |
| WO2020125129A1 (en) | Data processing method, bbu, rru and computer readable storage medium | |
| CN104506405B (en) | The method and device of cross-domain access | |
| CN108989157B (en) | Method and device for controlling intelligent equipment | |
| JP5940632B2 (en) | Network grouping system and network grouping method | |
| CN110049017B (en) | Message intercommunication device and method between heterogeneous platforms | |
| US12124709B2 (en) | Computing system and associated method | |
| CN116320316A (en) | Monitoring equipment control method, device and medium | |
| CN111614612B (en) | Communication protocol realization method, device, network management server and storage medium | |
| CN116257341A (en) | Application migration method, device, electronic equipment and storage medium | |
| WO2018068238A1 (en) | Cable media converter management method, apparatus and system | |
| US20190306073A1 (en) | Method and device for enhancing the throughput between smart meter and server | |
| CN111554291A (en) | Device control method, voice input terminal, voice platform and storage medium |
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 |