上篇我们看了ProcessMessages函数,这个函数就是侦听网络中的不同的消息命令来处理相应的逻辑。在后面如果有看到CNode对象在调用PushMessage函数的时候,其实就可以到这个函数里面查看相应的命令来看相应的处理了。这篇我们接着看下一个函数SendMessages。
这部分代码首先判断pto结点的版本信息,如果为0表示结点信息不对,则不处理。下面的代码判断什么时候发送ping命令消息。 如果结点版本大于BIP0031_VERSION则pto的npingUserStart参数使用当前时间,并且把nonce当作参数发送过去。(BIP:比特币改进协议(Bitcoin improvement proposals 简称 BIP));接着往下看:
这段代码首先对cs_main进行了锁定。但是这次用的是TRY_LOCK(尝试获取锁,如果获取到了执行同步的地方,如果获取不到那么返回的是false将做其他的事情), 可以看到代码进行了锁定成功与否的判断,如果没锁定成功,则直接返回true。不进行下面的代码执行。下面的代码是遍历了vNodes全部结点。这个vNodes是定义在net.h中的一个全局变量。
大家可以在解读五中看到 CCriticalSection 类型变量的意义。进行这个结点序列进行遍历的前提是!IsInitialBlockDownload()(是否初始化区块) && GetTime() - nLastRebroadcast > 24 * 60 * 60(一天24小时)。 意思就是如果不更新区块并且距上次遍历结点已经经过24小时,这种情况下再遍历vNodes并且将有效的地址放在pNode结点中。意思是24小时遍历一次。现在我们看下IsInitialBlockDownload()函数和PushAddress函数做了些什么事情。IsInitialBlockDownload函数就定义在main.cpp中。
这个函数会在多处调用。大家要记住这个函数的作用。这段代码首先进区块结点的高度进行了判断,如果当前链的高度小于检查点则return true.下面是直接对结点的判断,如果 当前链的最高区块不和上次的高度区块一致的话。则对上次更新时间进行更新。并且判断当前区块的构造当前时间减去24小时。这行语句的意思就是 如果当前时间距离上次更新区块时间小于10分钟并且当前区块的构建时间已经超过24小时,则返回true。
PushAddress是CNode的一个成员函数。定义在net.h中。
这段代码是将CAddress类型的对象放入了vaddrToSend序列中。
这个序列并不是无限长的。是有长度限制的(MAX_ADDR_TO_SEND)
可以看到这个向量的最大长度是1000。意思是这个存放广播地址的序列最多存1000个。如果已经有1000个了。则将新的地址随机覆盖其中一个。现在我们已经将地址都放入了发送列表中。现在我们就看一下如何发送:
这段代码用使用了CNodeState和 CBlockReject这两个结构。这两个结构都定义在main.cpp中。
可以看到CNodeState是对结点信息状态的一种记录。并包括了rejects这个CBlockReject这个记录reject消息的说明序列。
我们今天了解了sendMessages的ping消息和addr消息的存储和发送。通过代码我们可以了解ping相当于人的心跳,每隔一段时间发送一次,当然也可以人为发送。目的是保持网络的连接。addr是将有效的并准备好的地址消息发送出去。
今天就先写到这里,下篇我们将sendMessages函数读完。
作者:区块链研习社比特币源码研读班,black