CN112383473B - A method for establishing P2P direct connections between nodes in an auxiliary blockchain network - Google Patents

Abstract

The embodiment of this specification discloses a method for assisting nodes in a blockchain network to establish a P2P direct connection. Blockchain network includes P2P network and relay network. For several blockchain nodes belonging to the same intranet, relay nodes directly connected to these blockchain nodes can assist these nodes to establish P2P intranet connections based on private network addresses. After the P2P intranet connection is established, these blockchain nodes may obtain better network service quality when communicating through the P2P network. By assisting the establishment of some P2P direct connections that may improve network service quality, it helps to mine richer link optimization information.

Description

A method for establishing a P2P direct connection between nodes in an auxiliary blockchain network

Case Description

This application is a divisional application of the Chinese patent application CN202010534549.4 filed on June 12, 2020, entitled "Communication method in blockchain network, business data transmission method".

technical field

This specification relates to the field of communication, in particular to a method for assisting nodes in a blockchain network to establish a P2P direct connection.

Background technique

Due to the randomness of the distribution of nodes in the P2P (Peer to Peer, point-to-point) network, there are some problems in the P2P network, such as poor quality of service (Quality of Service, QoS) of some communication links and quality of service of communication links. . With the help of the fast transfer capability and stability of the relay network, the above-mentioned problems existing in the P2P network can be solved to a certain extent. However, since the same piece of data needs to be copied and transmitted in the relay network, it causes a waste of network bandwidth and machine resources, and affects the network processing capabilities of nodes to a certain extent.

Therefore, it is desirable to provide a network communication solution capable of reducing the amount of repeated data transmission.

Contents of the invention

One of the embodiments of this specification provides a method for assisting nodes in a blockchain network to establish a P2P direct connection. The blockchain network includes a P2P network and a relay network with communication connections. The method is executed by a certain relay node in the relay network, and the relay node is directly connected to at least two block chain nodes in the P2P network. The method includes: obtaining the public network addresses of the at least two blockchain nodes; judging whether the public network addresses of the at least two blockchain nodes are the same; if so, assisting the at least two blockchain nodes Establish a P2P direct connection. Wherein, said assisting said at least two blockchain nodes to establish a P2P direct connection includes: querying said at least two blockchain nodes for their respective private network addresses; - sending the private network addresses of other blockchain nodes, so that the at least two blockchain nodes establish a P2P direct connection based on the private network addresses.

One of the embodiments of this specification provides a system for assisting nodes in a blockchain network to establish a P2P direct connection. Wherein, the blockchain network includes a P2P network and a relay network with communication connections. The system is implemented on a certain relay node in the relay network, and the relay node is directly connected to at least two block chain nodes in the P2P network. The system includes: a public network address obtaining module for obtaining the public network addresses of the at least two blockchain nodes; a P2P direct connection assistance module for: judging the public network of the at least two blockchain nodes Whether the addresses are the same; if so, assisting the at least two blockchain nodes to establish a P2P direct connection. Wherein, said assisting said at least two blockchain nodes to establish a P2P direct connection includes: querying said at least two blockchain nodes for their respective private network addresses; - sending the private network addresses of other blockchain nodes, so that the at least two blockchain nodes establish a P2P direct connection based on the private network addresses.

One of the embodiments of this specification provides an apparatus for assisting nodes in a blockchain network to establish a P2P direct connection, including a processor and a storage device. The storage device is used to store instructions, and when the processor executes the instructions, the method for assisting nodes in the blockchain network to establish a P2P direct connection as described in any embodiment of this specification is implemented.

One of the embodiments of this specification provides a communication method in a blockchain network, wherein the blockchain network includes a P2P network and a relay network with communication connections, and the method is implemented by one of the P2P networks The block chain node executes, and the method includes: for any other block chain node in the P2P network: sending at least one first detection message to the other block chain node through the P2P network, receiving the At least one first response message returned by other blockchain nodes through the P2P network, the at least one first response message is in one-to-one correspondence with the at least one first detection message; according to the at least one first detection message The sending time and the receiving time of the at least one first response message determine the first quality of service data of the P2P network communication link between the certain block chain node and the other block chain nodes; through the The relay network sends at least one second detection message to the other blockchain nodes, and receives at least one second response message returned by the other blockchain nodes through the relay network, and the at least one second response message One-to-one correspondence with the at least one second detection message; according to the sending time of the at least one second detection message and the receiving time of the at least one second response message, obtain the connection between the certain block chain node and the The second quality of service data of the relay network communication link between other blockchain nodes; compare the first quality of service data and the second quality of service data; record the certain blockchain node according to the comparison result Link optimization information to the other block chain nodes, the link optimization information indicates that business data is transmitted from the certain block chain node to the other area through one of the P2P network and the relay network Blockchain nodes.

One of the embodiments of this specification provides a communication system in a block chain network, wherein the block chain network includes a P2P network and a relay network with communication connections, and the communication system in a certain part of the P2P network Realized on a block chain node, the communication system includes a first quality of service data acquisition module, a second service quality data acquisition module, a service quality data comparison module and a link optimization information recording module; for any in the P2P network One other block chain node: the first quality of service data obtaining module is used to: send at least one first detection message to the other block chain node through the P2P network, receive the other block chain node through the At least one first response message returned by the P2P network, according to the sending time of the at least one first detection message and the receiving time of the at least one first response message, determine the relationship between the certain block chain node and the other The first quality of service data of the P2P network communication link between blockchain nodes, wherein the at least one first response message corresponds to the at least one first detection message one by one; the second quality of service data is obtained The module is used to: send at least one second detection message to the other blockchain nodes through the relay network, and receive at least one second response message returned by the other blockchain nodes through the relay network, according to The sending time of the at least one second detection message and the receiving time of the at least one second response message obtain the relay network communication link between the certain blockchain node and the other blockchain nodes The second quality of service data, wherein, the at least one second response message is in one-to-one correspondence with the at least one second probe message; the first quality of service data obtaining module is used to compare the first quality of service data with The second quality of service data; the link optimization information recording module is used to record the link optimization information from the certain block chain node to the other block chain nodes according to the comparison result, and the link optimization information indicates The service data is transmitted from the certain block chain node to the other block chain node through one of the P2P network and the relay network.

