CN105763426B - A kind of internet of things service processing system based on multi-protocol instant messaging system - Google Patents

Abstract

The present invention provides an Internet of Things business processing system based on a multi-protocol instant communication system, in which a multi-protocol terminal device sends relevant request information when performing business processing with other devices in the Internet of Things; a protocol compiling module analyzes the multi-protocol terminal device in the protocol The relevant request message sent generates an IoT message with a uniform format; the security verification module verifies the legitimacy of the IoT message, returns the corresponding error message to the multi-protocol terminal device if it is illegal, and transmits the IoT message to the message management module if it is legal; The management module pushes the Internet of Things message to the corresponding multi-protocol terminal device according to the destination address of the Internet of Things message, so as to realize the communication between the multi-protocol terminal device and other multi-protocol terminal devices. Each compiler of the protocol compilation module listens to and parses relevant request information from multi-protocol terminal devices through different ports, and formats it into an IoT message with a unified format recognized by the security verification module and the message management module.

Description

An Internet of Things business processing system based on a multi-protocol instant messaging system

technical field

The invention relates to the technical field of the Internet of Things, in particular to an Internet of Things business processing system based on a multi-protocol instant communication system.

technical background

The Internet of Things is an important part of the new generation of information technology. It aims to use communication technologies such as local networks or the Internet to connect sensors, controllers, machines, people and things together in a new way to form a human-thing, thing-thing relationship. Connected to realize informatization, remote management control and intelligent network.

The Internet of Things is mainly composed of multi-protocol terminal devices and data processing systems. In order to adapt to different working scenarios, a wide variety of multi-protocol terminal devices must adopt different communication protocols to meet the requirements of data transmission rate, power consumption, real-time performance and security. However, in the traditional IoT data processing system, devices between different protocols cannot realize instant communication and data sharing, and the interconnection between people and things, and things and things has not been truly realized, which greatly reduces the practicability and feasibility of the IoT system. sex. In order for the IoT system to be practical, it is necessary to solve the problems of instant communication and data sharing between different protocols.

In order to solve this key problem, it is necessary to establish an instant communication system for devices between different protocols, and establish a data sharing and analysis platform based on this system, so as to truly realize the interconnection between people and things, and things and things, so that a large amount of data collected by the Internet of Things can be brought into play. greater value.

The current business processing method of the Internet of Things system mainly realizes the functions of equipment to transmit data and store data under a single protocol. The communication function between equipment is simple or even missing, and the security of data transmission is difficult to be guaranteed.

For example, Li Yin disclosed in his patent "A Web Service Method Based on the Internet of Things and the Internet of Things System" (CN104468830A) that includes at least one Internet of Things middleware, at least one Internet of Things application program, and multiple Internet of Things gateways. Web service method and internet of things system. IoT applications interact with IoT gateways and IoT hardware nodes through IoT middleware. All communication is implemented based on web service interface calls. This kind of system design using IoT middleware and IoT gateway is too complicated to deploy IoT based on the existing Internet infrastructure, which greatly reduces the cost and versatility of IoT deployment. The web service implemented by the system using the REST method only abstracts the hardware nodes and simplifies the way of data interaction, but does not solve the problem of communication between devices with different protocols and the problem of data sharing.

Another example is Chen Shengqun's patent "A Message Push System and Method for the Internet of Things" (CN104468819A) describing a message push system for the Internet of Things and its method. and data to identify and classify, and generate IoT messages; the message queue generation module is grouped according to IoT messages and user types, and sorted according to the priority of messages and users, to generate IoT message queues; the message processing module is based on the types of IoT messages and Its priority pushes corresponding IoT messages to users, and selectively processes feedback messages. This method only provides a one-way channel for messages to be pushed from the device to the user, and cannot transmit messages from the user to the device or from the device to the device. In the process of pushing the message from the device to the user, there is no data security detection module, which leads to a large security risk when the system is running, and it is difficult to apply it to the production environment.

In his patent "An Internet of Things Exchange System and Data Processing Method" (CN 103001862A), Liu Runzi discloses an Internet of Things exchange system including an exchange module, a transceiver module, a compilation module, an analysis module and a storage module. The system receives data, analyzes it, compiles it, and sends it. The system aims to provide a general system platform for sending and receiving messages for hardware devices with different underlying standards. However, with the development of industry standardization, the methods for IoT devices to send and receive messages in different application scenarios are nothing more than WebSocket, MQTT, CoAP and other categories. These methods have mature data encapsulation, message routing and other systems, and the IoT system no longer needs to directly compile data for hardware to unify messages. The exchange module in this system can only exchange the data that has been analyzed and compiled uniformly, and devices of different protocols cannot transmit messages to each other, and the communication function of device-to-device (M2M) has not really been realized.

Contents of the invention

In view of this, the present invention provides an Internet of Things business processing system based on a multi-protocol instant communication system, which achieves the purpose of point-to-point, point-to-multiple instant communication and data sharing of multi-protocol terminal devices in different protocols.

For realizing the above object, technical scheme of the present invention is:

An Internet of Things business processing system based on a multi-protocol instant messaging system, which includes: a message management module, a cache module, a storage module, a data processing module, a security verification module, a protocol compilation module, and a multi-protocol terminal device; wherein, the cache module, The device universal unique identification code UUID and the token of the multi-protocol terminal device are stored in the storage module;

The multi-protocol terminal device sends relevant request information when performing business processing with other multi-protocol terminal devices in the Internet of Things, and sends the relevant request information with the set protocol;

The protocol compiling module parses the relevant request message sent by the multi-protocol terminal device in the protocol, generates an Internet of Things message with a unified format, and transmits the Internet of Things message to the security verification module;

The security verification module verifies the legitimacy of the Internet of Things message. If it is not legal, it will return the corresponding error message to the multi-protocol terminal device. If it is legal, it will transmit the Internet of Things message to the message management module;

The message management module pushes the IoT message to the corresponding multi-protocol terminal device according to the destination address of the IoT message, so as to realize the communication between the multi-protocol terminal device and other multi-protocol terminal devices, or push the IoT message to the cache module temporarily storage, storage module solid storage, and data processing module for data processing.

The protocol compilation module includes: CoAP protocol compiler, MQTT protocol compiler, Socket.io protocol compiler, WebSocket protocol compiler, HTTPREST protocol compiler and protocol compiler; the protocol compiler is a reserved protocol extension interface ; Each compiler listens to and parses relevant request information from multi-protocol terminal devices through different ports, and formats it into an IoT message with a unified format recognized by the security verification module and the message management module.

The effect is better, the safety verification module includes a path verification module, a message verification module, a request parameter verification module and an operation verification module;

The path verification module verifies the legitimacy of the Internet of Things message request path. If it is not legal, it returns a corresponding error message to the multi-protocol terminal device; if it is legal, it judges whether the Internet of Things message needs to be verified. If it needs to be verified, Then send the Internet of Things message to the message verification module; otherwise, send the Internet of Things message to the request parameter verification module;

The message verification module obtains the corresponding token of the UUID from the cache module or storage module according to the UUID attached to the Internet of Things message; if the token in the Internet of Things message is consistent with the obtained token, the verification passes and enters the request parameter verification module; otherwise, return the corresponding error message to the multi-protocol terminal device;

Request parameter checking module, check whether the parameters in the Internet of Things message sent by the multi-protocol terminal device are legal, if legal, then enter the operation verification module (640), otherwise return corresponding error information to the multi-protocol terminal device;

Operate the verification module to verify whether the target device in the Internet of Things message allows the service request. If allowed, send the Internet of Things message to the message management module, otherwise return the corresponding error message to the multi-protocol terminal device.

The storage module stores data in the hard disk, including a device storage module and a data storage module;

The device storage module stores device attributes of registered multi-protocol terminal devices, and the device attributes include UUID and token;

The data storage module stores various types of data for business processing by each multi-protocol terminal device.

The effect is better, and the message management module includes a message routing module, a message channel module, a message publishing and subscription module, and a logging module; wherein, the message channel module is divided into a configuration message channel, a control message channel, and a data channel according to message types. message channel;

The message routing module analyzes the Internet of Things message sent by the multi-protocol terminal device, and sends it to the corresponding message channel module according to the message type and destination address; if the Internet of Things message belongs to the message of configuring device attributes, the Internet of Things message enters the configuration Message channel; if the IoT message belongs to the publish and subscribe message or return confirmation message, the IoT message enters the control message channel; if the IoT message belongs to the data message, the IoT message enters the data message channel;

The configuration message channel is connected to the device storage module, and the Internet of Things messages entering the configuration message channel are sent to the device storage module for processing;

The control message channel is respectively connected with the message subscription module and the protocol compilation module, sends the publish subscription message to the message subscription publishing module for processing, and sends the return confirmation message to the protocol compilation module;

The data message class channel is respectively connected with the protocol compiling module and the data storage module, if the destination address of the data message is equipment, then the data message is sent to the protocol compiling module (700), and is passed to the destination device after compiling the message format; if the data message If the destination address is the data storage module, it will be sent to the data storage module for storage;

The message publishing and subscribing module receives the publishing and subscribing messages sent by the control message channel. If the subscription target device allows the subscription request, the message publishing and subscribing module establishes a message channel between the subscribing devices, otherwise it sends a corresponding error to the requesting device. subscription device;

The log recording module monitors and records the running status of the message management module, and issues an early warning and generates a log when the message management module is overloaded or fails.

If the effect is good, the configuration message channel has the highest priority, the control message channel takes the second place, and the data message channel has the lowest priority.

The effect is better, the data of the cache module is stored in the memory;

When the message management module accesses the device information or the message verification module performs message verification, it first searches for the corresponding data in the cache module; if it finds it, it directly obtains it, and if it cannot find it, it enters the device storage module or data storage module of the storage module find;

And the data accessed more than 3 times in the storage module within the set time is imported into the cache module.

The effect is better, the data processing module includes a real-time data processing module and an offline data processing module;

The offline data processing module provides a platform for summarizing and processing the data stored in the storage module, which is used to analyze and mine various types of information collected in the historical time period, and store the analysis results in the storage module, or store the analysis results Push it directly to related devices through the message management module;

The real-time data processing module, which carries the messages that need to be processed in real time, is directly pushed to the real-time data processing module by the message management module. The real-time data processing module provides a platform that requires real-time data processing, and stores the processing results in the module, or passes the processing results through message management Modules are pushed directly to related devices.

Beneficial effect:

The present invention provides a unique identifier UUID for multi-protocol terminal equipment in different protocols. UUID is the Universally Unique Identifier (Universally Unique Identifier), which can ensure that the identifiers generated by each multi-protocol terminal device in different protocols will not be repeated. When a multi-protocol terminal device joins the system of the present invention for the first time, it first performs a registration operation to obtain a UUID, which is used as the unique identifier of the device in the system of the present invention. Multi-protocol terminal devices in different protocols identify and locate other multi-protocol terminal devices based on UUID, so as to realize the instant communication function of multi-protocol terminal devices between multiple protocols, and truly realize the interconnection between people and things, and things and things.

The present invention realizes the device instant communication function between multi-protocols through the compiling module and the message management module, and solves the most basic requirement of communication between people and devices and between devices and devices (M2M) in the Internet of Things. Other Internet of Things applications implement more complex Internet of Things applications on the basis of the multi-protocol instant communication function of the system of the present invention, reducing the development cost and technical difficulty of Internet of Things applications.

The invention decouples the compilation module from the safety verification module, message management module, data processing module, etc., and realizes the function of rapidly expanding protocol support without changing the overall structure of the system and multi-protocol terminal equipment. As long as the corresponding protocol compiling module is added to the proprietary protocol and the new protocol, the multi-protocol terminal equipment in the protocol can join the system of the present invention, and perform instant communication and data sharing with devices in other protocols.

