CN119071305A

CN119071305A - A data transmission method, device, related equipment and computer program product

Info

Publication number: CN119071305A
Application number: CN202411578758.3A
Authority: CN
Inventors: 陈华亮; 陈颖; 张岩; 朱为坡; 张义镇; 林圣梯; 潘锋; 王超
Original assignee: Zhejiang Hailiang Technology Co ltd
Current assignee: Zhejiang Hailiang Technology Co ltd
Priority date: 2024-11-07
Filing date: 2024-11-07
Publication date: 2024-12-03
Anticipated expiration: 2044-11-07
Also published as: CN119071305B

Abstract

The present disclosure provides a data transmission method, apparatus, related device and computer program product. The method comprises the steps of receiving a connection instruction sent by a server, wherein the connection instruction comprises equipment numbers of upper node equipment and peer adjacent node equipment which need to be connected, establishing connection with the upper node equipment and the peer adjacent node equipment which correspond to the equipment numbers respectively, obtaining an initial peer-to-peer network according to a connection result, enabling the number of node equipment between the upper node equipment and the lower node equipment in the initial peer-to-peer network to accord with a preset proportion, performing heartbeat communication detection on the upper node equipment and the peer adjacent node equipment, updating the initial peer-to-peer network to obtain an updated peer network, realizing data transmission between the node equipment and the server by utilizing the updated peer-to-peer network, realizing construction of a hierarchical peer-to-peer network with disaster tolerance capability, effectively dispersing data transmission pressure, improving data reporting efficiency and reducing connection load of each node equipment.

Description

Data transmission method, device, related equipment and computer program product

Technical Field

The present disclosure relates to the field of computer technology, and in particular, to a data transmission method, apparatus, related device, and computer program product.

Background

In the application scenario of local area network equipment, in particular to school environment, electronic banners have become an important means for daily attendance. Attendance activities tend to be focused on specific time periods, such as lessons, which prompt a large number of node devices (i.e., electronic banners) to focus high frequency attendance data reporting in a short period of time. These data are critical to subsequent attendance processing and analysis, and therefore need to be collected and uploaded to the server timely and accurately.

Currently, the prior art mainly relies on each terminal device directly reporting attendance data to a server. After the attendance is completed, each device sends the attendance data to the server through the local area network. The server is responsible for receiving, storing and processing these attendance data.

However, during the attendance peak period, the number of devices and the frequent data reporting may cause the connection load of each node device to be too large, and the server may also face huge data processing and connection management pressures.

Disclosure of Invention

The present disclosure provides a data transmission method, apparatus, related device and computer program product.

According to a first aspect of the present disclosure, there is provided a data transmission method, the method being applied to a node device, the method comprising:

Receiving a connection instruction sent by a server, wherein the connection instruction comprises equipment numbers of upper node equipment and peer adjacent node equipment which need to be connected;

Establishing connection with the superior node equipment and the peer adjacent node equipment corresponding to the equipment numbers respectively, and obtaining an initial peer-to-peer network according to the connection result, wherein the number of the node equipment between the superior node equipment and the subordinate node equipment in the initial peer-to-peer network accords with a preset proportion;

And performing heartbeat communication detection on the superior node equipment and the peer adjacent node equipment, updating the initial peer-to-peer network according to the heartbeat communication detection result, and obtaining an updated peer-to-peer network so as to realize data transmission between the node equipment and the server by using the updated peer-to-peer network.

In some embodiments of the present disclosure, deriving the initial peer-to-peer network from the connection results includes:

If the connection result is connection failure, feeding back connection failure information to the server, wherein the connection failure information comprises equipment numbers of abnormal node equipment in the superior node equipment and the peer adjacent node equipment;

Receiving an update connection instruction sent by a server, wherein the update connection instruction comprises the equipment number of the replacement node equipment corresponding to the abnormal node equipment;

Based on the equipment number of the replacement node equipment in the update connection instruction, replacing the connected abnormal node equipment with the replacement node equipment to obtain an initial peer-to-peer network;

If the connection result is that the connection is successful, node information of the superior node equipment and the peer adjacent node equipment is stored, an initial peer-to-peer network is obtained, and connection success information is fed back to the server.

In some embodiments of the present disclosure, if the connection result is that the connection is successful, node information of the superior node device and the peer neighboring node device is stored, an initial peer-to-peer network is obtained, and the connection success information is fed back to the server, and then the method includes:

And sending a disconnection task to the peer adjacent node equipment, wherein the disconnection task is used for indicating the peer adjacent node equipment to disconnect with the first node equipment in the hierarchy of the node equipment.

In some embodiments of the present disclosure, performing heartbeat communication detection on a superior node device and a peer neighboring node device, updating an initial peer-to-peer network according to a heartbeat communication detection result, and obtaining an updated peer-to-peer network includes:

if the heartbeat abnormality of the first node equipment in the superior node equipment and the peer adjacent node equipment is detected, sending the heartbeat abnormality result of the first node equipment to a server;

And receiving a reconnection instruction sent by the replacement node equipment corresponding to the first node equipment, replacing the connected first node equipment with the replacement node equipment to obtain an updated peer-to-peer network, wherein the reconnection instruction sent by the replacement node equipment is generated based on the replacement connection instruction sent by the server, and the replacement connection instruction is used for indicating the replacement node equipment to replace the first node equipment.

In some embodiments of the present disclosure, heartbeat communication detection is performed on a superior node device and a peer neighboring node device, an initial peer-to-peer network is updated according to a heartbeat communication detection result, and an updated peer-to-peer network is obtained, and then the method includes:

The transmission data are respectively sent to the superior node equipment and the peer neighboring node equipment corresponding to the updated peer-to-peer network, so that the superior node equipment and the peer neighboring node equipment are utilized to send the transmission data to the primary node equipment, the first-stage node equipment is directly connected with the server and is used for sending the received transmission data to the server.

In some embodiments of the present disclosure, sending transmission data to a superior node device and a peer neighboring node device corresponding to an update peer-to-peer network, respectively, includes:

If the number of routes with the upper node device is smaller than the preset route threshold value and the transmission data is not the historical transmission data, the transmission data is sent to the upper node device,

If the route times between the peer adjacent node equipment and the peer adjacent node equipment are smaller than a preset route threshold value and the transmission data are not historical transmission data, the route times are updated, and the transmission data are sent to the peer adjacent node equipment.

According to a second aspect of the present disclosure, there is provided a data transmission method, the method being applied to a server, the method comprising:

Determining the equipment number of the node equipment according to the request registration time of the node equipment;

Determining the device numbers of superior node devices and peer adjacent node devices which need to be connected with the node devices according to the device numbers of the node devices;

And forming a connection instruction according to the equipment numbers, and sending the connection instruction to the node equipment, wherein the connection instruction comprises equipment numbers of superior node equipment and peer adjacent node equipment which need to be connected with the node equipment.

In some embodiments of the present disclosure, determining, according to the device number of the node device, the device numbers of the upper node device and the peer neighboring node device that need to be connected to the node device includes:

If the equipment number of the node equipment is smaller than or equal to a preset scale factor corresponding to the preset scale, determining the equipment numbers of the superior node equipment and the peer adjacent node equipment which are required to be connected with the node equipment according to the node equipment list, wherein the preset scale factor is used for adjusting the number of the node equipment between the superior node equipment and the subordinate node equipment to accord with the preset scale;

If the equipment number of the node equipment is larger than the preset scale factor, determining the equipment numbers of the superior node equipment and the peer adjacent node equipment which need to be connected with the node equipment according to the equipment number of the node equipment and the preset scale factor.

In some embodiments of the present disclosure, determining, according to a device number of a node device and a preset scale factor, a device number of a superior node device and a peer neighboring node device that need to be connected to the node device includes:

determining the hierarchy of the node equipment according to the equipment number of the node equipment and a preset scale factor;

Determining a first equipment number of a first node equipment in a hierarchy according to the hierarchy of the node equipment and a preset scale factor;

determining the equipment number of the upper node equipment corresponding to the node equipment according to the first equipment number, the equipment number of the node equipment and a preset scale factor;