One of the embodiments of this specification provides a communication device in a blockchain network, which includes a processor and a storage device, and the storage device is used to store instructions. When the processor executes the instructions, any A communication method described in an embodiment.

One of the embodiments of this specification provides a business data transmission method in a block chain network, wherein the block chain network includes a P2P network and a relay network with communication connections; the method is implemented by the P2P network Execution by a certain block chain node, which includes: obtaining the business data to be transmitted; determining the target block chain node of the business data; querying the link from the certain block chain node to the target block chain node Path optimization information, the link optimization information indicates that business data is transmitted from the certain blockchain node to the destination blockchain node through one of the P2P network and the relay network; One of the P2P network and the relay network transmits the service data to the destination blockchain node.

One of the embodiments of this specification provides a business data transmission system in a blockchain network, wherein the blockchain network includes a P2P network and a relay network with communication connections; the business data transmission system is in the P2P Implemented on a block chain node in the network, which includes: a first business data acquisition module, used to obtain the business data to be transmitted; a target block chain node determination module, used to determine the target block of the business data Chain node; link optimization information query module, used to query the link optimization information corresponding to the target block chain node from the certain block chain node, the link optimization information indicates that through the P2P network and the One of the relay networks transmits business data from the certain block chain node to the target block chain node; the first selection module is used to select the P2P network and the relay network according to the query result. - transmitting the business data to the target blockchain node.

One of the embodiments of this specification provides a business data transmission device in a blockchain network, which includes a processor and a storage device, and the storage device is used to store instructions. When the processor executes the instructions, the The business data transmission method performed by the blockchain node described in any embodiment of the description.

One of the embodiments of this specification provides a business data transmission method in a block chain network, wherein the block chain network includes a P2P network and a relay network with communication connections; the method is implemented by the relay network Executed by a certain relay node, the relay node is directly connected to at least two blockchain nodes in the P2P network; the method includes: obtaining a certain block from the at least two blockchain nodes The service data broadcast by the chain node; obtain the link optimization information reported by the certain block chain node; A block chain node is transmitted to other block chain nodes in the at least two block chain nodes; according to the link optimization information reported by the certain block chain node, whether to send the link optimization information to the at least two block chain nodes Other blockchain nodes in the node send the business data.

One of the embodiments of this specification provides a business data transmission system in a blockchain network, wherein the blockchain network includes a P2P network and a relay network with communication connections; the business data transmission system in the Realized on a relay node in the relay network, the relay node is directly connected to at least two block chain nodes in the P2P network; the service data transmission system includes: a second service data obtaining module for obtaining Business data broadcast from a certain blockchain node among the at least two blockchain nodes; a link optimization information obtaining module, configured to obtain link optimization information reported by the certain blockchain node; the The link optimization information indicates that service data is transmitted from the certain block chain node to other block chain nodes in the at least two block chain nodes through one of the P2P network and the relay network; A selection module, configured to select whether to send the business data to other blockchain nodes among the at least two blockchain nodes according to the link optimization information reported by the certain blockchain node.

One of the embodiments of this specification provides a business data transmission device in a blockchain network, which includes a processor and a storage device, and the storage device is used to store instructions. When the processor executes the instructions, the The service data transmission method performed by the relay node described in any embodiment of the description.

Description of drawings

This specification will be further illustrated by way of exemplary embodiments, which will be described in detail with the accompanying drawings. These examples are non-limiting, and in these examples, the same number indicates the same structure, wherein:

FIG. 1 is a topological diagram of a block chain network according to some embodiments of this specification;

Fig. 2 is a schematic diagram of establishing a P2P direct connection between auxiliary blockchain nodes according to some embodiments of this specification;

Fig. 3 is an exemplary flow chart of a communication method in a blockchain network according to some embodiments of this specification;

Fig. 4 is a schematic diagram of a unicast mode of service data according to some embodiments of this specification;

Fig. 5 is a schematic diagram of a broadcasting manner of service data according to some embodiments of this specification;

Fig. 6 is a block diagram of a communication system in a blockchain network according to some embodiments of this specification;

7 is a block diagram of a business data transmission system in a blockchain network according to some embodiments of this specification;

Fig. 8 is a block diagram of a business data transmission system in a blockchain network according to some embodiments of this specification.

Detailed ways

In order to more clearly illustrate the technical solutions of the embodiments of the present specification, the following briefly introduces the drawings that need to be used in the description of the embodiments. Apparently, the accompanying drawings in the following description are only some examples or embodiments of this specification, and those skilled in the art can also apply this specification to other similar scenarios. Unless otherwise apparent from context or otherwise indicated, like reference numerals in the figures represent like structures or operations.

It should be understood that "system", "device", "unit" and/or "module" as used herein is a method for distinguishing different components, elements, components, parts or assemblies of different levels. However, the words may be replaced by other expressions if other words can achieve the same purpose.

As indicated in this specification, words such as "a", "an", "an" and/or "the" are not specific to the singular and may include the plural unless the context clearly indicates an exception. Generally speaking, the terms "comprising" and "comprising" only suggest the inclusion of clearly identified steps and elements, and these steps and elements do not constitute an exclusive list, and the method or device may also contain other steps or elements.

The flowchart is used in this specification to illustrate the operations performed by the system according to the embodiment of this specification. It should be understood that the preceding or following operations are not necessarily performed in the exact order. Instead, various steps may be processed in reverse order or simultaneously. At the same time, other operations can be added to these procedures, or a certain step or steps can be removed from these procedures.

Fig. 1 is a topological diagram of a blockchain network according to some embodiments of this specification. As shown in Figure 1, a blockchain network may include a P2P network and a relay network with communication connections.

The full name of P2P is peer-to-peer network (peer-to-peer), also known as peer-to-peer technology. It is an Internet system that has no central server and relies on user groups (peers) to exchange information. Different from the central network system with a central server, each client of the peer-to-peer network is not only a node, but also has the function of a server. The central server means that when attacked, once the central server goes down, the entire network and services will have problems. The advantage of the P2P network is that each node is both a client and a server, so when it is attacked, any machine crashes without affecting the overall service. The core of the blockchain is decentralization, which coincides with the concept of the P2P network, so the blockchain network generally uses P2P as the underlying implementation, including most public chains and alliance chains that use similar underlying implementations.

In the blockchain network, the underlying P2P network can include one or more P2P nodes. Such a P2P node is generally also a node in the blockchain network, as shown in Figure 1. Nodes A, B, ... , G, H. A relay network (relay for short) may include one or more relay nodes, such as relay1, relay2, relay3, and relay4 shown in FIG. 1 .

It should be noted that the "direct connection" (referred to as "direct connection") in this specification means that there is no other node connection between two nodes, in other words, there is a connection between two nodes that are not directly connected (that is, indirectly connected). There are also other nodes connected between them. For example, as shown in FIG. 1 , node A is directly connected to nodes C and D, nodes A, B, and C are directly connected to relay1, and node A is indirectly connected to nodes B, E, F, G, and H respectively. In addition, in Figure 1, Figure 3, Figure 4, and Figure 5, the one-way arrow pointing from the blockchain node to the relay node indicates that the communication connection between the blockchain node and the relay node can be actively initiated by the blockchain node Yes, it should be understood that two-way communication is possible between blockchain nodes and relay nodes.

The relay network has fast transfer capability and is relatively stable, which can make up for the poor service quality of the P2P network in some cases. The network service quality may be measured based on a quality of service (Quality of Service, QoS) element such as a message transmission delay. Take the transmission delay as an example. For example, if node A wants to send a message to node E, the delay between sending a message from node A and receiving the message from node E is smaller, or from sending a message to node A receiving feedback from node E. The smaller the message delay, the better the service quality of the link transmitting the message.

In some embodiments, the blockchain node can transmit the same service data through the links in the P2P network and the relay network respectively. Correspondingly, the destination blockchain node of the service data can receive the service data first as Valid data is retained, and the business data received later is discarded as invalid data. Among them, repeated data sending and receiving causes waste of network bandwidth and machine resources, and also affects the network processing capability of nodes to a certain extent. In a blockchain network, business data may include one or more of transaction records (referred to as transactions), request messages, and response messages.

For this reason, the embodiments in this specification can not only ensure the low-latency transmission of business data by assisting in the establishment of P2P direct connections between blockchain nodes, recording link optimization information, and selecting better links based on link optimization information. , can also effectively reduce repeated data sending and receiving (transmission), thereby saving network bandwidth and machine resources and reducing the impact on node network processing capabilities.

Fig. 2 is a schematic diagram of establishing a P2P direct connection between auxiliary blockchain nodes according to some embodiments of this specification. For parts in FIG. 2 that are the same as those in FIG. 1 , reference may be made to FIG. 1 and related descriptions.

In some embodiments, for several blockchain nodes belonging to the same Intranet (enterprise internal network, which may be referred to as intranet for short), the relay nodes directly connected to these blockchain nodes can assist these nodes to establish private-based A P2P subnet connection (may be called a P2P intranet connection) of a network address (or called an intranet address). After the P2P intranet connection is established, these blockchain nodes may obtain better network service quality (eg, low latency, large bandwidth) when communicating through the P2P network.

Specifically, after the blockchain node establishes a direct connection with the relay node, the relay node can obtain the public network address of the blockchain node. The relay node directly connected to the at least two blockchain nodes can obtain the external network addresses of the at least two blockchain nodes, and determine whether the external network addresses of the at least two blockchain nodes are the same. If they are the same, it means that the at least two blockchain nodes belong to the same intranet (the external network address of the same intranet device is the same), then the relay node can query the respective intranets from the at least two blockchain nodes address, and at least send the intranet addresses of other blockchain nodes to one of the at least two blockchain nodes, so that the at least two blockchain nodes can establish a P2P direct connection based on the intranet address.

Referring to Figure 2, assuming that nodes A, B, and C belong to the same intranet (marked by a dotted circle in Figure 2) and nodes A, B, and C are all directly connected to relay1, then relay1 can obtain the external network of nodes A, B, and C address, when relay1 finds that the external network addresses of nodes A, B, and C are the same, it can inquire about its internal network address from one or more of nodes A, B, and C, and send a query to one or more of nodes A, B, and C Multiple (can be each) send the intranet address of the remaining blockchain nodes. For example, relay1 may send the intranet addresses of nodes B and C to node A, so that node A initiates a P2P direct connection to nodes B and C based on the intranet addresses of nodes B and C. For another example, relay1 may send the internal network address of node A to node B and C respectively, so that node B and C initiate a P2P direct connection to node A based on the internal network address of node A respectively.

After assisting nodes A, B, and C to establish a P2P subnet connection, if relay1 finds that the newly connected blockchain node has the same external network address as nodes A, B, and C, relay1 can transfer the previously queried nodes to The intranet addresses of A, B, and C are all sent to the newly connected blockchain nodes, so that the newly connected blockchain nodes initiate P2P to nodes A, B, and C based on the intranet addresses of nodes A, B, and C, respectively. direct connection. It can also be that relay1 initiates a request to inquire the intranet address of the newly connected blockchain node, and sends the intranet address of the newly connected blockchain node to nodes A, B, and C respectively, so that nodes A, B C and C respectively initiate a P2P direct connection to the newly connected blockchain node based on the intranet address of the newly connected blockchain node.

