CN116192869A - Data transmission method, device, equipment and storage medium - Google Patents
Data transmission method, device, equipment and storage medium Download PDFInfo
- Publication number
- CN116192869A CN116192869A CN202211710685.XA CN202211710685A CN116192869A CN 116192869 A CN116192869 A CN 116192869A CN 202211710685 A CN202211710685 A CN 202211710685A CN 116192869 A CN116192869 A CN 116192869A
- Authority
- CN
- China
- Prior art keywords
- processing rule
- policy file
- computing node
- rule policy
- edge computing
- 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
Links
Images
Classifications
-
- 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/104—Peer-to-peer [P2P] networks
- H04L67/1074—Peer-to-peer [P2P] networks for supporting data block transmission mechanisms
- H04L67/1078—Resource delivery mechanisms
- H04L67/108—Resource delivery mechanisms characterised by resources being split in blocks or fragments
-
- 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
-
- 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/1095—Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
-
- 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/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
-
- 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
- H04L67/141—Setup of application sessions
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Information Transfer Between Computers (AREA)
Abstract
The application discloses a data transmission method, a device, equipment and a storage medium. The data transmission method comprises the following steps: splitting an original processing rule policy file into a plurality of data blocks; obtaining a data block list comprising each data block according to the plurality of data blocks; transmitting the data block list to a cloud server through the data transmission link; receiving the first processing rule policy file sent by the cloud server; and obtaining a synchronized processing rule policy file according to the original processing rule policy file and the first processing rule policy file. According to the embodiment of the application, the cost of data transmission in the data processing process is reduced, and the cloud edge collaborative management efficiency is improved.
Description
Technical Field
The present disclosure relates to the field of IT applications, and in particular, to a data transmission method, apparatus, device, and storage medium.
Background
The edge calculation is a novel calculation mode for sinking part of cloud calculation resources to the edge side, and is taken as a complementary form of cloud calculation at the edge side, so that the edge calculation is rapidly developed. Cloud edge cooperation refers to cooperation between cloud computing and edge computing in terms of resources, data and the like, so that resources are comprehensively distributed, the application value of the whole system is improved, and the requirements of various application scenes are better met.
The number of the dispatching objects of the existing global architecture is huge, and the architecture or the deployment mode of the edge equipment are different. Meanwhile, the existing cloud edge collaborative operation and maintenance management has low transmission and synchronization efficiency on processing rule strategies, and cannot effectively collect the resource states of edges, so that the cloud edge collaborative operation and maintenance management efficiency is affected.
Disclosure of Invention
According to the data transmission method, device, equipment and storage medium, the data transmission efficiency in cloud-edge collaborative operation and maintenance management can be effectively improved, the resource states of edges can be effectively collected, and the efficiency in cloud-edge collaborative operation and maintenance management is improved.
In a first aspect, an embodiment of the present application provides a data transmission method, where the data transmission method is applied to an edge computing node in a cloud edge cooperative system, and a data transmission link is established between the edge computing node and a cloud server in the cloud edge cooperative system, and the method includes:
splitting an original processing rule policy file into a plurality of data blocks;
obtaining a data block list comprising each data block according to the plurality of data blocks;
transmitting the data block list to a cloud server through the data transmission link, so that the cloud server compares the processing rule policy file in the cloud server with the data blocks in the data block list, and when determining that a first processing rule policy file which is not included in the data block list exists in the cloud server, transmitting the first processing rule policy file to the edge computing node through the data transmission link;
Receiving the first processing rule policy file sent by the cloud server;
and obtaining a synchronized processing rule policy file according to the original processing rule policy file and the first processing rule policy file.
In a second aspect, an embodiment of the present application provides a data transmission method, where the data transmission method is applied to a cloud server in a cloud edge cooperative system, and a data transmission link is established between the cloud server and an edge computing node in the cloud edge cooperative system, and the method includes:
receiving a data block list sent by an edge computing node through the data transmission link, wherein the data block is obtained after splitting an original processing rule policy file of the edge computing node;
comparing the processing rule policy file in the cloud server with the data blocks in the data block list;
and when the fact that the first processing rule strategy file which is not included in the data block list exists in the cloud server is determined, transmitting the first processing rule strategy file to the edge computing node through the data transmission link.
In a third aspect, an embodiment of the present application provides a data transmission device, where the data transmission device is applied to an edge computing node in a cloud edge cooperative system, and a data transmission link is established between the edge computing node and a cloud server in the cloud edge cooperative system, and the device includes:
The splitting module is used for splitting the original processing rule policy file into a plurality of data blocks;
the generating module is used for obtaining a data block list comprising each data block according to the plurality of data blocks;
the first sending module is configured to send the data block list to a cloud server through the data transmission link, so that the cloud server compares a processing rule policy file in the cloud server with data blocks in the data block list, and when determining that a first processing rule policy file not included in the data block list exists in the cloud server, transmits the first processing rule policy file to the edge computing node through the data transmission link;
the first receiving module is used for receiving the content of the first processing rule policy file sent by the cloud server and synchronizing the local processing rule policy file;
the feedback module is used for sending feedback information whether the processing rule policy file is successfully synchronized to the cloud server, so that the cloud server can record that the state of the first processing rule policy file is the state transmitted to the edge computing node when determining that the feedback information is that the edge computing node successfully receives the first processing rule policy file; and under the condition that the cloud server determines that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, recovering the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
In a fourth aspect, an embodiment of the present application provides a data transmission device, where the data transmission device is applied to a cloud server in a cloud edge cooperative system, and a data transmission link is established between the cloud server and an edge computing node in the cloud edge cooperative system, and the device includes:
the second receiving module is used for receiving a data block list sent by the edge computing node through the data transmission link, wherein the data block is obtained after splitting the processing rule policy file of the edge computing node;
the comparison module is used for carrying out polling comparison on each data block in the data block list and all processing rule policy files of the local terminal;
the second sending module is used for directly transmitting the first processing rule policy file content of the data block list to the edge computing node through the data transmission link;
the third receiving module is used for receiving feedback information of whether the first processing rule policy file returned by the edge computing node is successfully received; recording the state of the first processing rule policy file as the state transmitted to the edge computing node under the condition that the feedback information is that the edge computing node successfully receives the first processing rule policy file; and under the condition that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, recovering the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
In a fifth aspect, embodiments of the present application provide an electronic device, including: a processor and a memory storing computer program instructions;
the processor, when executing the computer program instructions, implements the data transmission method according to any one of the first and second aspects.
In a sixth aspect, embodiments of the present application provide a computer readable storage medium having stored thereon computer program instructions which, when executed by a processor, implement a data transmission method according to any one of the first and second aspects.
In a seventh aspect, embodiments of the present application provide a computer program product, the instructions in which, when executed by a processor of the electronic device, cause the electronic device to perform the data transmission method according to any one of the first and second aspects.
The data transmission method is applied to edge computing nodes in a cloud edge cooperative system, and a data transmission link is established between the edge computing nodes and a cloud server in the cloud edge cooperative system. During data transmission, the edge computing node splits an original processing rule policy file into a plurality of data blocks; and then, sending a data block list comprising each data block to the cloud server through a data transmission link. And the cloud server only transmits the first processing rule policy file which is not included in the data block list to the edge computing node through the data transmission link, and finally the edge computing node obtains the synchronized processing rule policy file according to the original processing rule policy file and the first processing rule policy file. In this way, in the embodiment of the application, the edge computing node and the cloud server perform data transmission through the special data transmission link, and the cloud server only synchronizes the processing rule policy file lacking in the edge computing node to the edge computing node, so that the rule policy data transmission and synchronization efficiency of edge data processing in cloud edge cooperative operation and maintenance management are improved, further, the resource state of the edge is effectively collected, and the efficiency of cloud edge cooperative operation and maintenance management is improved.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present application, the drawings that are needed in the embodiments of the present application will be briefly described, and it is possible for a person skilled in the art to obtain other drawings according to these drawings without inventive effort.
Fig. 1 is a schematic flow chart of a transmission process in a data transmission method according to an embodiment of the present application;
fig. 2 is a flow chart of a data transmission method according to an embodiment of the first aspect of the present application;
fig. 3 is a flow chart of another data transmission method according to an embodiment of the second aspect of the present application;
fig. 4 is a schematic structural diagram of a data transmission device according to an embodiment of the first aspect of the present application;
fig. 5 is a schematic structural diagram of another data transmission device according to an embodiment of the second aspect of the present application;
fig. 6 is a schematic structural diagram of an electronic device according to an embodiment of the present application.
Detailed Description
Features and exemplary embodiments of various aspects of the present application are described in detail below to make the objects, technical solutions and advantages of the present application more apparent, and to further describe the present application in conjunction with the accompanying drawings and the detailed embodiments. It should be understood that the specific embodiments described herein are intended to be illustrative of the application and are not intended to be limiting. It will be apparent to one skilled in the art that the present application may be practiced without some of these specific details. The following description of the embodiments is merely intended to provide a better understanding of the present application by showing examples of the present 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. Without further limitation, an element defined by the phrase "comprising … …" does not exclude the presence of other like elements in a process, method, article or apparatus that comprises the element.
In order to solve the problems in the prior art, embodiments of the present application provide a data transmission method, apparatus, device, and computer storage medium.
Fig. 1 is a schematic flow chart of a transmission process in a data transmission method according to an embodiment of the present application.
As shown in fig. 1, an embodiment of the present application may include a cloud server 1 and an edge computing node 1. The edge device directly interacts with the cloud server to complete the transmission process shown in fig. 1, wherein the transmission process comprises the following steps:
S101, splitting an original processing rule policy file into a plurality of data blocks;
s102, obtaining a data block list comprising each data block according to the plurality of data blocks;
s103, transmitting the data block list to a cloud server through the data transmission link, so that the cloud server compares the processing rule policy file in the cloud server with the data blocks in the data block list, and when determining that a first processing rule policy file which is not included in the data block list exists in the cloud server, transmitting the first processing rule policy file to the edge computing node through the data transmission link;
s104, receiving a data block list sent by an edge computing node through the data transmission link, wherein the data block is obtained after splitting an original processing rule policy file of the edge computing node;
s105, comparing the processing rule policy file in the cloud server with the data blocks in the data block list;
s106, when the fact that a first processing rule strategy file which is not included in the data block list exists in the cloud server is determined, the first processing rule strategy file is transmitted to the edge computing node through the data transmission link;
S107, receiving the first processing rule policy file sent by the cloud server;
s108, obtaining the synchronized processing rule policy file according to the original processing rule policy file and the first processing rule policy file.
By adopting a remote synchronization (Remote synchronize, rsync) algorithm, the edge computing node uploads the own policy file block to the cloud server, so that file-level incremental transmission of the processing rule policy file and data block-level incremental transmission are realized. And the cloud server compares the received strategy files and only sends the first processing rule strategy file which is not included in the data block list to the edge computing node, so that the transmission cost in the synchronization process of the processing rule strategy file is reduced. The regular policy data transmission and synchronization efficiency of edge data processing in cloud-edge collaborative operation and maintenance management is improved, further, the effective collection of the resource state of the edge is achieved, and the efficiency in cloud-edge collaborative operation and maintenance management is improved.
Referring to S106, the first processing rule policy file refers to a processing rule policy file that is owned by the cloud server but not existed in the data block list uploaded by the edge computing node.
In some embodiments, to achieve synchronization of the processing rule policy file, after S108, the method may further include: and sending feedback information whether the first processing rule policy file is successfully received or not to the cloud server.
In this way, when the cloud server determines that the feedback information is that the edge computing node successfully receives the first processing rule policy file, the cloud server records that the state of the first processing rule policy file is the state transmitted to the edge computing node; and under the condition that the cloud server determines that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, restoring the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
Through the operation, the synchronization of the processing rule policy file between the cloud server and the edge computing node can be ensured.
In some embodiments, to enable transmission of data by the edge computing node, after S108, the method may further include:
processing the acquired state parameters of the edge equipment according to the synchronized processing rule policy file to obtain processed equipment data;
Splitting the processed equipment data to obtain multiple pieces of sub-equipment data;
carrying out parallel processing on the data of the multiple pieces of sub-equipment to obtain a data processing result;
transmitting the data processing result to the cloud server according to the data transmission thread in the synchronized processing rule policy file, so that the cloud server returns a response message to the edge computing node after receiving the data processing result, and disconnects a transmission link with the edge computing node;
and receiving response information returned by the cloud server.
Therefore, the collected state parameters of the edge equipment are processed according to the latest processing rule policy file, and the pressure of the subsequent cloud server data processing is reduced. And the data processing result is actively pushed through the data transmission thread, so that the communication resource overhead in the whole transmission flow is reduced.
Here, before the collected state parameters of the edge device are processed according to the synchronized processing rule policy file to obtain processed device data, the edge device needs to complete registration of the device plugin, and the registering step includes:
the device plugin needs to report the following information to the edge computing node with the identity of the client: 1) Managed device and service names; 2) A port for data collected by the device service plug-in; 3) Interactive API version.
After the service associated with the device service plugin is started, the edge computing node establishes a long data acquisition connection to the device plugin.
Therefore, by establishing the data acquisition long connection, the edge computing node can timely acquire the distribution condition of the equipment and the health state of the equipment.
Here, before the processing the acquired state parameters of the edge device according to the synchronized processing rule policy file to obtain the processed device data, the edge device needs to complete registration of the device plugin, and the acquiring manner may include: and detecting and collecting different depths according to different service scenes, such as protocol detection, flow mirror image detection, code insertion probes, interfaces or direct connection and the like.
Here, after the parallel processing is performed on the multiple pieces of sub-device data to obtain a data processing result, the method further includes:
and carrying out localization temporary warehouse entry on the data processing result.
Therefore, the temporary storage of the data processing result is realized, and the subsequent transmission of the data processing result is facilitated.
Here, the method further includes, after performing parallel processing on the multiple sub-state parameters to obtain a data processing result:
And sending the data processing result to a notification program of a local terminal according to the communication mode in the processing rule policy file so as to send the data processing result to a cloud server through the notification program. The notification program may include various notification forms such as short messages, mail, interfaces, telephones, etc.
Therefore, the active transmission of the data processing result by the edge computing node is realized through the communication mode in the processing rule policy file.
In some embodiments, in order to better synchronize processing rule policy files, the cloud server, after S108, may further include:
receiving feedback information of whether the first processing rule policy file returned by the edge computing node is successfully received;
recording the state of the first processing rule policy file as the state transmitted to the edge computing node under the condition that the feedback information is that the edge computing node successfully receives the first processing rule policy file;
and under the condition that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, recovering the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
Therefore, the cloud end server and the processing rule policy files of the edge computing nodes in cloud edge collaborative management are unified by recording the first processing rule policy file synchronization state cloud end server of the edge computing nodes.
In some embodiments, in order to process the data transmitted by the edge computing node, after S108, the method further includes:
receiving state parameters which are sent by an edge computing node and are acquired continuously for k times, wherein k is an integer which is more than or equal to 2, and the state parameters are acquired by the edge computing node according to an acquisition strategy issued by a cloud server;
determining the state parameter variation of the edge equipment according to the state parameters of the edge equipment acquired for k times continuously;
judging whether the state parameter variation is within a preset state parameter variation interval;
and if the judgment result is yes, keeping the original acquisition frequency to continuously acquire the state parameters of the edge equipment.
Here, for the determining whether the state parameter variation is within a preset state parameter variation interval, the method includes:
the state parameter variation amount is calculated by the following equation 1:
Wherein Δf is the state change amount; k is the number of collection points of the moving average; f (f) n Is the device state parameter acquired for the nth time. Then judging whether the state parameter variation is in a preset state parameter variation interval [ alpha ] min ,α max ]Within the range where alpha min Refers to the minimum state parameter variation of the device, alpha max Refers to the maximum state parameter variation of the device.
Thus, the calculation of the state parameter variation of the edge device is realized.
Here, after the determining whether the state parameter variation is within the preset state parameter variation interval, the method further includes:
reducing the acquisition frequency of acquiring the state parameters of the edge equipment under the condition that the state parameter variation is smaller than the lower limit value of the preset state parameter variation interval;
and increasing the acquisition frequency of acquiring the state parameters of the edge equipment under the condition that the state parameter variation is larger than the lower limit value of the preset state parameter variation interval.
Therefore, the timely change of the acquisition frequency of the edge equipment is realized, and the network pressure in the whole cloud edge system is reduced.
After the acquiring the state parameters of the edge device computing node acquired for k times, the method further includes:
Calculating the interpolation times between every two adjacent acquired state parameters by adopting a linear interpolation method through the following formula 2:
wherein DeltaT min Refers to the minimum acquisition time interval; t is t n Refers to the nth acquisition time.
Thus, the time difference of the time of the adjacent two collection times is determined according to the adjacent two collection times.
According to the state parameters acquired by two adjacent acquisitions and the interpolation times, determining the state parameter interpolation corresponding to the interpolation times, and calculating the state parameter interpolation through a formula 3:
where i represents an interpolation coefficient, which is a ratio of a distance from the nth acquired device state parameter to the n-1 th acquired device state parameter to a distance from the nth acquired device state parameter to the n+1th acquired device state parameter.
Thus, the interpolation times are determined according to the time difference and the minimum acquisition time interval.
Interpolation is carried out on the corresponding state parameters, and an interpolation sequence is obtained;
according to the state parameters in the original data sequence and the interpolation sequence formed by the collected state parameters, calculating the collection errors of the state parameters through the following formula 4:
wherein,,
and->
Respectively representing an interpolation sequence of the adaptive acquisition algorithm and a value sequence of the original data, wherein the interpolation sequence refers to that interpolation of each state parameter is arranged according to the time sequence of interpolation times
For the value sequence of the self-adaptive acquisition algorithm,
is a value sequence of the original data.
Thus, the frequency of the acquisition task is automatically triggered and adjusted according to the result error ratio of the adaptive algorithm.
Fig. 2 is a flow chart illustrating a data transmission method according to an embodiment of the present application, where the data transmission method is applied to an edge computing node in a cloud-edge cooperative system, and it should be noted that the data transmission method may also be applied to a data transmission device of an edge computing node in a cloud-edge cooperative system, where a data transmission link is established between the edge computing node and a cloud server in the cloud-edge cooperative system, and the method includes the following steps:
s201, splitting an original processing rule policy file into a plurality of data blocks;
s202, obtaining a data block list comprising each data block according to the plurality of data blocks;
s203, the data block list is sent to a cloud server through the data transmission link, so that the cloud server compares the processing rule policy file in the cloud server with the data blocks in the data block list, and when the fact that a first processing rule policy file which is not included in the data block list exists in the cloud server is determined, the first processing rule policy file is transmitted to the edge computing node through the data transmission link;
S204, receiving the first processing rule policy file sent by the cloud server;
s205, obtaining the synchronized processing rule policy file according to the original processing rule policy file and the first processing rule policy file.
Fig. 3 is a schematic flow chart of a data transmission method provided in an embodiment of the present application, where the data transmission method is applied to a cloud server in a cloud-edge cooperative system, and it should be noted that the data transmission method may also be applied to a data transmission device of the cloud server in the cloud-edge cooperative system, and a data transmission link is established between an edge computing node and the cloud server in the cloud-edge cooperative system, and the method includes the following steps:
s301, receiving a data block list sent by an edge computing node through the data transmission link, wherein the data block is obtained after splitting an original processing rule policy file of the edge computing node;
s302, comparing the processing rule policy file in the cloud server with the data blocks in the data block list;
and S303, when the fact that the first processing rule policy file which is not included in the data block list exists in the cloud server is determined, transmitting the first processing rule policy file to the edge computing node through the data transmission link.
By adopting the Rsync algorithm, the cloud server realizes the file-level increment transmission of the processing rule policy file and the data block-level increment transmission of the edge computing node, reduces the data transmission cost, improves the data transmission efficiency, and lays a foundation for the follow-up data acquisition and cloud edge collaborative management.
Based on the data transmission method provided by the above embodiment, the present application provides a specific implementation manner of the data transmission device. Please refer to the following examples.
The virtual data transmission apparatus of claim 1 is implemented as shown in fig. 4, the apparatus being applied to an edge computing node in a cloud-edge cooperative system, the apparatus comprising:
a splitting module 401, configured to split the original processing rule policy file into a plurality of data blocks;
a generating module 402, configured to obtain a data block list including each data block according to the plurality of data blocks;
a first sending module 403, configured to send, through the data transmission link, the data block list to a cloud server, so that the cloud server compares a processing rule policy file in the cloud server with data blocks in the data block list, and when determining that a first processing rule policy file not included in the data block list exists in the cloud server, transmits the first processing rule policy file to the edge computing node through the data transmission link;
The first receiving module 404 is configured to receive the content of the first processing rule policy file sent by the cloud server, and synchronize a local processing rule policy file;
the feedback module 405 is configured to send feedback information about whether the processing rule policy file is successfully synchronized to the cloud server, so that the cloud server successfully receives the first processing rule policy file when determining that the feedback information is the state of the edge computing node, and records that the state of the first processing rule policy file is the state of the edge computing node; and under the condition that the cloud server determines that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, restoring the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
Therefore, the splitting module of the device can split the local processing rule policy file into data blocks, the generating module generates a data block list, and the first sending module sends the data block list to the cloud server, so that the file level and the data block level of the processing rule policy file are synchronized. The first receiving module is used for receiving the first processing rule policy file sent by the cloud server, and the feedback module is used for feeding back whether the information is successfully received. Therefore, the unification of the processing rule policy file in cloud edge collaborative management in the whole system is maintained.
Based on the data transmission method provided by the above embodiment, the present application provides another specific implementation manner of the data transmission device. Please refer to the following examples.
Fig. 5 shows a data transmission device, where the device is applied to a cloud server in a cloud-edge collaboration system, and the device includes:
the second receiving module 501 is configured to receive, through the data transmission link, a data block list sent by an edge computing node, where the data block is a data block obtained after splitting a processing rule policy file of the edge computing node;
a comparison module 502, configured to poll and compare each data block in the data block list with all processing rules policy files of the local side;
a second sending module 503, configured to directly send the content of the first processing rule policy file to the edge computing node through the data transmission link;
a third receiving module 504, configured to receive feedback information about whether the first processing rule policy file returned by the edge computing node is successfully received; recording the state of the first processing rule policy file as the state transmitted to the edge computing node under the condition that the feedback information is that the edge computing node successfully receives the first processing rule policy file; and under the condition that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, recovering the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
Therefore, the receiving module can receive the data block list transmitted by the edge computing node, compare the data block list with the local processing rule file through the comparison module, directly send the first processing rule policy file through the second sending module, unify the processing rule files on the two sides of the cloud edge with lower communication resources, and finally realize the synchronous state of the processing rule policy file of the whole system through the third receiving module.
In order to achieve the purpose of sending the message whether the first processing rule policy file is synchronized to the cloud server, as another optional embodiment of the present application, the foregoing apparatus may further include:
the third sending module is configured to send feedback information about whether the first processing rule policy file is successfully received to the cloud server after the third receiving module 504 receives the first processing rule policy file sent by the cloud server, so that when the cloud server determines that the feedback information is that the edge computing node successfully receives the first processing rule policy file, record that a state of the first processing rule policy file is a state that is already transmitted to the edge computing node; and under the condition that the cloud server determines that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, restoring the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
In this way, the third sending module is used for sending whether the received first processing rule policy file is synchronously sent to the cloud server, so that the cloud server updates the first processing rule policy file synchronization state of the edge computing node, and finally, the state of the processing rule policy file of the whole system is timely synchronized.
For the purpose of processing the acquired edge device state parameters, as another optional embodiment of the present application, the apparatus may further include:
the first data processing module is configured to process the acquired state parameters of the edge device according to the synchronized processing rule policy file after the feedback module 405 sends feedback information about whether the processing rule policy file is successfully synchronized to the cloud server, so as to obtain processed device data; splitting the processed equipment data to obtain multiple pieces of sub-equipment data; carrying out parallel processing on the data of the multiple pieces of sub-equipment to obtain a data processing result; transmitting the data processing result to the cloud server according to the data transmission thread in the synchronized processing rule policy file, so that the cloud server returns a response message to the edge computing node after receiving the data processing result, and disconnects a transmission link with the edge computing node; and receiving response information returned by the cloud server.
Therefore, the first data processing module preprocesses the acquired state parameters of the edge equipment, reduces the volume of the state parameters acquired by the edge equipment, and reduces the processing pressure of the cloud server.
For the purpose of actively transmitting data, as another alternative embodiment of the present application, the feedback module 405 may further include:
and sending the data processing result to a notification program of a local terminal according to the communication mode in the processing rule policy file so as to send the data processing result to edge equipment through the notification program.
In this way, the feedback module 405 performs data transmission by selecting a communication mode in the predetermined processing rule policy file, so that consistency of the data transmission mode of the whole system is ensured, and the same data type is ensured by the predetermined transmission mode.
For the purpose of synchronizing whether the edge node successfully receives the processing rule policy file, as another optional embodiment of the present application, the third receiving module 504 may further include:
receiving feedback information of whether the first processing rule policy file returned by the edge computing node is successfully received; recording the state of the first processing rule policy file as the state transmitted to the edge computing node under the condition that the feedback information is that the edge computing node successfully receives the first processing rule policy file; and under the condition that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, recovering the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
In this way, the third receiving module 504 receives feedback information about whether the first processing rule policy file returned by the edge computing node is successfully received, and records the transmission state of the first processing rule policy file in time, so as to realize unification of the processing rule policy files of the cloud server and the edge computing node in the system.
For processing data from an edge computing node, as another optional embodiment of the present application, the apparatus may further include:
the second data processing module is configured to receive, after the third receiving module 504 receives feedback information about whether the first processing rule policy file returned by the edge computing node is successfully received, a state parameter that is sent by the edge computing node and is acquired continuously k times, where k is an integer greater than or equal to 2, and the state parameter is acquired by the edge computing node according to an acquisition policy issued by the cloud server; determining the state parameter variation of the edge equipment according to the state parameters of the edge equipment acquired for k times continuously; judging whether the state parameter variation is within a preset state parameter variation interval; and if the judgment result is yes, keeping the original acquisition frequency to continuously acquire the state parameters of the edge equipment.
In this way, the second data processing module determines the state parameter variation of the edge device according to the parameter k, and then judges whether the state parameter variation is within a preset state parameter variation interval range so as to judge whether the acquisition frequency needs to be modified.
In order to implement a change of the acquisition frequency of the state parameter of the edge device, as another optional embodiment of the present application, the apparatus may further include:
the frequency changing module is used for reducing the acquisition frequency of acquiring the state parameters of the edge equipment under the condition that the state parameter variation is smaller than the lower limit value of the preset state parameter variation interval after judging whether the state parameter variation is in the preset state parameter variation interval; and increasing the acquisition frequency of acquiring the state parameters of the edge equipment under the condition that the state parameter variation is larger than the lower limit value of the preset state parameter variation interval.
In this way, a change in the acquisition frequency of the state parameters of the edge device is achieved.
In order to implement calculation of the acquisition error, as another alternative embodiment of the present application, the apparatus may further include:
the third data processing module is used for calculating the interpolation times between every two adjacent acquired state parameters and the corresponding state parameter interpolation by adopting a linear interpolation method after the state parameters of the edge equipment calculation nodes acquired for k times are acquired, so as to obtain an interpolation sequence; and determining the acquisition error of the state parameters according to the original data sequence and the interpolation sequence which are formed by the acquired state parameters.
In this way, the third data processing module determines the acquisition error of the state parameter through the interpolation sequence obtained by the linear interpolation method.
In order to implement calculation of the interpolation sequence, as another optional embodiment of the present application, the apparatus may further include:
the fourth data processing module is used for calculating the interpolation times between the state parameters acquired every two adjacent times and the corresponding state parameter interpolation by adopting a linear interpolation method, and determining the time difference of the time of the two adjacent times according to the time of the two adjacent times after obtaining an interpolation sequence; determining interpolation times according to the time difference and the minimum acquisition time interval; according to the state parameters acquired by two adjacent times and the interpolation times, determining state parameter interpolation corresponding to the interpolation times; and arranging the state parameter interpolation according to the time sequence of the interpolation times to obtain an interpolation sequence.
In this way, the state parameter interpolation corresponding to the interpolation times is determined through the time difference and the interpolation times of the adjacent two acquisition times, and finally the interpolation is arranged according to the time sequence of the interpolation times, so as to obtain an interpolation sequence.
Fig. 6 shows a schematic hardware structure of data transmission according to an embodiment of the present application.
A processor 601 may be included in a data transmission device and a memory 602 storing computer program instructions.
In particular, the processor 601 may include a Central Processing Unit (CPU), or an application specific integrated circuit (Application Specific Integrated Circuit, ASIC), or may be configured to implement one or more integrated circuits of embodiments of the present application.
In particular embodiments, read-only memory (ROM), random-access memory (RAM), magnetic disk storage media devices, optical storage media devices, flash memory devices, electrical, optical, or other physical/tangible memory storage devices may be included. Thus, in general, the memory includes one or more tangible (non-transitory) computer-readable storage media (e.g., memory devices) encoded with software comprising computer-executable instructions and when the software is executed (e.g., by one or more processors) it is operable to perform the operations described with reference to methods in accordance with aspects of the present disclosure.
The processor 601 implements any of the data transmission methods of the above embodiments by reading and executing computer program instructions stored in the memory 602.
In one example, the data transfer device may also include a communication interface 603 and a bus 610. As shown in fig. 6, the processor 601, the memory 602, and the communication interface 603 are connected to each other through a bus 610 and perform communication with each other.
The communication interface 603 is mainly configured to implement communication between each module, apparatus, unit and/or device in the embodiments of the present application.
The data transmission device can execute the data transmission method in the embodiment of the application based on the currently intercepted junk short message and the short message reported by the user, thereby realizing the data transmission method and the device described in connection with fig. 2-3 and fig. 4-5.
In addition, in combination with the data transmission method in the above embodiment, the embodiment of the application may be implemented by providing a computer storage medium. The computer storage medium has stored thereon computer program instructions; the computer program instructions, when executed by a processor, implement any of the data transmission methods of the above embodiments.
It should be clear that the present application is not limited to the particular arrangements and processes described above and illustrated in the drawings. For the sake of brevity, a detailed description of known methods is omitted here. In the above embodiments, several specific steps are described and shown as examples. However, the method processes of the present application are not limited to the specific steps described and illustrated, and those skilled in the art can make various changes, modifications, and additions, or change the order between steps, after appreciating the spirit of the present application.
The functional blocks shown in the above-described structural block diagrams may be implemented in hardware, software, firmware, or a combination thereof. When implemented in hardware, it may be, for example, an electronic circuit, an Application Specific Integrated Circuit (ASIC), suitable firmware, a plug-in, a function card, or the like. When implemented in software, the elements of the present application are the programs or code segments used to perform the required tasks. The program or code segments may be stored in a machine readable medium or transmitted over transmission media or communication links by a data signal carried in a carrier wave. A "machine-readable medium" may include any medium that can store or transfer information. Examples of machine-readable media include electronic circuitry, semiconductor memory devices, ROM, flash memory, erasable ROM (EROM), floppy disks, CD-ROMs, optical disks, hard disks, fiber optic media, radio Frequency (RF) links, and the like. The code segments may be downloaded via computer networks such as the internet, intranets, etc.
It should also be noted that the exemplary embodiments mentioned in this application describe some methods or systems based on a series of steps or devices. However, the present application is not limited to the order of the above-described steps, that is, the steps may be performed in the order mentioned in the embodiments, may be different from the order in the embodiments, or several steps may be performed simultaneously.
Aspects of the present disclosure are described above with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems) and computer program products according to embodiments of the disclosure. It will be understood that each block of the flowchart illustrations and/or block diagrams, and combinations of blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, enable the implementation of the functions/acts specified in the flowchart and/or block diagram block or blocks. Such a processor may be, but is not limited to being, a general purpose processor, a special purpose processor, an application specific processor, or a field programmable logic circuit. It will also be understood that each block of the block diagrams and/or flowchart illustration, and combinations of blocks in the block diagrams and/or flowchart illustration, can be implemented by special purpose hardware which performs the specified functions or acts, or combinations of special purpose hardware and computer instructions.
In the foregoing, only the specific embodiments of the present application are described, and it will be clearly understood by those skilled in the art that, for convenience and brevity of description, the specific working processes of the systems, modules and units described above may refer to the corresponding processes in the foregoing method embodiments, which are not repeated herein. It should be understood that the scope of the present application is not limited thereto, and any person skilled in the art can easily conceive various equivalent modifications or substitutions within the technical scope of the present application, which are intended to be included in the scope of the present application.
Claims (15)
1. The data transmission method is characterized by being applied to an edge computing node in a cloud edge cooperative system, wherein a data transmission link is established between the edge computing node and a cloud server in the cloud edge cooperative system, and the method comprises the following steps:
splitting an original processing rule policy file into a plurality of data blocks;
obtaining a data block list comprising each data block according to the plurality of data blocks;
transmitting the data block list to a cloud server through the data transmission link, so that the cloud server compares the processing rule policy file in the cloud server with the data blocks in the data block list, and when determining that a first processing rule policy file which is not included in the data block list exists in the cloud server, transmitting the first processing rule policy file to the edge computing node through the data transmission link;
Receiving the first processing rule policy file sent by the cloud server;
and obtaining a synchronized processing rule policy file according to the original processing rule policy file and the first processing rule policy file.
2. The method of claim 1, wherein after receiving the first processing rule policy file sent by the cloud server, the method further comprises:
the method comprises the steps that feedback information whether a first processing rule strategy file is successfully received is sent to the cloud server, so that when the cloud server determines that the feedback information is that the edge computing node successfully receives the first processing rule strategy file, the state of the first processing rule strategy file is recorded as the state transmitted to the edge computing node; and under the condition that the cloud server determines that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, restoring the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
3. The method according to claim 1, wherein the method further comprises:
Processing the acquired state parameters of the edge equipment according to the synchronized processing rule policy file to obtain processed equipment data;
splitting the processed equipment data to obtain multiple pieces of sub-equipment data;
carrying out parallel processing on the data of the multiple pieces of sub-equipment to obtain a data processing result;
transmitting the data processing result to the cloud server according to the data transmission thread in the synchronized processing rule policy file, so that the cloud server returns a response message to the edge computing node after receiving the data processing result, and disconnects a transmission link with the edge computing node;
and receiving response information returned by the cloud server.
4. A method according to claim 3, wherein after parallel processing of the multi-molecule device data to obtain a data processing result, the method further comprises:
and sending the data processing result to a notification program of a local terminal according to the communication mode in the processing rule policy file so as to send the data processing result to edge equipment through the notification program.
5. The data transmission method is characterized by being applied to a cloud server in a cloud edge cooperative system, wherein a data transmission link is established between the cloud server and an edge computing node in the cloud edge cooperative system, and the method comprises the following steps:
Receiving a data block list sent by an edge computing node through the data transmission link, wherein the data block is obtained after splitting an original processing rule policy file of the edge computing node;
comparing the processing rule policy file in the cloud server with the data blocks in the data block list;
and when the fact that the first processing rule strategy file which is not included in the data block list exists in the cloud server is determined, transmitting the first processing rule strategy file to the edge computing node through the data transmission link.
6. The method of claim 5, wherein after transmitting the first processing rule policy file to the edge computing node over the data transmission link, the method further comprises:
receiving feedback information of whether the first processing rule policy file returned by the edge computing node is successfully received;
recording the state of the first processing rule policy file as the state transmitted to the edge computing node under the condition that the feedback information is that the edge computing node successfully receives the first processing rule policy file;
and under the condition that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, recovering the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
7. The method of claim 5, wherein in the event that the feedback information is that the edge computing node successfully received the first processing rule policy file, recording that the state of the first processing rule policy file is a state that has been transmitted to an edge computing node, the method further comprises:
receiving state parameters which are sent by an edge computing node and are acquired continuously for k times, wherein k is an integer which is more than or equal to 2, and the state parameters are acquired by the edge computing node according to an acquisition strategy issued by a cloud server;
determining the state parameter variation of the edge equipment according to the state parameters of the edge equipment acquired for k times continuously;
judging whether the state parameter variation is within a preset state parameter variation interval;
and if the judgment result is yes, keeping the original acquisition frequency to continuously acquire the state parameters of the edge equipment.
8. The method according to claim 7, wherein after said determining whether the state parameter variation is within a preset state parameter variation interval, the method further comprises:
reducing the acquisition frequency of acquiring the state parameters of the edge equipment under the condition that the state parameter variation is smaller than the lower limit value of the preset state parameter variation interval;
And increasing the acquisition frequency of acquiring the state parameters of the edge equipment under the condition that the state parameter variation is larger than the lower limit value of the preset state parameter variation interval.
9. The method of claim 7, wherein after the acquiring the state parameters of the computing node of the edge device for k consecutive acquisitions, the method further comprises:
calculating interpolation times between every two adjacent acquired state parameters and corresponding state parameter interpolation by adopting a linear interpolation method to obtain an interpolation sequence;
and determining the acquisition error of the state parameters according to the original data sequence and the interpolation sequence which are formed by the acquired state parameters.
10. The method of claim 9, wherein calculating the number of interpolations between each two adjacent acquired state parameters and the corresponding state parameter interpolation by using a linear interpolation method to obtain an interpolation sequence includes:
the following operations are respectively executed for any pair of state parameters acquired by two adjacent times:
determining the time difference of the time of the adjacent two collection times according to the time of the adjacent two collection times;
determining interpolation times according to the time difference and the minimum acquisition time interval;
According to the state parameters acquired by two adjacent times and the interpolation times, determining state parameter interpolation corresponding to the interpolation times;
and arranging the state parameter interpolation according to the time sequence of the interpolation times to obtain an interpolation sequence.
11. The utility model provides a data transmission device which characterized in that is applied to the edge computing node in cloud limit cooperation system, establish the data transmission link between the cloud server in the cloud limit cooperation system and the edge computing node, the device includes:
the splitting module is used for splitting the original processing rule policy file into a plurality of data blocks;
the generating module is used for obtaining a data block list comprising each data block according to the plurality of data blocks;
the first sending module is configured to send the data block list to a cloud server through the data transmission link, so that the cloud server compares a processing rule policy file in the cloud server with data blocks in the data block list, and when determining that a first processing rule policy file not included in the data block list exists in the cloud server, transmits the first processing rule policy file to the edge computing node through the data transmission link;
The first receiving module is used for receiving the content of the first processing rule policy file sent by the cloud server and synchronizing the local processing rule policy file;
the feedback module is used for sending feedback information whether the processing rule policy file is successfully synchronized to the cloud server, so that the cloud server can record that the state of the first processing rule policy file is the state transmitted to the edge computing node when determining that the feedback information is that the edge computing node successfully receives the first processing rule policy file; and under the condition that the cloud server determines that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, restoring the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
12. The utility model provides a data transmission device, its characterized in that is applied to cloud server in cloud limit cooperation system, establish the data transmission link between cloud server and the edge computing node in the cloud limit cooperation system, the device includes:
The second receiving module is used for receiving a data block list sent by the edge computing node through the data transmission link, wherein the data block is obtained after splitting the processing rule policy file of the edge computing node;
the comparison module is used for carrying out polling comparison on each data block in the data block list and all processing rule policy files of the local terminal;
the second sending module is used for directly transmitting the first processing rule policy file content of the data block list to the edge computing node through the data transmission link;
the third receiving module is used for receiving feedback information of whether the first processing rule policy file returned by the edge computing node is successfully received; recording the state of the first processing rule policy file as the state transmitted to the edge computing node under the condition that the feedback information is that the edge computing node successfully receives the first processing rule policy file; and under the condition that the feedback information is that the edge computing node does not successfully receive the first processing rule policy file, recovering the synchronous state of the processing rule policy file between the cloud server and the edge computing node to the state before the transmission of the first processing rule policy file.
13. An electronic device, the device comprising: a processor and a memory storing computer program instructions;
the processor, when executing the computer program instructions, implements a data transmission method as claimed in any one of claims 1-10.
14. A computer readable storage medium, characterized in that the computer readable storage medium has stored thereon computer program instructions, which when executed by a processor, implement a data transmission method according to any of claims 1-10.
15. A computer program product, characterized in that instructions in the computer program product, when executed by a processor of an electronic device, cause the electronic device to perform the data transmission method according to any of claims 1-10.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211710685.XA CN116192869B (en) | 2022-12-29 | 2022-12-29 | Data transmission methods, apparatus, equipment and storage media |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211710685.XA CN116192869B (en) | 2022-12-29 | 2022-12-29 | Data transmission methods, apparatus, equipment and storage media |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN116192869A true CN116192869A (en) | 2023-05-30 |
| CN116192869B CN116192869B (en) | 2025-12-12 |
Family
ID=86449973
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202211710685.XA Active CN116192869B (en) | 2022-12-29 | 2022-12-29 | Data transmission methods, apparatus, equipment and storage media |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN116192869B (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20190146718A1 (en) * | 2017-11-13 | 2019-05-16 | Weka.IO LTD | Tiering Data Strategy for a Distributed Storage System |
| CN110032383A (en) * | 2019-04-08 | 2019-07-19 | 网易（杭州）网络有限公司 | Oftware updating method, device and storage medium |
| CN110069454A (en) * | 2017-09-11 | 2019-07-30 | 中兴通讯股份有限公司 | A kind of network file management method, terminal and computer readable storage medium |
| US20200278993A1 (en) * | 2019-03-01 | 2020-09-03 | Soundtrack Game LLC | System and method for automatic synchronization of video with music, and gaming applications related thereto |
| CN113986121A (en) * | 2021-10-14 | 2022-01-28 | 北京师范大学珠海校区 | Self-adaptive threshold value adjusting method for data safe storage and synchronous updating |
-
2022
- 2022-12-29 CN CN202211710685.XA patent/CN116192869B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110069454A (en) * | 2017-09-11 | 2019-07-30 | 中兴通讯股份有限公司 | A kind of network file management method, terminal and computer readable storage medium |
| US20190146718A1 (en) * | 2017-11-13 | 2019-05-16 | Weka.IO LTD | Tiering Data Strategy for a Distributed Storage System |
| US20200278993A1 (en) * | 2019-03-01 | 2020-09-03 | Soundtrack Game LLC | System and method for automatic synchronization of video with music, and gaming applications related thereto |
| CN110032383A (en) * | 2019-04-08 | 2019-07-19 | 网易（杭州）网络有限公司 | Oftware updating method, device and storage medium |
| CN113986121A (en) * | 2021-10-14 | 2022-01-28 | 北京师范大学珠海校区 | Self-adaptive threshold value adjusting method for data safe storage and synchronous updating |
Non-Patent Citations (2)
| Title |
|---|
| 张志强;郑加林;王伟钧;苏长明;黎忠文;: "一种自适应FTP服务器的增量文件下载算法", 成都大学学报(自然科学版), no. 03, 30 September 2016 (2016-09-30) * |
| 张文锦;汪金虎;蓝芳萍;钱振江;: "云存储关键技术研究", 常熟理工学院学报, no. 02, 20 March 2018 (2018-03-20) * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN116192869B (en) | 2025-12-12 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US7475272B2 (en) | Method for calculating clock offset and skew | |
| CN105991412B (en) | Information push method and device | |
| CN111831748A (en) | Data synchronization method, device and storage medium | |
| US8972577B2 (en) | Masterless slot allocation | |
| CN107071005A (en) | A kind of method of data synchronization and system | |
| EP3890218A1 (en) | Timestamp acquisition method and time synchronization system | |
| CN111263338A (en) | Network distribution method of Bluetooth Mesh network and related network distribution equipment and system | |
| CN106603711B (en) | Communication method, system and message server | |
| CN111083049B (en) | User table item recovery method and device, electronic equipment and storage medium | |
| CN111901174B (en) | Service state notification method, related device and storage medium | |
| CN115002894A (en) | Uplink timing synchronization method, device, equipment and storage medium | |
| CN116156609B (en) | Data communication method, device, electronic equipment and storage medium | |
| CN116192869B (en) | Data transmission methods, apparatus, equipment and storage media | |
| CN107241216A (en) | Maintain the method and device of the stable transmission of critical data | |
| CN110659863A (en) | Object monitoring method, apparatus, electronic device, and computer-readable storage medium | |
| CN110585724B (en) | Method and device for updating form data in game client | |
| CN102546137B (en) | Method and device for detecting wireless link | |
| CN105205390A (en) | Security check system and security check method of mobile terminal | |
| CN106293996A (en) | Method of data synchronization, main equipment, alternate device and system | |
| CN112423278B (en) | ZigBee router equipment self-recovery networking method and terminal equipment | |
| CN109257158B (en) | Peer-to-peer sampling synchronization method and system for optical difference communication | |
| CN110134547B (en) | Middleware-based repeated data deleting method and related device | |
| CN117202335A (en) | Timing synchronization method, device, equipment and storage medium between star ad hoc networks | |
| CN118827481B (en) | A method, device, and storage medium for calculating the online status of a device. | |
| CN106992890B (en) | Multi-server switching method and system |
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 |