And determining the equipment numbers of peer adjacent node equipment corresponding to the node equipment according to the equipment numbers of the node equipment and a preset scale factor.

In some embodiments of the present disclosure, determining the hierarchy of node devices according to the device number of the node device and the preset scale factor includes:

According to the following formula 1, determining a hierarchy of node equipment according to the equipment number of the node equipment and a preset scale factor:

Equation 1

Wherein L is the hierarchy of node equipment, P is the equipment number of the node equipment, and N is a preset scale factor;

According to the following formula 2, according to the hierarchy of node devices and a preset scale factor, determining a first device number in the hierarchy:

Equation 2

Wherein, A first equipment number of a first node equipment in a hierarchy of node equipment is given, N is a preset scale factor, and L is the hierarchy of the node equipment;

According to the following formula 3, determining the device number of the upper node device corresponding to the node device according to the first device number, the device number of the node device and a preset scale factor:

equation 3

Wherein, The device number of the upper node device corresponding to the node device is given, P is the device number of the node device,The first device number of the first node device in the hierarchy of node devices is N, which is a preset scale factor, and L, which is the hierarchy of node devices.

According to a third aspect of the present disclosure, there is provided a data transmission apparatus, the apparatus being applied to a node device, the apparatus comprising:

The receiving unit is used for receiving a connection instruction sent by the server, wherein the connection instruction comprises equipment numbers of upper node equipment and peer adjacent node equipment which need to be connected;

The construction unit is used for respectively establishing connection with the superior node equipment and the peer adjacent node equipment corresponding to the equipment numbers, and obtaining an initial peer-to-peer network according to the connection result, wherein the number of the node equipment between the superior node equipment and the subordinate node equipment in the initial peer-to-peer network accords with a preset proportion;

and the updating unit is used for carrying out heartbeat communication detection on the superior node equipment and the peer-to-peer adjacent node equipment, updating the initial peer-to-peer network according to the heartbeat communication detection result, and obtaining an updated peer-to-peer network so as to realize data transmission between the node equipment and the server by utilizing the updated peer-to-peer network.

According to a fourth aspect of the present disclosure, there is provided a data transmission apparatus, the apparatus being applied to a server, the apparatus comprising:

a first determining unit, configured to determine an equipment number of the node equipment according to a registration request time of the node equipment;

A second determining unit, configured to determine, according to the device number of the node device, the device numbers of the upper node device and the peer neighboring node device that need to be connected to the node device;

And the sending unit is used for forming a connection instruction according to the equipment number and sending the connection instruction to the node equipment, wherein the connection instruction comprises the equipment numbers of the superior node equipment and the peer adjacent node equipment which are required to be connected with the node equipment.

According to a fifth aspect of the present disclosure, there is provided an electronic device comprising a storage medium, a processor and a computer program stored on the storage medium and executable on the processor, characterized in that the processor implements the method of the first or second aspect described above when executing the computer program.

According to a sixth aspect of the present disclosure, there is provided a computer program product comprising a computer program which, when executed by a processor, implements the method of the preceding first or second aspect.

The data transmission method, the device, the related equipment and the computer program product provided by the disclosure are characterized in that a connection instruction sent by a server is received, the connection instruction comprises equipment numbers of upper node equipment and peer adjacent node equipment which need to be connected, connection is established between the upper node equipment and the peer adjacent node equipment which correspond to the equipment numbers respectively, an initial peer-to-peer network is obtained according to a connection result, the number of node equipment between the upper node equipment and the lower node equipment in the initial peer-to-peer network accords with a preset proportion, heartbeat communication detection is carried out on the upper node equipment and the peer adjacent node equipment, the initial peer-to-peer network is updated according to the heartbeat communication detection result, the updated peer-to-peer network is obtained, so that data transmission between the node equipment and the server is realized by utilizing the updated peer-to-peer network, the hierarchical peer-to-peer network with disaster tolerance capability is realized, the node equipment is ensured to utilize heartbeat communication detection, meanwhile, data is reported to the server step by step according to step, data transmission pressure is effectively dispersed, the connection load of each node equipment is reduced, and effective support is provided for realizing an information system with low load, high disaster tolerance capability and high transmission efficiency.

It should be understood that the description in this section is not intended to identify key or critical features of the embodiments of the application or to delineate the scope of the application. Other features of the present application will become apparent from the description that follows.

Drawings

The drawings are for a better understanding of the present solution and are not to be construed as limiting the present disclosure. Wherein:

fig. 1 is a flow chart of a data transmission method according to an embodiment of the disclosure;

Fig. 2 is a flowchart of another data transmission method according to an embodiment of the disclosure;

Fig. 3 is a flowchart of another data transmission method according to an embodiment of the disclosure;

Fig. 4 is a flow chart of a data transmission method according to an embodiment of the disclosure;

fig. 5 is a flowchart of another data transmission method according to an embodiment of the disclosure;

FIG. 6 is a schematic diagram of a network architecture of a particular peer-to-peer network provided by an embodiment of the present disclosure;

Fig. 7 is a schematic structural diagram of a data transmission device according to an embodiment of the present disclosure;

Fig. 8 is a schematic structural diagram of a data transmission device according to an embodiment of the disclosure;

fig. 9 is a schematic hardware structure of an electronic device according to an embodiment of the disclosure.

Detailed Description

Exemplary embodiments of the present disclosure are described below in conjunction with the accompanying drawings, which include various details of the embodiments of the present disclosure to facilitate understanding, and should be considered as merely exemplary. Accordingly, one of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the present disclosure. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness.

In the current application scenario of local area network equipment, the rapid progress of the internet of things technology has prompted a large number of node devices to access a network to realize data communication. These devices cover a variety of types of sensors, smart appliances, monitoring cameras, etc., that require data to be sent to a server on a regular or on-demand basis.

Taking school environment as an example, electronic banners have become a common way to check in and punch cards. Since attendance activities tend to be concentrated in specific time periods, such as before and after a lesson, this can result in numerous node devices being concentrated in high frequency data reporting in a short period of time. These attendance data need to be collected and uploaded to the server in time for subsequent data processing and analysis.

Currently, the related art is that each node device independently reports the attendance data to the server. After the attendance record is completed, the node equipment directly transmits the data to the server through the local area network. The server then assumes the role of receiving, storing and processing these data.

However, during the attendance peak period, a large number of node devices report data at the same time, so that the connection load of each node device is increased sharply, and the server also bears huge data processing and connection management pressure when processing massive concurrent data requests. This may not only extend the response time of the server, but may also cause problems with data loss or processing delays, thereby affecting the efficiency and reliability of the overall attendance system.

In order to solve the problems in the related art, the data transmission method provided by the present disclosure constructs a hierarchical peer-to-peer network architecture, which has a strong disaster recovery capability. The node equipment intelligently connects the upper level and the peer adjacent node equipment according to the connection instruction sent by the server to form an initial network, and ensures that the number of the level nodes accords with a preset proportion. The state of the node equipment is monitored in real time through heartbeat communication detection, and the network structure is dynamically adjusted, so that continuous stability and high efficiency of the network are realized. The architecture realizes hierarchical management of node devices, peer node devices form a ring structure to share data, and peer adjacent node devices are connected with different upper node devices in a scattered manner to enhance disaster tolerance. Even if the superior node equipment fails, the child node equipment can still report data through the adjacent node equipment, so that the data continuity and the integrity are ensured. The connection load of the node equipment is reduced, and the requirements of low-performance equipment such as electronic banners are met, so that the network has excellent disaster recovery capability while operating efficiently.

Data transmission methods, apparatuses, electronic devices, storage media, and computer program products of embodiments of the present disclosure are described below with reference to the accompanying drawings.

Fig. 1 is a flowchart of a data transmission method according to an embodiment of the disclosure. As shown in fig. 1, the method is applied to a node device, and includes:

Step 101, receiving a connection instruction sent by a server, wherein the connection instruction comprises equipment numbers of upper node equipment and peer adjacent node equipment which need to be connected.

In some embodiments, a node device is a device or computer connected to a network that is capable of communicating with a server or other node device. A node device may be any device capable of processing data and exchanging data with other devices, such as a client, router, switch, etc.

In the present disclosure, the device numbers of the upper node device and the peer neighboring node device to be connected are determined by the server, specifically, the node device may send a registration request to the server, and after receiving the registration request sent by the node device, the server may determine the device numbers of the upper node device and the peer neighboring node device to be connected to the node device, and form a connection instruction by using the device numbers, and send the connection instruction to the current node device, where the connection instruction is used to instruct how the current node device establishes a connection with other node devices (the upper node device and the peer neighboring node device).

In the present disclosure, there may be a hierarchical relationship between node devices. The upper node device refers to a node device of which the current node device is higher in logical or physical structure. Peer neighboring node devices refer to node devices that are at the same level as the current node device and are logically or physically neighboring. The device number is an identifier for uniquely identifying each node device in the network, and may be an IP address, a MAC address, a custom ID number, etc., and in this disclosure, the device number of the current node device may be determined by the server according to a request registration time sequence in which the node device sends a registration request to the server, and for a superior node device and a peer neighboring node device that need to be connected may be determined by the server through the device number of the current node device.

And 102, respectively establishing connection with the superior node equipment and the peer adjacent node equipment corresponding to the equipment numbers, and obtaining an initial peer-to-peer network according to the connection result, wherein the number of the node equipment between the superior node equipment and the subordinate node equipment in the initial peer-to-peer network accords with a preset proportion.

In some embodiments, after the current node device receives the connection instruction sent by the server, the node device may respectively establish connection with the upper node device and the peer neighboring node device according to the device numbers of the upper node device and the peer neighboring node device to be connected in the connection instruction, so as to obtain an initial peer-to-peer network according to the connection result.

The lower node device refers to a node device of a lower level in a logical or physical structure of the current node device.

In the initial peer-to-peer network, the number of node devices between the upper node device and the lower node device needs to conform to a preset ratio. The preset proportion can be determined according to the target and the requirement of the network design to ensure the stability and the efficiency of the network, for example, in some cases, the number of the lower node devices connected under each upper node device needs to be ensured to be within a certain range, so as to avoid the problems of network congestion or data loss, etc., and the preset proportion is expressed as 1:N in the disclosure. N is a preset scale factor in the preset proportion.

In this disclosure, peer-to-Peer (P2P) networks are a network architecture model that distributes tasks and workloads among peers (peers). In a P2P network, individual nodes (or peers) are peer-to-peer, and there is no need for a central server or centralized management node to coordinate the transmission and processing of data. Instead, each node may communicate and exchange data directly with other nodes. The characteristics of the P2P network include decentralization, distributed resource storage and sharing, and scalability. The entire network is more resistant to attacks and robust since there is no single central node. Even if part of nodes are failed or attacked, other nodes can still continue to work normally, and the stability of the network and the availability of data are ensured.

It should be noted that, in the peer-to-peer network of the present disclosure, since the node device is a currently registered node device, the node device may be connected with the first node device in the same hierarchy, so as to implement the interconnection of the node devices in the same hierarchy into a ring, so as to ensure horizontal sharing of data.

Step 103, performing heartbeat communication detection on the superior node equipment and the peer adjacent node equipment, updating the initial peer-to-peer network according to the heartbeat communication detection result, and obtaining an updated peer-to-peer network so as to realize data transmission between the node equipment and the server by using the updated peer-to-peer network.

In some embodiments, the present disclosure may perform heartbeat communication detection on a superior node device and a peer neighboring node device, and update a peer-to-peer network accordingly, to achieve more efficient and reliable data transmission.

Heartbeat communication detection is a technique for monitoring the survival status and connection availability of network node devices. By periodically sending heartbeat packets (also referred to as heartbeat messages or keep-alive messages) by the superordinate node device and the peer neighboring node devices, the current node device can confirm whether its connection with the superordinate node device and the peer neighboring node devices is still valid.

In the initial peer-to-peer network of the present disclosure, each node device is configured with a heartbeat detection mechanism. The mechanism can be sent by the superior node equipment and the peer adjacent node equipment periodically, or actively initiated or passively received by the current node equipment. The heartbeat packet typically contains identification information of the node device (e.g., device number, IP address, etc.), a timestamp, etc., to ensure accuracy and integrity of the data.

If the response of the superior node or the peer neighboring node is not received within the specified time, the node is considered to be possibly invalid or the connection is interrupted, and the heartbeat communication detection result is determined to be abnormal.

In the present disclosure, the node device of the present disclosure may identify, according to the heartbeat communication detection result, which nodes are still online, which nodes have failed or have a connection break, so as to update the initial peer-to-peer network. The updated update peer-to-peer network can comprise the latest node information and connection state, and the node equipment sends the data packet to the target server or the target node equipment according to the updated network topology structure and the routing table, so that the data transmission between the node equipment and the server is more efficient and reliable.

In summary, the technical scheme provided by the disclosure includes that a connection instruction sent by a server is received, the connection instruction includes equipment numbers of an upper node equipment and a peer neighboring node equipment to be connected, connection is established between the upper node equipment and the peer neighboring node equipment corresponding to the equipment numbers respectively, an initial peer-to-peer network is obtained according to a connection result, the number of node equipment between the upper node equipment and a lower node equipment in the initial peer-to-peer network accords with a preset proportion, heartbeat communication detection is performed on the upper node equipment and the peer neighboring node equipment, the initial peer-to-peer network is updated according to the heartbeat communication detection result, the updated peer-to-peer network is obtained, data transmission between the node equipment and the server is realized by utilizing the updated peer-to-peer network, a hierarchical peer-to-peer network with disaster tolerance capability is constructed, network stability is guaranteed by utilizing the heartbeat communication detection by the node equipment, meanwhile, data transmission pressure is gradually reported to the server according to a hierarchical structure, the connection load of each node equipment is effectively dispersed, and powerful support is provided for realizing education information system with low load, high disaster tolerance capability and high transmission efficiency.

As a possible implementation manner, as shown in fig. 2, a flowchart of another data transmission method, based on the above embodiment, obtains a specific process of the initial peer-to-peer network according to the connection result, which includes the following steps:

and 201, respectively establishing connection with the superior node equipment and the peer adjacent node equipment corresponding to the equipment numbers to obtain a connection result.

Step 202, if the connection result is connection failure, feeding back connection failure information to the server, wherein the connection failure information comprises equipment numbers of abnormal node equipment in the superior node equipment and the peer adjacent node equipment.

In some embodiments, in some application scenarios, the online stability of the node device cannot be absolutely guaranteed. Although the server may trigger the change mechanism immediately upon detecting that the node is offline to restore its online state, the node may still be offline due to delays and potential fluctuations in network transmissions, resulting in connection failure. Connection failure refers to the inability of a connection between a current node device and a superior node device or peer neighboring node device to be established or maintained. This may be due to network failure, equipment failure, configuration errors, etc.

The abnormal node device refers to an upper node device or a peer neighboring node device that causes connection failure.

Step 203, receiving an update connection instruction sent by the server, wherein the update connection instruction comprises the equipment number of the replacement node equipment corresponding to the abnormal node equipment.

In some embodiments, after the node device sends the connection failure information to the server, the server may query the node information of the registered online node device according to the device number of the abnormal node device in the connection failure information, determine the device number of the replacement node device corresponding to the abnormal node device, and form an update connection instruction based on the device number of the replacement node device corresponding to the abnormal node device, and send the update connection instruction to the node device.

The server determines the device number of the replacement node device corresponding to the abnormal node device, and may adopt a replacement policy of a device type and a priority, or may adopt a replacement policy of load balancing and fault recovery, where the specific policy may be designed according to an actual situation, and is not limited in the embodiments of the present disclosure.

In an alternative embodiment of the present disclosure, the present disclosure may employ an alternative policy based on device type and priority, as follows:

The server may query the type of the abnormal node device (e.g., sensor, smart device, etc.) and determine a replacement node device of the same or a compatible type using the node information of the registered rewriting node device. By comparing the device types, the server can ensure that the replacement node device can functionally meet the requirements of the original abnormal node device.

After finding multiple replacement node devices of the same or compatible type, the server may determine the best replacement node device according to a certain prioritization policy (e.g., device status, duration of use, maintenance record, etc.). For example, the server may select, as the replacement node device, the device that has the best status, the shortest use period, or the best maintenance record. Once the best replacement node device is determined, the server obtains the device number of the replacement node device and uses it to generate updated connection instructions.

In an alternative embodiment of the present disclosure, the present disclosure employs a replacement policy based on load balancing and fault recovery, as follows:

The server can determine the replacement node equipment according to the load balancing condition of the whole system, namely, the server can select one replacement node equipment with fewer connection numbers or lighter load to balance the load of the whole system. Meanwhile, the server can also determine the replacement node equipment according to the requirement of fault recovery, and if the abnormal node equipment is a key equipment in the system, the server can select one replacement node equipment with higher reliability and redundancy to ensure the stable operation of the system.

After the replacement node device is determined, the server acquires the device number of the replacement node device and generates an update connection instruction.

And 204, replacing the connected abnormal node equipment with replacement node equipment based on the equipment number of the replacement node equipment in the updated connection instruction, so as to obtain an initial peer-to-peer network.

In some embodiments, after receiving the update connection instruction sent by the server, the node device may parse the update connection instruction, disconnect the connection with the abnormal node based on the device number of the replacement node device in the update connection instruction, and establish a connection with the replacement node device.

After the node device establishes a connection with the replacement node device, the node device may again perform connection detection to ensure that the connection with the replacement node device is valid and secure.

In the present disclosure, the node apparatuses may also notify other relevant nodes (e.g., the superordinate node apparatuses and/or the peer neighboring node apparatuses) of information of their connection establishment with the replacement node apparatus so that they can update their connection information as well.

After the steps, the node equipment which is originally connected with the abnormal node equipment is connected with the replacement node equipment, so that a new initial peer-to-peer network which does not contain the abnormal node equipment is formed.

And 205, if the connection result is that the connection is successful, storing the node information of the superior node equipment and the peer adjacent node equipment to obtain an initial peer-to-peer network, and feeding back the connection success information to the server.

In some embodiments, if the connection result is that the connection is successful, node information of a superior node device and a peer neighboring node device of the node device is stored, and information of the connection success is fed back to the server, so that the server is ensured to know that the node device has successfully joined the network.

In the present disclosure, the node device may send node information and connection relationships of a superior node device and a peer neighboring node device of the node device to the server, and the server stores the node information and connection relationships.

The node information and the connection relation stored by the server may specifically be a node identifier (node ID), mac address, device group ID, node public network address, node local area network address, node number, upper node identifier (parent node ID), peer neighboring node identifier (left node ID, right node ID), lower node identifier (List < child node ID >), and status of the node device. The key data structures of node information and connection relations stored in the server are shown in table 1.

TABLE 1

Because peer node devices can be connected in a ring and the ring of peer nodes is always reconnected with the newly registered node device. Therefore, if the connection result is that the connection is successful, the node information of the upper node device and the peer neighboring node device is stored, an initial peer-to-peer network is obtained, and the connection success information is fed back to the server, and then, when the node device is not the first node device in the same hierarchy, the method can further comprise the step of sending a disconnection task to the peer neighboring node device (peer neighboring left node), wherein the disconnection task is used for indicating that the peer neighboring node device disconnects from the first node device in the hierarchy of the node device. Specifically, the disclosure may first determine, according to the number of the node device, whether the node device is the first node device in the hierarchy of node devices, and if not the first node device, send a disconnection task to the peer neighboring node on the left side, so as to ensure the correctness of the network structure and avoid unnecessary connection or loop.

The device number of the node device and the hierarchy of the node device are determined by the server and sent to the node device.

In summary, the present disclosure effectively processes the connection state when constructing the initial peer-to-peer network, stores the related node information and notifies the server when successful, and finds out the replacement node and re-establishes the connection with the assistance of the server when failed, thereby ensuring the integrity of the network structure and the validity of the connection.

As a possible implementation manner, as shown in a flow chart of another data transmission method in fig. 3, on the basis of the foregoing embodiment, performing heartbeat communication detection on a superior node device and a peer neighboring node device, and updating an initial peer-to-peer network according to a heartbeat communication detection result, to obtain a specific process of updating the peer-to-peer network after updating, including the following steps:

Step 301, if the heartbeat abnormality of the first node device in the superior node device and the peer neighboring node device is detected, sending the heartbeat abnormality result of the first node device to a server.

In some embodiments, the heartbeat exception result includes a device number of the first node device.

The node equipment, the superior node equipment and the peer adjacent node equipment keep connected with the heartbeat so as to detect the heartbeat communication in real time and monitor the connection state of the node equipment and the peer adjacent node equipment.

When a node device detects a heartbeat abnormality of a certain node (such as a first node device) in its superior node device or peer neighboring node device, it is considered that the node may be offline or unstable in connection. The node device immediately sends the abnormal heartbeat result to the server so that the server can process the abnormal heartbeat result in time.

In the embodiment of the present disclosure, in order to reduce false alarms caused by network fluctuations, the present disclosure may also set an anomaly threshold value at the server side. And determining that the first node device is offline only when the number of times the server receives the heartbeat abnormal result of the first node device is greater than or equal to the abnormal threshold value.

The setting of the abnormal threshold needs to comprehensively consider a plurality of factors including preset proportion, the number of node devices, stability of the network, connection condition of the nodes and the like, and is not limited in the embodiment of the disclosure. The anomaly threshold may be set to be less than n+3 (where N is a preset scale factor in a preset scale) considering that peer neighboring node devices of the node devices may also be offline. Meanwhile, in order to cope with sporadic offline reporting caused by network fluctuation, the abnormality threshold may be set to be greater than 1 (unless there is a special case, such as that the end node device is connected by only 1 node device). This ensures that when a single node device is briefly offline due to network fluctuations, it does not cause the server to misjudge its offline state.

Through mechanisms such as heartbeat detection, abnormal reporting, threshold setting and the like, the server can effectively monitor the online state and connection health of the node equipment, and false alarms and missing alarms caused by network fluctuation are reduced.

Step 302, receiving a reconnection instruction sent by a replacement node device corresponding to the first node device, replacing the connected first node device with the replacement node device, and obtaining an updated peer-to-peer network, wherein the reconnection instruction sent by the replacement node device is generated based on the replacement connection instruction sent by the server, and the replacement connection instruction is used for indicating the replacement node device to replace the first node device.

In some embodiments, in order to quickly enable a healthy replacement node device to replace the operation of the first node device under the condition that the first node device cannot normally operate, after receiving a heartbeat abnormal result sent by the node device, the server of the present disclosure may query node information of the registered online node device according to the device number of the first node device in the heartbeat abnormal result, determine the device number of the replacement node device corresponding to the first node device, and form a replacement connection instruction based on the device number of the replacement node device corresponding to the first node device, and send the replacement connection instruction to the replacement node device. The replacement node device may generate a reconnection instruction based on the connection policy and send the reconnection instruction to the node device, so that the node device replaces the connected first node device with the replacement node device, thereby obtaining an updated peer-to-peer network.

Because the server side can set an abnormal threshold, when the server side receives that the heartbeat abnormal result of the first node device sent by the node device is greater than or equal to the abnormal threshold, the server can inquire the node information of the registered online node device according to the device number of the first node device in the heartbeat abnormal result, determine the device number of the replacement node device corresponding to the first node device, form a replacement connection instruction based on the device number of the replacement node device corresponding to the first node device, send the replacement connection instruction to the replacement node device, and generate a reconnection instruction based on the connection policy and send the reconnection instruction to the node device, so that the node device replaces the connected first node device with the replacement node device, and an updated peer-to-peer network is obtained.

The manner in which the server determines the device number of the replacement node device corresponding to the first node device and the manner in which the server determines the device number of the replacement node device corresponding to the abnormal node device in step 203 may be the same or different, and the method is specifically selected according to the actual situation, which is not limited in the embodiments of the present disclosure. In addition, in order to ensure that the change to the original connection is minimal, the replacement node device of the present disclosure may also be preset, that is, the node device of the last device number in the initial peer-to-peer network is set as the replacement node device each time.