In some embodiments, for several blockchain nodes with close geographical locations, the relay nodes directly connected to these blockchain nodes can assist these nodes to establish P2P subnet connections based on external network addresses. Due to the geographical proximity of these blockchain nodes, communication through the P2P network after establishing a P2P direct connection with each other may obtain better network service quality (eg, low latency, large bandwidth).

Specifically, for at least two blockchain nodes, the relay node directly connected to the at least two blockchain nodes can obtain the external network addresses of the at least two blockchain nodes, and based on the at least two The external network addresses of the two blockchain nodes determine the geographic location information of the at least two blockchain nodes. Furthermore, the relay node can determine whether the geographical locations of the at least two blockchain nodes are close according to the geographic location information of the at least two blockchain nodes, and if they are close, assist the at least two blockchain nodes Establish a P2P subnet connection. Wherein, the method of assisting the at least two blockchain nodes to establish a P2P connection may include: at least sending the external network addresses of other blockchain nodes to one of the at least two blockchain nodes, so that the at least two blockchain nodes A blockchain node establishes a P2P direct connection based on the external network address.

In some embodiments, the geographic location information may include geographic coordinates (such as latitude and longitude), and when the relay node finds that the distance between any two of the two blockchain nodes (can be calculated according to the coordinates) is less than the distance threshold, It can be considered that the geographical location of the two is close. In some embodiments, the geographic location information may include place names (such as city names) in the physical world. When any two blockchain nodes are found to be located in the same city, they may also be considered to be geographically close.

Referring to Figure 2, assuming that nodes E, H, and G are all directly connected to relay4, relay4 can obtain the external network addresses of nodes E, H, and G. When relay4 finds the addresses of nodes E and H, nodes H and G, and nodes G and E When the distance is less than the distance threshold, or when nodes E and H, nodes H and G, and nodes G and E are found to belong to the same city, relay4 can send the external network address of node H (or E) to node E (or H), and send Node H (or G) sends the external network address of node G (or H), and sends the external network address of node E (or G) to node G (or E), so that nodes E and H, nodes H and G, Nodes G and E respectively establish P2P direct connections based on external network addresses.

In some embodiments, the network address mentioned in this specification may be an IP address. In some embodiments, the relay node may query the geographic location information corresponding to the IP address in the IP geographic information database, where the geographic location information corresponding to each IP address is stored.

It should be understood that the blockchain nodes that the relay node assists in establishing the P2P subnet connection may include the blockchain nodes that have established the P2P direct connection. For example, referring to FIG. 1 and FIG. 2 together, before the relay node assists nodes A, B, and C to establish a P2P intranet connection, nodes A and C have established a P2P direct connection. If the nodes A and B have established the P2P direct connection based on the intranet address, the nodes A and B do not need to initiate the P2P direct connection based on the intranet address. If nodes A and B establish a P2P direct connection based on an external network address, nodes A and B can re-establish a P2P direct connection based on an internal network address.

By assisting the establishment of some P2P direct connections that may improve network service quality, it helps to mine richer link optimization information. For details of the link optimization information, refer to FIG. 3 and related descriptions.

Fig. 3 is an exemplary flowchart of a communication method in a blockchain network according to some embodiments of this specification. The process 300 can be executed by any blockchain node (denoted as node X) in the P2P network to obtain link optimization information from node X to any other blockchain node (denoted as node Y). The link optimization information indicates that the service data is transmitted from the node X to the node Y through one of the P2P network and the relay network. In some embodiments, the process 300 can be implemented by the system 600 shown in FIG. 6 . As shown in Figure 3, the process 300 may include:

Step 310, sending at least one first detection message to node Y through the P2P network.

Step 320, receiving at least one first response message returned by node Y through the P2P network.

The at least one first response message is in one-to-one correspondence with the at least one first detection message. In some embodiments, a single probe message (first probe message/second probe message) and its corresponding response message (first response message/second response message) may contain the same tag (eg, message number).

In some embodiments, the sending node may continuously (eg, periodically) send the probe message to the receiving node. For example, the probe message may be a heartbeat message in the P2P network for the sending node to confirm whether the receiving node is online/failed/currently available.

Step 330: Obtain first quality of service data of the P2P network communication link between node X and node Y according to the sending time of the at least one first probe message and the receiving time of the at least one first response message.

In some embodiments, the QoS data of any network (P2P network/relay network) link can be determined based on the round-trip time delay (Round-TripTime, RTT) of a message pair (including a probe message and a response message corresponding to each other). It should be understood that, for any message pair, the RTT of the message pair can be obtained by subtracting the sending time of the detection message in the message pair from the receiving time of the response message in the message pair.

It is worth noting that the quality of service of the network communication link in one-way communication and two-way communication can be considered to be stable, so the round-trip delay can be used to measure the network communication link service covering both one-way communication and two-way communication quality.

Node X can continuously send detection messages to dynamically detect the service quality of the communication link between node X and node Y. Correspondingly, node X can continuously calculate the RTT of multiple message pairs, and then node X can make statistics based on the round-trip delay of each message pair to obtain the service quality data of the network communication link between node X and node Y. In some embodiments, node X may accumulate round-trip delays of each message pair according to a smoothing algorithm to obtain continuously updated QoS data (also referred to as accumulated round-trip delay). Specifically, node X can update the QoS data according to SRTT=(alpha*SRTT)+((1-alpha)*RTT) (that is, the cumulative round-trip delay), where the SRTT around the equal sign represents the cumulative round-trip delay before and after the update , alpha is a preset weight coefficient (0<alpha<1), and RTT represents the currently calculated round-trip delay of a certain message pair. Normally, the value of alpha can be close to 1 (correspondingly, 1-alpha is close to 0), for example, alpha=0.9, to avoid short-term fluctuations of network service quality (reflected on a single RTT) and make the overall QoS data value appear large fluctuations.

