CN112073473B - Internet of things equipment heartbeat packet data acquisition method - Google Patents

Abstract

The invention discloses a method for collecting heartbeat packet data of an Internet of Things device, and provides an Internet of Things communication system. The Internet of Things communication system includes a plurality of terminal devices and a monitoring platform server, and the monitoring platform server communicates with a plurality of the terminal devices. connected, the plurality of terminal devices are used for real-time collection of on-site physical parameters, the monitoring platform server is used for receiving heartbeat data sent by the terminal devices, the heartbeat packet data collection method includes a pre-processing step and a data collection step, the pre-stage The processing steps include: a representative device selection sub-step, selecting a number of representative devices from the terminal devices, each of the representative devices is used to receive the heartbeat data of several terminal devices corresponding to it, and send all the heartbeat data in the form of a heartbeat packet The form is sent to the monitoring platform server. The heartbeat packet data collection method of the present invention can increase the effective load of the heartbeat packet and reduce the network bandwidth.

Description

A method for collecting heartbeat packet data of Internet of things equipment

technical field

The invention relates to the technical field of communication, in particular to a method for collecting heartbeat packet data of an Internet of Things device.

Background technique

With the help of industrial Internet of Things technology or platform, enterprises can connect and monitor elements such as people, machines, materials, methods, environment, and testing in the workshop in real time. To interconnect many elements, the performance of system platforms, networks and other components, Throughput and response time have relatively high requirements. Taking the traditional plastic woven manufacturing industry as an example, its production line equipment mainly includes wire drawing machines, circular looms, printing machines, discount machines, edge sewing machines, weighbridges, etc., and each device has an average of about 5-8 pulse counts Sensors, 1-2 PLCs, a medium-sized manufacturer with about 220 machines, in order to collect all production data of the equipment, need to be equipped with about 1,500 IoT terminal devices, and the IoT terminal devices are connected to the underlying pulse counting Sensor, PLC, weighbridge serial interface. These IoT terminal devices send the collected data to the monitoring platform server through the network, so that managers can view it in real time, or provide basic data for further in-depth mining. The terminal device itself will send some necessary information to the platform in the form of heartbeat packets, and processing the heartbeat packets of 150,000 terminal devices at the same time requires 1.5Gb bandwidth, so the requirements for network bandwidth, number of servers, server cluster scheduling, etc. are quite high.

Contents of the invention

The purpose of the present invention is to provide a method for collecting heartbeat packet data of an Internet of Things device, which can increase the payload of a single heartbeat packet and reduce network bandwidth.

In order to achieve the above object, the present invention provides the following technical solutions: a method for collecting heartbeat packet data of an Internet of Things device, providing an Internet of Things communication system, the Internet of Things communication system includes several terminal devices and a monitoring platform server, and the monitoring platform The server communicates with a plurality of terminal devices, the plurality of terminal devices are used for real-time collection of on-site physical parameters, the monitoring platform server is used for receiving heartbeat data sent by the terminal devices, and the heartbeat packet data collection method includes a pre-processing step And data collection step, described preprocessing step comprises:

The representative device selection sub-step is to select several representative devices from the terminal devices, and each representative device is used to receive the heartbeat data of several terminal devices corresponding to it, and send all the heartbeat data to the monitor in the form of heartbeat packets. platform server;

The sub-step of obtaining reference heartbeat data is to select a heartbeat data as the reference heartbeat data from the historical heartbeat data sent by the representative device to the monitoring platform server, and write the reference heartbeat data into the representative device and the monitoring platform server in advance. platform server;

The sub-step of establishing a heartbeat table is to obtain all the heartbeat data of all terminal devices, compare the heartbeat data with the reference heartbeat data respectively to generate the difference code of each heartbeat data, establish a heartbeat table according to the difference code and its corresponding heartbeat data, and set The heartbeat table is pre-written into the representative device and the monitoring platform server;

The data collection steps include:

The heartbeat code query sub-step, the representative device receives the heartbeat data from the terminal device, and queries the heartbeat table according to the heartbeat data to obtain the corresponding difference code of the heartbeat data,

The heartbeat packet generation sub-step is to form a feature code list with the difference codes corresponding to some heartbeat data received by the representative device, and write the feature code list into the heartbeat packet of the representative device;

The heartbeat packet sending substep; several said representative devices send the heartbeat packet to the monitoring platform server according to the first heartbeat time;

Parsing sub-step: the monitoring platform server decodes the received heartbeat packet, and the decoding operation includes decoding the heartbeat packet according to the reference heartbeat data and generating a heartbeat data sub-packet.