It should be noted that, because the server cannot directly contact the node device that does not establish a connection, when the server sends the alternative connection instruction, the alternative connection instruction may be issued step by step through the network structure of the initial peer-to-peer network until the alternative node device is notified, that is, the alternative node device receives the alternative connection instruction sent by the server and is received layer by layer according to the network structure of the initial peer-to-peer network.

In some embodiments, since the first node device is any one of an upper node device and a peer neighboring node device of the node device, after receiving the replacement connection instruction corresponding to the first node device sent by the server, the replacement node device may connect with the upper node device and the peer neighboring node device connected before the first node device according to the replacement connection instruction and the connection policy, and share data, so as to implement replacement of the first node device by the replacement node device by the node device.

In the process of replacing connection, the connection policy of the replacement node device may be determined according to a determination result of determining whether the replacement node device is the first node device at the same level as the first node device. The connection policy may include a first connection policy and a second connection policy.

Specifically, the replacement node device determines whether the replacement node device is a first node device in the same hierarchy as the first node device, and if not, obtains a first connection policy, that is, notifies a left peer neighboring node device of a peer neighboring node device connected to the first node device to directly connect a right peer neighboring node device (to reconnect the same-hierarchy node device into a ring), disconnects the connection with the left peer neighboring node device to directly connect the right peer neighboring node device, and disconnects an upper node device connected to the first node device. If so, a second connection strategy is obtained, namely, the connection of the upper node equipment connected with the first node equipment is disconnected. After the replacement node obtains the connection policy, a reconnection instruction may be sent to the node device based on the connection policy.

After the replacement node device establishes a new connection with the upper node device and the peer neighboring node device, the replacement completion information may also be sent to the server to notify the network that the update is completed.

It should be noted that in the present disclosure, performing heartbeat communication detection on a superior node device and a peer neighboring node device, updating an initial peer-to-peer network according to a heartbeat communication detection result, and obtaining an updated peer-to-peer network, and then, the present disclosure may further include: the transmission data are respectively sent to the superior node equipment and the peer neighboring node equipment corresponding to the updated peer-to-peer network, so that the superior node equipment and the peer neighboring node equipment are utilized to send the transmission data to the primary node equipment, the first-stage node equipment is directly connected with the server and is used for sending the received transmission data to the server.

The primary node device is responsible for receiving the transmission data from the subordinate node device and transmitting it to the server. The transmission data is transferred step by step upwards in the updated peer-to-peer network. When the data arrives at the primary node device, the primary node device sends it to the server. The server receives and processes the data to complete the whole data transmission process.

In order to reduce the concurrency pressure of the server, for data with low timeliness requirements, a time interval threshold can be set, and after the primary node equipment receives the transmission data, the transmission data in the current time interval are reported to the server in batches according to the time interval threshold.

Because the number of the first-stage node devices is not large and plays a key role in reporting the server, in order to ensure disaster recovery, the first-stage node devices can share transmission data to all other first-stage nodes in the updating peer-to-peer network, and when the first-stage node devices originally holding the transmission data are offline unexpectedly, the transmission data can be reported to the server by the other first-stage node devices.

The primary node device may also negotiate with all other primary node devices in the update peer-to-peer network to determine a target primary node device for reporting the transmission data to the server. The first-level node equipment can share respective load scores through two-by-two communication as a decision basis, and the first-level node with the lowest load is negotiated and selected by using the same decision algorithm to serve as a target node and is responsible for reporting data transmission to a server so as to avoid repeated reporting and reduce network load. The calculation mode of the responsible score may be set according to actual situations and requirements, which is not limited in the embodiments of the present disclosure.

The first-level node equipment can wait for the successful receipt of the target first-level node equipment for reporting the transmission data, namely, because the negotiated target first-level node equipment is still possibly offline accidentally, other first-level node equipment can set the timeout time for waiting for the receipt, if the successful receipt is not fed back within the specified timeout time, the other first-level node equipment considers that the target first-level node equipment reports the failure, and then the reported target first-level node equipment can renegotiate between the other first-level node equipment to report the transmission data to the server again according to the mode.

In order to save the repeated expenditure of the node equipment for transmitting data, the method can set the routing threshold value of the horizontal routing times between the node equipment at the same level on the premise of guaranteeing the disaster recovery requirement, and when the routing threshold value is reached, the data transmission is not performed any more. In the process of forwarding the lower node device to the upper node device, only the routing times are judged, and the routing times are not increased after the data transmission, because the forwarding of the lower node device to the upper node device is a necessary way for ensuring the data to reach the server, if the routing times are increased, the disaster recovery effect of the horizontal data forwarding originally designed for disaster recovery is lost, and the data transmission cost caused by the horizontal data forwarding is wasted. In other words, if the number of routes with the upper node device is smaller than the preset routing threshold and the transmission data is not the historical transmission data, the transmission data is sent to the upper node device, if the number of routes with the peer neighboring node device is smaller than the preset routing threshold and the transmission data is not the historical transmission data, the number of routes is updated, and the transmission data is sent to the peer neighboring node device.

The routing threshold may be set according to the actual network size and complexity to avoid infinite circulation or excessive spreading of data in the network, and is not limiting in the disclosed embodiments.

The historical transmission data is the transmission data forwarded by the previous node equipment. Each batch of transmission data carries a unique data identifier so as to ensure that when the data is forwarded through the multi-node equipment, even if the same node equipment receives the data of the same batch from different routes, the repeated forwarding can be judged and avoided by checking the data identifier. The present disclosure may determine whether the transmission data is historical transmission data by examining a data identification of the transmission data.

In summary, the present disclosure timely discovers and processes heartbeat anomalies of nodes in a network through a heartbeat communication detection mechanism, thereby ensuring network stability. When detecting that the heartbeat of a node in the superior node or the peer adjacent node is abnormal, reporting an abnormal result to a server immediately, and triggering a process of replacing the abnormal node by the replacement node, so that the network structure is quickly recovered, and an updated peer-to-peer network is obtained. On the basis, the method and the device also realize reliable transmission of the data, namely, the transmission data is sent to the superior node equipment and the peer adjacent node equipment according to the routing times and the degree of new and old data, and finally, the data is reported to the server through the first-stage node equipment. Not only improves the efficiency and accuracy of data transmission, but also effectively avoids the problems of network congestion and repeated data transmission, and ensures the robustness and reliability of the whole peer-to-peer network.

Fig. 4 is a flowchart of a data transmission method according to an embodiment of the disclosure. As shown in fig. 4, the method is applied to a server, and includes:

step 401, determining the device number of the node device according to the registration time of the node device.

In some embodiments, upon receiving a registration request for a node device, the server records the requested registration time for the request. And then, the server numbers the node equipment according to the sequence of the request registration time to obtain the equipment number of the node equipment. Specifically, the server will number from small to large in the morning and evening when registration time is requested. In this way, the earliest registered node device will obtain the smallest number, while the latest registered node device will obtain the largest number, so that the server can ensure that each node device has a unique and orderly device number, which helps the server to better manage and maintain the node devices in the peer-to-peer network.

Step 402, determining the device numbers of the superior node device and the peer neighboring node device which need to be connected with the node device according to the device numbers of the node devices.

In some embodiments, the server may select different number determining policies based on a size relationship between a device number of the node device and a preset scale factor in a preset proportion, to determine device numbers of a superior node device and a peer neighboring node device that need to be connected to the node device.

Step 403, forming a connection instruction according to the equipment number, and sending the connection instruction to the node equipment, wherein the connection instruction comprises the equipment numbers of the superior node equipment and the peer adjacent node equipment which need to be connected with the node equipment.

In some embodiments, after obtaining the device numbers of the upper node device and the peer neighboring node device that need to be connected to the node device, the server may generate a connection instruction, and send the connection instruction to the node device, so as to instruct the node device to connect to the upper node device and the peer neighboring node device that are optionally connected.

In summary, the technical scheme provided by the disclosure determines the equipment numbers of the node equipment according to the request registration time of the node equipment, determines the equipment numbers of the superior node equipment and the peer neighboring node equipment which need to be connected with the node equipment according to the equipment numbers of the node equipment, forms a connection instruction according to the equipment numbers, and sends the connection instruction to the node equipment, wherein the connection instruction comprises the equipment numbers of the superior node equipment and the peer neighboring node equipment which need to be connected with the node equipment, so that a hierarchical peer-to-peer network is constructed, the node equipment reports data to a server step by step according to a hierarchical structure, the data transmission pressure is effectively dispersed, the data reporting efficiency is improved, the connection load of each node equipment is reduced, and powerful support is provided for an education informatization system for realizing low load, high disaster tolerance capability and high transmission efficiency.

As a possible implementation manner, as shown in fig. 5, a flowchart of another data transmission method, based on the above embodiment, a specific process of determining, according to the device number of the node device, the device numbers of the upper node device and the peer neighboring node devices that need to be connected to the node device includes the following steps:

Step 501, determining the device numbers of the superior node device and the peer neighboring node device which need to be connected with the node device according to the device numbers of the node device and the preset scale factors corresponding to the preset scale.

Step 502, if the device number of the node device is smaller than or equal to a preset scale factor corresponding to a preset scale, determining the device numbers of the superior node device and the peer neighboring node device which need to be connected with the node device according to the node device list, wherein the preset scale factor is used for adjusting the number of the node devices between the superior node device and the subordinate node device to accord with the preset scale.

In some embodiments, each node device has a unique device number. The method and the device determine whether the device number of the node device is smaller than or equal to a preset scale factor corresponding to a preset scale.

If the device number of the Node device is smaller than or equal to a preset scale factor (P is smaller than or equal to N) corresponding to the preset scale, the device numbers of the superior Node device and the peer neighboring Node devices which need to be connected with the Node device can be determined by referring to the Node information of each Node device in the stored Node device List (List < Node >).

The node information of each node device in the node device list may include a device number, a location, a hierarchy, and the like of the node device. Server information for the server may also be included in the node device list.

Step 503, if the device number of the node device is greater than the preset scale factor, determining the device numbers of the superior node device and the peer neighboring node device that need to be connected with the node device according to the device number of the node device and the preset scale factor.

In some embodiments, if the device number of the node device is greater than a preset scale factor (P > N), determining a hierarchy of the node device according to the device number of the node device and the preset scale factor, determining a first device number of a first node device in the hierarchy according to the hierarchy of the node device and the preset scale factor, determining a device number of an upper node device corresponding to the node device according to the first device number, the device number of the node device and the preset scale factor, and determining a device number of a peer neighboring node device corresponding to the node device according to the device number of the node device and the preset scale factor.

In an alternative embodiment of the present disclosure, the present disclosure may determine the hierarchy of the node devices according to the following equation 1, according to the device number of the node device and the preset scale factor:

Equation 1

Wherein L is the hierarchy of node devices, P is the device number of the node devices, N is a preset scale factor,Is rounded downwards;

Equation 2

By passing through The upper node of the node device can be determined as the first levelAnd a node device.

Based on the foregoing, the disclosure may determine, according to the following formula 3, the device number of the upper node device corresponding to the node device according to the first device number, the device number of the node device, and the preset scale factor:

equation 3

In an optional embodiment of the disclosure, determining the device number of the peer neighboring node device corresponding to the node device according to the device number of the node device and a preset scale factor may specifically include determining whether the node device is a first node device in a hierarchy of the node device, and determining the device number of the peer neighboring node device corresponding to the node device according to the device number of the node device and the preset scale factor based on a determination result.

If the node device is the first node device in the hierarchy (i.e) It is determined that the node device does not have a peer neighboring node device. In other words, since the node device is the first node device in the hierarchy, there is no left peer neighboring node device in the node device, and the node device is the node device currently requesting registration, is the end node device, and its right peer neighboring node device is the next node device registered with the server, so there is no right peer neighboring node device currently.

If the node device is not the first node device in the hierarchy, determining the device number of the peer neighboring node device on the left side of the node device. Wherein, The device number of the peer adjacent node device on the left side of the node device is given, and P is the device number of the node device. Determining that a device number of a peer neighboring node device to the right of the node device is the first node device in the hierarchyWherein, the method comprises the steps of, wherein,The device number of the peer neighboring node device to the left of the node device,The first device number of the first node device in the hierarchy of node devices is N, which is a preset scale factor, and L, which is the hierarchy of node devices.

It can be understood that, since the node device is a node device that sends a registration request to the server currently, and is an end node device in the current network, its lower node device is a node device that subsequently sends a registration request to the server, so that there is no lower node device at present, and after other subsequent node devices send registration requests to the server, the node device may be connected as an upper node device of the node devices.

In summary, the present disclosure may flexibly determine, by comparing the device number of the node device with a preset scale factor, the device numbers of the upper node and the peer neighboring node to which the node device needs to be connected. And when the node equipment number is greater than the preset proportion factor, determining the level of the node equipment and the first node number in the level by calculation, and further pushing out the equipment numbers of the upper node and the adjacent nodes of the same level. The logic and accuracy of connection between the node devices are ensured, and meanwhile, the distribution of the node devices can be adjusted according to a preset proportion factor so as to meet specific proportion requirements.

Based on the embodiments shown in fig. 1-5, as shown in fig. 6, the present disclosure provides a network architecture schematic of a specific peer-to-peer network.

In the present disclosure, referring to fig. 6, fig. 6 includes a SERVER (SERVER) and node devices, wherein a numbered circle is each node device, and a device number in the circle is the device number of each node device. The network architecture can adopt a mode of step-by-step jurisdiction among node devices and step-by-step data reporting, and a preset proportion (namely supporting a configurable father-son jurisdiction ratio (such as 1:N)) is met between the upper node device and the lower node device. By increasing the preset scale factor N, the level can be shortened, and the data reporting efficiency can be improved, but at the same time, the connection load of a single node can be increased, so that the preset scale factor can be set according to the actual requirement, and fig. 6 is only an example. The node devices at the same level can be connected with each other in a ring by adopting a mode of horizontally sharing data, so that the rapid transmission and sharing of the data are realized.

In the present disclosure, the network architecture may also feature high availability and low connection load. Different superior node devices can be connected in a scattered manner by the same-level adjacent node devices, so that disaster recovery capability is enhanced. When a certain upper node device breaks down, the lower node device connected with the upper node device can report data through the same-level adjacent node device, only 1 route is added, and the continuity and stability of the data are ensured. In addition, considering the disaster recovery effect, in the present disclosure, each node device establishes a connection of n+3 at most (N is a preset scale factor).

In summary, compared with the traditional P2P network, the peer-to-peer network of the present disclosure greatly reduces the load pressure of single-node devices, and is particularly suitable for low-performance node devices, such as electronic banners and the like.

Corresponding to the data transmission method, the invention also provides a data transmission device applied to the node equipment side and a data transmission device applied to the server side. Since the device embodiment of the present invention corresponds to the above-mentioned method embodiment, details not disclosed in the device embodiment may refer to the above-mentioned method embodiment, and details are not described in detail in the present invention.

Fig. 7 is a schematic structural diagram of a data transmission device according to an embodiment of the present disclosure, where, as shown in fig. 7, the device is applied to a node device, and the device includes:

A receiving unit 710, configured to receive a connection instruction sent by a server, where the connection instruction includes device numbers of a superior node device and a peer neighboring node device that need to be connected;

A construction unit 720, configured to establish connection with an upper node device and a peer neighboring node device corresponding to the device number, and obtain an initial peer-to-peer network according to a connection result, where the number of node devices between the upper node device and the lower node device in the initial peer-to-peer network meets a preset ratio;

And the updating unit 730 is configured to perform heartbeat communication detection on the upper node device and the peer neighboring node device, update the initial peer-to-peer network according to the heartbeat communication detection result, and obtain an updated peer-to-peer network, so as to implement data transmission between the node device and the server by using the updated peer-to-peer network.

In some embodiments of the present disclosure, the construction unit 720 is configured to, if the connection result is a connection failure, feed back connection failure information to the server, where the connection failure information includes device numbers of abnormal node devices in the upper node device and the peer neighboring node devices, receive an update connection instruction sent by the server, where the update connection instruction includes a device number of a replacement node device corresponding to the abnormal node device, replace the connected abnormal node device with the replacement node device based on the device number of the replacement node device in the update connection instruction, obtain an initial peer-to-peer network, and if the connection result is that the connection is successful, store node information of the upper node device and the peer neighboring node device, obtain the initial peer-to-peer network, and feed back connection success information to the server.

In some embodiments of the present disclosure, the construction unit 720 is further configured to store node information of the upper node device and the peer neighboring node device if the connection result is that the connection is successful, obtain an initial peer-to-peer network, and feed back the connection success information to the server, and then send a disconnection task to the peer neighboring node device, where the disconnection task is used to instruct the peer neighboring node device to disconnect from a first node device in the hierarchy of the node device.

In some embodiments of the present disclosure, an updating unit 730 is configured to send a heartbeat abnormality result of a first node device to a server if a heartbeat abnormality of the first node device in a superior node device and a peer neighboring node device is detected, receive a reconnection instruction sent by a replacement node device corresponding to the first node device, replace the connected first node device with the replacement node device, and obtain an updated peer-to-peer network, where the reconnection instruction sent by the replacement node device is generated based on a replacement connection instruction sent by the server, and the replacement connection instruction is used to instruct the replacement node device to replace the first node device.

In some embodiments of the present disclosure, the apparatus further includes a data transmission unit, configured to perform heartbeat communication detection on an upper node device and a peer neighboring node device, update an initial peer-to-peer network according to a heartbeat communication detection result, obtain an updated peer-to-peer network, and then send transmission data to the upper node device and the peer neighboring node device corresponding to the updated peer-to-peer network, respectively, so that the upper node device and the peer neighboring node device are used to send the transmission data to a first node device, where the first node device is directly connected with a server, and the first node device is configured to send the received transmission data to the server.

In some embodiments of the present disclosure, the data transmission unit is configured to send the transmission data to the upper node device if the number of routes with the upper node device is less than a preset routing threshold and the transmission data is not historical transmission data, update the number of routes if the number of routes with the peer neighboring node device is less than the preset routing threshold and the transmission data is not historical transmission data, and send the transmission data to the peer neighboring node device.

Fig. 8 is a schematic structural diagram of a data transmission device according to an embodiment of the present disclosure, where, as shown in fig. 8, the device is applied to a server, and the device includes:

a first determining unit 810, configured to determine a device number of the node device according to a registration request time of the node device;

A second determining unit 820 configured to determine, according to the device number of the node device, the device numbers of the upper node device and the peer neighboring node device that need to be connected to the node device;

The sending unit 830 is configured to form a connection instruction according to the device number, and send the connection instruction to the node device, where the connection instruction includes the device numbers of the upper node device and the peer neighboring node device that need to be connected to the node device.

In some embodiments of the present disclosure, the second determining unit 820 is configured to determine, according to the node device list, device numbers of an upper node device and a peer neighboring node device that need to be connected to the node device if the device numbers of the node devices are less than or equal to a preset scale factor corresponding to a preset scale, where the preset scale factor is used to adjust the number of node devices between the upper node device and a lower node device to conform to the preset scale, and determine, according to the device numbers of the node devices and the preset scale factor, the device numbers of the upper node device and the peer neighboring node device that need to be connected to the node device if the device numbers of the node devices are greater than the preset scale factor.

In some embodiments of the present disclosure, the second determining unit 820 is configured to determine a hierarchy of node devices according to a device number of the node device and a preset scale factor, determine a first device number of a first node device in the hierarchy according to the hierarchy of the node device and the preset scale factor, determine a device number of a superior node device corresponding to the node device according to the first device number, the device number of the node device, and the preset scale factor, and determine a device number of a peer neighboring node device corresponding to the node device according to the device number of the node device and the preset scale factor.

In some embodiments of the present disclosure, the second determining unit 820 is configured to:

Equation 1

Equation 2

equation 3

The foregoing explanation of the method embodiment is also applicable to the apparatus of this embodiment, and the principle is the same, and this embodiment is not limited thereto.

Based on the above-described methods shown in fig. 1 to 5, correspondingly, the present embodiment further provides a computer program product, which comprises a computer program that, when executed by a processor, implements the above-described methods shown in fig. 1 to 5.

Based on the above-described methods shown in fig. 1 to 5, correspondingly, the present embodiment further provides a computer-readable storage medium, on which a computer program is stored, which when executed by a processor, implements the above-described methods shown in fig. 1 to 5.

Based on such understanding, the technical solution of the present application may be embodied in the form of a software product, which may be stored in a non-volatile storage medium (may be a CD-ROM, a U-disk, a mobile hard disk, etc.), and includes several instructions for causing a computer device (may be a personal computer, a server, or a network device, etc.) to execute the method of each implementation scenario of the present application.

Fig. 9 is a schematic diagram of a hardware structure of an electronic device according to the present invention, including:

At least one processor 901, and

A memory 902 communicatively coupled to at least one of the processors 901, wherein,

The memory 902 stores instructions executable by at least one of the processors to enable the at least one processor to perform the data transmission method as described above.

In fig. 9, a processor 901 is taken as an example.

The electronic device may further comprise an input means 903 and a display means 904.

The processor 901, memory 902, input device 903, and display device 904 may be connected by a bus or other means, the connection being illustrated as a bus.

The memory 902 is used as a non-volatile computer readable storage medium for storing a non-volatile software program, a non-volatile computer executable program, and modules, such as program instructions/modules corresponding to the review content generating method in the embodiment of the present application, for example, the method flows shown in fig. 1 to 5. The processor 901 executes various functional applications and data processing by running nonvolatile software programs, instructions, and modules stored in the memory 902, that is, implements the data transmission method in the above-described embodiments.

The memory 902 may include a storage program area that may store an operating system, an application program required for at least one function, and a storage data area that may store data created according to the use of the review content generation method, and the like. In addition, the memory 902 may include high-speed random access memory, and may also include non-volatile memory, such as at least one magnetic disk storage device, flash memory device, or other non-volatile solid-state storage device. In some embodiments, the memory 902 optionally includes memory remotely located relative to the processor 901, which may be connected via a network to a device performing the review content generation method. Examples of such networks include, but are not limited to, the internet, intranets, local area networks, mobile communication networks, and combinations thereof.

The input device 903 may receive input user clicks and generate signal inputs related to user settings and function controls of review content generation methods. The display device 904 may include a display apparatus such as a display screen.

The data transmission method in any of the method embodiments described above is performed when the one or more modules are stored in the memory 902 and when executed by the one or more processors 901.

Optionally, the entity device may further include a user interface, a network interface, a camera, a Radio Frequency (RF) circuit, a sensor, an audio circuit, a WI-FI module, and so on. The user interface may include a Display screen (Display), an input unit such as a Keyboard (Keyboard), etc., and the optional user interface may also include a USB interface, a card reader interface, etc. The network interface may optionally include a standard wired interface, a wireless interface (e.g., WI-FI interface), etc.

It will be appreciated by those skilled in the art that the above-described physical device structure provided in this embodiment is not limited to this physical device, and may include more or fewer components, or may combine certain components, or may be a different arrangement of components.

The storage medium may also include an operating system, a network communication module. The operating system is a program that manages the physical device hardware and software resources described above, supporting the execution of information handling programs and other software and/or programs. The network communication module is used for realizing communication among all components in the storage medium and communication with other hardware and software in the information processing entity equipment.

From the above description of the embodiments, it will be apparent to those skilled in the art that the present application may be implemented by means of software plus necessary general hardware platforms, or may be implemented by hardware. By applying the scheme of the embodiment, compared with the prior art, the embodiment receives the connection instruction sent by the server, the connection instruction comprises the equipment numbers of the superior node equipment and the peer adjacent node equipment which need to be connected, establishes connection with the superior node equipment and the peer adjacent node equipment which correspond to the equipment numbers respectively, obtains an initial peer-to-peer network according to the connection result, carries out heartbeat communication detection on the superior node equipment and the peer adjacent node equipment, updates the initial peer-to-peer network according to the heartbeat communication detection result, obtains an updated peer-to-peer network, realizes data transmission between the node equipment and the server by utilizing the updated peer-to-peer network, realizes construction of a hierarchical peer-to-peer network with disaster tolerance capability, ensures that the node equipment utilizes the heartbeat communication detection to ensure network stability, simultaneously reports data to the server step by step according to a hierarchical structure, effectively disperses data transmission pressure, improves the data reporting efficiency, reduces the connection load of each node equipment, and provides powerful support for realizing an information system with low load, high disaster tolerance capability and high transmission efficiency.