Step 340, sending at least one second detection message to node Y through the relay network.

Step 350, receiving at least one second response message returned by node Y through the relay network.

Step 360, according to the sending time of the at least one second probe message and the receiving time of the at least one second response message, obtain second quality of service data of the relay network communication link between node X and node Y.

For details about obtaining the second quality of service (QoS) data, reference may be made to the related description of obtaining the first quality of service data (steps 310-330).

Step 370, comparing the first quality of service data with the second quality of service data.

Step 380, record link optimization information from node X to node Y according to the comparison result.

The quality of service data is associated with the starting and ending nodes (ie node X and node Y) and the network where the communication link is located (P2P network/relay network). The first quality of service (QoS) data corresponds to the P2P network, and the second quality of service (QoS) data corresponds to the relay network. By comparing the first QoS data and the second QoS data, it can be determined which is the better choice between the communication link of the P2P network and the communication link of the relay network. Therefore, node X may record link optimization data indicating to transmit service data from node X to node Y through one of the P2P network and the relay network according to the comparison result. The nodes in the blockchain network (blockchain nodes/relay nodes) may not send business data to the destination blockchain through the communication link of the network with poor service quality (P2P network/relay network) according to the link optimization data Nodes, which can reduce the amount of repeated data sending and receiving.

In some embodiments, the link optimization information may indicate that service data is transmitted from node X to node Y through one of the P2P network and the relay network by setting different flags, for example, "0" is used in the link optimization information One of "0" and "1" indicates that the service data is transmitted through the P2P network, and the other of "0" and "1" indicates that the service data is transmitted through the relay network.

In some embodiments, node X may only record the link optimization information indicating that the service data is transmitted from node X to node Y through the P2P network, that is, when the link optimization information about node Y (as the destination node) cannot be queried , it means that the service data can be transmitted from node X to node Y through the relay network to obtain better quality of service. Specifically, the link optimization information indicating that the service data is transmitted from node X to node Y through the P2P network may include identification information of node Y. Correspondingly, when the link optimization information including the identification information of node Y (as the destination node) cannot be queried, it means that the service data can be transmitted from node X to node Y through the P2P network to obtain better service quality.

Similarly, in some other embodiments, node X may only record the link optimization information indicating that the service data is transmitted from node X to node Y through the relay network, that is, when the relevant node Y (as the destination node) cannot be queried When the link optimization information is obtained, it means that the service data can be transmitted from node X to node Y through the P2P network to obtain better service quality. Specifically, the link optimization information indicating that the service data is transmitted from node X to node Y through the relay network may include identification information of node Y. Correspondingly, when the link optimization information including the identification information of node Y (as the destination node) cannot be queried, it means that the service data can be transmitted from node X to node Y through the relay network to obtain better service quality.

In some embodiments, node X can create a link optimization table for saving link optimization information from node X to each other blockchain node, and the link optimization table can follow the link optimization information from node X to each node dynamic updates. Referring to the foregoing, in some embodiments, it may be: for any node, when the link optimization table saved by node X contains the identification information of the node, it means that the service data is transmitted from node X to the node through the P2P network A better quality of service can be obtained. In some other embodiments, it may also be: for any node, when the link optimization table saved by node X contains the identification information of the node, it means that the service data can be transmitted from node X to the node through the relay network Get better quality of service.

For business data (i.e. unicast messages) sent to a designated blockchain node (single destination blockchain node), node X can choose to pass through the P2P network or relay according to the link optimization information from node X to the destination blockchain node The network transmits the business data to the destination blockchain node. That is, for unicast service data, if node X chooses to transmit the service data through one of the P2P network and the relay network according to the query link optimization information, it does not need to transmit the service data through the other of the P2P network and the relay network. The service data can reduce repeated sending and receiving of data. Specifically, node X can obtain the business data to be transmitted, and determine the destination blockchain node of the business data. Furthermore, node X can query the link optimization information corresponding to the target block chain node (refer to the aforementioned node Y), and choose to transmit the business data to the target block through one of the P2P network and the relay network according to the query result chain node. For more details about link optimization information, refer to FIG. 3 and related descriptions.

The unicast of service data is illustrated below with reference to FIG. 4 . As shown in Figure 4, the link optimization table saved by node A (identified by list in Figure 4) contains the identification information of nodes B, C, and F, and the link optimization table will save the other blockchain nodes except node A Divided into two parts, the first part contains nodes B, C, F, and the second part contains nodes D, E, G, H.

If the link optimization table indicates that the business data is transmitted from node A to the blockchain nodes belonging to the first part through the P2P network, node A will choose to send the business data to the blockchain nodes belonging to the first part through the P2P network, and through The relay network sends the business data to the blockchain nodes belonging to the second part. For example, as shown in Figure 4, node A wants to send business data data1 to node F, node A will not send data1 to the directly connected relay1, but will send data1 to data1 is sent to node F.

If the link optimization table indicates that the business data is transmitted from node A to the blockchain nodes belonging to the first part through the relay network, node A will choose to send the business data to the blockchain nodes belonging to the first part through the relay network, And send the business data to the blockchain nodes belonging to the second part through the relay network. Still taking data1 to be sent to node F as an example, node A will send data1 to node F through a certain communication link in the relay network.

In some embodiments, node X can report the link optimization information from node X to the target blockchain node to the same relay node, wherein the target blockchain node is directly connected to the same relay node as node X Blockchain nodes. In this way, the relay node can determine whether to send the service data broadcast by node X to the directly connected target blockchain node according to the link optimization information reported by node X. Among them, if the link optimization information reported by node X indicates that the business data is transmitted to the target blockchain node through the P2P network, the relay node can no longer send broadcast business data to the target blockchain node, which can reduce data duplication send and receive. It should be understood that since the link optimization information can be continuously updated, node X can report the updated link optimization information to the directly connected relay node, so as to realize the synchronization of the link optimization information.

