CN108347350A - A kind of communication means and device - Google Patents
A kind of communication means and device Download PDFInfo
- Publication number
- CN108347350A CN108347350A CN201810072794.0A CN201810072794A CN108347350A CN 108347350 A CN108347350 A CN 108347350A CN 201810072794 A CN201810072794 A CN 201810072794A CN 108347350 A CN108347350 A CN 108347350A
- Authority
- CN
- China
- Prior art keywords
- node
- network connection
- neighbor node
- neighbor
- connection status
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
- H04L43/16—Threshold monitoring
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/06—Management of faults, events, alarms or notifications
- H04L41/0654—Management of faults, events, alarms or notifications using network fault recovery
- H04L41/0659—Management of faults, events, alarms or notifications using network fault recovery by isolating or reconfiguring faulty entities
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
- H04L43/08—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
- H04L43/0805—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability
- H04L43/0811—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability by checking connectivity
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
- H04L43/10—Active monitoring, e.g. heartbeat, ping or trace-route
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Health & Medical Sciences (AREA)
- Cardiology (AREA)
- General Health & Medical Sciences (AREA)
- Environmental & Geological Engineering (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
Description
技术领域technical field
本申请涉及通信技术领域,尤其涉及一种通信方法及装置。The present application relates to the technical field of communication, and in particular to a communication method and device.
背景技术Background technique
现代生活中,常需要证明某项数据(事物)的存在,即数据的存证,如撰写过的文章、历史的操作指令、签订过的合同等,此时便需经过第三方认证机构进行认证,这种认证方式对认证机构的信用度要求极高,而且操作繁琐、成本较高、时效性差。为了解决上述通过第三方认证机构进行数据存证时存在的种种问题,目前已出现很多通过区块链数据存证的方案,利用区块链的无中心化结构及不可更改的特性很好地解决了上述问题。目前比较热门的区块链技术是基于全球范围内的分布式网络,受外部运营商、传播距离的限制,缺乏有效的控制。In modern life, it is often necessary to prove the existence of a certain data (thing), that is, the storage of data, such as written articles, historical operation instructions, signed contracts, etc. At this time, it needs to be certified by a third-party certification agency , this certification method has extremely high requirements on the credibility of the certification body, and the operation is cumbersome, the cost is high, and the timeliness is poor. In order to solve the above-mentioned various problems in data storage through third-party certification agencies, there have been many solutions for data storage through blockchain, which can be solved well by using the decentralized structure and immutable characteristics of blockchain. the above problems. The currently popular blockchain technology is based on a distributed network on a global scale, which is limited by external operators and transmission distances, and lacks effective control.
随着业务的发展,交易系统的交易量逐渐增长,某段时间会出现交易高峰,当大量的交易数据涌入区块链网络中,这时区块链网络的广播能力及记账节点处理交易数据的能力就会出现瓶颈,造成业务无法正常运行,甚至产生广播风暴。With the development of the business, the transaction volume of the transaction system is gradually increasing, and there will be a transaction peak in a certain period of time. When a large amount of transaction data floods into the blockchain network, the broadcasting capability of the blockchain network and the transaction data processing of the accounting nodes If there is a bottleneck in the capacity of the network, the business cannot run normally, and even a broadcast storm will occur.
另外,通过全网广播的方式发送消息,由于在互联网上数据传输,存在不可避免的延迟等网络问题,目前的分布式网络目前没有纠错机制,发生丢包错包后难以弥补。因而如何提升分布式数据传输性能,提高数据存证的可靠性和可信性,是目前亟需解决的问题。In addition, when sending messages through network-wide broadcast, due to data transmission on the Internet, there are inevitable network problems such as delays. The current distributed network currently does not have an error correction mechanism, and it is difficult to make up for packet loss and error packets. Therefore, how to improve the performance of distributed data transmission and improve the reliability and credibility of data storage certificates is an urgent problem to be solved.
发明内容Contents of the invention
本申请实施例提供一种通信方法及装置,用以分布式数据传输性能,提高分布式网络的处理效率。Embodiments of the present application provide a communication method and device, which are used to distribute data transmission performance and improve processing efficiency of a distributed network.
本申请实施例提供一种通信方法,应用于包含多个节点的区块链系统,所述多个节点中的至少一个节点包括邻居节点;所述邻居节点为与所述节点直接通信的节点;所述方法包括:An embodiment of the present application provides a communication method, which is applied to a blockchain system including multiple nodes, at least one node of the multiple nodes includes a neighbor node; the neighbor node is a node that directly communicates with the node; The methods include:
针对至少一个邻居节点,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值;若确定所述网络连接状态值超过第一阈值,则停止通过无连接报文与所述邻居节点进行数据传输。For at least one neighbor node, the node determines the network connection state value between the node and the neighbor node through a connection message; if it is determined that the network connection state value exceeds the first threshold, then stop passing the connectionless message The text performs data transmission with the neighbor node.
一种可能的实现方式,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值,包括:A possible implementation manner, the node determines the network connection status value between the node and the neighbor node through a connection message, including:
若确定与所述邻居节点的网络连接状态为正常状态,则确定所述网络连接状态值不变;If it is determined that the network connection state with the neighbor node is a normal state, then determine that the network connection state value remains unchanged;
若确定与所述邻居节点的网络连接状态为异常状态,则增加所述网络连接状态值。If it is determined that the network connection status with the neighbor node is abnormal, then increase the network connection status value.
一种可能的实现方式,所述停止与所述邻居节点进行数据传输之后,还包括:A possible implementation manner, after the stop of data transmission with the neighbor node, further includes:
若确定与所述邻居节点的网络连接状态恢复正常,则将所述网络连接状态值按照预设规则随时间衰减。If it is determined that the network connection state with the neighbor node returns to normal, the network connection state value is decayed with time according to a preset rule.
一种可能的实现方式,所述方法还包括:A possible implementation, the method also includes:
若确定所述网络连接状态值小于或等于第二阈值,则重新在所述邻居节点与所述节点之间通过无连接报文进行数据传输。If it is determined that the network connection status value is less than or equal to the second threshold, data transmission is performed again between the neighbor node and the node by using a connectionless message.
一种可能的实现方式,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值,包括:A possible implementation manner, the node determines the network connection status value between the node and the neighbor node through a connection message, including:
所述节点向所述邻居节点发送心跳包;The node sends a heartbeat packet to the neighbor node;
所述节点根据在预定时间是否接收到所述邻居节点返回的心跳响应,确定与所述邻居节点的网络连接状态是否为正常状态。The node determines whether the network connection status with the neighbor node is normal according to whether it receives the heartbeat response returned by the neighbor node at a predetermined time.
本申请实施例提供一种通信装置,应用于包含多个节点的区块链系统,所述多个节点中的至少一个节点包括邻居节点;所述邻居节点为与所述节点直接通信的节点;所述装置包括:An embodiment of the present application provides a communication device, which is applied to a blockchain system including multiple nodes, at least one of the multiple nodes includes a neighbor node; the neighbor node is a node that directly communicates with the node; The devices include:
获取单元,用于针对至少一个邻居节点,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值;An acquisition unit, configured to determine a network connection status value between the node and the neighbor node through a connected message for at least one neighbor node;
处理单元,用于若确定所述网络连接状态值超过第一阈值,则停止通过无连接报文与所述邻居节点进行数据传输。A processing unit, configured to stop data transmission with the neighbor node through a connectionless message if it is determined that the network connection state value exceeds a first threshold.
一种可能的实现方式,所述获取装置具体用于:若确定与所述邻居节点的网络连接状态为正常状态,则确定所述网络连接状态值不变;若确定与所述邻居节点的网络连接状态为异常状态,则增加所述网络连接状态值。In a possible implementation manner, the obtaining means is specifically configured to: if it is determined that the network connection status with the neighbor node is normal, then determine that the network connection status value remains unchanged; if it is determined that the network connection status with the neighbor node is If the connection status is abnormal, then increase the network connection status value.
一种可能的实现方式,所述处理单元还用于:A possible implementation manner, the processing unit is further configured to:
若确定与所述邻居节点的网络连接状态恢复正常,则将所述网络连接状态值按照预设规则随时间衰减。If it is determined that the network connection state with the neighbor node returns to normal, the network connection state value is decayed with time according to a preset rule.
一种可能的实现方式,所述处理单元还用于:A possible implementation manner, the processing unit is further configured to:
若确定所述网络连接状态值小于或等于第二阈值,则重新在所述邻居节点与所述节点之间通过无连接报文进行数据传输。If it is determined that the network connection status value is less than or equal to the second threshold, data transmission is performed again between the neighbor node and the node by using a connectionless message.
一种可能的实现方式,所述获取单元还用于:所述节点向所述邻居节点发送心跳包;所述节点根据在预定时间是否接收到所述邻居节点返回的心跳响应,确定与所述邻居节点的网络连接状态是否为正常状态。In a possible implementation manner, the acquiring unit is further configured to: the node sends a heartbeat packet to the neighbor node; Whether the network connection status of the neighbor node is normal.
综上所述,本申请实施例提供一种通信方法及装置,应用于包含多个节点的区块链系统,所述述多个节点中的至少一个节点包括邻居节点;所述邻居节点为与所述节点直接通信的节点;所述方法包括:针对至少一个邻居节点,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值;若确定所述网络连接状态值超过第一阈值,则停止与所述邻居节点进行数据传输。在本申请实施例中,区块链系统中通过无连接报文可以实现对邻居节点网络状态的监控;进而确定节点与所述邻居节点间的网络连接状态值;在网络连接状态值超过第一阈值时,停止两者之间的数据传输,从而实现对网络状态较差的邻居节点进行抑制,有效的去除了无效数据的发送对网络资源的占用,提高了网络资源的利用率。To sum up, the embodiments of the present application provide a communication method and device, which are applied to a blockchain system including a plurality of nodes, at least one of the plurality of nodes includes a neighbor node; the neighbor node is a The node directly communicates with the node; the method includes: for at least one neighbor node, the node determines the network connection status value between the node and the neighbor node through a connected message; if the network connection is determined If the state value exceeds the first threshold, data transmission with the neighbor node is stopped. In the embodiment of the present application, the monitoring of the network status of neighboring nodes can be realized through connectionless messages in the blockchain system; then the network connection status value between the node and the neighbor node can be determined; when the network connection status value exceeds the first When the threshold is reached, the data transmission between the two is stopped, so as to suppress the neighboring nodes with poor network status, effectively remove the occupation of network resources by sending invalid data, and improve the utilization rate of network resources.
附图说明Description of drawings
为了更清楚地说明本申请实施例中的技术方案,下面将对实施例描述中所需要使用的附图作简要介绍,显而易见地,下面描述中的附图仅仅是本申请的一些实施例,对于本领域的普通技术人员来讲,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the technical solutions in the embodiments of the present application, the following will briefly introduce the drawings that need to be used in the description of the embodiments. Obviously, the drawings in the following description are only some embodiments of the present application. For Those of ordinary skill in the art can also obtain other drawings based on these drawings without any creative effort.
图1为本申请实施例提供的一种区块链系统架构示意图;FIG. 1 is a schematic diagram of a block chain system architecture provided by an embodiment of the present application;
图2为本申请实施例提供的一种通信方法的流程示意图;FIG. 2 is a schematic flowchart of a communication method provided in an embodiment of the present application;
图3为本申请实施例提供的一种通信方法的流程示意图;FIG. 3 is a schematic flowchart of a communication method provided in an embodiment of the present application;
图4为本申请实施例提供的一种通信装置的结构示意图。FIG. 4 is a schematic structural diagram of a communication device provided by an embodiment of the present application.
具体实施方式Detailed ways
为了使本申请的目的、技术方案和优点更加清楚,下面将结合附图对本申请作进一步地详细描述,显然,所描述的实施例仅仅是本申请一部份实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其它实施例,都属于本申请保护的范围。In order to make the purpose, technical solutions and advantages of the application clearer, the application will be further described in detail below in conjunction with the accompanying drawings. Obviously, the described embodiments are only some of the embodiments of the application, not all of them. . Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the scope of protection of this application.
区块链是一项全新的技术,脱胎于2008年出现的比特币技术,它提供了一种去中心化的、无需信任积累的信用建立范式。在这种范式中,任何互不了解的人可以通过加入一个公开透明的数据库,通过点对点的记账、数据传输、认证或是合约,而不需要借助任何一个中间方来达成信用共识。这个公开透明的数据库包括了过去所有的交易记录、历史数据及其他相关信息,所有信息都分布式存储并透明可查,并以密码学协议的方式保证其不能非法篡改。Blockchain is a brand-new technology born out of the Bitcoin technology that appeared in 2008. It provides a decentralized credit establishment paradigm that does not require trust accumulation. In this paradigm, anyone who does not know each other can join an open and transparent database, through point-to-point bookkeeping, data transmission, certification or contract, without any intermediary to reach a credit consensus. This open and transparent database includes all past transaction records, historical data and other relevant information. All information is stored in a distributed manner and is transparently searchable, and it is guaranteed that it cannot be illegally tampered with in a cryptographic protocol.
区块链技术是通过去中心化和去信任的方式集体维护一个可靠数据库的技术方案,更通俗一点说,区块链技术就是一种全民参与记账的方式。Blockchain technology is a technical solution for collectively maintaining a reliable database through decentralization and trustlessness. More generally speaking, blockchain technology is a way for all people to participate in bookkeeping.
在区块链网络中,区块链网络中的某个记账节点会接收到服务器发送的交易数据,该记账节点会将接收到的交易数据向其他记账节点广播,各记账节点在接收到一定量的交易数据后,会进行记账,记账成功的记账节点会生成交易数据的区块,以供区块链网络中的其他节点下载区块,从而达到全民参与记账的方式。区块链的广播方式主要使用于同一交换机或者相邻交换机,延迟低、可靠性相对高。考虑到记账间隔,现有的区块链信息的传递可以通过组播方式进行数据共享,即相同类型数据的用户设备作为一组广播的节点,用于共享该相同类型的数据,可以节省服务器的负载。In the blockchain network, a bookkeeping node in the blockchain network will receive the transaction data sent by the server, and the bookkeeping node will broadcast the received transaction data to other bookkeeping nodes. After receiving a certain amount of transaction data, it will perform bookkeeping, and the bookkeeping node that successfully bookkeeping will generate a block of transaction data for other nodes in the blockchain network to download the block, so as to achieve the goal of all people participating in bookkeeping Way. The blockchain broadcast method is mainly used on the same switch or adjacent switches, with low delay and relatively high reliability. Considering the billing interval, the transfer of existing blockchain information can be shared through multicast, that is, user equipment of the same type of data is used as a group of broadcast nodes to share the same type of data, which can save server load.
为了更好地理解本方案中的系统整体架构,下面对系统的整体架构作一下说明,系统的架构图如下图1所示:In order to better understand the overall system architecture in this solution, the overall architecture of the system is described below. The architecture diagram of the system is shown in Figure 1 below:
图1示例性示出了本申请实施例提供的一种区块链系统,包括多个节点。其中,所述多个节点通过对等网络(Peer to Peer,P2P)动态组网,形成一个“去中心化”的系统。图1为本申请实施例提供的一种可行的区块链系统架构示意图,如图1所示,区块链系统中包括节点0、节点1、节点2、节点3和节点4,这五个节点之间互为对等节点,通过P2P动态组网构成一个去中心化的系统。图1中的直线表示各节点之间的数据传输关系,每个节点的邻居节点为与所述节点直接通信的节点。以节点2为例,节点2的邻居节点为节点0、节点1和节点3;节点2向节点2的邻居节点广播消息,节点2的广播消息可由节点0、节点1和节点3接收。Fig. 1 exemplarily shows a blockchain system provided by an embodiment of the present application, including multiple nodes. Wherein, the plurality of nodes form a "decentralized" system through a peer-to-peer network (Peer to Peer, P2P) dynamic networking. Figure 1 is a schematic diagram of a feasible block chain system architecture provided by the embodiment of the present application. As shown in Figure 1, the block chain system includes node 0, node 1, node 2, node 3 and node 4, the five The nodes are peers to each other, and form a decentralized system through P2P dynamic networking. The straight lines in FIG. 1 indicate the data transmission relationship between the nodes, and the neighbor nodes of each node are the nodes that directly communicate with the node. Taking node 2 as an example, the neighbor nodes of node 2 are node 0, node 1 and node 3; node 2 broadcasts a message to the neighbor nodes of node 2, and the broadcast message of node 2 can be received by node 0, node 1 and node 3.
在使用本申请实施例所提供的区块链系统写入数据时,可将系统的多个节点中的任一节点作为接收节点接收待写入数据;接收节点将待写入数据向其它节点发送数据写入请求;数据写入请求中包括该待写入数据;数据写入请求用于指示其它节点中任一个节点将待写入数据存入各自的待写入数据集,即对于其它节点中的任一节点,在收到数据写入请求后,获取其中的待写入数据并存入各自的待写入数据集。When using the blockchain system provided by the embodiment of this application to write data, any node in the multiple nodes of the system can be used as a receiving node to receive the data to be written; the receiving node sends the data to be written to other nodes Data write request; the data write request includes the data to be written; the data write request is used to instruct any node in other nodes to store the data to be written into their respective data sets to be written, that is, for other nodes Any node of , after receiving the data write request, obtains the data to be written and stores them in their respective data sets to be written.
以图1所示的区块链系统举例说明,节点2作为接收节点接收待写入数据;节点2将待写入数据存入其本地的待写入数据集,并向节点0、节点1和节点3发送数据写入请求;数据写入请求中包括待写入数据;节点0、节点1和节点3将数据写入请求中的待写入数据存入各自的待写入数据集,节点1或节点3继续转发该数据写入请求至节点4;节点4接收节点1和节点3中最先到达的数据写入请求,并将数据写入请求中的待写入数据存入节点4的待写入数据集中,经过上述过程,系统中的每一个对等节点都收到了待写入数据。Taking the block chain system shown in Figure 1 as an example, node 2 receives data to be written as a receiving node; node 2 stores the data to be written in its local data set to be written, and sends data to node 0, node 1 and Node 3 sends a data write request; the data write request includes the data to be written; node 0, node 1 and node 3 store the data to be written in the data write request into their respective data sets to be written, and node 1 Or node 3 continues to forward the data writing request to node 4; node 4 receives the first data writing request from node 1 and node 3, and stores the data to be written in the data writing request into the waiting data of node 4 Write into the data set. After the above process, each peer node in the system has received the data to be written.
应理解,本申请实施例的技术方案可以应用于各种分布式系统中,例如比特币系统等。本申请实施例中,获取多个服务器发送的数据可以是服务器确定需要上传后立即发送,也可以是周期性发送,也可以是周期性从各服务器中获取数据。存储的数据可以是一个对象,例如,转账,对象中会包括时间、转账双方账号、转账金额等信息;如果是一段文字记录,对象中会包括信息内容和信息发送者的标识;存储的类型可以是文件存储、缓存、关系型数据存储、非关系型数据存储等,用于保障数据的可用性,存储的类型包括这些类型但不限于这些类型,还可以是其它类型。It should be understood that the technical solutions of the embodiments of the present application can be applied to various distributed systems, such as the Bitcoin system and the like. In the embodiment of the present application, obtaining the data sent by multiple servers may be sent immediately after the server determines that it needs to be uploaded, or periodically sent, or periodically obtained from each server. The stored data can be an object, for example, transfer, the object will include information such as time, account number of both parties to the transfer, transfer amount, etc.; if it is a text record, the object will include the content of the information and the identity of the information sender; the storage type can be It is file storage, cache, relational data storage, non-relational data storage, etc., used to ensure the availability of data. The types of storage include but are not limited to these types, and can also be other types.
目前区块链技术是基于全球范围内的分布式网络,该技术普遍使用广播或组播传递数据,受外部运营商、传播距离的限制,随着业务的发展,交易系统的交易量逐渐增长,某段时间会出现交易高峰,当大量的交易数据涌入区块链网络中,这时区块链网络的广播能力及记账节点处理交易数据的能力就会出现瓶颈,造成业务无法正常运行,甚至产生广播风暴。如不进行有效的控制广播泛洪的行为,严重时可能导致堵塞数据传输。At present, blockchain technology is based on a distributed network on a global scale. This technology generally uses broadcast or multicast to transmit data, which is limited by external operators and transmission distance. With the development of business, the transaction volume of the transaction system is gradually increasing. There will be a transaction peak in a certain period of time. When a large amount of transaction data floods into the blockchain network, the broadcasting capability of the blockchain network and the ability of the accounting nodes to process transaction data will become bottlenecks, causing the business to fail to run normally, or even Generate a broadcast storm. If the behavior of effectively controlling broadcast flooding is not carried out, it may lead to blockage of data transmission in severe cases.
现有技术可以通过自定义规则放弃记录部分数据来保证网络中对交易的处理能力,这样可能会导致部分交易数据出现丢失。The existing technology can guarantee the transaction processing capacity in the network by giving up recording part of the data through custom rules, which may lead to the loss of part of the transaction data.
由于在互联网上进行数据传输时,每10公里增加1ms以上的延迟,导致发生丢包错包的问题。分布式网络与单播协议相比没有纠错机制,发生丢包错包后难以弥补。因而分布式数据丢失风险,且数据无法找回。Due to the delay of more than 1ms per 10 kilometers during data transmission on the Internet, the problem of packet loss and error occurs. Compared with unicast protocols, distributed networks have no error correction mechanism, and it is difficult to make up for packet loss and error packets. Therefore, there is a risk of distributed data loss, and the data cannot be retrieved.
图2示例性示出了本申请实施例提供的一种通信方法流程示意图,应用于包含多个节点的区块链系统,所述多个节点中的至少一个节点包括邻居节点;所述邻居节点为与所述节点直接通信的节点;如图2所示,包括以下步骤:Figure 2 exemplarily shows a schematic flow diagram of a communication method provided by an embodiment of the present application, which is applied to a blockchain system including multiple nodes, at least one of the multiple nodes includes a neighbor node; the neighbor node Be the node of direct communication with described node; As shown in Figure 2, comprise the following steps:
步骤201:针对至少一个邻居节点,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值;Step 201: For at least one neighbor node, the node determines the network connection status value between the node and the neighbor node through a connected message;
步骤202:若确定所述网络连接状态值超过第一阈值,则停止通过无连接报文与所述邻居节点进行数据传输。Step 202: If it is determined that the network connection state value exceeds the first threshold, stop data transmission with the neighbor node through a connectionless message.
其中,所述有连接报文为在正式收发数据前,发送方必须和接收方可以建立可靠的连接,确定接收方可以正确接收发送方发送的数据的报文。例如,传输控制协议(Transmission Control Protocol,TCP)报文。所述无连接报文为发送方无需与接收方建立可靠的连接,即无需接收接收方返回的接收数据的响应报文,进而确定接收方是否正确接收所述数据。例如用户数据报协议(User Datagram Protocol,UDP)报文。Wherein, the connected message is a message that the sender must establish a reliable connection with the receiver before officially sending and receiving data, and confirm that the receiver can correctly receive the data sent by the sender. For example, a transmission control protocol (Transmission Control Protocol, TCP) message. The connectionless message is a response message in which the sender does not need to establish a reliable connection with the receiver, that is, does not need to receive the received data returned by the receiver, so as to determine whether the receiver receives the data correctly. For example, a User Datagram Protocol (User Datagram Protocol, UDP) packet.
在步骤201之前,可以通过以下步骤确定所述节点的至少一个邻居节点:Before step 201, at least one neighbor node of the node may be determined through the following steps:
步骤一、所述节点向邻居节点发送TCP注册请求报文;Step 1, the node sends a TCP registration request message to a neighbor node;
步骤二、所述邻居节点接收到所述TCP注册请求报文后,发送TCP注册请求的响应报文至所述节点;Step 2, after the neighbor node receives the TCP registration request message, send a response message of the TCP registration request to the node;
步骤三、所述节点若在预定时间内接收到所述邻居节点发送的TCP注册请求的响应报文,则确定所述邻居节点为所述节点的邻居节点;所述节点发送空包请求至所述至少一个邻居节点。Step 3, if the node receives the response message of the TCP registration request sent by the neighbor node within a predetermined time, it determines that the neighbor node is the neighbor node of the node; the node sends an empty packet request to the at least one neighbor node.
步骤四、所述至少一个邻居节点发送空包请求至所述节点,结束此次短连接会话。Step 4. The at least one neighbor node sends an empty packet request to the node to end the short connection session.
在步骤一中,所述节点可以根据预设的邻居节点列表中的邻居节点确定邻居节点,也可以根据上一次与所述节点进行数据传输的节点确定所述节点的邻居节点,在此不做限定。In step 1, the node can determine the neighbor nodes according to the neighbor nodes in the preset neighbor node list, or determine the neighbor nodes of the node according to the node that performed data transmission with the node last time, which is not done here limited.
在步骤三中,通过确定所述邻居节点是否返回所述TCP注册请求的响应报文,确定当前所述邻居节点是否在线,进而确定当前进行数据传输时的所述节点的邻居节点。In step 3, by determining whether the neighbor node returns a response message of the TCP registration request, it is determined whether the neighbor node is online at present, and then the neighbor node of the node at the time of data transmission is determined.
例如,结合图1,节点2向节点0、节点1和节点3发送TCP注册请求报文,若节点2在预定时间内接收到节点0和节点1的TCP注册请求的响应报文,未接收到节点3的TCP注册请求的响应报文,则可以确定当前的节点2的邻居节点为节点0和节点1。For example, in conjunction with Figure 1, node 2 sends a TCP registration request message to node 0, node 1, and node 3. If node 2 receives the response message of the TCP registration request of node 0 and node 1 within a predetermined time, it does not receive The response message of the TCP registration request of node 3 can determine that the current neighbor nodes of node 2 are node 0 and node 1 .
以上为根据TCP为短连接会话为例进行说明,在具体实施过程中,也可以为所述节点将注册完成的邻居节点保持长连接的状态,用于实时监控所述节点与所述邻居节点的连接状态。The above is an example based on TCP as an example of a short connection session. In the specific implementation process, the registered neighbor node can also be kept in a long connection state for the node, so as to monitor the connection between the node and the neighbor node in real time. Connection Status.
为了避免TCP传输数据带来的时间延迟的问题(数据包从一节点到另一节点所需要的时间),可以采用用户数据报协议(User Datagram Protocol,UDP)代替使用TCP发送传送一次区块所需要的数据。In order to avoid the problem of time delay caused by TCP transmission data (the time required for a data packet to travel from one node to another node), the User Datagram Protocol (UDP) can be used instead of sending a block using TCP. data needed.
由于UDP为无连接的传输协议类型,因此,发送端无法确定接收端是否正确接收到发送端发送的数据,因此,在接收端网络状态较差时,发送端仍旧持续向接收端发送数据包,导致占用了大量的网络资源。Since UDP is a connectionless transmission protocol type, the sending end cannot determine whether the receiving end has correctly received the data sent by the sending end. Therefore, when the network status of the receiving end is poor, the sending end still continues to send data packets to the receiving end. As a result, a large amount of network resources are occupied.
本申请实施例中,在步骤201中,可以包括以下步骤:In the embodiment of the present application, in step 201, the following steps may be included:
步骤一、所述节点向所述邻居节点发送心跳包;Step 1, the node sends a heartbeat packet to the neighbor node;
步骤二、所述节点根据在预定时间是否接收到所述邻居节点返回的心跳响应,确定所述邻居节点的网络连接状态是否为正常状态。Step 2: The node determines whether the network connection status of the neighbor node is normal according to whether it receives the heartbeat response returned by the neighbor node at a predetermined time.
在步骤一中,所述心跳包可以为周期性的发送,也可以为其他形式的发送,在此不做限定。In step 1, the heartbeat packet may be sent periodically or in other forms, which is not limited here.
在具体实施过程中,可以包括:In the specific implementation process, it may include:
所述节点若确定在预定时间接收到所述邻居节点返回的心跳响应,则确定所述邻居节点的网络连接状态为正常状态。If the node determines to receive the heartbeat response returned by the neighbor node at a predetermined time, it determines that the network connection status of the neighbor node is a normal state.
所述节点若确定在超过第一预定时间且小于第二预定时间接收到所述至少一个邻居节点返回的心跳响应,则确定所述邻居节点的网络连接状态为异常状态,且该异常状态为网络延迟。If the node determines that the heartbeat response returned by the at least one neighbor node is received within the first predetermined time and less than the second predetermined time, it is determined that the network connection state of the neighbor node is an abnormal state, and the abnormal state is a network connection state. Delay.
所述节点若确定超过第二预定时间接收到所述邻居节点返回的心跳响应,则确定所述邻居节点的网络连接状态为异常状态,且该异常状态为无法连接状态。If the node determines that the heartbeat response returned by the neighbor node is received after a second predetermined time, it determines that the network connection status of the neighbor node is an abnormal state, and the abnormal state is an unconnectable state.
所述节点在确定所述节点的邻居节点后,可以初始化所述邻居节点的网络连接状态值,例如,可以将所述邻居节点的网络连接状态值设为0。After the node determines the neighbor nodes of the node, it may initialize the network connection state value of the neighbor node, for example, the network connection state value of the neighbor node may be set to 0.
在步骤202中,包括:In step 202, including:
一种可能的实现方式,若确定与所述邻居节点的网络连接状态为正常状态,则确定所述网络连接状态值不变;A possible implementation manner, if it is determined that the network connection state with the neighbor node is in a normal state, then determine that the network connection state value remains unchanged;
一种可能的实现方式,若确定与所述邻居节点的网络连接状态为异常状态,则增加所述网络连接状态值。A possible implementation manner is to increase the value of the network connection status if it is determined that the network connection status with the neighbor node is abnormal.
在具体实施过程中,可以为通过增加一固定值,也可以为随时间变化的值,在此不做限定。In a specific implementation process, it may be by adding a fixed value, or it may be a value that changes with time, which is not limited here.
举例来说,若节点2确定节点1在初始化后的一监测时刻的连接状态为异常状态,则可以增加节点1的网络连接状态值至100。所述监测时刻可以为所述节点向所述至少一个邻居节点确定所述至少一个邻居节点的网络状态的时刻。在下一监测时刻,若节点2确定节点1在该时刻的连接状态仍为异常状态,则可以增加节点1的网络连接状态值至200。For example, if the node 2 determines that the connection status of the node 1 is abnormal at a monitoring moment after initialization, the network connection status value of the node 1 may be increased to 100. The monitoring time may be the time when the node determines the network status of the at least one neighbor node from the at least one neighbor node. At the next monitoring moment, if node 2 determines that the connection status of node 1 is still in an abnormal state at that moment, it may increase the network connection status value of node 1 to 200.
若所述第一阈值为180,则确定节点1的网络连接状态值超过所述第一阈值,因此,节点2将停止数据传输至节点1。If the first threshold is 180, it is determined that the network connection status value of node 1 exceeds the first threshold, so node 2 stops data transmission to node 1 .
一种可能的实现方式,包括:A possible implementation, including:
步骤一、所述节点停止发送数据至所述邻居节点;Step 1, the node stops sending data to the neighbor node;
步骤二、所述节点停止接收所述邻居节点发送至所述节点的数据;Step 2, the node stops receiving the data sent by the neighbor node to the node;
通过停止对所述邻居节点发送数据,节省了不必要的网络资源的开销。并且,对于所述邻居节点发送至所述节点的数据,由于网络状态较差,从所述邻居节点获得的数据的可靠性也较低,因此,将所述数据丢弃,减少了所述节点对不必要的数据的处理,节约了所述节点的资源,增加区块链网络的广播能力及记账节点处理交易数据的能力,提高了区块链中每个节点的处理效率。By stopping sending data to the neighbor nodes, unnecessary network resource overhead is saved. Moreover, for the data sent from the neighbor node to the node, due to the poor network status, the reliability of the data obtained from the neighbor node is also low, therefore, the data is discarded, reducing the need for the node to The processing of unnecessary data saves the resources of the nodes, increases the broadcast capability of the blockchain network and the ability of the accounting nodes to process transaction data, and improves the processing efficiency of each node in the blockchain.
一种可能的实现方式,包括:若确定所述邻居节点与所述节点的网络连接状态为网络延迟,可以向所述邻居节点发送网络状态告警,通知所述邻居节点停止向所述节点发送数据。A possible implementation method includes: if it is determined that the network connection status between the neighbor node and the node is network delay, a network status alarm may be sent to the neighbor node, and the neighbor node is notified to stop sending data to the node .
通过发送告警,可以进一步的提高区块链的网络资源的利用率,增加区块链网络的广播能力及记账节点处理交易数据的能力。By sending alarms, it is possible to further improve the utilization of blockchain network resources, increase the broadcasting capability of the blockchain network and the ability of accounting nodes to process transaction data.
通过对网络状态异常后恢复正常的邻居节点,为减少所述邻居节点恢复数据传输所需等待的时间,可以通过以下方式实现:To reduce the waiting time for the neighbor node to resume data transmission by recovering the normal neighbor node after the network state is abnormal, it can be achieved in the following ways:
一种可能的实现方式,所述停止与所述邻居节点进行数据传输之后,还包括:A possible implementation manner, after the stop of data transmission with the neighbor node, further includes:
若确定所述节点与所述邻居节点的网络连接状态恢复正常,则将所述网络连接状态值按照预设规则随时间衰减。If it is determined that the network connection status between the node and the neighbor node returns to normal, the network connection status value is decayed with time according to a preset rule.
在具体实施过程中,所述预设规则可以为指数衰减的形式,也可以为其他形式,在此不做限定。In a specific implementation process, the preset rule may be in the form of exponential decay or other forms, which are not limited here.
一种可能的实现方式,所述方法还包括:A possible implementation, the method also includes:
若确定与所述节点停止数据传输的邻居节点的网络连接状态值小于或等于第二阈值,则重新在所述邻居节点与所述节点之间通过UDP进行数据传输。If it is determined that the network connection state value of the neighbor node that stops data transmission with the node is less than or equal to the second threshold, data transmission is performed again through UDP between the neighbor node and the node.
其中,为避免频繁的确定所述邻居节点是否进行数据传输,影响区块链的正常运行,所述第二阈值小于所述第一阈值。Wherein, in order to avoid frequently determining whether the neighbor node performs data transmission and affecting the normal operation of the blockchain, the second threshold is smaller than the first threshold.
一种可能的实现方式,为避免长时间无法恢复网络连接状态正常的邻居节点的数据传输,可以设置网络连接状态值的第三阈值,当网络状态值到达所述第三阈值时,所述邻居节点的网络状态值不再增加。所述第三阈值大于所述第一阈值。In a possible implementation, in order to avoid the data transmission of neighbor nodes whose network connection status is normal and cannot be restored for a long time, a third threshold of the network connection status value may be set, and when the network status value reaches the third threshold, the neighbor The node's network status value no longer increases. The third threshold is greater than the first threshold.
举例来说,在t1时刻,节点2确定节点1的网络状态为异常,则将节点1的网络状态值增加为100;在t2时刻,节点2确定节点1的网络状态为异常,则将节点1的网络状态值增加为200;在t3时刻,节点2确定节点1的网络状态为异常,则将节点1的网络状态值增加为300;此时,节点1的网络状态值超过第一阈值(230),则停止节点1与节点2间通过UDP报文进行数据传输。在t4时刻,节点2确定节点1的网络状态恢复正常,则将节点1的网络状态值按照预设规则衰减;在t5时刻,节点2确定节点1的网络状态值小于第二阈值(180),将重新在节点1与节点2之间通过UDP报文进行数据传输。For example, at time t1, node 2 determines that the network status of node 1 is abnormal, and then increases the network status value of node 1 to 100; at time t2, node 2 determines that the network status of node 1 is abnormal, and then adds The network status value of node 1 is increased to 200; at time t3, node 2 determines that the network status of node 1 is abnormal, and then increases the network status value of node 1 to 300; at this time, the network status value of node 1 exceeds the first threshold (230 ), then stop data transmission between node 1 and node 2 through UDP packets. At time t4, node 2 determines that the network state of node 1 returns to normal, then the network state value of node 1 is attenuated according to preset rules; at time t5, node 2 determines that the network state value of node 1 is less than the second threshold (180), Data transmission will be performed between node 1 and node 2 through UDP packets again.
一种可能的实现方式,在所述停止与所述邻居节点进行数据传输之前,还包括:A possible implementation manner, before the stopping of data transmission with the neighbor node, further includes:
若确定所述节点与所述邻居节点的网络连接状态恢复正常,则将所述网络连接状态值按照预设规则随时间衰减。If it is determined that the network connection status between the node and the neighbor node returns to normal, the network connection status value is decayed with time according to a preset rule.
例如,举例来说,若节点2确定节点1在初始化后的一监测时刻的连接状态为异常状态,则可以增加节点1的网络连接状态值至100。所述监测时刻可以为所述节点向所述至少一个邻居节点确定所述至少一个邻居节点的网络状态的时刻。在下一监测时刻,若节点2确定节点1在该时刻的连接状态为正常状态,则可以根据预设规则将节点1的网络连接状态值衰减,例如,在下一监测时刻,节点1的网络连接状态值衰减至80。For example, if the node 2 determines that the connection status of the node 1 is abnormal at a monitoring moment after initialization, the network connection status value of the node 1 may be increased to 100, for example. The monitoring time may be the time when the node determines the network status of the at least one neighbor node from the at least one neighbor node. At the next monitoring moment, if node 2 determines that the connection status of node 1 is normal at that moment, it can attenuate the network connection status value of node 1 according to preset rules. For example, at the next monitoring moment, the network connection status of node 1 The value decays to 80.
举例来说,结合图1,如图3所示,在t1时刻,节点2确定节点1的网络状态为异常,则将节点1的网络状态值增加为100;在t1至t2时刻之间,若确定节点1的网络状态恢复正常,则根据预设规则对节点1的网络状态值进行衰减;在t2时刻,节点1的网络状态值衰减至80,节点2确定节点1的网络状态为异常,则将节点1的网络状态值增加为180;在t2至t3时刻之间,若确定节点1的网络状态恢复正常,则根据预设规则对节点1的网络状态值进行衰减;在t3时刻,节点1的网络状态值衰减至150,节点2确定节点1的网络状态为异常,则将节点1的网络状态值增加为250;此时,节点1的网络状态值超过第一阈值(230),则停止节点1与节点2间通过UDP报文进行数据传输。在t4时刻,节点2确定节点1的网络状态恢复正常,则将节点1的网络状态值按照预设规则衰减;在t5时刻,节点1的网络状态值衰减至130,节点2确定节点1的网络状态值小于第二阈值(180),将重新在节点1与节点2之间通过UDP报文进行数据传输。For example, referring to Fig. 1, as shown in Fig. 3, at time t1, node 2 determines that the network status of node 1 is abnormal, and increases the network status value of node 1 to 100; between t1 and t2, if If it is determined that the network status of node 1 is back to normal, the network status value of node 1 is attenuated according to the preset rules; at time t2, the network status value of node 1 is attenuated to 80, and node 2 determines that the network status of node 1 is abnormal, then Increase the network state value of node 1 to 180; between t2 and t3, if it is determined that the network state of node 1 returns to normal, the network state value of node 1 will be attenuated according to the preset rules; at time t3, node 1 The network status value of node 1 decays to 150, node 2 determines that the network status of node 1 is abnormal, then increases the network status value of node 1 to 250; at this time, the network status value of node 1 exceeds the first threshold (230), then stop Data transmission is performed between node 1 and node 2 through UDP packets. At time t4, node 2 determines that the network status of node 1 has returned to normal, then the network status value of node 1 is attenuated according to the preset rules; If the status value is less than the second threshold (180), data transmission will be performed between node 1 and node 2 through UDP packets again.
本申请实施例提供一种通信方法的流程示意图,应用于包含多个节点的区块链系统,所述多个节点中的至少一个节点包括邻居节点;所述邻居节点为与所述节点直接通信的节点;包括以下步骤:An embodiment of the present application provides a schematic flow diagram of a communication method, which is applied to a blockchain system including multiple nodes, at least one of the multiple nodes includes a neighbor node; the neighbor node directly communicates with the node node; including the following steps:
步骤一、所述节点向邻居节点发送TCP注册请求报文;Step 1, the node sends a TCP registration request message to a neighbor node;
步骤二、所述预设的邻居节点接收到所述TCP注册请求报文后,发送TCP注册请求的响应报文至所述节点;Step 2. After receiving the TCP registration request message, the preset neighbor node sends a TCP registration request response message to the node;
步骤三、所述节点若在预定时间内接收到所述邻居节点发送的TCP注册请求的响应报文,则确定所述邻居节点为所述节点的邻居节点。Step 3: If the node receives the response message of the TCP registration request sent by the neighbor node within a predetermined time, it determines that the neighbor node is the neighbor node of the node.
步骤四、所述节点向所述节点的至少一个邻居节点发送心跳包;Step 4, the node sends a heartbeat packet to at least one neighbor node of the node;
步骤五、所述节点根据在预定时间是否接收到所述至少一个邻居节点返回的心跳响应,确定所述至少一个邻居节点的网络连接状态是否为正常状态。Step 5: The node determines whether the network connection status of the at least one neighbor node is normal according to whether it receives a heartbeat response returned by the at least one neighbor node at a predetermined time.
步骤六、针对至少一个邻居节点,所述节点通过确定的所述至少一个邻居节点的网络连接状态,确定所述节点与所述邻居节点间的网络连接状态值;Step 6. For at least one neighbor node, the node determines a network connection status value between the node and the neighbor node through the determined network connection status of the at least one neighbor node;
其中,包括:Among them, including:
若确定所述邻居节点的网络连接状态为正常状态,则确定所述邻居节点的网络连接状态值不变;If it is determined that the network connection state of the neighbor node is a normal state, then determine that the network connection state value of the neighbor node remains unchanged;
若确定所述邻居节点的网络连接状态为异常状态,则增加所述邻居节点的网络连接状态值;If it is determined that the network connection status of the neighbor node is abnormal, then increasing the network connection status value of the neighbor node;
步骤七、若确定所述网络连接状态值超过第一阈值,则停止与所述邻居节点进行数据传输。Step 7: If it is determined that the network connection state value exceeds the first threshold, stop data transmission with the neighbor node.
步骤八、若确定所述节点与所述邻居节点的网络连接状态恢复正常,则将所述邻居节点的网络连接状态值按照预设规则随时间衰减。Step 8: If it is determined that the network connection status between the node and the neighbor node returns to normal, the network connection status value of the neighbor node is decayed with time according to a preset rule.
步骤九、若确定与所述邻居节点的网络连接状态值小于或等于第二阈值,则重新在所述邻居节点与所述节点之间通过UPD报文进行数据传输。Step 9: If it is determined that the network connection status value with the neighbor node is less than or equal to the second threshold, re-transmit data between the neighbor node and the node through UPD messages.
本申请实施例提供一种通信装置,应用于包含多个节点的区块链系统,所述多个节点中的至少一个节点包括邻居节点;所述邻居节点为与所述节点直接通信的节点;如图4所示,所述装置包括:An embodiment of the present application provides a communication device, which is applied to a blockchain system including multiple nodes, at least one of the multiple nodes includes a neighbor node; the neighbor node is a node that directly communicates with the node; As shown in Figure 4, the device includes:
获取单元401,用于针对至少一个邻居节点,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值;The obtaining unit 401 is configured to determine, for at least one neighbor node, a network connection status value between the node and the neighbor node through a connected message;
处理单元402,用于若确定所述网络连接状态值超过第一阈值,则停止通过无连接报文与所述邻居节点进行数据传输。The processing unit 402 is configured to, if it is determined that the network connection state value exceeds a first threshold, stop data transmission with the neighbor node through a connectionless message.
一种可能的实现方式,获取装置401具体用于:若确定与所述邻居节点的网络连接状态为正常状态,则确定所述网络连接状态值不变;若确定与所述邻居节点的网络连接状态为异常状态,则增加所述网络连接状态值。In a possible implementation manner, the obtaining means 401 is specifically configured to: if it is determined that the network connection status with the neighbor node is normal, then determine that the network connection status value remains unchanged; if it is determined that the network connection status with the neighbor node is If the status is abnormal, then increase the network connection status value.
一种可能的实现方式,处理单元402还用于:In a possible implementation manner, the processing unit 402 is further configured to:
若确定与所述邻居节点的网络连接状态恢复正常,则将所述网络连接状态值按照预设规则随时间衰减。If it is determined that the network connection state with the neighbor node returns to normal, the network connection state value is decayed with time according to a preset rule.
一种可能的实现方式,处理单元402还用于:In a possible implementation manner, the processing unit 402 is further configured to:
若确定所述网络连接状态值小于或等于第二阈值,则重新在所述邻居节点与所述节点之间通过无连接报文进行数据传输。If it is determined that the network connection status value is less than or equal to the second threshold, data transmission is performed again between the neighbor node and the node by using a connectionless message.
一种可能的实现方式,获取单元401还用于:所述节点向所述邻居节点发送心跳包;所述节点根据在预定时间是否接收到所述邻居节点返回的心跳响应,确定与所述邻居节点的网络连接状态是否为正常状态。In a possible implementation manner, the acquiring unit 401 is also configured to: the node sends a heartbeat packet to the neighbor node; Whether the network connection status of the node is normal.
综上所述,本申请实施例提供一种通信方法及装置,应用于包含多个节点的区块链系统,其特征在于,所述多个节点中的至少一个节点包括邻居节点;所述邻居节点为与所述节点直接通信的节点;所述方法包括:针对至少一个邻居节点,所述节点通过有连接报文,确定所述节点与所述邻居节点间的网络连接状态值;若确定所述网络连接状态值超过第一阈值,则停止与所述邻居节点进行数据传输。在本申请实施例中,通过对网络状态较差的邻居节点进行抑制,有效的去除了无效数据的发送对网络资源的占用,进而保证交易数据不被丢失,避免交易数据的重复发送,能够提高网络处理交易数据的效率,提高了网络资源的利用率。To sum up, the embodiments of the present application provide a communication method and device, which are applied to a blockchain system including a plurality of nodes, wherein at least one of the plurality of nodes includes a neighbor node; the neighbor The node is a node that directly communicates with the node; the method includes: for at least one neighbor node, the node determines the network connection status value between the node and the neighbor node through a connection message; if the determined If the network connection state value exceeds the first threshold, stop data transmission with the neighbor node. In the embodiment of the present application, by suppressing neighbor nodes with poor network status, the network resources occupied by the transmission of invalid data are effectively removed, thereby ensuring that transaction data is not lost, avoiding repeated transmission of transaction data, and improving The efficiency of network processing transaction data improves the utilization rate of network resources.
基于相同的技术构思,本申请实施例还提供一种计算设备,该计算设备具体可以为桌面计算机、便携式计算机、智能手机、平板电脑、个人数字助理(Personal DigitalAssistant,PDA)等。本申请实施例提供的一种计算设备结构示意图,该计算设备可以包括中央处理器(Center Processing Unit,CPU)、存储器、输入设备、输出设备等,输入设备可以包括键盘、鼠标、触摸屏等,输出设备可以包括显示设备,如液晶显示器(Liquid CrystalDisplay,LCD)、阴极射线管(Cathode Ray Tube,CRT)等。Based on the same technical idea, an embodiment of the present application further provides a computing device, and the computing device may specifically be a desktop computer, a portable computer, a smart phone, a tablet computer, a personal digital assistant (Personal Digital Assistant, PDA), and the like. A schematic structural diagram of a computing device provided in an embodiment of the present application, the computing device may include a central processing unit (Center Processing Unit, CPU), a memory, an input device, an output device, etc., the input device may include a keyboard, a mouse, a touch screen, etc., and the output The device may include a display device, such as a liquid crystal display (Liquid Crystal Display, LCD), a cathode ray tube (Cathode Ray Tube, CRT), and the like.
存储器可以包括只读存储器(ROM)和随机存取存储器(RAM),并向处理器提供存储器中存储的程序指令和数据。在本申请实施例中,存储器可以用于存储本申请实施例所提供的区块链生成方法的程序,处理器通过调用存储器存储的程序指令,按照获得的程序指令执行上述任一项所述的区块链生成方法。The memory may include read only memory (ROM) and random access memory (RAM), and provides the processor with program instructions and data stored in the memory. In the embodiment of the present application, the memory can be used to store the program of the block chain generation method provided in the embodiment of the present application, and the processor executes any of the above-mentioned steps according to the obtained program instructions by calling the program instructions stored in the memory. Blockchain generation method.
基于相同的技术构思,本申请实施例还提供一种计算机可读存储介质,用于存储为上述计算设备所用的计算机程序指令,其包含用于执行上述任一项所述的区块链生成方法的程序。Based on the same technical concept, the embodiment of the present application also provides a computer-readable storage medium for storing computer program instructions used by the above-mentioned computing device, which includes a block chain generation method for executing any of the above-mentioned program of.
所述计算机存储介质可以是计算机能够存取的任何可用介质或数据存储设备,包括但不限于磁性存储器(例如软盘、硬盘、磁带、磁光盘(MO)等)、光学存储器(例如CD、DVD、BD、HVD等)、以及半导体存储器(例如ROM、EPROM、EEPROM、非易失性存储器(NAND FLASH)、固态硬盘(SSD))等。The computer storage medium can be any available medium or data storage device that can be accessed by a computer, including but not limited to magnetic storage (such as floppy disk, hard disk, magnetic tape, magneto-optical disk (MO), etc.), optical storage (such as CD, DVD, BD, HVD, etc.), and semiconductor memory (such as ROM, EPROM, EEPROM, non-volatile memory (NAND FLASH), solid state disk (SSD)) and the like.
基于相同的技术构思,本申请实施例还提供一种计算设备,该计算设备具体可以为桌面计算机、便携式计算机、智能手机、平板电脑、个人数字助理(Personal DigitalAssistant,PDA)等。本申请实施例提供的一种计算设备结构示意图,该计算设备可以包括中央处理器(Center Processing Unit,CPU)、存储器、输入设备、输出设备等,输入设备可以包括键盘、鼠标、触摸屏等,输出设备可以包括显示设备,如液晶显示器(Liquid CrystalDisplay,LCD)、阴极射线管(Cathode Ray Tube,CRT)等。Based on the same technical idea, an embodiment of the present application further provides a computing device, and the computing device may specifically be a desktop computer, a portable computer, a smart phone, a tablet computer, a personal digital assistant (Personal Digital Assistant, PDA), and the like. A schematic structural diagram of a computing device provided in an embodiment of the present application, the computing device may include a central processing unit (Center Processing Unit, CPU), a memory, an input device, an output device, etc., the input device may include a keyboard, a mouse, a touch screen, etc., and the output The device may include a display device, such as a liquid crystal display (Liquid Crystal Display, LCD), a cathode ray tube (Cathode Ray Tube, CRT), and the like.
存储器可以包括只读存储器(ROM)和随机存取存储器(RAM),并向处理器提供存储器中存储的程序指令和数据。在本申请实施例中,存储器可以用于存储本申请实施例所提供的数据验证方法的程序,处理器通过调用存储器存储的程序指令,按照获得的程序指令执行上述任一项所述的数据验证方法。The memory may include read only memory (ROM) and random access memory (RAM), and provides the processor with program instructions and data stored in the memory. In the embodiment of the present application, the memory can be used to store the program of the data verification method provided in the embodiment of the present application, and the processor executes the data verification described in any of the above by calling the program instructions stored in the memory according to the obtained program instructions method.
基于相同的技术构思,本申请实施例还提供一种计算机可读存储介质,用于存储为上述计算设备所用的计算机程序指令,其包含用于执行上述任一项所述的数据验证方法的程序。Based on the same technical concept, an embodiment of the present application also provides a computer-readable storage medium for storing computer program instructions used by the above-mentioned computing device, which includes a program for executing the data verification method described in any one of the above-mentioned .
所述计算机存储介质可以是计算机能够存取的任何可用介质或数据存储设备,包括但不限于磁性存储器(例如软盘、硬盘、磁带、磁光盘(MO)等)、光学存储器(例如CD、DVD、BD、HVD等)、以及半导体存储器(例如ROM、EPROM、EEPROM、非易失性存储器(NAND FLASH)、固态硬盘(SSD))等。The computer storage medium can be any available medium or data storage device that can be accessed by a computer, including but not limited to magnetic storage (such as floppy disk, hard disk, magnetic tape, magneto-optical disk (MO), etc.), optical storage (such as CD, DVD, BD, HVD, etc.), and semiconductor memory (such as ROM, EPROM, EEPROM, non-volatile memory (NAND FLASH), solid state disk (SSD)) and the like.
尽管已描述了本申请的优选实施例,但本领域内的技术人员一旦得知了基本创造性概念,则可对这些实施例作出另外的变更和修改。所以,所附权利要求意欲解释为包括优选实施例以及落入本申请范围的所有变更和修改。While preferred embodiments of the present application have been described, additional changes and modifications to these embodiments can be made by those skilled in the art once the basic inventive concept is appreciated. Therefore, the appended claims are intended to be construed to cover the preferred embodiment and all changes and modifications which fall within the scope of the application.
显然,本领域的技术人员可以对本申请进行各种改动和变型而不脱离本申请的精神和范围。这样,倘若本申请的这些修改和变型属于本申请权利要求及其等同技术的范围之内,则本申请也意图包含这些改动和变型在内。Obviously, those skilled in the art can make various changes and modifications to the application without departing from the spirit and scope of the application. In this way, if these modifications and variations of the present application fall within the scope of the claims of the present application and their equivalent technologies, the present application is also intended to include these modifications and variations.
Claims (10)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810072794.0A CN108347350B (en) | 2018-01-25 | 2018-01-25 | A communication method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810072794.0A CN108347350B (en) | 2018-01-25 | 2018-01-25 | A communication method and device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN108347350A true CN108347350A (en) | 2018-07-31 |
| CN108347350B CN108347350B (en) | 2022-04-15 |
Family
ID=62960931
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201810072794.0A Active CN108347350B (en) | 2018-01-25 | 2018-01-25 | A communication method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN108347350B (en) |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109444802A (en) * | 2018-10-26 | 2019-03-08 | 山东德源电力科技有限公司 | Intelligent electric meter detection method and device, equipment, medium |
| CN110189161A (en) * | 2019-04-26 | 2019-08-30 | 华中科技大学 | For realizing marketing label shared block chain common recognition method and block chain network |
| WO2020037578A1 (en) * | 2018-08-22 | 2020-02-27 | 区链通网络有限公司 | Method, device, and storage medium for controlling use of blockchain resource |
| CN113254306A (en) * | 2021-05-10 | 2021-08-13 | 支付宝(杭州)信息技术有限公司 | Running state monitoring method, device, equipment and storage medium |
| CN114172828A (en) * | 2021-12-08 | 2022-03-11 | 河南健创电气科技有限公司 | A method for monitoring the running state of a communication module of a communication terminal |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102215123A (en) * | 2011-06-07 | 2011-10-12 | 南京邮电大学 | Multi-ring-network-topology-structure-based large-scale trunking system |
| CN106789095A (en) * | 2017-03-30 | 2017-05-31 | 腾讯科技(深圳)有限公司 | Distributed system and message processing method |
| CN106789920A (en) * | 2016-11-25 | 2017-05-31 | 深圳前海微众银行股份有限公司 | The joint connecting method and device of block chain |
| CN107204875A (en) * | 2017-05-11 | 2017-09-26 | 腾讯科技(深圳)有限公司 | Data reporting links monitoring method, device, electronic equipment and storage medium |
| CN107295080A (en) * | 2017-06-19 | 2017-10-24 | 北京百度网讯科技有限公司 | Date storage method and server applied to distributed server cluster |
| EP3256998A1 (en) * | 2015-02-11 | 2017-12-20 | British Telecommunications Public Limited Company | Validating computer resource usage |
-
2018
- 2018-01-25 CN CN201810072794.0A patent/CN108347350B/en active Active
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102215123A (en) * | 2011-06-07 | 2011-10-12 | 南京邮电大学 | Multi-ring-network-topology-structure-based large-scale trunking system |
| EP3256998A1 (en) * | 2015-02-11 | 2017-12-20 | British Telecommunications Public Limited Company | Validating computer resource usage |
| CN106789920A (en) * | 2016-11-25 | 2017-05-31 | 深圳前海微众银行股份有限公司 | The joint connecting method and device of block chain |
| CN106789095A (en) * | 2017-03-30 | 2017-05-31 | 腾讯科技(深圳)有限公司 | Distributed system and message processing method |
| CN107204875A (en) * | 2017-05-11 | 2017-09-26 | 腾讯科技(深圳)有限公司 | Data reporting links monitoring method, device, electronic equipment and storage medium |
| CN107295080A (en) * | 2017-06-19 | 2017-10-24 | 北京百度网讯科技有限公司 | Date storage method and server applied to distributed server cluster |
Cited By (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2020037578A1 (en) * | 2018-08-22 | 2020-02-27 | 区链通网络有限公司 | Method, device, and storage medium for controlling use of blockchain resource |
| CN109444802A (en) * | 2018-10-26 | 2019-03-08 | 山东德源电力科技有限公司 | Intelligent electric meter detection method and device, equipment, medium |
| CN109444802B (en) * | 2018-10-26 | 2020-12-11 | 山东德源电力科技股份有限公司 | Intelligent electric meter detection method and device, equipment and medium |
| CN110189161A (en) * | 2019-04-26 | 2019-08-30 | 华中科技大学 | For realizing marketing label shared block chain common recognition method and block chain network |
| CN110189161B (en) * | 2019-04-26 | 2022-06-17 | 华中科技大学 | Block chain consensus method and system for realizing marketing label sharing |
| CN113254306A (en) * | 2021-05-10 | 2021-08-13 | 支付宝(杭州)信息技术有限公司 | Running state monitoring method, device, equipment and storage medium |
| CN114172828A (en) * | 2021-12-08 | 2022-03-11 | 河南健创电气科技有限公司 | A method for monitoring the running state of a communication module of a communication terminal |
| CN114172828B (en) * | 2021-12-08 | 2024-12-06 | 河南健创电气科技有限公司 | A method for monitoring the operating status of a communication module of a communication terminal |
Also Published As
| Publication number | Publication date |
|---|---|
| CN108347350B (en) | 2022-04-15 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110458582B (en) | Business processing method, device, medium and electronic equipment based on block chain system | |
| JP7432686B2 (en) | Probabilistic relay for efficient propagation in blockchain networks | |
| CN108347350B (en) | A communication method and device | |
| CN115004673B (en) | Message pushing method, device, electronic equipment and computer readable medium | |
| US8544075B2 (en) | Extending a customer relationship management eventing framework to a cloud computing environment in a secure manner | |
| WO2021249490A1 (en) | Communication method and service data transmission method in blockchain network | |
| US20180139162A1 (en) | Systems and methods for transferring message data | |
| CN110062004A (en) | A kind of message handling system and method based on Internet of Things fidonetFido | |
| CN105991412A (en) | Method and device for pushing message | |
| CN108600316B (en) | Data management method, system and device for cloud storage service | |
| CN112333298A (en) | Message transmission method and device, computer equipment and storage medium | |
| CN107135274A (en) | Storage management method and device for a distributed cluster system | |
| CN116542668A (en) | Block chain-based data processing method, equipment and readable storage medium | |
| Chang et al. | A Probabilistic Spray‐and‐Wait Routing Algorithm Based on Node Interest Preference in Delay Tolerant Networks | |
| US20230129107A1 (en) | Method and apparatus to aggregate objects to be stored in a memory to optimize the memory bandwidth | |
| CN107343037B (en) | Data transmission method and device for distributed storage system | |
| CN116074331A (en) | Block data synchronization method and related products | |
| CN110855726A (en) | Communication method, apparatus and gateway, computing device and medium | |
| WO2025167331A1 (en) | Request processing method and apparatus, storage medium and electronic device | |
| CN110309225B (en) | Data processing method and system | |
| US20190238637A1 (en) | Data replication in scalable messaging system | |
| JP2021144571A (en) | Information processing device, transmission control method, and communication program | |
| CN112866346B (en) | A blockchain-based data distribution method and device | |
| CN113595894B (en) | Communication method, device, equipment and medium between service nodes and client nodes | |
| CN110149365A (en) | Service adaptation method, apparatus, system, and computer-readable medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |