共识协议

共识消息格式

P2P消息格式

ConsensusPayload

Changeview 消息格式

PrepareRequest 消息格式

PrepareResponse 消息格式

传输协议

共识消息进入P2P网络后，和其他数据包一样，进行广播传输，（因为共识节点之间并不知道对方的IP地址), 即普通节点都可能收到共识数据包。共识消息的广播流程如下图。

1. 共识节点A， 直接将共识消息 consensus 广播连接上的节点B

2. 节点B在收到 consensus 消息后，先进行共识消息处理，再进行共识消息的转发。转发共识消息前，先发送 inv 消息，并携带上 consensus 消息的 payload 的hash数据。

3. 若节点C已经收到过该hash对应的数据，或在短时间内，已经重复获取该 inv 消息时，则不处理；否则，进入步骤四。

4. C向B发送 getdata 消息，附带上 inv 消息中的hash数据。

5. 节点B收到 getdata 消息后，则发送 consenus 消息给对方。

6. C节点收到 consensus 消息后，则触发共识模块对消息处理, 以及转发该共识消息,回到步骤二。

inv 消息格式

Payload格式为： inv.type + inv.payloads.length + inv.payload inv 消息的payload，有三种类型:

• 0x01 : 交易， inv.payload 存放为交易hash列表

• 0x02 : 区块， inv.payload 存放共识消息 ConsensusPayload 的hash列表

• 0xe0 : 共识， inv.payload 存放区块的hash列表

getdata 消息格式

getdata 消息主要用来获取 inv 消息附带hash列表对应的具体内容。

共识消息处理

校验

1. 检查 ConsensusPayload.BlockIndex 。若小于或等于当前高度，则忽略该消息。

2. 检查验证脚本是否通过，以及验证脚本的地址hash，是否等于 ConsensusPayload.ValidatorIndex 所在议员列表中，对应的地址签名脚本hash。

3. 检查 ConsensusPayload.ValidatorIndex 。若等于当前节点的共识列表序号，则忽略该消息（自己发出的消息，不接收）。

4. 检查共识版本号。若不等于当前共识协议版本号时，则忽略。

5. 检查 ConsensusPayload.PreHash 和 ConsensusPayload.BlockIndex , 是否等于当前共识节点上下文的 PreHash 与 BlockIndex 。 若不是，则忽略。

6. 检查 ConsensusPayload.ValidatorIndex ，若超过当前议员总数时，则忽略。

7. 检查 ConsensusMessage.ViewNumber , 若不等于当前共识阶段上下文的 ViewNumber 且不是 ChangeView 消息时，则忽略。

处理

1. PrepareRequest 由一轮共识的议长发出，其中附带了 block 相关的数据：

   1. 检查节点自身，是否在本轮共识是议员。如果不是议员，或者 PrepareRequest 已接收过，则忽略该消息。

   2. 根据 ConsensusPayload.ValidatorIndex 确定对方是不是本轮的议长，若不是，则忽略。

   3. 检查 ConsensusPayload.Timestamp ， 若小于等于上一个区块的时间戳，或者超过了当前时间10分钟以上，则认为消息过期，忽略。

   4. 检查对block的签名是否对。

   5. 过滤在此之前收到的不合法签名（Prepare-Reponse 消息可能先到达）。

   6. 收下议长附带的签名

   7. 从内存池收集和验证提案block所需的交易。

   8. 若交易已经在区块链中，或共识交易过滤插件校验失败，则认为交易数据不对，发起 ChangeView 消息.

   9. 否则收下该交易，存放到共识上下文中。

   10. 若提案块中的交易，已全部收集齐全，则对外广播 PrepareResponse 消息。

   11. 检查未确认交易池中包含的block所需的交易，首先进行交易验证，再将交易存放到共识上下文中，以便构建完整的区块。

   12. 检查block中第一笔交易，即 MinerTransaction 。

   13. 若缺少 block 中的交易时，则广播 getdata 消息，附带缺少交易的hash列表。

2. PrepareResponse 是议员对议长发的 PrepareRequest 消息回应，并附带了对block的签名：

   1. 若对方签名已经收到过，则忽略。

   2. 若在此之前尚未收到 PrepareRequest 消息时，则先收下该签名（后续收到PrepareRequest时，进行过滤）。否则进入步骤 3）。

   3. 校验对方的签名，若通过，则收下签名，否则忽略。

   4. 检查签名数，若已经满足 N-f 个签名，则出新块，向网络广播 block 。

3. Changeview 议员或者议长，在遇到超时（议长第一次超时例外，发送 PrepareRequest 消息），或者校验失败时，则发送 ChangeView 消息。议员，议长收到 ChangeView 消息做如下处理：

   1. 若新视图编号，小于该议员之前的视图编号，则忽略。

   2. 若有不少于 N-f 个议员的视图编号等于新视图编号时，则切换视图成功，当前议员重置共识流程，视图编号为新的视图编号。

4. onTimeout 消息处理

   1. 若是议长超时，第一次超时发送 PrepareRequest 消息，后续则发起 ChangeView 消息。

   2. 若是议员超时，则直接发送 ChangeView 消息

5. NewBlock 事件处理

   重置共识过程。

6. New Tx 事件处理

   1. 若是挖矿交易，则忽略。（挖矿交易是直接附在 PrepareRequest 消息中，不需要单独进行广播该交易）。

   2. 若当前节点是议长，或已经发送过 PrepareRequset 或者 PrepareResponse 消息，或正在切换视图中，则忽略该交易。

   3. 若已经收到过该交易，则忽略。

   4. 若交易不在待打包block里面的，则忽略。

   5. 将交易收下，放到待打包的block里。