The invention adopts the caching module to import frequently accessed and queried data from the hard disk into the memory, which greatly shortens the time for the message management module to search for device information and data information. The operation and response speed of the system are greatly improved, so that the system of the present invention can meet the requirements of practical applications.

The present invention adopts the cache module to establish a message waiting queue, and the speed of data calculation and hard disk storage is relatively slow compared with I/O operations. When the load of data calculation and hard disk storage is too heavy to process the received data in time, the message waiting queue of the cache module It improves the concurrency and stability of the system.

In the present invention, the data collected by multi-protocol terminal devices in different protocols are uniformly stored in the data storage module, and the data processing module can analyze and mine the data upon authorization. The present invention separates the bottom layer multi-protocol terminal device development from the upper layer data mining process, lowers the development threshold of the Internet of Things application, allows the data collected by the multi-protocol terminal device to play a greater value, thereby reducing the cost of the Internet of Things deployment, and has the advantages of It saves manpower and material resources, has a high degree of intelligence, and can be widely used in various fields.

Description of drawings

Fig. 1 is the overall structure diagram of the present invention.

Fig. 2 is a system structure diagram of a specific implementation example of the present invention.

Fig. 3 is a structural diagram of the safety verification module of the present invention.

Fig. 4 is a structural diagram of the message management module of the present invention.

Detailed ways

Specific embodiments of the present invention will be described in detail below in conjunction with the technical solutions and drawings, but the embodiments of the present invention are not limited thereto.

The present invention provides a business processing system for the Internet of Things based on a multi-protocol instant messaging system, as shown in Figure 1, characterized in that it includes a message management module (100), a cache module (200), a storage module (300), A processing module (400), a security verification module (600), a compiling module (700) and a multi-protocol terminal device (800).

When any multi-protocol terminal device joins the network, it requests registration from the server. After the registration is successful, the server allocates a unique device UUID and token for the multi-protocol terminal device; the server also stores the device UUID and token of the multi-protocol terminal device in the storage module (300);

The multi-protocol terminal device (800) sends relevant information when it needs to perform business processing with other multi-protocol terminal devices in the network, and sends it with the set protocol for communication between devices; the protocol compilation module (700) parses the multi-protocol terminal in the protocol The message sent by the device (800) generates an Internet of Things message (500) with a unified format, and transmits the Internet of Things message to a security verification module (600);

The security verification module (600) verifies the validity of the Internet of Things message (500), if it is not legal, the corresponding error message will be returned with the protocol of the multi-protocol terminal device (800), and if it is legal, the Internet of Things message will be transmitted to the message management module (100);

The message management module (100) pushes the Internet of Things message to other multi-protocol terminal devices according to the destination address of the Internet of Things message, so as to realize the communication between the multi-protocol terminal device (800) and other multi-protocol terminal devices, or simultaneously send the Internet of Things message to other multi-protocol terminal devices. The message is pushed to the cache module (200) for temporary storage, the storage module (300) for permanent storage, and the data processing module (400) for data processing.

Further, as shown in Figure 2, the protocol compilation module (700) of the present invention is connected to each multi-protocol terminal device and the security verification module, and the protocol compilation module (700) includes a CoAP protocol compiler (710), an MQTT protocol compiler (720), Socket.io protocol compiler (730), WebSocket protocol compiler (740), HTTPREST protocol compiler (750) and protocol compiler (760). The above-mentioned compiler makes this embodiment have the function of supporting mutual communication between multi-protocol terminal devices in MQTT, CoAP, WebSocket, Socket.io, WebSocket, HTTPREST and other protocols. The invention monitors requests from multi-protocol terminal equipment in different protocols through different ports. The compilers of the different protocols are respectively responsible for parsing the requests from the corresponding protocols, and formatting them into IoT messages (500) with a uniform format that can be processed by the security verification module (600) and the message management module (100). Wherein, the protocol compiler (760) of the present invention is a reserved protocol extension interface, the purpose of which is to develop a corresponding protocol compilation module for a newly developed protocol or a private protocol, and to format the request of the new protocol into an Internet of Things with a unified format. message(500). The decoupling design of different protocol compilation modules enables the present invention to expand the support for other protocols without changing the whole system and the device terminal, so that devices in other protocols can be quickly added to the system of the present invention. The flexibility of protocol support and the rapidity of expansion enable the present invention to add multi-protocol terminal devices using various networking protocols into the same instant communication system, thereby truly realizing the goal of Internet of Things.

As shown in Figure 3, the safety verification module (600) of the present invention is connected to each protocol compilation module and message management module, and the safety verification module (600) includes a path verification module (610), a message verification module (620), a request A parameter verification module (630) and an operation verification module (640). The request of the multi-protocol terminal device (800) in different protocols is formatted into an Internet of Things message (500) with a unified format through the compiling module (700), and then enters the path verification module (610) of the security verification module (600), and the path verification The module (610) first verifies the legitimacy of the Internet of Things message (500) request path, and returns corresponding error information to the multi-protocol terminal device if it is not legal; if it is legal, then judges whether the Internet of Things message (500) needs to be verified. The purpose of the Internet of Things message (500) is to access the data of other multi-protocol terminal devices or to communicate with other multi-protocol terminal devices, so device verification is required, and the Internet of Things message (500) enters the message verification module (620); otherwise, no Equipment verification is required, and the Internet of Things message (500) directly enters the request parameter verification module (630).

After the message verification module (620) obtains the corresponding token of the device UUID from the cache module (200) according to the attached device UUID and the token in the Internet of Things message (500), if there is no corresponding token for obtaining the device UUID in the cache module (200) token. If the token in the Internet of Things message (500) is consistent with the obtained token, the verification is passed, and the request parameter verification module (630) is entered; otherwise, corresponding error information is returned to the multi-protocol terminal device (800).

The request parameter verification module (630) verifies whether the parameters in the Internet of Things message (500) sent by the multi-protocol terminal device are legal, and the parameters include the legality of the request field, the legality of the request value, and the like. If the verification is passed, enter the operation verification module (640), otherwise return corresponding error information to the multi-protocol terminal device (800).

The operation verification module (640) verifies whether the target multi-protocol terminal device in the Internet of Things message (500) allows the service request. If it is allowed, the verification is passed, and the message management module (100) is entered to perform corresponding operations, otherwise corresponding error information is returned to the multi-protocol terminal device (800).

The message management module (100) is the core module of the present invention, and this module is connected with the safety verification module, cache module, storage module and data processing module, and the data interaction, data operation and control operation of all devices will be realized through this module messaging. The message management module (100) includes a message routing module (110), a message channel module (120), a message publishing and subscribing module (130), and a log recording module (140).

The data of the storage module (300) of the present invention is stored in the hard disk, connected to the message management module (100), the cache module (200) and the data processing module (400), mainly including the device storage module (310) and the data storage module (320) ).

The device storage module (310) stores various attributes of the registered multi-protocol terminal device (800), including device UUID, state, geographic location, token, configuration black and white list, access black and white list, parent device, etc. Wherein, the device UUID refers to a universally unique identifier (Universally Unique Identifier), which can ensure that the identifier generated by each multi-protocol terminal device (800) will not be repeated. When a multi-protocol terminal device (800) joins the system of the present invention for the first time, it first performs a registration operation to obtain a UUID, which is used as the unique identifier of the device in the system of the present invention. Multi-protocol terminal devices (800) in different protocols are based on UUID to identify and locate other multi-protocol terminal devices (800).

The data storage module (320) stores various types of data collected and pushed by various devices, including collection location, collection time, collection value, etc., and provides a material library for the data processing module (400).

The message routing module (110) parses the Internet of Things message (500) sent by the multi-protocol terminal device (800), and sends the message to the corresponding message channel module (120) according to its category and destination address. The message channel module (120) is divided into three categories according to message types: configuration message channel (121), control message channel (122), and data message channel (123).

If the Internet of Things message (500) belongs to the message of configuring device attributes, then the Internet of Things message (500) enters the configuration message channel (121); The networking message (500) enters the control message channel (122); if the IoT message (500) is a data message, the IoT message (500) enters the data message channel (123).

The configuration message channel (121) is connected with the device storage module (310), and transmits messages for configuring various attributes of the device, including device registration, device deletion, token update, parent device settings, black and white list list settings, etc., and the messages entering the channel It will be passed to the device storage module for processing.

The control message channel (122) is connected with the message subscription module (130) and the compilation module (700), and transmits device control messages, including messages such as message subscription and return confirmation. If the control message is a publish-subscribe message, send the message to the message subscription publishing module (130) for processing. If a confirmation message is sent back, the message is sent to the protocol compilation module (700) where the destination device is located, compiled into a message format that can be transmitted by the protocol, and then delivered to the destination device.

The data message channel (123) is connected with the protocol compilation module (700) and the data storage module (320) to transmit data messages, mainly including data collected by the equipment and data in the storage module. If the destination address of the data message is a device, send the message to the protocol compilation module where the destination device is located, compile it into a message format that can be transmitted by the protocol, and then pass it to the destination device. If the destination address of the data message is the data storage module (320), it is sent to the data storage module (320) to store and acquire data.

The configuration message channel (121) has the highest priority, followed by the control message channel (122), and the data message channel (123) is the lowest. Different types of channels have different information priorities, so as to ensure that messages with high real-time requirements can reach the destination device as soon as possible. Each type of channel in the present invention is a set of channels of the same type, and the elements in the set are message channels with different destination addresses, and one destination address corresponds to one message channel.

The message publishing and subscribing module (130) handles the subscription requests of multi-protocol terminal devices, which is equivalent to the "operator" in the message management module, and establishes and cancels channels for transmitting messages for various devices in different protocols, so that the communication between different protocols The device is able to communicate without hindrance. It is characterized in that, if the multi-protocol terminal device A wants to subscribe to a certain type of message of the multi-protocol terminal device B, it sends a corresponding request, and the message publishing and subscribing module checks whether the multi-protocol terminal device B allows the multi-protocol terminal device A to subscribe to its type of message. If allowed, the message publishing and subscribing module establishes a message channel from the multi-protocol terminal device B to the multi-protocol terminal device A. If not allowed, the corresponding error is sent to the requesting multi-protocol terminal device A.

The log recording module (140) monitors and records the operating status of the message management module, and when the message management module (100) generates overload, failure, etc., it issues an early warning and generates a log, so as to improve the operating stability of the system of the present invention.

The data of the cache module (200) in the present invention is stored in the internal memory, and the module is located between the message management module (100) and the storage module (300). It is characterized in that, when the message management module (200) accesses the device information or the data collected by the device, it first searches in the cache module (200). If found, the data is directly acquired, and if not found, the device storage module (310) and the data storage module (320) of the storage module (300) are searched to obtain corresponding data. The possibility that the device information is accessed again is very high, so the present invention directly stores the device information obtained by searching in the device storage module (310) into the cache module (200), and improves the efficiency of the message management module (100) to access the device information next time. speed.

However, the data in the storage module (320) is less likely to be accessed again, and only the data that is accessed more than 3 times in a short time t second is imported from the data storage module (320) into the cache module (200), wherein The size of the t value depends on the specific application where the data is located. The Internet of Things system is receiving, processing, and storing a large amount of data all the time, and the speed of data calculation and hard disk storage is slower than that of I/O operations. When the load of data calculation and hard disk storage is too heavy to process the received data in time, the cache module (200) Establishing a waiting queue for message processing, thereby improving the concurrent performance of the system. The cache module (200) greatly shortens the time for the message management module to search for device information and data information, greatly improves the operation and response speed of the system, and enables the system of the present invention to meet the requirements of practical applications.

The data processing module (400) is a platform for data analysis and data mining, connected with the message management module (100), cache module (200) and storage module (300), mainly including real-time data processing module and offline data processing module. Based on the platform, the authorization data can be analyzed and mined, so that the data collected by the present invention can exert greater value under the premise of ensuring safety, and increase the value of each multi-protocol terminal device in different protocols. The offline data processing module provides a platform for summarizing and processing the data stored in the data storage module. Using this module, various types of information collected in the past period of time can be analyzed and mined, and the analysis results can be stored in the data after corresponding conclusions are obtained. The storage module can also be directly pushed to related devices through the message management module. The real-time data processing module provides a platform for analyzing and processing data with high real-time requirements. Messages carrying data that require real-time processing are directly pushed to the real-time data processing module by the message management module. It can be stored in the data storage module, and can also be directly pushed to related devices, which can be used to prompt early warning and issue alarms, etc.

To sum up, the above are only preferred embodiments of the present invention, and are not intended to limit the protection scope of the present invention. Any modifications, equivalent replacements, improvements, etc. made within the spirit and principles of the present invention shall be included within the protection scope of the present invention.

Claims (7)

1. An Internet of Things business processing system based on a multi-protocol instant messaging system, characterized in that it comprises: a message management module (100), a cache module (200), a storage module (300), a data processing module (400), a security Verification module (600), protocol compilation module (700) and multi-protocol terminal device (800); wherein, the device general unique identification code of the multi-protocol terminal device (800) is stored in the cache module (200) and the storage module (300) UUID and token; The multi-protocol terminal device (800), when performing business processing with other multi-protocol terminal devices in the Internet of Things, sends relevant request information, and sends the relevant request information with a set protocol; The protocol compiling module (700) parses the relevant request message sent by the multi-protocol terminal device (800) in the protocol, generates an Internet of Things message (500) with a unified format, and transmits the Internet of Things message (500) to the security verification module (600); The safety verification module (600) verifies the legitimacy of the Internet of Things message (500), returns corresponding error information to the multi-protocol terminal device (800) if it is illegal, and transmits the Internet of Things message (500) to the message management module (100) if it is legal ; The message management module (100) pushes the Internet of Things message (500) to the corresponding multi-protocol terminal device according to the destination address of the Internet of Things message (500), so as to realize communication between the multi-protocol terminal device (800) and other multi-protocol terminal devices , or simultaneously push the IoT message (500) to the cache module (200) for temporary storage, the storage module (300) for solid storage, and the data processing module (400) for data processing; The safety verification module (600) includes a path verification module (610), a message verification module (620), a request parameter verification module (630) and an operation verification module (640); The path check module (610) verifies the legitimacy of the Internet of Things message (500) request path, and returns corresponding error information to the multi-protocol terminal device (800) if it is not legal; if legal, then judges whether the Internet of Things message (500) needs Carry out message verification, if need to carry out message verification, then send Internet of Things message (500) to message verification module (620); Otherwise, send Internet of Things message (500) to request parameter verification module (630); The message verification module (620), obtains the corresponding token of the UUID from the cache module (200) or the storage module (300) according to the attached UUID in the Internet of Things message (500); if the token in the Internet of Things message (500) and If the obtained token is consistent, the verification is passed, and the request parameter verification module (630) is entered; otherwise corresponding error information is returned to the multi-protocol terminal device (800); Request the parameter verification module (630), check whether the parameters in the Internet of Things message (500) sent by the multi-protocol terminal device (800) are legal, if legal, then enter the operation verification module (640), otherwise return the corresponding error message To multi-protocol terminal equipment (800); Operate the check module (640), verify whether the target device in the Internet of Things message (500) allows the service request, if allowed, then send the Internet of Things message (500) to the message management module (100), otherwise return the corresponding error message to multiple A protocol terminal device (800). 2. the Internet of Things business processing system based on multi-protocol instant messaging system as claimed in claim 1, is characterized in that, described protocol compiling module (700) comprises: CoAP protocol compiler (710), MQTT protocol compiler (720 ), Socket.io protocol compiler (730), WebSocket protocol compiler (740), HTTPREST protocol compiler (750) and protocol compiler (760); the protocol compiler (760) is a reserved protocol extension interface ; Each compiler listens to and parses relevant request information from multi-protocol terminal devices through different ports, and formats it into an Internet of Things message with a unified format recognized by the security verification module (600) and the message management module (100) (500). 3. the Internet of Things business processing system based on multi-protocol instant messaging system as claimed in claim 1, is characterized in that, described storage module (300) stores data in hard disk, comprises equipment storage module (310) and data storage module (320); The device storage module (310) stores the device attributes of the registered multi-protocol terminal device (800), and the device attributes include UUID and token; The data storage module (320) stores various types of data for business processing by each multi-protocol terminal device (800). 4. the Internet of Things business processing system based on multi-protocol instant messaging system as claimed in claim 3, is characterized in that, described message management module (100) comprises message routing module (110), message channel module (120), message Publish and subscribe module (130), log recording module (140); wherein, the message channel module (120), according to the message type, is divided into configuration message class channel (121), control message class channel (122), data message class channel (123 ); The message routing module (110) parses the Internet of Things message (500) sent by the multi-protocol terminal device (800), and sends it to the corresponding message channel module (120) according to message type and destination address; if the Internet of Things message ( 500) belongs to the message of configuring device attributes, then the Internet of Things message (500) enters the configuration message channel (121); Enter the control message class channel (122); if the Internet of Things message (500) belongs to the data message, then the Internet of Things message (500) enters the data message class channel (123); The configuration message channel (121) is connected with the device storage module (310), and the Internet of Things message (500) entering the configuration message channel (121) is passed to the device storage module (310) for processing; The control message channel (122) is respectively connected with the message subscription module (130) and the protocol compilation module (700), sends the publish and subscribe message to the message subscription release module (130) for processing, and sends the return confirmation message to the protocol compile module; The data message channel (123) is connected with the protocol compilation module (700) and the data storage module (320) respectively, if the destination address of the data message is equipment, then the data message is sent to the protocol compilation module (700), and the message format is compiled Pass to destination equipment after; If the destination address of data message is data storage module (320), then it is sent to data storage module (320) storage; The message publishing and subscribing module (130) receives the publishing and subscribing message sent by the control message channel (122), and if the subscription target device allows the subscription request, the message publishing and subscribing module (130) establishes a subscription between the devices of both parties Message channel, otherwise send the corresponding error to the requesting subscription device; The log recording module (140) monitors and records the running state of the message management module (100), and issues an early warning and generates a log when the message management module (100) is overloaded or fails. 5. the Internet of Things business processing system based on multi-protocol instant messaging system as claimed in claim 4, is characterized in that, The configuration message channel (121) has the highest priority, followed by the control message channel (122), and the data message channel (123) is the lowest. 6. the Internet of Things business processing system based on multi-protocol instant messaging system as claimed in claim 1, is characterized in that, The data of the cache module (200) is stored in memory; When the message management module (100) accesses the device information or the message verification module (620) performs message verification, it first searches the corresponding data in the cache module (200); (300) in the device storage module (310) or the data storage module (320); And the data accessed more than 3 times in the storage module (300) within the set time is imported into the cache module (200). 7. the Internet of Things business processing system based on multi-protocol instant messaging system as claimed in claim 1, is characterized in that, described data processing module (400) comprises real-time data processing module and off-line data processing module; The off-line data processing module provides a platform for summarizing and processing the data stored in the storage module (300), for analyzing and mining various types of information collected in historical time periods, and storing the analysis results in the storage module (300) ), or directly push the analysis results to relevant devices through the message management module (100); The real-time data processing module carries the message that needs to be processed in real time and is directly pushed to the real-time data processing module by the message management module (100). The real-time data processing module provides a platform that requires real-time data processing, and stores the processing results in the module (300), or The processing results are directly pushed to relevant devices through the message management module (100).