The broadcast of service data will be illustrated below with reference to FIG. 5 . As shown in Figure 5, the link optimization table saved by node A (identified by list in Figure 5) contains the identification information of nodes C and E, and the link optimization table divides the rest of the blockchain nodes except node A into Two parts, the first part includes nodes C and E (node C is the target blockchain node directly connected to relay1 with node A), and the second part includes nodes B, D, F, G, and H. Node A can report the link optimization table missing the identification information of node E (corresponding to the list containing only C in Figure 5) to the directly connected relay1. Of course, node A can also report the complete link optimization table to the directly connected relay1.

If the link optimization table indicates that the business data is transmitted from node A to the blockchain node belonging to the first part through the P2P network, as shown in Figure 5, after relay1 receives the broadcast business data data2, it can check the chain link reported by node A. Whether the link optimization table contains the identification information of the blockchain node directly connected to relay1. When it is found that the link optimization table reported by node A contains the identification information of node C, relay1 can transfer a copy of data2 to node B but not to Node C transfers a copy of data2.

If the link optimization table indicates that the business data is transmitted from node A to the blockchain nodes belonging to the first part through the relay network, after relay1 receives the broadcast business data data2, it can check whether the link optimization table reported by node A is Contains the identification information of the blockchain node directly connected to relay1. When it is found that the link optimization table reported by node A contains the identification information of node C, relay1 can transfer a copy of data2 to node C but not transfer a copy to node B data2.

After POC (Proof of Concept, proof of concept) verification, it is found that with the help of the method of establishing P2P direct connection between auxiliary blockchain nodes, the communication method in the blockchain network, and the business data transmission method provided by the embodiment of this manual, synchronous transactions, The speed of the block is significantly improved (the average consensus delay is significantly reduced), and more than 40% of bandwidth can be saved.

It should be noted that, the above descriptions about the process are only for illustration and description, and do not limit the scope of application of this specification. For those skilled in the art, various modifications and changes can be made to the flow under the guidance of this specification. However, such modifications and changes are still within the scope of this specification.

Fig. 6 is a block diagram of a communication system in a blockchain network according to some embodiments of this specification. The system 600 can be implemented on a certain blockchain node (denoted as node X) in the P2P network, and is used to obtain link optimization information from node X to any other blockchain node (denoted as node Y). As shown in FIG. 6 , the system 600 may include a first QoS data obtaining module 610 , a second QoS data obtaining module 620 , a QoS data comparing module 630 and a link optimization information recording module 640 .

The first quality of service data obtaining module 610 may be configured to: send at least one first probe message to node Y through the P2P network, receive at least one first response message returned by node Y through the P2P network, and according to the at least one first probe message The sending time of the at least one first response message and the receiving time of the at least one first response message are used to obtain the first quality of service data of the P2P network communication link between node X and node Y.

The second quality of service data obtaining module 620 may be configured to: send at least one second detection message to node Y through the relay network, receive at least one second response message returned by node Y through the relay network, and according to the at least one second The sending time of the probe message and the receiving time of the at least one second response message obtain the second quality of service data of the relay network communication link between node X and node Y.

The QoS data comparing module 630 may be used for comparing the first QoS data and the second QoS data.

The link optimization information recording module 640 may be configured to record link optimization information from node X to node Y according to the comparison result.

For more details about the system 600 and its modules, refer to FIG. 3 and related descriptions.

Fig. 7 is a block diagram of a communication system in a blockchain network according to some embodiments of this specification. System 700 can be implemented on a certain block chain node in the P2P network. As shown in FIG. 7 , the system 700 may include a first business data acquisition module 710 , a destination blockchain node determination module 720 , a link optimization information query module 730 and a first selection module 740 .

The first service data obtaining module 710 may be used to obtain service data to be transmitted.

The destination blockchain node determining module 720 can be used to determine the destination blockchain node of the business data.

The link optimization information query module 730 can be used to query the link optimization information corresponding to the target blockchain node from the certain block chain node, and the link optimization information indicates that one of the P2P network and the relay network will The service data is transmitted from the certain block chain node to the target block chain node.

The first selection module 740 may be configured to select one of a P2P network and a relay network to transmit the service data to the target blockchain node according to the query result.

For more details about the system 700 and its modules, refer to FIG. 4 and related descriptions.

Fig. 8 is a block diagram of a communication system in a blockchain network according to some embodiments of this specification. The system 800 can be implemented on a certain relay node in the relay network, and the relay node is directly connected to at least two blockchain nodes in the P2P network. As shown in FIG. 8 , the system 800 may include a second service data obtaining module 810 , a link optimization information obtaining module 820 and a second selection module 830 .

The second service data obtaining module 810 may be configured to obtain service data broadcast from a certain block chain node among the at least two block chain nodes.

The link optimization information obtaining module 820 can be used to obtain the link optimization information reported by the certain block chain node.

The second selection module 830 may be configured to select whether to send the service data to other blockchain nodes among the at least two blockchain nodes according to the link optimization information reported by the certain blockchain node.

For more details about the system 800 and its modules, reference may be made to FIG. 5 and its related descriptions.

It should be understood that the systems and modules thereof shown in FIGS. 6-8 can be implemented in various ways. For example, in some embodiments, the system and its modules may be implemented by hardware, software, or a combination of software and hardware. Wherein, the hardware part can be implemented by using dedicated logic; the software part can be stored in a memory and executed by an appropriate instruction execution system, such as a microprocessor or specially designed hardware. Those skilled in the art will appreciate that the methods and systems described above can be implemented using computer-executable instructions and/or contained in processor control code, for example on a carrier medium such as a magnetic disk, CD or DVD-ROM, such as a read-only memory (firmware ) or on a data carrier such as an optical or electronic signal carrier. The system and its modules in this specification can not only be realized by hardware circuits such as very large scale integrated circuits or gate arrays, semiconductors such as logic chips, transistors, etc., or programmable hardware devices such as field programmable gate arrays, programmable logic devices, etc. , can also be realized by software executed by various types of processors, for example, and can also be realized by a combination of the above-mentioned hardware circuits and software (for example, firmware).

