Alipay (hangzhou) Information Technology Co., Ltd.

Alipay Information Technology Co., Ltd.

Jiang Wang

Chao Zeng

He Sun

Fuxi Deng

Zheng Cao

Zongru Zhan

Xiaoli Liu

Lei Zhang

Ke Cheng Liu

Guannan Kou

Lingtao Kong

Han Xiao

Liman Hou

Wenxiang Jin

Youpeng Xie

Yifan Chen

Rungui Ye

Ke Liu

One or more embodiments of this specification provide methods and apparatuses for transmitting messages. A method includes: determining a blockchain message from two or more message queues stored in a relay node in a blockchain relay communication network based on a message transmission policy, the message transmission policy being configured to transmit blockchain messages in the blockchain relay communication network based upon a priority identifier representing a priority of a blockchain message to be transmitted in the blockchain relay communication network; obtaining identifier from the blockchain message, and determining one or more target blockchain nodes in the blockchain relay communication network corresponding to the identifier; determining a target relay node connected to the one or more target blockchain nodes in the blockchain relay communication network; and transmitting the blockchain message to the one or more target blockchain nodes through the target relay node.

Methods and apparatuses for transmitting messages

Computer-implemented methods, apparatuses, and systems for transferring a transaction using a blockchain integrated station are provided. The blockchain integrated station includes a central processing unit (CPU) and a smart network card. The smart network card is configured to receive a transaction of a blockchain network, wherein the blockchain integrated station is a blockchain node of the blockchain network, and determine other blockchain nodes in the blockchain network; and in response to determining the other blockchain nodes of the blockchain network, transfer the transaction to the other blockchain nodes of the blockchain network.

Methods and apparatuses for transferring transaction based on blockchain integrated station

This specification provides a message transmission methods and apparatuses. One method includes: receiving a digital certificate sent by each blockchain node of a plurality of blockchain nodes in a blockchain relay communication network, wherein the digital certificate comprises identity information of each blockchain node of the plurality of blockchain nodes and a network identifier of a blockchain network of the blockchain relay communication network that comprises a corresponding blockchain node of the plurality of blockchain nodes; verifying that a digital signature of the digital certificate is authentic based on a public key of a certification authority (CA) issuing the digital certificate; and recording a mapping relationship between the identity information of each blockchain node of the plurality of blockchain nodes and the network identifier.

Message transmission methods and apparatuses

Computer-implemented methods, apparatuses, and systems are provided for synchronizing data based on a blockchain integrated station. The blockchain integrated station includes a central processing unit (CPU) and an intelligent network card. The intelligent network card includes a processor different from the CPU. The blockchain integrated station serves as a blockchain node of a blockchain network, and the intelligent network card is configured to inquiry other blockchain nodes of the blockchain network on whether there is to-be-synchronized block data; in response to determining that there is the to-be-synchronized block data, pull the to-be-synchronized block data from the other nodes of the blockchain network; and provide the to-be-synchronized block data to the CPU.

Methods and apparatuses for synchronizing data based on blockchain integrated station

One or more embodiments of this specification provide a message transmission method and apparatus applied to a relay node in a blockchain relay communication network. The method includes: receiving, by a relay node in a blockchain relay communication network, a plurality of message packets, each message packet configured to record a partial message content of a message to be transmitted; parsing, by the relay node, the plurality of message packets to obtain encapsulation information of the message to be transmitted, the encapsulation information configured to indicate a type of a blockchain message within the encapsulation information in the message to be transmitted; determining, by the relay node, that the encapsulation information indicates that the blockchain message is a block synchronization message; and forwarding, by the relay node, at least one of the plurality of message packets without receiving all of the plurality of message packets corresponding to the message to be transmitted.

Computer-implemented methods, apparatuses, and systems for identifying a to-be-filtered transaction using a blockchain integrated station are provided. The blockchain integrated station includes a central processing unit (CPU); and a smart network card. The smart network card includes a processor different from the CPU. The smart network card is configured to receive a transaction of a blockchain network, wherein the blockchain integrated station is a blockchain node of the blockchain network, and identify a transaction by operations comprising determining whether the transaction satisfies a predetermined filtering condition; and in response to determining that the transaction satisfies the predetermined filtering condition, determining the transaction as a to-be-filtered transaction.

Methods and apparatuses for identifying to-be-filtered transaction based on blockchain integrated station

Computer-implemented methods, apparatuses, and system for processing transactions using a blockchain integrated station are provided. The blockchain integrated station includes a central processing unit (CPU) and a smart network card, wherein the smart network card comprises a processor different from the CPU. The smart network card is configured to receive a transaction of a blockchain network, wherein the blockchain integrated station is a blockchain node of the blockchain network; write the transaction into a cache; in a process that the blockchain integrated station participates in a blockchain consensus of the blockchain network, perform consensus interactions with other blockchain nodes of the blockchain network based on the transaction in the cache; determine, based on a result of the blockchain consensus, a to-be-executed transaction list; and send the to-be-executed transaction list to the CPU.

Methods and apparatuses for processing transactions based on blockchain integrated station

One or more embodiments of this specification provide methods and apparatuses for transmitting messages. A method includes: registering, based on a registration request sent by each blockchain node in a blockchain relay communication network, a blockchain node to a blockchain node set indicated by the registration request; determining, in response to receiving a blockchain message to be sent to a target blockchain node set, a target blockchain node registered to the target blockchain node set and a target relay node in the blockchain relay communication network; and transmitting the blockchain message to the target blockchain node through the target relay node.

Methods, systems, and apparatus for optimizing communication in a blockchain network. An example method includes establishing, by a first relay node in the blockchain network, a connection with a first blockchain node in the blockchain network in response to a connection request of the first blockchain node; receiving, by the first relay node, a registration request transmitted by the first blockchain node; generating, by the first relay node, a registration event based on the registration request; updating, by the first relay node, a local routing table based on the registration event; and forwarding, by the first relay node, a message of the first blockchain node to another relay node or another blockchain node in the blockchain network that is connected to the first relay node based on the local routing table.

Communication optimization systems of blockchain network, registration methods and message forwarding methods

One or more embodiments of this specification provide a message transmission methods and apparatuses. A method includes: registering each of a plurality of blockchain nodes in a blockchain relay communication network to a blockchain node set indicated in a registration request submitted by a corresponding blockchain node of the plurality of blockchain nodes; generating a routing policy corresponding to each of the plurality of blockchain nodes, the routing policy comprising the blockchain node set that comprises the plurality of blockchain nodes and a relay node that connects to the corresponding blockchain node of the plurality of blockchain nodes; and receiving a first blockchain message sent for a target blockchain node in a target blockchain node set from one of the plurality of blockchain nodes.

Computer-implemented methods, apparatuses, and system for processing transactions using a blockchain integrated station are provided. The blockchain integrated station includes a central processing unit (CPU) and an intelligent network card. The intelligent network card includes a processor different from the CPU. The intelligent network card is coupled with one or more caches. The blockchain integrated station serves as a blockchain node of a blockchain network. The intelligent network card is configured to receive a transaction of the blockchain network; identify the transaction as a replay transaction by operations comprising: comparing the transaction with historically received transactions in the one or more caches; and in response to a comparison result indicates that the transaction is the same as one of the historically received transactions, determining the transaction as a replay transaction.

Methods and apparatuses for identifying replay transaction based on blockchain integrated station

One or more embodiments of this specification provide block synchronization methods and apparatuses. A method includes: receiving, by a block synchronization device in a blockchain relay communication network and from a relay node of a plurality of relay nodes, a block obtaining request sent by a blockchain node of a plurality of blockchain nodes; selecting, by the block synchronization device from one or more locally stored blocks on the block synchronization device, one or more historical blocks; and sending, by the block synchronization device via the relay node of the plurality of relay nodes, one or more historical blocks to the blockchain node of the one or more blockchain nodes to perform block synchronization by the blockchain node of the one or more blockchain nodes on blocks locally stored by the blockchain node of the plurality of blockchain nodes based on the one or more historical blocks.

Block synchronization methods and apparatuses

One or more embodiments of this specification provide message transmission methods and apparatuses. A method includes: registering each of a plurality of blockchain nodes in a blockchain relay communication network to a blockchain node set indicated in a registration request submitted by a corresponding blockchain node of the plurality of blockchain nodes; generating a routing policy corresponding to each of the plurality of blockchain nodes, the routing policy comprising a blockchain node set that the corresponding blockchain node belongs and a relay node that connects to the corresponding blockchain node; receiving a blockchain message for a target blockchain node in a target blockchain node set; determining a target relay node connected to the target blockchain node according to a tree-structured routing table obtained by organizing routing policies in a tree structure; and transmitting the blockchain message to the target blockchain node.

One or more embodiments of this specification provide a blockchain system, and a message transmission method and apparatus. The method includes: receiving a blockchain message from a blockchain node of a plurality of blockchain nodes in a blockchain relay communication network; sending the blockchain message to a relay node in a relay cluster of a plurality of relay clusters; and transmitting the blockchain message to the target blockchain node through the target relay cluster, wherein each blockchain node of the plurality of blockchain nodes is connected to at least one relay cluster of the plurality of relay clusters, and each relay cluster of the plurality of relay clusters comprises a load balancer and at least one relay node connected to the load balancer.

Growing community of inventors

Hangzhou, China

Jiang Wang