Preferably, the step of obtaining the reference heartbeat data includes obtaining all the heartbeat data sent by the representative device to the monitoring platform server within any selected time period, and selecting the heartbeat data with the highest occurrence frequency as the reference heartbeat data; obtaining the It represents all the heartbeat data sent by the device to the monitoring platform server within any selected time period, and the heartbeat data with the smallest difference with other heartbeat data is selected as the reference heartbeat data.

Preferably, the step of obtaining the reference heartbeat data includes obtaining all the heartbeat data sent by the representative device to the monitoring platform server within any selected time period, and selecting the heartbeat data with the smallest difference from other heartbeat data as the reference heartbeat data .

Preferably, the pre-processing step further includes a heartbeat coordination sub-step for synchronizing the time of the terminal device with the time of the representative device.

Preferably, the heartbeat data information of the terminal device includes a time stamp, a device ID number and status information representing the operation of the device.

Preferably, the representative device selection sub-step is configured with a selection strategy, the selection strategy includes classifying the terminal devices according to device types, obtaining the historical transmission rates of all terminal devices under the same category, and selecting the terminal device with the highest transmission rate Elected as a representative device.

Preferably, the sub-step of selecting a representative device is configured with a selection strategy, and the selection strategy includes selecting a terminal device with the highest hardware processing capability as a representative device.

Preferably, the representative device selection sub-step is configured with a selection strategy, the selection strategy includes classifying the terminal devices according to device types, obtaining historical transmission rates and location information of all terminal devices under the same category, and the location The information includes the sum of the location distances from other terminal devices. The historical transmission rate and location information of the terminal devices are weighted according to a certain weight ratio to generate a priority queue. According to the number of terminal devices under the category, the highest priority One or more terminal devices are elected as representative devices.

Preferably, one representative device is connected to 20 terminal devices at most.

Preferably, the length of the difference code is 1/3-3/5 of the heartbeat data length of the terminal device.

Compared with prior art, the beneficial effect of the present invention is:

The present invention selects a representative device from terminal devices by setting the representative device selection sub-step, and the representative device sends the heartbeat data of the terminal device to the monitoring platform server for management, which increases the payload of a single heartbeat packet; in addition, by establishing a heartbeat table, and compare the heartbeat data with the reference heartbeat data to generate the difference codes of each heartbeat data, and form the feature code list by the difference codes of the heartbeat data of the terminal equipment, and write the feature code list into the heartbeat packet of the representative device, reducing the Network bandwidth for overall heartbeat data transmission.

Description of drawings

Fig. 1 is the circuit connection block diagram of a kind of Internet of Things equipment heartbeat packet data collection method of the present invention;

Fig. 2 is a block flow diagram of the pre-processing steps in a method for collecting heartbeat packet data of an Internet of Things device according to the present invention;

Fig. 3 is a block flow diagram of data collection steps in a method for collecting heartbeat packet data of an Internet of Things device according to the present invention.

In the figure: 1. Monitoring platform server; 2. Terminal device 1; 3. Representative device 1; 4. Terminal device 2; 5. Representative device 2.

Detailed ways

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some, not all, embodiments of the present invention. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.

As shown in Figure 1, an embodiment provided by the present invention, a method for collecting heartbeat packet data of an Internet of Things device, provides an Internet of Things communication system, the Internet of Things communication system includes a plurality of terminal devices and a monitoring platform server 1, A representative device is selected from several terminal devices, and the representative device sends all terminal devices and the heartbeat packets of the representative device to the monitoring platform server 1; terminal device 1 is a terminal device belonging to the same category, and the operating status of the same category of equipment The information is the same, and the difference in the device ID number can determine which terminal device it is, so the length of the difference code of the terminal device under the same category can be reduced, thereby reducing the heartbeat data transmission network bandwidth caused by redundant data Insufficient problem, the monitoring platform server 1 is communicatively connected with some of the terminal devices, and the several terminal devices are used to collect the physical parameters or electrical parameters of the scene in real time, and the monitoring platform server 1 is used to receive the information sent by the terminal devices. The heartbeat data, the heartbeat packet data collection method includes a pre-processing step and a data collection step.

As shown in Figure 2, it is a flow chart of the pre-processing steps in a method for collecting heartbeat packet data of an Internet of Things device according to the present invention. The pre-processing steps include: representative device selection sub-step S101, selecting several terminal devices A representative device, each of which is used to receive the heartbeat data of several terminal devices corresponding to it, and send all the heartbeat data to the monitoring platform server 1 in the form of heartbeat packets;

The reference heartbeat data acquisition sub-step S102 is to select a heartbeat data from the historical heartbeat data sent by the representative device to the monitoring platform server 1 as the reference heartbeat data, and write the reference heartbeat data into the representative device and the monitoring platform server 1 in advance. The monitoring platform server 1;

The heartbeat table establishment sub-step S103 is to obtain all the heartbeat data of all terminal devices, compare the heartbeat data with the reference heartbeat data respectively to generate a difference code of each heartbeat data, and establish a heartbeat table according to the difference code and its corresponding heartbeat data, The heartbeat table is written into the representative device and the monitoring platform server 1 in advance.

As shown in FIG. 3 , it is a flow chart of the data collection step in a method for collecting heartbeat packet data of an Internet of Things device according to the present invention. The data collection step includes: heartbeat code query substep S201, and the representative device receives the The heartbeat data of the device, and query the heartbeat table according to the heartbeat data to obtain the corresponding difference code of the heartbeat data,

Heartbeat packet generation sub-step S202, forming a feature code list from the difference codes corresponding to the heartbeat data received by the representative device, and writing the feature code list into the heartbeat packet of the representative device;

Heartbeat packet sending sub-step S203; several said representative devices send heartbeat packets to the monitoring platform server 1 according to the first heartbeat time;

Parsing sub-step S204: the monitoring platform server 1 performs a decoding operation on the received heartbeat packet, and the decoding operation includes decoding the heartbeat packet according to the reference heartbeat data and generating a heartbeat data sub-packet.

Preferably, the step of obtaining the reference heartbeat data includes obtaining all the heartbeat data sent by the representative device to the monitoring platform server 1 within any selected time period, and selecting the heartbeat data with the highest frequency of occurrence as the reference heartbeat data; All the heartbeat data sent by the representative device to the monitoring platform server 1 within any selected time period, and the heartbeat data with the smallest difference with other heartbeat data are selected as the reference heartbeat data.

Preferably, the step of obtaining the reference heartbeat data includes obtaining all the heartbeat data sent by the representative device to the monitoring platform server 1 within any selected time period, and selecting the heartbeat data with the smallest difference from other heartbeat data as the reference heartbeat data.

Preferably, the pre-processing step further includes a heartbeat coordination sub-step for synchronizing the time of the terminal device with the time of the representative device. Reduce the problem of information out of synchronization caused by hardware aging.

Preferably, the heartbeat data information of the terminal device includes a time stamp, a device ID number and status information representing the operation of the device. The time stamp includes the sending time information of the heartbeat data, so that the heartbeat sending time of different terminal devices can be calibrated.

Preferably, the representative device selection sub-step is configured with a selection strategy, the selection strategy includes classifying the terminal devices according to device types, obtaining the historical transmission rates of all terminal devices under the same category, and selecting the terminal device with the highest transmission rate Elected as a representative device.

Since the representative device sends the heartbeat data of the terminal device to the monitoring platform server 1 for management, selecting the terminal device with the highest transmission efficiency as the representative device can improve the communication efficiency of the entire IoT system.

Preferably, the sub-step of selecting a representative device is configured with a selection strategy, and the selection strategy includes selecting a terminal device with the highest hardware processing capability as a representative device.

High hardware processing capability can increase the load capacity of a single terminal device, and can increase the payload of a single heartbeat packet.

Preferably, the representative device selection sub-step is configured with a selection strategy, the selection strategy includes classifying the terminal devices according to device types, obtaining historical transmission rates and location information of all terminal devices under the same category, and the location The information includes the sum of the location distances from other terminal devices. The historical transmission rate and location information of the terminal devices are weighted according to a certain weight ratio to generate a priority queue. According to the number of terminal devices under the category, the highest priority One or more terminal devices are elected as representative devices.

Preferably, a representative device is connected to 20 terminal devices at most, and the specific conditions are determined according to the load capacity of the representative device, but the terminal devices connected to a representative device cannot be too many. After more than 20 devices, although it is possible to Normal network data communication, but it will seriously reduce the communication quality and communication efficiency of the IoT system.

Preferably, the byte length of the difference encoding is 1/3-3/5 of the byte length of the heartbeat data of the terminal equipment, and by setting the heartbeat table, the heartbeat data is compared with the reference heartbeat data to generate the difference of each heartbeat data Coding reduces the redundant part of the heartbeat data of different devices under the same category and reduces the amount of data processing.

Working principle: the present invention selects a representative device from the terminal device by setting the representative device selection sub-step, and the representative device sends the heartbeat data of the terminal device to the monitoring platform server 1 for management, increasing the payload of a single heartbeat packet, It reduces the redundant part of the heartbeat data of different devices under the same category, and reduces the amount of data processing; in addition, by establishing a heartbeat table and comparing the heartbeat data with the reference heartbeat data to generate a difference code for each heartbeat data, the terminal equipment The differential encoding of the heartbeat data forms a feature encoding list, and writing the feature encoding list into the heartbeat packet representing the device reduces the network bandwidth of the overall heartbeat data transmission.