It should be noted that in this document, 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 one does not exclude the presence of other like elements in a process, method, article, or apparatus that comprises an element.

The foregoing is only a specific embodiment of the application to enable those skilled in the art to understand or practice the application. Various modifications to these embodiments will be readily apparent to those skilled in the art, and the generic principles defined herein may be applied to other embodiments without departing from the spirit or scope of the application. Thus, the present application is not intended to be limited to the embodiments shown herein but is to be accorded the widest scope consistent with the principles and novel features disclosed herein.

Claims

1. A method of data transmission, the method being applied to a node device, the method comprising:

receiving a connection instruction sent by a server, wherein the connection instruction comprises equipment numbers of superior node equipment and peer adjacent node equipment which need to be connected;

Establishing connection with the upper node equipment and the peer adjacent node equipment corresponding to the equipment numbers respectively, and obtaining an initial peer-to-peer network according to a connection result, wherein the number of the node equipment between the upper node equipment and the lower node equipment in the initial peer-to-peer network accords with a preset proportion;

And performing heartbeat communication detection on the superior node equipment and the peer adjacent node equipment, updating the initial peer-to-peer network according to a heartbeat communication detection result, and obtaining an updated update peer-to-peer network so as to realize data transmission between the node equipment and the server by utilizing the update peer-to-peer network.

2. The method of claim 1, wherein obtaining an initial peer-to-peer network based on the connection result comprises:

Receiving an update connection instruction sent by the server, wherein the update connection instruction comprises the equipment number of the replacement node equipment corresponding to the abnormal node equipment;

Based on the equipment number of the replacement node equipment in the updated connection instruction, replacing the connected abnormal node equipment with the replacement node equipment to obtain an initial peer-to-peer network;

And if the connection result is that the connection is successful, storing the node information of the superior node equipment and the peer adjacent node equipment to obtain an initial peer-to-peer network, and feeding back the connection success information to the server.

3. A method as recited in claim 2, wherein if the connection result is that the connection is successful, storing node information of the upper node device and the peer neighboring node device, obtaining an initial peer-to-peer network, and feeding back connection success information to the server, and thereafter, the method includes:

4. A method as recited in claim 1, wherein performing heartbeat communication detection on the superior node device and peer neighboring node devices, updating the initial peer-to-peer network based on a heartbeat communication detection result, and obtaining an updated peer-to-peer network comprises:

If the heartbeat abnormality of the first node equipment in the superior node equipment and the peer adjacent node equipment is detected, sending the heartbeat abnormality result of the first node equipment to the server;

5. A method as recited in claim 1, wherein the detecting of heartbeat communications between the upper node device and the peer neighboring node device updates the initial peer-to-peer network based on a result of the detecting of heartbeat communications to obtain an updated peer-to-peer network, and wherein the method comprises:

And respectively sending the transmission data to superior node equipment and peer neighboring node equipment corresponding to the updated peer-to-peer network, so that the superior node equipment and the peer neighboring node equipment are utilized to send the transmission data to primary node equipment, the primary node equipment is directly connected with the server, and the primary node equipment is used for sending the received transmission data to the server.

6. A method as recited in claim 5, wherein said sending the transmission data to the corresponding upper node device and peer neighboring node device of the updated peer-to-peer network, respectively, comprises:

if the number of routes with the superior node device is smaller than a preset route threshold and the transmission data is not historical transmission data, the transmission data is sent to the superior node device,

If the number of routes between the peer neighboring node device and the peer neighboring node device is smaller than a preset route threshold value and the transmission data is not historical transmission data, updating the number of routes and sending the transmission data to the peer neighboring node device.

7. A data transmission method, wherein the method is applied to a server, the method comprising:

Determining the equipment numbers of superior node equipment and peer adjacent node equipment which need to be connected with the node equipment according to the equipment numbers of the node equipment;

8. A method as recited in claim 7, wherein the determining the device numbers of the upper node device and the peer neighboring node devices that need to be connected to the node device based on the device number of the node device comprises:

If the equipment number of the node equipment is smaller than or equal to a preset scale factor corresponding to a preset scale, determining equipment numbers of superior node equipment and peer adjacent node equipment which are required to be connected with the node equipment according to a node equipment list, wherein the preset scale factor is used for adjusting the number of the node equipment between the superior node equipment and the subordinate node equipment to accord with the preset scale;

If the equipment number of the node equipment is larger than the preset scale factor, determining the equipment numbers of the superior node equipment and the peer adjacent node equipment which are needed to be connected with the node equipment according to the equipment number of the node equipment and the preset scale factor.

9. A method as recited in claim 8, wherein the determining the device numbers of the upper node device and the peer neighboring node devices that need to be connected to the node device according to the device numbers of the node devices and the preset scale factor includes:

determining the hierarchy of the node equipment according to the equipment number of the node equipment and the preset scale factor;

Determining a first equipment number of a first node equipment in the hierarchy according to the hierarchy of the node equipment and the preset scale factor;

Determining the equipment number of the upper node equipment corresponding to the node equipment according to the first equipment number, the equipment number of the node equipment and the preset scale factor;

and determining the equipment number of the peer adjacent node equipment corresponding to the node equipment according to the equipment number of the node equipment and a preset scale factor.

10. The method of claim 9, wherein determining the hierarchy of the node devices based on the device number of the node device and the preset scale factor comprises:

According to the following formula 1, determining a hierarchy of the node device according to the device number of the node device and the preset scale factor:

Equation 1

Wherein L is the hierarchy of the node equipment, P is the equipment number of the node equipment, and N is the preset scale factor;

Wherein, according to the following formula 2, according to the hierarchy of the node device and the preset scale factor, determining a first device number in the hierarchy:

Equation 2

Wherein, A first device number of a first node device in the hierarchy of node devices is given, N is a preset scale factor, and L is the hierarchy of node devices;

According to the following formula 3, according to the first device number, the device number of the node device, and the preset scale factor, determining the device number of the upper node device corresponding to the node device:

equation 3

Wherein, The device number of the upper node device corresponding to the node device is given, P is the device number of the node device,And numbering a first device of a first node device in the hierarchy of the node devices, wherein N is a preset scale factor, and L is the hierarchy of the node devices.

11. A data transmission apparatus, the apparatus being applied to a node device, the apparatus comprising:

The construction unit is used for respectively establishing connection with the superior node equipment and the peer adjacent node equipment corresponding to the equipment number, and obtaining an initial peer-to-peer network according to a connection result, wherein the number of the node equipment between the superior node equipment and the subordinate node equipment in the initial peer-to-peer network accords with a preset proportion;

And the updating unit is used for carrying out heartbeat communication detection on the superior node equipment and the peer adjacent node equipment, updating the initial peer-to-peer network according to a heartbeat communication detection result, and obtaining an updated peer-to-peer network so as to realize data transmission between the node equipment and the server by utilizing the updated peer-to-peer network.

12. A data transmission apparatus, the apparatus being applied to a server, the apparatus comprising:

a first determining unit, configured to determine an equipment number of a node equipment according to a registration request time of the node equipment;

A second determining unit, configured to determine, according to the device number of the node device, device numbers of a superior node device and a peer neighboring node device that need to be connected to the node device;

And the sending unit is used for forming a connection instruction according to the equipment number and sending the connection instruction to the node equipment, wherein the connection instruction comprises equipment numbers of superior node equipment and peer adjacent node equipment which need to be connected with the node equipment.

13. An electronic device comprising a storage medium, a processor and a computer program stored on the storage medium and executable on the processor, characterized in that the processor implements the method of any one of claims 1 to 6 or 7 to 10 when executing the computer program.

14. A computer program product comprising a computer program which, when executed by a processor, implements the method of any one of claims 1 to 6 or claims 7 to 10.