Movatterモバイル変換


[0]ホーム

URL:


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

Internet of things equipment heartbeat packet data acquisition method
Download PDF

Info

Publication number
CN112073473A
CN112073473ACN202010829579.8ACN202010829579ACN112073473ACN 112073473 ACN112073473 ACN 112073473ACN 202010829579 ACN202010829579 ACN 202010829579ACN 112073473 ACN112073473 ACN 112073473A
Authority
CN
China
Prior art keywords
heartbeat
equipment
data
representative
heartbeat data
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Granted
Application number
CN202010829579.8A
Other languages
Chinese (zh)
Other versions
CN112073473B (en
Inventor
吴宗鸿
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Chongqing Gengle Technology Development Co.,Ltd.
Original Assignee
Zhejiang Hongcheng Technology Co ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by Zhejiang Hongcheng Technology Co ltdfiledCriticalZhejiang Hongcheng Technology Co ltd
Priority to CN202010829579.8ApriorityCriticalpatent/CN112073473B/en
Publication of CN112073473ApublicationCriticalpatent/CN112073473A/en
Application grantedgrantedCritical
Publication of CN112073473BpublicationCriticalpatent/CN112073473B/en
Activelegal-statusCriticalCurrent
Anticipated expirationlegal-statusCritical

Links

Images

Classifications

Landscapes

Abstract

The invention discloses an internet of things equipment heartbeat packet data acquisition method, and provides an internet of things communication system, wherein the internet of things communication system comprises a plurality of terminal equipment and a monitoring platform server, the monitoring platform server is in communication connection with the terminal equipment, the terminal equipment is used for acquiring field physical parameters in real time, the monitoring platform server is used for receiving heartbeat data sent by the terminal equipment, the heartbeat packet data acquisition method comprises a pre-processing step and a data acquisition step, and the pre-processing step comprises: and a representative device selecting substep, selecting a plurality of representative devices from the terminal devices, wherein each representative device is used for receiving heartbeat data of a plurality of terminal devices corresponding to the representative device and sending all the heartbeat data to the monitoring platform server in the form of heartbeat packets. The heartbeat packet data acquisition method can increase the effective load of the heartbeat packet and reduce the network bandwidth.

Description

Internet of things equipment heartbeat packet data acquisition method
Technical Field
The invention relates to the technical field of communication, in particular to a heartbeat packet data acquisition method for equipment of the Internet of things.
Background
With the help of industrial internet of things technology or platforms, enterprises can connect and monitor elements such as people, machines, materials, methods, rings, tests and the like of workshops in real time, and a plurality of elements are interconnected, so that high requirements are imposed on the performance, throughput and response time of components such as system platforms and networks. Taking a traditional plastic weaving manufacturing industry as an example, production line equipment of the plastic weaving manufacturing industry mainly comprises a wire drawing machine, a circular weaving machine, a printing machine, a buckle folding machine, a hemming machine, a wagon balance and the like, wherein each piece of equipment is provided with about 5-8 pulse counting sensors on average, 1-2 PLCs (programmable logic controllers), about one-family-type-middle-class-type-left and about-family-type-right producers, the equipment is approximately 220 machines, in order to collect all production data of the equipment, about 1500 Internet of things terminal equipment are required to be equipped, and the Internet of things terminal equipment is connected with a pulse counting sensor, the PLCs and a wagon balance serial. The terminal equipment of the internet of things sends the acquired data to the monitoring platform server through the network so as to be convenient for a manager to check in real time or provide basic data for further deep mining. The terminal devices send some necessary information to the platform in the form of heartbeat packets, and meanwhile, 1.5Gb bandwidth is needed to process the heartbeat packets of 150000 terminal devices, which has quite high requirements on network bandwidth, number of servers, server cluster scheduling and the like.
Disclosure of Invention
The invention aims to provide a heartbeat packet data acquisition method of Internet of things equipment, which can increase the effective load of a single heartbeat packet and reduce the network bandwidth.
In order to achieve the purpose, the invention provides the following technical scheme: the utility model provides a thing networking equipment heartbeat package data acquisition method, provides a thing networking communication system, thing networking communication system includes a plurality of terminal equipment and monitor platform server, monitor platform server and a plurality of the terminal equipment communication is connected, a plurality of terminal equipment are used for gathering on-the-spot physical parameter in real time, monitor platform server is used for receiving the heartbeat data that terminal equipment sent, and heartbeat package data acquisition method includes preprocessing step and data acquisition step, preprocessing step includes:
a representative device selecting substep, selecting a plurality of representative devices from the terminal devices, wherein each representative device is used for receiving heartbeat data of a plurality of terminal devices corresponding to the representative device and sending all the heartbeat data to a monitoring platform server in the form of heartbeat packets;
a reference heartbeat data acquisition substep, selecting one piece of heartbeat data from historical heartbeat data sent to the monitoring platform server by the representative equipment as reference heartbeat data, and writing the reference heartbeat data into the representative equipment and the monitoring platform server in advance;
a heartbeat table establishing sub-step, namely acquiring all heartbeat data of all terminal devices, comparing the heartbeat data with reference heartbeat data respectively to generate a difference code of each heartbeat data, establishing a heartbeat table according to the difference codes and the heartbeat data corresponding to the difference codes, and writing the heartbeat table into the representative device and the monitoring platform server in advance;
the data acquisition step comprises:
a heartbeat code query substep, wherein the representative device receives heartbeat data from the terminal device and queries a heartbeat table according to the heartbeat data to obtain a difference code corresponding to the heartbeat data,
a heartbeat packet generation substep, namely forming a characteristic code list by the difference codes corresponding to a plurality of heartbeat data received by the representative equipment, and writing the characteristic code list into a heartbeat packet of the representative equipment;
a heartbeat packet sending sub-step; the representative devices send heartbeat packets to the monitoring platform server according to the first heartbeat time;
and a resolution substep: and the monitoring platform server decodes the heartbeat packet received by the monitoring platform server, wherein the decoding operation comprises decoding the heartbeat packet according to the reference heartbeat data and generating a heartbeat data sub-packet.
Preferably, the reference heartbeat data acquiring step includes acquiring all heartbeat data sent to the monitoring platform server by the representative device in any selected time period, and selecting heartbeat data with the highest frequency of occurrence as reference heartbeat data; and acquiring all heartbeat data sent to the monitoring platform server by the representative equipment in any selected time period, and selecting the heartbeat data with the minimum difference value with other heartbeat data as reference heartbeat data.
Preferably, the reference heartbeat data acquiring step includes acquiring all heartbeat data sent by the representative device to the monitoring platform server in any selected time period, and selecting heartbeat data with the minimum difference value with other heartbeat data as reference heartbeat data.
Preferably, the pre-processing step further includes a heartbeat cooperation sub-step, configured to synchronize the time of the terminal device with the time of the representative device.
Preferably, the heartbeat data information of the terminal device includes a timestamp, a device ID number, and status information representing the operation status of the device.
Preferably, the representative device election substep is configured with an election policy, and the election policy includes classifying the terminal devices according to device types, acquiring historical transmission rates of all terminal devices in the same class, and electing a terminal device with the highest transmission rate as the representative device.
Preferably, the representative device election substep is configured with an election policy, and the election policy includes election of a terminal device with the highest hardware processing capability as the representative device.
Preferably, the representative device election substep is configured with an election policy, the election policy includes classifying the terminal devices according to device types, obtaining historical transmission rates and location information of all terminal devices in the same category, where the location information includes a sum of location distances from other terminal devices, weighting the historical transmission rates and the location information of the terminal devices according to a certain weight proportion to generate a priority queue, and electing one or more terminal devices with the highest priority as the representative devices according to the number of the terminal devices in the category.
Preferably, one of the representative devices is connected to at most 20 terminal devices.
Preferably, the length of the difference code is 1/3-3/5 of the heartbeat data length of the terminal device.
Compared with the prior art, the invention has the beneficial effects that:
the representative equipment is selected from the terminal equipment by setting a representative equipment selecting sub-step, the representative equipment uniformly sends heartbeat data of the terminal equipment to the monitoring platform server for management, and the effective load of a single heartbeat packet is increased; in addition, a heartbeat table is established, heartbeat data are respectively compared with reference heartbeat data to generate difference codes of each heartbeat data, the difference codes of the heartbeat data of the terminal equipment are formed into a characteristic code list, and the characteristic code list is written into a heartbeat packet of the representative equipment, so that the network bandwidth of the whole heartbeat data transmission is reduced.
Drawings
Fig. 1 is a circuit connection block diagram of a heartbeat packet data acquisition method of an internet of things device according to the present invention;
fig. 2 is a flow chart of a preprocessing step in the internet of things device heartbeat packet data acquisition method of the present invention;
fig. 3 is a flow chart of a data acquisition step in the heartbeat packet data acquisition method of the internet of things device according to the present invention.
In the figure: 1. a monitoring platform server; 2. a first terminal device; 3. representing a first device; 4. a second terminal device; 5. representing a second device.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
As shown in fig. 1, in an embodiment provided by the present invention, a method for acquiring heartbeat packet data of an internet of things device provides an internet of things communication system, where the internet of things communication system includes a plurality of terminal devices and a monitoring platform server 1, a representative device is selected from the plurality of terminal devices, and the representative device sends heartbeat packets of all the terminal devices and the representative device to the monitoring platform server 1; the firstterminal device 2 belongs to the same category of terminal devices, the state information of the running conditions of the same category of device is the same, the different ID numbers of the device can judge which specific terminal device can be, so the length of the difference code of the terminal devices under the same category can be reduced, the problem of insufficient bandwidth of a heartbeat data transmission network caused by redundant data is reduced, the monitoring platform server 1 is in communication connection with a plurality of terminal devices, the terminal devices are used for collecting the physical parameters or the electrical parameters of a field in real time, the monitoring platform server 1 is used for receiving heartbeat data sent by the terminal devices, and the heartbeat packet data collecting method comprises a preprocessing step and a data collecting step.
As shown in fig. 2, the flow chart of the preprocessing step in the internet of things device heartbeat packet data collection method of the present invention is shown, and the preprocessing step includes: a representative device selecting substep S101, selecting a plurality of representative devices from the terminal devices, where each representative device is configured to receive heartbeat data of a plurality of terminal devices corresponding to the representative device, and send all heartbeat data to the monitoring platform server 1 in the form of heartbeat packets;
a reference heartbeat data obtaining substep S102, selecting heartbeat data from historical heartbeat data sent from the representative device to the monitoring platform server 1 as reference heartbeat data, and writing the reference heartbeat data into the representative device and the monitoring platform server 1 in advance;
a heartbeat table establishing substep S103, acquiring all heartbeat data of all terminal devices, comparing the heartbeat data with reference heartbeat data respectively to generate a difference code of each heartbeat data, establishing a heartbeat table according to the difference code and the heartbeat data corresponding to the difference code, and writing the heartbeat table into the representative device and the monitoring platform server 1 in advance.
As shown in fig. 3, the present invention is a flow chart of a data acquisition step in a heartbeat packet data acquisition method of an internet of things device, where the data acquisition step includes: a heartbeat code query substep S201, in which the representative device receives heartbeat data from the terminal device, and queries a heartbeat table according to the heartbeat data to obtain a difference code corresponding to the heartbeat data,
a heartbeat packet generation substep S202, which is to form a feature code list by the difference codes corresponding to a plurality of heartbeat data received by the representative equipment and write the feature code list into the heartbeat packet of the representative equipment;
a heartbeat packet sending substep S203; the representative devices send heartbeat packets to the monitoring platform server 1 according to the first heartbeat time;
resolution substep S204: and the monitoring platform server 1 decodes the heartbeat packet received by the monitoring platform server, wherein the decoding operation comprises decoding the heartbeat packet according to the reference heartbeat data and generating a heartbeat data sub-packet.
Preferably, the reference heartbeat data acquiring step includes acquiring all heartbeat data sent by the representative device to the monitoring platform server 1 in any selected time period, and selecting heartbeat data with the highest frequency of occurrence as reference heartbeat data; and acquiring all heartbeat data sent to the monitoring platform server 1 by the representative equipment in any selected time period, and selecting the heartbeat data with the minimum difference value with other heartbeat data as reference heartbeat data.
Preferably, the reference heartbeat data acquiring step includes acquiring all heartbeat data sent by the representative device to the monitoring platform server 1 in any selected time period, and selecting heartbeat data with the minimum difference value from the heartbeat data as reference heartbeat data.
Preferably, the pre-processing step further includes a heartbeat cooperation sub-step, configured to synchronize the time of the terminal device with the time of the representative device. The problem of information asynchronization caused by hardware aging is reduced.
Preferably, the heartbeat data information of the terminal device includes a timestamp, a device ID number, and status information representing the operation status of the device. The time stamp includes transmission time information of the heartbeat data, whereby heartbeat transmission times of different terminal devices can be calibrated.
Preferably, the representative device election substep is configured with an election policy, and the election policy includes classifying the terminal devices according to device types, acquiring historical transmission rates of all terminal devices in the same class, and electing a terminal device with the highest transmission rate as the representative device.
Because the representative equipment uniformly sends the heartbeat data of the terminal equipment to the monitoring platform server 1 for management, the terminal equipment with the highest transmission efficiency is selected as the representative equipment, so that the communication efficiency of the whole internet of things system can be improved.
Preferably, the representative device election substep is configured with an election policy, and the election policy includes election of a terminal device with the highest hardware processing capability as the representative device.
The high hardware processing capacity can improve the load capacity of a single terminal device and increase the effective load of a single heartbeat packet.
Preferably, the representative device election substep is configured with an election policy, the election policy includes classifying the terminal devices according to device types, obtaining historical transmission rates and location information of all terminal devices in the same category, where the location information includes a sum of location distances from other terminal devices, weighting the historical transmission rates and the location information of the terminal devices according to a certain weight proportion to generate a priority queue, and electing one or more terminal devices with the highest priority as the representative devices according to the number of the terminal devices in the category.
Preferably, at most 20 terminal devices are connected to one representative device, and the specific situation is determined according to the load carrying capacity of the representative device, but the number of the terminal devices connected to one representative device cannot be too large, and after the number of the terminal devices exceeds 20, although normal network data communication can be performed, the communication quality and the communication efficiency of the internet of things system are seriously reduced.
Preferably, the byte length of the differential coding is 1/3-3/5 of the byte length of the heartbeat data of the terminal device, the heartbeat data are respectively compared with the reference heartbeat data by setting a heartbeat table to generate the differential coding of each heartbeat data, the redundant parts of the heartbeat data of different devices in the same category are reduced, and the data processing capacity is reduced.
The working principle is as follows: the representative equipment is selected from the terminal equipment by setting a representative equipment selecting sub-step, the representative equipment uniformly sends heartbeat data of the terminal equipment to the monitoring platform server 1 for management, the effective load of a single heartbeat packet is increased, the redundant parts of the heartbeat data of different equipment in the same category are reduced, and the data processing capacity is reduced; in addition, a heartbeat table is established, heartbeat data are respectively compared with reference heartbeat data to generate difference codes of each heartbeat data, the difference codes of the heartbeat data of the terminal equipment are formed into a characteristic code list, and the characteristic code list is written into a heartbeat packet of the representative equipment, so that the network bandwidth of the whole heartbeat data transmission is reduced.
It will be evident to those skilled in the art that the invention is not limited to the details of the foregoing illustrative embodiments, and that the present invention may be embodied in other specific forms without departing from the spirit or essential attributes thereof. The present embodiments are therefore to be considered in all respects as illustrative and not restrictive, the scope of the invention being indicated by the appended claims rather than by the foregoing description, and all changes which come within the meaning and range of equivalency of the claims are therefore intended to be embraced therein. Any reference sign in a claim should not be construed as limiting the claim concerned.

Claims (10)

CN202010829579.8A2020-08-182020-08-18Internet of things equipment heartbeat packet data acquisition methodActiveCN112073473B (en)

Priority Applications (1)

Application NumberPriority DateFiling DateTitle
CN202010829579.8ACN112073473B (en)2020-08-182020-08-18Internet of things equipment heartbeat packet data acquisition method

Applications Claiming Priority (1)

Application NumberPriority DateFiling DateTitle
CN202010829579.8ACN112073473B (en)2020-08-182020-08-18Internet of things equipment heartbeat packet data acquisition method

Publications (2)

Publication NumberPublication Date
CN112073473Atrue CN112073473A (en)2020-12-11
CN112073473B CN112073473B (en)2023-03-24

Family

ID=73661909

Family Applications (1)

Application NumberTitlePriority DateFiling Date
CN202010829579.8AActiveCN112073473B (en)2020-08-182020-08-18Internet of things equipment heartbeat packet data acquisition method

Country Status (1)

CountryLink
CN (1)CN112073473B (en)

Cited By (6)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN112666819A (en)*2020-12-292021-04-16重庆贵飞科技有限公司Clock guarantee method and system for intelligent lighting system
CN112910740A (en)*2021-02-092021-06-04珠海格力电器股份有限公司State reporting method, device, equipment and computer readable storage medium
CN113079065A (en)*2021-03-262021-07-06山东英信计算机技术有限公司Heartbeat detection method, device, equipment and medium based on Ambari
CN113225219A (en)*2021-03-172021-08-06陕西云长信息科技有限公司Heartbeat data acquisition and storage method for server monitoring
CN114124970A (en)*2021-11-292022-03-01深圳腾视科技有限公司Terminal communication coordination service system and method
CN114640705A (en)*2022-04-222022-06-17山东恒远智能科技有限公司Large-scale heartbeat monitoring method for internet of things terminal

Citations (6)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN101179555A (en)*2006-11-102008-05-14上海三零卫士信息安全有限公司Automatic election mechanism based master-salve proxy system and applicaton technique thereof
CN101212263A (en)*2007-12-252008-07-02深圳清华大学研究院 The Compression Coding Method of Securities Information Data
CN105357116A (en)*2015-10-232016-02-24上海斐讯数据通信技术有限公司Method of multiple terminals for accessing server and intelligent terminal
CN106790550A (en)*2016-12-232017-05-31华中科技大学A kind of system suitable for the compression of power distribution network Monitoring Data
US20170366620A1 (en)*2015-10-222017-12-21Phicomm (Shanghai) Co., Ltd.Long connection method between a plurality of smart devices and a server, and smart device thereof
CN110248089A (en)*2019-05-312019-09-17深圳市华讯方舟卫星产业科技有限公司A kind of image transfer method, system and terminal device

Patent Citations (6)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN101179555A (en)*2006-11-102008-05-14上海三零卫士信息安全有限公司Automatic election mechanism based master-salve proxy system and applicaton technique thereof
CN101212263A (en)*2007-12-252008-07-02深圳清华大学研究院 The Compression Coding Method of Securities Information Data
US20170366620A1 (en)*2015-10-222017-12-21Phicomm (Shanghai) Co., Ltd.Long connection method between a plurality of smart devices and a server, and smart device thereof
CN105357116A (en)*2015-10-232016-02-24上海斐讯数据通信技术有限公司Method of multiple terminals for accessing server and intelligent terminal
CN106790550A (en)*2016-12-232017-05-31华中科技大学A kind of system suitable for the compression of power distribution network Monitoring Data
CN110248089A (en)*2019-05-312019-09-17深圳市华讯方舟卫星产业科技有限公司A kind of image transfer method, system and terminal device

Cited By (8)

* Cited by examiner, † Cited by third party
Publication numberPriority datePublication dateAssigneeTitle
CN112666819A (en)*2020-12-292021-04-16重庆贵飞科技有限公司Clock guarantee method and system for intelligent lighting system
CN112666819B (en)*2020-12-292021-10-29重庆贵飞科技有限公司Clock guarantee method and system for intelligent lighting system
CN112910740A (en)*2021-02-092021-06-04珠海格力电器股份有限公司State reporting method, device, equipment and computer readable storage medium
CN113225219A (en)*2021-03-172021-08-06陕西云长信息科技有限公司Heartbeat data acquisition and storage method for server monitoring
CN113225219B (en)*2021-03-172022-08-26陕西云长信息科技有限公司Heartbeat data acquisition and storage method for server monitoring
CN113079065A (en)*2021-03-262021-07-06山东英信计算机技术有限公司Heartbeat detection method, device, equipment and medium based on Ambari
CN114124970A (en)*2021-11-292022-03-01深圳腾视科技有限公司Terminal communication coordination service system and method
CN114640705A (en)*2022-04-222022-06-17山东恒远智能科技有限公司Large-scale heartbeat monitoring method for internet of things terminal

Also Published As

Publication numberPublication date
CN112073473B (en)2023-03-24

Similar Documents

PublicationPublication DateTitle
CN112073473B (en)Internet of things equipment heartbeat packet data acquisition method
CN107390650B (en)A kind of data collection system based on Internet of Things and the data compression method based on the system
CN103532776B (en)Service traffics detection method and system
CN111242807B (en)Method for accessing substation data into ubiquitous power Internet of things
CN110311990B (en) A configurable Internet of Things data acquisition system and configuration method
CN106257874A (en)Big data quantity remote collection method and system in a kind of unstable network
CN103532940A (en)Network security detection method and device
CN103281366A (en)Embedded agency monitoring device and method supporting real-time operating state acquiring
CN112118174A (en) Software Defined Data Gateway
CN105577431A (en)User information identification and classification method based on internet application and system thereof
CN102118293A (en)Method for compressing and storing communication messages
CN117768930B (en)Power equipment testing system and method based on wireless communication network
US20190058644A1 (en)Data acquisition using remote platform gateways
CN112712606A (en)Automatic inspection management method and system based on operation and maintenance service
CN118175181A (en)Data transmission management system based on station control system configuration
CN120017736A (en) A power equipment data acquisition and processing system and method
CN104601374A (en)Network fault processing method and device for numerical control machine tool
CN112308731A (en)Cloud computing method and system for multitask concurrent processing of acquisition system
CN107918273A (en)A kind of application system of mobile technology of Internet of things on halved belt sorter
CN111291028A (en)High-speed industrial field oriented data acquisition system and method
CN114157577A (en)Internet of things comprehensive management analysis system
CN111007337B (en)Intelligent monitoring and information transmission system for safe production electricity consumption
CN113702746A (en)Safe energy-saving power utilization system based on air compression station
CN116155940A (en) Data transmission method, device, equipment and medium based on passive internet of things
CN115396752A (en)Redis-based biplane data acquisition method and system

Legal Events

DateCodeTitleDescription
PB01Publication
PB01Publication
SE01Entry into force of request for substantive examination
SE01Entry into force of request for substantive examination
GR01Patent grant
GR01Patent grant
TR01Transfer of patent right

Effective date of registration:20231116

Address after:No. 23-2, No. 27 Yuzhou Road, Shiqiaopu, Jiulongpo District, Chongqing, 400000

Patentee after:Chongqing Gengle Technology Development Co.,Ltd.

Address before:Room 1009, building 2, 1780 Jiangling Road, Xixing street, Binjiang District, Hangzhou City, Zhejiang Province 310000

Patentee before:Zhejiang Hongcheng Technology Co.,Ltd.

TR01Transfer of patent right

[8]ページ先頭

©2009-2025 Movatter.jp