It will be apparent to those skilled in the art that the invention is not limited to the details of the above-described exemplary embodiments, but that the invention can be embodied in other specific forms without departing from the spirit or essential characteristics of the invention. Accordingly, the embodiments should be regarded in all points of view as exemplary and not restrictive, the scope of the invention being defined by the appended claims rather than the foregoing description, and it is therefore intended that the scope of the invention be defined by the appended claims rather than by the foregoing description. All changes within the meaning and range of equivalents of the elements are embraced in the present invention. Any reference sign in a claim should not be construed as limiting the claim concerned.

Claims (8)

1. A method for collecting heartbeat packet data of an Internet of Things device, providing a communication system for the Internet of Things, the communication system for the Internet of Things includes several terminal devices and a monitoring platform server, and the monitoring platform server communicates with some of the terminal devices, The plurality of terminal devices are used for real-time collection of on-site physical parameters, and the monitoring platform server is used for receiving heartbeat data sent by the terminal devices, wherein the heartbeat packet data collection method includes a pre-processing step and a data collection step. The pre-processing steps mentioned above include: The representative device selection sub-step is to select several representative devices from the terminal devices, and each representative device is used to receive the heartbeat data of several terminal devices corresponding to it, and send all the heartbeat data to the monitor in the form of heartbeat packets. platform server; The sub-step of obtaining reference heartbeat data is to select a heartbeat data as the reference heartbeat data from the historical heartbeat data sent by the representative device to the monitoring platform server, and write the reference heartbeat data into the representative device and the monitoring platform server in advance. platform server; The step of obtaining the reference heartbeat data includes obtaining all heartbeat data sent by the representative device to the monitoring platform server within any selected time period, and selecting the heartbeat data with the highest frequency of occurrence as the reference heartbeat data; obtaining the representative device at any time. All heartbeat data sent to the monitoring platform server within a selected time period, from which the heartbeat data with the smallest difference with other heartbeat data is selected as the benchmark heartbeat data; The sub-step of establishing a heartbeat table is to obtain all the heartbeat data of all terminal devices, compare the heartbeat data with the reference heartbeat data respectively to generate the difference code of each heartbeat data, establish a heartbeat table according to the difference code and its corresponding heartbeat data, and set The heartbeat table is pre-written into the representative device and the monitoring platform server; The data collection steps include: The heartbeat code query sub-step, the representative device receives the heartbeat data from the terminal device, and queries the heartbeat table according to the heartbeat data to obtain the corresponding difference code of the heartbeat data, The heartbeat packet generation sub-step is to form a feature code list with the difference codes corresponding to some heartbeat data received by the representative device, and write the feature code list into the heartbeat packet of the representative device; The heartbeat packet sending substep; several said representative devices send the heartbeat packet to the monitoring platform server according to the first heartbeat time; Parsing sub-step: the monitoring platform server decodes the received heartbeat packet, and the decoding operation includes decoding the heartbeat packet according to the reference heartbeat data and generating a heartbeat data sub-packet. 2. A method for collecting heartbeat packet data of an Internet of Things device according to claim 1, characterized in that: the pre-processing step also includes a heartbeat coordination sub-step for comparing the time of the terminal device with the representative device The time is synchronized. 3. A method for collecting heartbeat packet data of an Internet of Things device according to claim 1, wherein the heartbeat data information of the terminal device includes a time stamp, a device ID number and status information representing the operation of the device. 4. according to a kind of Internet of things equipment heartbeat packet data collection method described in any one of claims 1-3, it is characterized in that: the sub-step of selecting representative equipment is configured with a selection strategy, and the selection strategy includes The terminal devices are classified according to device types, the historical transmission rates of all terminal devices in the same category are obtained, and the terminal device with the highest transmission rate is selected as the representative device. 5. A method for collecting heartbeat packet data of an Internet of Things device according to any one of claims 1-3, characterized in that: the representative device selection sub-step is configured with a selection strategy, and the selection strategy includes hardware The terminal device with the highest processing capability is selected as the representative device. 6. A method for collecting heartbeat packet data of an Internet of Things device according to any one of claims 1-3, characterized in that: the representative device selection sub-step is configured with a selection strategy, and the selection strategy includes The terminal equipment is classified according to the equipment type, and the historical transmission rate and location information of all terminal equipment under the same category are obtained. The location information includes the sum of the location distances from other terminal equipment, and the historical transmission rate and location information of the terminal equipment are combined. The location information is weighted according to a certain weight ratio to generate a priority queue, and one or more terminal devices with the highest priority are selected as representative devices according to the number of terminal devices under the category. 7. A method for collecting heartbeat packet data of an Internet of Things device according to claim 6, characterized in that: one representative device is connected to 20 terminal devices at most. 8. A method for collecting heartbeat packet data of an Internet of Things device according to claim 1, wherein the length of the difference code is 1/3-3/5 of the length of the heartbeat data of the terminal device.

Images