Python编写区块链时节点交易池同步及交易确认问题咨询

• 变量覆盖问题：当前代码在循环中每次请求节点交易池后都会直接覆盖response变量，循环结束后仅会将最后一个节点的交易池内容添加到本地，前面所有节点的同步结果全部丢失。
• 缺少去重逻辑：不同节点的交易池存在大量重复的待处理交易，直接累加会导致本地交易池出现重复交易，后续挖矿会将无效的重复交易打包进区块。
• 无异常处理：只要任意一个节点掉线、请求超时或返回非法数据，整个同步方法会直接崩溃，无法完成剩余节点的同步。
• 无交易校验：直接信任其他节点返回的交易内容，未验证交易签名、输入合法性，会导致本地交易池被伪造的非法交易污染。

import requests

def sync_transaction_pool(self):
    # 预先存储本地已有交易的哈希，用于快速去重
    local_tx_hashes = {tx["tx_hash"] for tx in self.transactions}
    network = self.nodes
    
    for node in network:
        try:
            # 添加超时限制，避免同步卡住
            resp = requests.get(f'http://{node}/tspool', timeout=3)
            resp.raise_for_status() # 非200状态码直接抛出异常跳过
            node_tx_pool = resp.json()
            
            for tx in node_tx_pool:
                # 先校验交易合法性（需自行实现validate_transaction方法，校验签名、未花费输入等）
                if tx["tx_hash"] not in local_tx_hashes and self.validate_transaction(tx):
                    self.transactions.append(tx)
                    local_tx_hashes.add(tx["tx_hash"])
        except Exception as e:
            # 单个节点同步失败不影响整体流程，打印日志跳过即可
            print(f"节点{node}同步失败: {str(e)}")
            continue

• 区分打包与确认：交易被打包进区块仅代表1次区块确认，此时仍存在链重组导致交易回滚的风险，不可直接标记为交易完成。
• 确认数阈值设置：可参考主流公链规则，将6个区块确认作为交易最终不可逆的标准，也可根据项目场景自定义阈值。实现逻辑为：每次同步到最长链后，遍历链上交易，计算交易所在区块之后新增的区块数量，达到阈值后标记交易为已确认。
• 交易池联动清理：每次挖出新区块或同步到更长链时，遍历本地交易池，删除所有已经被打包进链上区块的交易，避免重复打包。
• 过期交易清理：给待处理交易设置最大停留时长（比如24小时），超时未被打包的交易直接从交易池移除，避免交易池无限膨胀。
• 冲突交易处理：如果收到两笔消耗了相同未花费输入的冲突交易，仅保留手续费更高的交易进入本地交易池，另一笔直接丢弃。

内容的提问来源于stack exchange，提问作者Hoomehr Kz