(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210641627.X (22)申请日 2022.06.07 (71)申请人 北京溪塔科技有限公司 地址 100086 北京市海淀区青云里满庭芳 园小区9号楼青 云当代大厦17层1708- 705 (72)发明人 王晓亮　宁志伟　 (74)专利代理 机构 北京德崇智捷知识产权代理 有限公司 1 1467 专利代理师 王欣 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 一种基于流式处理的区块链共识算法实现 方法和装置 (57)摘要 本说明书实施例公开了一种基于流式处理 的区块链共识算法实现方法和装置， 其中方法， 用于执行区块链共识算法的共识模块包括外部 事件、 共识引擎、 中间件和数据源； 对应于实现共 识算法， 包括： 接收所述外部事件， 以及根据消息 类型将所述外部事件分发至所述共识引擎， 所述 共识引擎包括对应于所述消息类型的处理单元； 所述共识引擎实时读取由所述数据源提供的最 新数据， 以及基于所述最新数据和对应所述消息 类型， 将所述外部事件提交至所述共识引擎相应 所述处理单元进行计算； 调用所述中间件将所述 处理数据实时写入所述数据源。 本发 明引入流式 处理， 将共识模块的实现拆分为相应功能模块， 具有通用性强， 扩展性强， 高性能、 可 维护性强等 特点。 权利要求书2页 说明书8页 附图4页 CN 115269615 A 2022.11.01 CN 115269615 A 1.一种基于流式处理的区块链共识算法实现方法， 其特征在于， 用于执行区块链共识 算法的共识模块包括外 部事件、 共识引擎、 中间件和数据源； 对应于实现共识算法， 包括： 接收所述外部事件， 以及根据消息类型将所述外部事件分发至所述共识引擎， 所述共 识引擎包括对应于所述消息类型的处 理单元； 所述共识引擎实时读取由所述数据源提供的最新数据， 以及基于所述最新数据和对应 所述消息类型， 将所述外 部事件提交至所述共识引擎相应所述处 理单元进行计算； 调用所述中间件将所述处 理数据实时写入所述数据源。 2.根据权利要求1所述的方法， 其特征在于， 所述区块链共识算法至少包括Tendermint 共识算法。 3.根据权利要求1所述的方法， 其特征在于， 所述消息类型至少包括Noop、 Proposal、 Prevote、 Precom mit、 NewView、 LeaderPrevote或LeaderPrecom mit中的一种。 4.根据权利要求1所述的方法， 其特征在于， 根据 所述消息类型将所述外部事件分发至 所述共识引擎包括： 根据所述数据源提供的所述最新数据， 更新所述共识模块的参数配置； 以及， 根据所述外 部事件的所述消息类型， 检查 块的有效性。 5.根据权利要求1所述的方法， 其特征在于， 还包括当节点共识 投票数量超过验证节点 总数的设定比例， 更新所述节点状态， 以及广播至区块链节点后调用所述中间件将所述节 点状态写入所述数据源。 6.一种基于流式处理的区块链共识算法实现装置， 其特征在于， 用于执行区块链共识 算法的共识模块包括外 部事件、 共识引擎、 中间件和数据源； 对应于实现共识算法， 包括： 外部事件接收模块， 用于接收所述外部事件， 以及根据消息类型将所述外部事件分发 至所述共识引擎， 所述共识引擎包括对应于所述消息类型的处 理单元； 共识引擎计算模块， 用于所述共识引擎读取由所述数据源提供的最新数据， 以及基于 所述最新数据和对应所述消息类型， 将所述外部事件提交至所述共识引擎相应所述处理单 元进行计算； 数据更新模块， 用于调用所述中间件将所述处 理数据实时写入所述数据源。 7.根据权利要求6所述的装置， 其特征在于， 所述区块链共识算法至少包括Tendermint 共识算法。 8.根据权利要求6所述的装置， 其特征在于， 所述消息类型至少包括Noop、 Proposal、 Prevote、 Precom mit、 NewView、 LeaderPrevote或LeaderPrecom mit中的一种。 9.根据权利要求6所述的装置， 其特征在于， 根据 所述消息类型将所述外部事件分发至 所述共识引擎包括： 根据所述数据源提供的所述最新数据， 更新所述共识模块的参数配置； 以及根据所述外 部事件的所述消息类型检查 块的有效性。 10.根据权利要求6所述的装置， 其特征在于， 还包括共识反馈模块， 用于当节点共识 投 票数量超过验证节点总 数的设定比例， 更新所述节点状态， 以及广播至区块链节点后调用 所述中间件将所述节点状态写入所述数据源。 11.一种电子设备， 其特 征在于， 包括： 处理器； 以及 被安排成存储计算机可执行指令的存储器， 所述可执行指令在被执行时使所述处理器 执行权利要求1至 5任一项所述的方法。权　利　要　求　书 1/2 页 2 CN 115269615 A 212.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储一个或多个 程序， 所述一个或多个程序当被包括多个应用程序的电子设备执行时， 使得所述电子设备 执行权利要求1至 5任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115269615 A 3