CN114024850B - Method for accelerating operation of edge node by optimizing node communication - Google Patents
Method for accelerating operation of edge node by optimizing node communication Download PDFInfo
- Publication number
- CN114024850B CN114024850B CN202011368496.XA CN202011368496A CN114024850B CN 114024850 B CN114024850 B CN 114024850B CN 202011368496 A CN202011368496 A CN 202011368496A CN 114024850 B CN114024850 B CN 114024850B
- Authority
- CN
- China
- Prior art keywords
- node
- edge
- edge node
- data information
- block
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000004891 communication Methods 0.000 title claims abstract description 30
- 238000000034 method Methods 0.000 title claims abstract description 24
- 230000006835 compression Effects 0.000 claims abstract description 17
- 238000007906 compression Methods 0.000 claims abstract description 17
- 238000012545 processing Methods 0.000 claims abstract description 5
- 230000006837 decompression Effects 0.000 claims description 9
- 238000004364 calculation method Methods 0.000 abstract description 5
- 230000005540 biological transmission Effects 0.000 abstract description 4
- 230000007547 defect Effects 0.000 abstract description 3
- 238000005457 optimization Methods 0.000 abstract description 2
- 230000009471 action Effects 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 230000004075 alteration Effects 0.000 description 1
- 238000004458 analytical method Methods 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000008901 benefit Effects 0.000 description 1
- 238000006243 chemical reaction Methods 0.000 description 1
- 238000013500 data storage Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 230000010365 information processing Effects 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 230000009466 transformation Effects 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/08—Configuration management of networks or network elements
- H04L41/0803—Configuration setting
- H04L41/0823—Configuration setting characterised by the purposes of a change of settings, e.g. optimising configuration for enhancing reliability
- H04L41/083—Configuration setting characterised by the purposes of a change of settings, e.g. optimising configuration for enhancing reliability for increasing network speed
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1097—Protocols in which an application is distributed across nodes in the network for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/14—Session management
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/04—Protocols for data compression, e.g. ROHC
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Security & Cryptography (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The invention relates to the technical field of blockchain, and discloses a method for accelerating operation of edge nodes by optimizing node communication, which comprises a server, wherein the server stores blockchain data and interconnects at least one edge node, the edge node is communicated with at least one acquisition node, an edge processor acquires data information from the edge acquisition node, a high compression block is formed in the edge processor, the data information acquired by the edge node can be compressed, and the edge processor stores the data information into the edge node in a compression format so as to facilitate one-time transmission. The method for accelerating the operation of the edge node by optimizing the node communication integrates the core capabilities of network, calculation, storage and application through the optimization of the block node, can make up the defects of the existing edge point signal acquisition and processing, and can solve the problems of slow communication and incapability of normally acquiring data due to the limitation of network conditions.
Description
Technical Field
The invention relates to the technical field of blockchain, in particular to a method for accelerating operation of edge nodes by optimizing node communication.
Background
The edge calculation integrates the core capabilities of network, calculation, storage and application, can make up for the defects of the existing sensor system of the Internet of things in sensor signal acquisition and processing, and can solve the uncertainty problem of poor real-time performance and Internet service quality of the sensor system of the Internet of things. The edge calculation fully utilizes the embedded calculation capability of the object end, realizes the intelligence and autonomy of the object end in a distributed information processing mode, and combines with the cloud end to realize the intelligent operation of the sensor system.
With the rapid development of information technology and internet of things technology, data has become an important factor affecting industry upgrading and transformation, millions of mass mobile application programs on the market gradually become an integral part of people's daily life, and from entertainment consumption to daily communication, the application programs play an increasingly important role in the fields of social life, information transmission and the like.
In the block chain environment data acquisition system at the present stage, data acquisition is formed by various types of control equipment, sensor equipment and execution equipment, and the position layout is relatively scattered, because the number of signal acquisition nodes is numerous and the data storage and conversion capability are not possessed, the distance between the nodes in the edge of the block chain and the rest nodes is far, the communication speed is very slow, the communication preference of the rest nodes is not realized, if the data acquired by the nodes are all uploaded into the block chain cluster, the data cannot be normally acquired due to the limitation of network conditions, the burden of a network is greatly increased, the processing such as acquisition, analysis and storage of the block chain data becomes difficult, and the network pressure is increased.
Disclosure of Invention
The invention provides a method for accelerating the operation of an edge node by optimizing node communication, which has the advantage of relieving the network pressure by accelerating the operation of the edge node, and solves the problems in the background technology.
The invention provides the following technical scheme: the method for accelerating the operation of the edge nodes by optimizing the node communication comprises a server, wherein the server stores blockchain data and interconnects at least one edge node, the edge node is communicated with at least one acquisition node, the edge processor acquires data information by the edge acquisition node, a high compression block is formed in the edge processor, the data information acquired by the edge node can be compressed, and the edge processor stores the data information in the edge node in a compression format so as to facilitate one-time transmission;
the method comprises the following steps:
s1, constructing an interconnection system according to the system architecture, and enabling an edge node to communicate with a server through a wireless network;
s2, among a plurality of edge nodes, the edge nodes which collect digital information are placed into corresponding sub-blocks according to the address intervals in a segmented mode according to the address intervals (such as A1, A2 and A3 and corresponding servers);
s3, creating a highly compressed block section in the same address section, and communicating between network nodes of the same address section where the highly compressed block section is located;
s4, compressing node data information in a highly compressed interval, wherein in the highly compressed node data information set B, the part exceeding the individual compression height is put into a waiting set C to be processed, and at the moment, the data information newly collected by the edge node is put into a set D;
s5, merging and compressing a plurality of data (set B and set D) to be compressed in the same segment into a highly compressed block interval;
s6, merging the data information in the block section which is already highly compressed in the same address section into a single piece, and sending the single piece to an edge node;
s7, decompressing and applying the highly compressed data by the edge node.
Preferably, after the system is started, communication connection with a target edge node is established, when the system is started, a node allocation request is sent to a starting node of the system, node allocation information fed back by the starting node is received, the node allocation information indicates the starting node to select the target edge node from an edge node server cluster based on a preset node selection strategy, and long connection is established between the terminal equipment and the target edge node.
Preferably, a highly compressed block interval is established in the interval where the target edge node is located, a plurality of edge nodes in the interval are combined, the maximum combining parameter is set, the data information exceeding the combining parameter is put into the to-be-processed area, and the newly added edge node data information is waited for input and combination.
Preferably, the merging and compressing process is performed in the highly compressed section in the interval, and the compressed highly compressed section and the target edge node in the same section establish communication, and then the communication is transmitted to the target edge node once.
Preferably, after the target edge point establishes long connection communication with the system, the system gives the target edge point a decompression function, and the target edge point with the decompression function decompresses and applies the compressed data in the high decompression block interval.
Preferably, when storing compressed data, the target edge point can write to the multi-system according to the block sequence in turn to overcome the limitation of writing speed, and the corresponding relation between the block height of the block chain and the server is used as metadata, and when the application is performed, only the edge point with metadata is required to be accessed for application.
The invention has the following beneficial effects:
according to the method for accelerating the operation of the edge node by optimizing the node communication, the computing of the edge point is integrated with the core capabilities of network, computing, storage and application through the optimization of the block node, so that the defects of the existing edge point signal acquisition and processing can be overcome, and the problems that the communication is slow and the data cannot be normally acquired due to the limitation of network conditions can be solved.
Drawings
FIG. 1 is a schematic diagram of the flow steps of the method of the present invention.
Detailed Description
The following description of the embodiments of the present invention will be made clearly and completely with reference to the accompanying drawings, in which it is apparent that the embodiments described are only some embodiments of the present invention, but not all embodiments. All other embodiments, which can be made by those skilled in the art based on the embodiments of the invention without making any inventive effort, are intended to be within the scope of the invention.
FIG. 1 is a flow chart of the present invention.
Referring to fig. 1, a method for accelerating operation of edge nodes by optimizing node communication includes a server, the server stores blockchain data and interconnects at least one edge node, the edge node communicates with at least one acquisition node, an edge processor acquires data information from the edge acquisition node, a high compression block is formed in the edge processor, the data information acquired by the edge node can be compressed, and the edge processor stores the data information in the edge node in a compression format, so that disposable transmission is convenient;
the method comprises the following steps:
s1, constructing an interconnection system according to the system architecture, and enabling an edge node to communicate with a server through a wireless network;
s2, among a plurality of edge nodes, the edge nodes which collect digital information are placed into corresponding sub-blocks according to the address intervals in a segmented mode according to the address intervals (such as A1, A2 and A3 and corresponding servers);
s3, creating a highly compressed block section in the same address section, and communicating between network nodes of the same address section where the highly compressed block section is located;
s4, compressing node data information in a highly compressed interval, wherein in the highly compressed node data information set B, the part exceeding the individual compression height is put into a waiting set C to be processed, and at the moment, the data information newly collected by the edge node is put into a set D;
s5, merging and compressing a plurality of data (set B and set D) to be compressed in the same segment into a highly compressed block interval;
s6, merging the data information in the block section which is already highly compressed in the same address section into a single piece, and sending the single piece to an edge node;
s7, decompressing and applying the highly compressed data by the edge node.
After the system is started, communication connection with a target edge node is established, when the system is started, a node allocation request is sent to a starting node of the system, node allocation information fed back by the starting node is received, the node allocation information indicates the starting node to select the target edge node from the edge node server cluster based on a preset node selection strategy, and long connection is established between the terminal equipment and the target edge node;
establishing a highly compressed block interval in the interval where the target edge node is located, merging a plurality of edge nodes in the interval, setting a maximum merging parameter, and waiting for the data information input merging of the newly added edge node when the data information exceeding the merging parameter is put into a to-be-processed area;
the high compression block interval and the target edge node in the same interval are communicated after the high compression block interval is compressed, and the high compression block interval and the target edge node in the same interval are transmitted to the target edge node at one time;
after the target edge point establishes long connection communication with the system, the system endows the target edge point with a decompression function, and the target edge point with the decompression function decompresses and applies the compressed data in the high decompression block interval;
when compressed data is stored in the target edge point, in order to overcome the limit of writing speed, writing can be circularly and sequentially performed to the multiple systems according to the block sequence, the corresponding relation between the block height of the block chain and the server is used as metadata, and when the application is performed, only the edge point with the metadata is required to be accessed for application.
It is noted that relational terms such as first and second, and the like are used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Moreover, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus.
Although embodiments of the present invention have been shown and described, it will be understood by those skilled in the art that various changes, modifications, substitutions and alterations can be made therein without departing from the principles and spirit of the invention, the scope of which is defined in the appended claims and their equivalents.
Claims (6)
1. A method for accelerating edge node operation by optimizing node communication, comprising: the system comprises a server, wherein the server stores blockchain data and at least one edge node is connected with each other, the edge node is communicated with at least one acquisition node, an edge processor acquires data information by the edge acquisition node, a high compression block is formed in the edge processor, the data information acquired by the edge node can be compressed, and the edge processor stores the data information in the edge node in a compression format, so that the data information is convenient to transmit once;
the method comprises the following steps:
s1, constructing a system architecture according to the server, the edge processor and the edge nodes, constructing an interconnection system, and enabling the edge nodes to communicate with the server through a wireless network;
s2, among a plurality of edge nodes, the edge nodes with the acquired digital information are segmented in sequence according to the address intervals, and the edge nodes with the acquired digital information are segmented and placed into corresponding sub-blocks according to the address intervals;
s3, creating a highly compressed block section in the same address section, and communicating between network nodes of the same address section where the highly compressed block section is located;
s4, compressing node data information in a highly compressed interval, wherein in the highly compressed node data information set B, the part exceeding the individual compression height is put into a waiting set C to be processed, and at the moment, the data information newly collected by the edge node is put into a set D;
s5, merging and compressing a plurality of data to be compressed in the same segment into a highly compressed block interval;
s6, merging the data information in the block section which is already highly compressed in the same address section into a single piece, and sending the single piece to an edge node;
s7, decompressing and applying the highly compressed data by the edge node.
2. A method for accelerating edge node operations by optimizing node communications as recited in claim 1, wherein: after the interconnection system is started, communication connection with a target edge node is established, when the system is started, a node allocation request is sent to a starting node of the system, node allocation information fed back by the starting node is received, the node allocation information indicates the starting node to select the target edge node from an edge node server cluster based on a preset node selection strategy, and long connection is established between terminal equipment and the target edge node.
3. A method for accelerating edge node operations by optimizing node communications as recited in claim 2, wherein: and establishing a highly compressed block interval in the interval where the target edge node is positioned, combining a plurality of edge nodes in the interval, setting a maximum combining parameter, placing data information exceeding the combining parameter into a to-be-processed area, and waiting for the data information input and combination of newly added edge nodes.
4. A method for accelerating edge node operations by optimizing node communications as recited in claim 2, wherein: and carrying out merging compression processing in a high compression section in the same section, establishing communication between the compressed high compression block section and a target edge node in the same section, and transmitting the communication to the target edge node at one time.
5. A method for accelerating edge node operations by optimizing node communications as recited in claim 2, wherein: after the target edge node establishes long connection communication with the system, the system endows the target edge node with a decompression function, and the target edge node with the decompression function decompresses and applies the compressed data in the high decompression block interval.
6. A method for accelerating edge node operations by optimizing node communications as recited in claim 2, wherein: when the target edge node stores compressed data, in order to overcome the limit of writing speed, the target edge node can write to a plurality of systems in turn according to a block sequence, and the corresponding relation between the block height of the block chain and the server is used as metadata, and when the target edge node is applied, only the edge point with the metadata is accessed to apply.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011368496.XA CN114024850B (en) | 2020-11-30 | 2020-11-30 | Method for accelerating operation of edge node by optimizing node communication |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011368496.XA CN114024850B (en) | 2020-11-30 | 2020-11-30 | Method for accelerating operation of edge node by optimizing node communication |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114024850A CN114024850A (en) | 2022-02-08 |
| CN114024850B true CN114024850B (en) | 2024-02-02 |
Family
ID=80053839
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011368496.XA Active CN114024850B (en) | 2020-11-30 | 2020-11-30 | Method for accelerating operation of edge node by optimizing node communication |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114024850B (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107249046A (en) * | 2017-08-15 | 2017-10-13 | 李俊庄 | A kind of distributed cloud storage system construction method based on block chain |
| CN109189327A (en) * | 2018-07-27 | 2019-01-11 | 阿里巴巴集团控股有限公司 | The compression processing method and device of block chain data |
| WO2020030527A1 (en) * | 2018-08-07 | 2020-02-13 | Signify Holding B.V. | Systems and methods for optimizing compression and reconstruction of sensor data in distributed computing networks |
| CN111612393A (en) * | 2020-04-16 | 2020-09-01 | 南京邮电大学 | Medicine supply chain management system and method based on block chain and edge calculation |
| KR102153673B1 (en) * | 2019-12-18 | 2020-09-08 | 제주대학교 산학협력단 | Method, system and recordable medium for storing and transmission processing of intelligent CCTV video data using the edge blockchain |
-
2020
- 2020-11-30 CN CN202011368496.XA patent/CN114024850B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107249046A (en) * | 2017-08-15 | 2017-10-13 | 李俊庄 | A kind of distributed cloud storage system construction method based on block chain |
| CN109189327A (en) * | 2018-07-27 | 2019-01-11 | 阿里巴巴集团控股有限公司 | The compression processing method and device of block chain data |
| WO2020030527A1 (en) * | 2018-08-07 | 2020-02-13 | Signify Holding B.V. | Systems and methods for optimizing compression and reconstruction of sensor data in distributed computing networks |
| KR102153673B1 (en) * | 2019-12-18 | 2020-09-08 | 제주대학교 산학협력단 | Method, system and recordable medium for storing and transmission processing of intelligent CCTV video data using the edge blockchain |
| CN111612393A (en) * | 2020-04-16 | 2020-09-01 | 南京邮电大学 | Medicine supply chain management system and method based on block chain and edge calculation |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114024850A (en) | 2022-02-08 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111142487A (en) | Equipment data acquisition system based on OPC UA unified architecture protocol | |
| CN101383839A (en) | Data distribution system based on data server and implementation method | |
| CN113742135B (en) | Data backup method, device and computer readable storage medium | |
| CN107146623B (en) | Speech recognition method, device and system based on artificial intelligence | |
| CN101848188A (en) | Method and device for updating data block checking information | |
| CN109451019A (en) | High concurrent acquisition method for industrial real-time data | |
| CN104243610A (en) | Distributed file transmission service method | |
| CN113286002B (en) | Power data transmission method based on multi-priority queue | |
| CN110995566A (en) | Message data pushing method, system and device | |
| CN108228625B (en) | Push message processing method and device | |
| WO2022037176A1 (en) | Inter-core communication method and apparatus, electronic assembly, and electronic device | |
| CN114090388A (en) | Information acquisition method, server cluster, server and equipment | |
| CN103095785A (en) | Remote procedure call method and system, client and server | |
| CN114024850B (en) | Method for accelerating operation of edge node by optimizing node communication | |
| CN110868447B (en) | Multi-rocket concurrent measurement and control system and working method thereof | |
| CN110198533B (en) | Method for remotely controlling BLE Bluetooth device and BLE Bluetooth device | |
| CN101808079B (en) | Method, server and client for determining direct neighbor nodes | |
| CN110362055A (en) | A kind of industrial data acquisition system that terminal is expansible and method | |
| CN102685155B (en) | The method that content transmits, content delivering server and content transmit proxy server | |
| US8145698B1 (en) | Self organizing peer-to-peer system, method, and/or apparatus | |
| CN109862094B (en) | Water affair equipment data sharing method and device based on stream computing | |
| CN111092952A (en) | Data interaction method and related product | |
| CN105657451A (en) | Method and system for simultaneously uploading video file and transcoding | |
| CN102521360B (en) | Raster data transmission method and system | |
| CN113242313B (en) | Data synchronization method, system, device, server and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |