共识机制（块同步）

Author: 建平

README.md

@@ -1263,7 +1263,7 @@ void Blockchain::updateUTXOPool(const Block& block) {
 ### 保持一致性
 
 * 所有全节点遵循同样的**共识规则**；
-* 当有新区块生成，会通过点对点网络广播；
+* 当有==新区块生成==，会通过点对点网络广播；
 * 节点在接收到新区块后：
 
   * 验证区块（工作量、哈希、交易等）；
@@ -1475,9 +1475,16 @@ make
 
 #### 更新UTOX
 
-#### 共识机制
 
 
+#### 区块查找
+
+区块链查找仅用于handleConsensusResult（见后），所以包含在此处，其实其应该是P2P_Node的基本功能。
+
+- 根据区块高度查找（区块号）
+- 根据区块Hash查找
+
+#### 获取最小共识节点
 
 
 
@@ -2319,41 +2326,6 @@ p2p_node包含了一个Blockchain成员，其所有对区块链的操作都通
 
 
 
-
-
-
-
-
-
-
-
-
-
-
-​	
-
-
-
-#### 共识机制
-
-##### 共识投票
-
-```c++
-    std::mutex consensus_mutex_;
-    std::map<std::string, std::pair<int, int>> consensus_votes_;
-```
-
-##### 区块查找
-
-区块链查找仅用于handleConsensusResult（见后），所以包含在此处，其实其应该是P2P_Node的基本功能。
-
-- 根据区块高度查找（区块号）
-- 根据区块Hash查找
-
-##### 获取最小共识节点
-
-
-
 ## 网络通讯进阶
 
 先把3个线程改成3个进程跑起来吧
@@ -3275,6 +3247,144 @@ void P2PNode::connect(const std::string& host, int port) {
 
 
 
+### 业务流程
+
+
+
+#### 共识机制(块同步)
+
+1. 让我详细解释一下这个共识机制的工作流程：
+
+   1. 共识发起：
+
+   - 当节点收到新的区块时，会发起共识
+   - 发起者会广播 `CONSENSUS_VOTE` 消息给所有节点
+   - 消息包含：区块哈希、完整区块内容、投票者ID，投票决定
+
+   2. 投票过程：
+
+   - 所有节点都会收到投票请求
+   - 每个节点需要验证区块的有效性
+   - 节点根据验证结果投赞成票或反对票
+   - 投票信息通过 `CONSENSUS_VOTE` 消息广播给所有节点
+
+   3. 投票检查：
+
+   ​       当收到投票消息时
+
+   - 如果本节点已经处理过该节点的投票，丢弃该消息，否则计入已投票节点
+   - 如果本节点已经给该块投过票了（不同节点广播的投票），跳过投票阶段
+   - 验证节点，如果通过则投赞成票，否则投反对票。记录该块当前节点已投票
+   - 更新投票记录
+   - 每次更新后检查是否达到共识阈值
+
+   4. 共识达成：
+
+   - 当赞成票比例超过阈值（比如2/3）时，认为达成共识
+   - 达成共识的节点会广播 `CONSENSUS_RESULT` 消息
+   - 消息包含：区块哈希、共识结果（通过/拒绝），区块信息，投票者ID（==怎么用==）
+
+   5. 共识结果处理：
+
+   - 所有节点收到共识结果后，根据结果决定是否将区块添加到链中
+   - 如果共识通过，区块被添加到链中
+   - 如果共识拒绝，区块被丢弃
+
+   6. 防止重复：
+
+   - 每个节点都维护
+
+     - 个投票记录表 `consensus_votes_`，记录每个区块的赞成票和反对票数量
+     - 个是否投票表voted_blocks_，记录每个块当前节点是否已经投票_
+     - 一个投票节点表voted_nodes_，记录每个块已投票节点记录
+
+   - 每个节点维护 `voted_blocks_` 记录已投票的区块
+
+   - 防止对同一个区块重复投票
+
+   - 确保共识过程的完整性
+
+
+     这个机制的特点：
+
+       1. 去中心化：所有节点都可以发起共识和投票
+       2. 透明性：所有投票都是公开的
+      3. 安全性：需要多数节点同意才能达成共识
+       4. 容错性：可以容忍部分节点故障或恶意行为
+
+
+```c++
+    std::mutex consensus_mutex_;
+    std::map<std::string, std::pair<int, int>> consensus_votes_;  // blockHash -> (赞成票数, 反对票数)
+    std::map<std::string, bool> voted_blocks_;  // blockHash -> 是否已投票
+    std::map<std::string, std::set<std::string>> voted_nodes_;  // blockHash -> 已投票的节点列表
+```
+
+##### 添加新块时触发投票
+
+​	节点收到新块添加NEW_BLOCK时发起投票
+
+- 解析新块
+
+- ==（0525补充）检查块是否已经在链上了，如果是则丢弃==
+
+- 检查该块是否正在投票，如果是则丢弃该消息
+
+- 本地验证区块，如果失败则丢弃
+
+- 检查块是否已经在链上（==如果在链上上一步应该验证失败==）
+
+- 广播共识投票（包括自己？==修改broadcastConsensusVote==）
+
+  
+
+##### 收到投票
+
+节点收到CONSENSUS_VOTE消息，开始处理投票
+
+- ==（0525补充）检查块是否已经在链上了，如果是则丢弃==（防止已经完成节点添加的节点收到其他节点因为网络延迟还在发送的投票消息）
+- 创建一个块对象
+- 验证此投票是否合法（消息携带的块HASH和新块的HASH是否一致）
+- 检查==发送者==是否已经对此块投过票，避免重复投票
+  - 如果是直接返回
+  - 如果不是则将发送节点添加进本地该块的已投票节点(下次收到该节点对此块的投票丢弃)
+
+- 检查本地是否已经投过票(如果本地已经投过则仅记录本次投票信息)
+  - 如果未投票，开始投票
+    - 验证块哈希（索引号，前一块的Hash值，块Hash验证，块难度，验证交易，验证MerkleRoot）
+      - 成功投赞成票
+      - 失败投反对票
+    - 标记本节点已经对该块发起过投票
+  - 如果已经投票标记已经投过票
+  - 验证通过则发起通过投票，否则发起拒绝投票
+  - 将此块计入已投票列表
+- 记录投票信息
+- 记录投票节点
+- 检查共识
+
+##### 共识检测
+
+- 获取当前投票总数
+- 比较投票数是否满足最小共识节点数
+  - 比较投票通过数的比率是否达到阈值
+    - 如果超过则广播发送共识通过（包含块信息）
+    - 否则广播共识拒绝
+
+##### 共识结果
+
+- 解析块和信息
+- 查看是否达成共识，如果是添加节点
+  - 检查本地是否存在该节点，如果是则跳过
+  - 检查是否包含块信息，如果不是则跳过
+  - 创建块，并验证块
+    - 如果验证失败则跳过
+    - 如果验证成功则将块加入本地
+- 清理投票记录（指定块）
+- 清理投票块记录（指定块）
+- 清理投票节点记录（指定块）
+
+#### UTXO同步
+