It should be noted that the above description of the system and its modules is only for convenience of description, and does not limit this description to the scope of the illustrated embodiments. It can be understood that for those skilled in the art, after understanding the principle of the system, it is possible to combine various modules arbitrarily, or form a subsystem to connect with other modules without departing from this principle. For example, in some embodiments, the first QoS data obtaining module 610 and the second QoS data obtaining module 620 shown in FIG. 6 may be different modules in one system, or one module may implement the two modules. Function. As another example, in some embodiments, the first service data obtaining module 710 and the target blockchain node determining module 720 shown in FIG. 7 may be two modules, or may be combined into one module. Such deformations are within the protection scope of this specification.

The possible beneficial effects of the embodiments of this specification include but are not limited to: (1) By assisting the establishment of some P2P direct connections that may improve the quality of network service, it is helpful to mine richer link optimization information; (2) by recording Link optimization information helps to select a better network communication link to transmit business data, and can reduce repeated data sending and receiving, thereby saving network bandwidth and machine resources and reducing the impact on node network processing capabilities. It should be noted that different embodiments may have different beneficial effects. In different embodiments, the possible beneficial effects may be any one or a combination of the above, or any other possible beneficial effects.

The basic concepts have been described above. Obviously, for those skilled in the art, the above detailed disclosure is only an example, and does not constitute a limitation to the embodiment of this specification. Although not explicitly stated here, those skilled in the art may make various modifications, improvements and amendments to the embodiments of this specification. Such modifications, improvements and corrections are suggested in the embodiments of this specification, so such modifications, improvements and corrections still belong to the spirit and scope of the exemplary embodiments of this specification.

Meanwhile, this specification uses specific words to describe the embodiments of this specification. For example, "one embodiment", "an embodiment", and/or "some embodiments" refer to a certain feature, structure or characteristic related to at least one embodiment of this specification. Therefore, it should be emphasized and noted that two or more references to "an embodiment" or "an embodiment" or "an alternative embodiment" in different places in this specification do not necessarily refer to the same embodiment . In addition, certain features, structures or characteristics in one or more embodiments of this specification may be properly combined.

In addition, those skilled in the art will understand that all aspects of the embodiments of this specification can be illustrated and described by several patentable categories or situations, including any new and useful process, machine, product or combination of substances, or Any new and useful improvements to them. Correspondingly, various aspects of the embodiments of this specification may be completely executed by hardware, may be completely executed by software (including firmware, resident software, microcode, etc.), or may be executed by a combination of hardware and software. The above hardware or software may be referred to as "block", "module", "engine", "unit", "component" or "system". In addition, aspects of the embodiments of this specification may be embodied as a computer product on one or more computer-readable media, the product including computer-readable program code.

A computer storage medium may contain a propagated data signal embodying a computer program code, for example, in baseband or as part of a carrier wave. The propagated signal may have various manifestations, including electromagnetic form, optical form, etc., or a suitable combination. A computer storage medium may be any computer-readable medium, other than a computer-readable storage medium, that can be used to communicate, propagate, or transfer a program for use by being coupled to an instruction execution system, apparatus, or device. Program code residing on a computer storage medium may be transmitted over any suitable medium, including radio, electrical cable, fiber optic cable, RF, or the like, or combinations of any of the foregoing.

The computer program codes required for the operation of each part of the embodiments of this specification can be written in any one or more programming languages, including object-oriented programming languages such as Java, Scala, Smalltalk, Eiffel, JADE, Emerald, C++, C#, VB.NET , Python, etc., conventional programming languages such as C language, VisualBasic, Fortran2003, Perl, COBOL2002, PHP, ABAP, dynamic programming languages such as Python, Ruby and Groovy, or other programming languages. The program code may run entirely on the user's computer, or as a stand-alone software package, or run partly on the user's computer and partly on a remote computer, or entirely on the remote computer or processing device. In the latter case, the remote computer can be connected to the user computer through any form of network, such as a local area network (LAN) or wide area network (WAN), or to an external computer (such as through the Internet), or in a cloud computing environment, or as a service Use software as a service (SaaS).

In addition, unless clearly stated in the claims, the sequence of processing elements and sequences, the use of numbers and letters, or the use of other names in the embodiments of this specification are not used to limit the sequence of the processes and methods of the embodiments of this specification. While the foregoing disclosure has discussed by way of various examples some embodiments of the invention that are presently believed to be useful, it should be understood that such detail is for illustrative purposes only and that the appended claims are not limited to the disclosed embodiments, but rather, the claims The claims are intended to cover all modifications and equivalent combinations that fall within the spirit and scope of the embodiments of this specification. For example, while the system components described above may be implemented as hardware devices, they may also be implemented as a software-only solution, such as installing the described system on an existing processing device or mobile device.

Similarly, it should be noted that, in order to simplify the description of the disclosure of the embodiments of this specification, so as to facilitate the understanding of one or more embodiments of the invention, in the foregoing descriptions of the embodiments of this specification, sometimes multiple features are combined into one implementation examples, drawings or descriptions thereof. However, this method of disclosure does not imply that the embodiments of the present specification require more features than those recited in the claims. Indeed, embodiment features are less than all features of a single foregoing disclosed embodiment.

Each patent, patent application, patent application publication, and other material, such as article, book, specification, publication, document, etc., cited in this specification is hereby incorporated by reference in its entirety. Application history documents that are inconsistent with or conflict with the content of this specification are excluded, and documents (currently or later appended to this specification) that limit the broadest scope of the claims of this specification are also excluded. It should be noted that if there is any inconsistency or conflict between the descriptions, definitions, and/or terms used in the accompanying materials of this manual and the contents of this manual, the descriptions, definitions and/or terms used in this manual shall prevail .

Finally, it should be understood that the embodiments described in this specification are only used to illustrate the principles of the embodiments of this specification. Other modifications may also fall within the scope of the embodiments of this specification. Therefore, by way of example and not limitation, alternative configurations of the embodiments of this specification may be considered consistent with the teachings of this specification. Accordingly, the embodiments of this specification are not limited to the embodiments explicitly introduced and described in this specification.

Claims (9)

1. A method for assisting a node in a blockchain network to establish P2P direct connection is provided, wherein the blockchain network comprises a P2P network with communication connection and a relay network; the method is executed by a relay node in the relay network, and the relay node is directly connected with at least two block chain nodes in a P2P network; the method comprises the following steps:

obtaining a common network address of the at least two blockchain nodes;

judging whether the public network addresses of the at least two block chain nodes are the same; if so, assisting the at least two block link points to establish P2P direct connection;

wherein the assisting the at least two blockchain nodes to establish the P2P direct connection comprises: querying the at least two blockchain nodes for respective private network addresses; and at least sending the private network addresses of other blockchain nodes to one of the at least two blockchain nodes, so that the at least two blockchain nodes establish the P2P direct connection based on the private network addresses.

2. The method of claim 1, further comprising:

obtaining service data broadcasted by a certain block chain node in the at least two block chain nodes;

obtaining link optimization information reported by the link point of the certain block; the link optimization information indicates that traffic data is transmitted from the certain blockchain node to other blockchain nodes of the at least two blockchain nodes through one of the P2P network and the relay network;

and selecting whether to send the service data to other block chain nodes in the at least two block chain nodes according to the link optimization information reported by the certain block chain node.

3. The method of claim 2, wherein the link optimization information is obtained by a certain block link point in the P2P network:

for any other blockchain node in the P2P network:

sending at least one first probe message to the other blockchain nodes through the P2P network, and receiving at least one first response message returned by the other blockchain nodes through the P2P network, wherein the at least one first response message corresponds to the at least one first probe message one to one; determining first quality of service data of P2P network communication links between the certain block chain node and the other block chain nodes according to the sending time of the at least one first probe message and the receiving time of the at least one first response message;

sending at least one second probe message to the other blockchain nodes through the relay network, and receiving at least one second response message returned by the other blockchain nodes through the relay network, wherein the at least one second response message corresponds to the at least one second probe message one to one; obtaining second quality of service data of a relay network communication link between the certain block link node and the other block link nodes according to the sending time of the at least one second probe message and the receiving time of the at least one second response message;

comparing the first quality of service data and the second quality of service data;

and recording link optimization information from the certain blockchain node to the other blockchain nodes according to the comparison result, wherein the link optimization information indicates that service data is transmitted from the certain blockchain node to the other blockchain nodes through one of the P2P network and the relay network.

4. The method of claim 3, wherein the determining first quality of service data for the P2P network communication link between the certain block chain node and the other block chain nodes based on the transmission time of the at least one first probe message and the reception time of the at least one first response message comprises:

acquiring at least one first message pair, wherein the first message pair comprises a first detection message and a first response message which correspond to each other; determining a round trip delay of the at least one first message pair based on a transmission time of the at least one first probe message and a reception time of the at least one first response message; counting round trip delay based on the at least one first message pair to obtain the first quality of service data;

the determining, according to the sending time of the at least one second probe message and the receiving time of the at least one second response message, second quality of service data of the P2P network communication link between the certain block link node and the other block link nodes includes:

acquiring at least one second message pair, wherein the second message pair comprises a second detection message and a second response message which correspond to each other; determining a round trip delay of the at least one second message pair based on a transmission time of the at least one second probe message and a reception time of the at least one second response message; and counting the round trip delay based on the at least one second message pair to obtain the second service quality data.

5. The method of claim 4, wherein the counting round trip delays based on the at least one first message pair comprises: accumulating the round trip delay of the at least one first message pair using a smoothing algorithm;

the counting round trip delays based on the at least one second message pair comprises: accumulating the round trip delay of the at least one second message pair using a smoothing algorithm.

6. The method of claim 3, further comprising:

establishing a link optimization table, wherein the link optimization table is used for storing link optimization information from the certain block chain node to each other block chain node; and the link optimization table is dynamically updated along with the link optimization information from the certain blockchain node to each other blockchain node.

7. The method of claim 6, wherein the link optimization table includes identification information of at least one of the other blockchain nodes to indicate transmission of traffic data from the certain blockchain node to the at least one blockchain node through one of the P2P network and the relay network.

8. A system that assists nodes in a blockchain network to establish P2P direct, wherein the blockchain network includes a P2P network with communication connections and a relay network; the system is realized on a relay node in the relay network, and the relay node is directly connected with at least two block chain nodes in a P2P network; the system comprises:

a public network address obtaining module, configured to obtain public network addresses of the at least two block link nodes;

a P2P direct connection assistance module to: judging whether the public network addresses of the at least two block chain nodes are the same or not; if so, assisting the at least two block link points to establish P2P direct connection;

wherein the assisting the at least two blockchain nodes to establish the P2P direct connection comprises: querying the at least two blockchain nodes for respective private network addresses; and at least sending the private network addresses of other blockchain nodes to one of the at least two blockchain nodes, so that the at least two blockchain nodes establish the P2P direct connection based on the private network addresses.

9. An apparatus for assisting a node in a blockchain network to establish P2P direct, comprising a processor and a storage device, wherein the storage device is configured to store instructions, and when the processor executes the instructions, the method according to any one of claims 1 to 7 is implemented.

Images