数字货币交易系统架构 Python实现 黄毅 目录 CONTENTS 交易系统功能介绍 交易系统架构设计 钱包实现介绍 1 交易系统功能介绍 交易系统功能-基本概念 class Side(Enum): ‘下单方向’ BUY = 0 SELL = 1 class Order(NamedTuple): ‘订单’ id: int side: Side amount: min(self.taker.amount, self.maker.amount) def side(self): return self.taker.side 交易系统功能-伪代码 @app.post('/limit_order') def limit_order(order: Order): # 冻结资金 lock_user_fund(order) save_order(order, trades) # 更新K线 update_kline(trades) # 推送用户信息变更 push_user_messages(trades) 交易系统功能-撮合 def match_buy(book, taker: Order): for price, orders in sorted(book.asks): for maker

第三届中国Rust开发者大会 Rust 在算法交易中的实际应用 与积极效应 非凸科技首席架构师 乔丹 上海非凸智能科技有限公司（简称“非凸科技”）成 立于2018年，是国内领先的智能算法和交易系统服 务公司，专注于智能算法交易领域的研究和开发。 公司正基于Rust生态，结合机器学习、深度学习等新 兴技术，打造高效率、低延迟、高可靠、全内存高频 交易平台，满足自身在量化行业交易业务的同时也为 券商、量化私募等众多大型金融机构提供优质的算法 券商、量化私募等众多大型金融机构提供优质的算法 交易解决方案。 公司介绍 证监会信息技术系统备案 国家高新技术企业 科技型中小企业 双软企业资质认证 智能投研技术联盟核心成员 100+ 团队规模 80亿+ 日均成交额 100+ 合作机构 公司结构 50% 工程师 20% 策略研究 20% 运维中台 10% 市场商务 上海 徐汇漕河泾 总部 浦东世纪汇 策略中心 北京/成都 北京/成都 分公司 研发中心 自建超算中心 徐州 新加坡/美国 海外 研发中心 Rust 在非凸算法交易服务中的全栈应用实践 内 部 智 能 引 擎 行情服务 总控模块 预测模型 策略模块 数据总线 智 能 特 征 工 程 去量纲：标准化、归一化 缺失值处理：样条插值 降维：PCA A I 信 号 生 成 LSTM 神经网络 BP 全连接网络 XGBoost 集成学习模型

数字货币交易系统 Python实践 代少飞 目录 CONTENTS 常见问题 数据库锁问题 任务调度框架 监控 单击此处添加标题 1 常见问题  队列数据丢失  队列挂掉  负数资产  冲钱一次，转两倍资产 用户资产 用户发现自己资产为负数 负数资产 充一次转双倍 队列数据丢失 队列挂掉 RabbitMQ 撮合或者清算队列数据丢失 订单摆上去，能交易 却始终交易不了 却始终交易不了 RabbitMQ 大部分功能瘫痪 钱包 用户充值一次 收到两次充值资金 常见问题 RabbitMQ队列数据丢失 • 确保消息持久化，设置durable=True, 声明exchange，queue 持久化，delivery_mode=2 指明message为持久 • 处理完后才确认消息 RabbitMQ挂掉 • 流程设计不合理，导致队列之间高频互传， 最后RabbitMQ挂掉 布式计算的Python模块)，少量代码，轻松远程调用 APscheduler+twisted 4 监控  交易系统一行代码写错，可能损失好几百万 监控 • 首先每一笔资金变动都得有变动前后的值和原因 • 挂单精度是否正确 • 一个账户，一个币种，不算手续费，初略盘点 • 利用订单客观数据(挂单价格，数量，手续费)，复现交易，与交 易记录进行对比 • 每个币种，整个资金池的流入和流出是否平衡 • 等等 THANK

区块链浏览器 669 19 运维部署工具 693 20 数据治理通用组件 745 21 多方协作治理组件 751 22 区块链应用开发组件 759 i 23 整体架构 767 24 区块链交易流程 773 25 数据结构与编码协议 779 26 核心模块设计解析 783 27 MVP 867 28 贡献者 871 29 合作伙伴 879 30 深入浅出FISCO BCOS 903 搭建第一个区块链网络 • 开发第一个区块链应用 • 关键概念 • 区块链网络搭建 • 区块链应用开发 • FISCO BCOS Java SDK • 问题排查 • 整体架构 • 共识算法 • 交易并行 • 分布式存储 • 预编译合约 • 更多设计文档 • Github主页 • 深度解析系列文章 • 贡献代码 • 反馈问题 • 应用案例集 • 微信群 、公众号 • FISCO 共识，从而快速丰富业务场景、扩大业务 规模，且大幅简化链的部署和运维成本。 两翼指的是支持并行计算模型和分布式存储，二者为群组架构带来更好的扩展性。前者改变了区块中按 交易顺序串行执行的做法，基于DAG（有向无环图）并行执行交易，大幅提升性能；后者支持企业（节 点）将数据存储在远端分布式系统中，克服了本地化数据存储的诸多限制。 多引擎是一系列功能特性的总括，比如预编译合约能够突破EVM的性能瓶颈，实现高性能合约；控制台

区块链浏览器 669 19 运维部署工具 693 20 数据治理通用组件 745 21 多方协作治理组件 751 22 区块链应用开发组件 759 i 23 整体架构 767 24 区块链交易流程 773 25 数据结构与编码协议 779 26 核心模块设计解析 783 27 MVP 867 28 贡献者 871 29 合作伙伴 879 30 深入浅出FISCO BCOS 903 搭建第一个区块链网络 • 开发第一个区块链应用 • 关键概念 • 区块链网络搭建 • 区块链应用开发 • FISCO BCOS Java SDK • 问题排查 • 整体架构 • 共识算法 • 交易并行 • 分布式存储 • 预编译合约 • 更多设计文档 • Github主页 • 深度解析系列文章 • 贡献代码 • 反馈问题 • 应用案例集 • 微信群 、公众号 • FISCO 共识，从而快速丰富业务场景、扩大业务 规模，且大幅简化链的部署和运维成本。 两翼指的是支持并行计算模型和分布式存储，二者为群组架构带来更好的扩展性。前者改变了区块中按 交易顺序串行执行的做法，基于DAG（有向无环图）并行执行交易，大幅提升性能；后者支持企业（节 点）将数据存储在远端分布式系统中，克服了本地化数据存储的诸多限制。 多引擎是一系列功能特性的总括，比如预编译合约能够突破EVM的性能瓶颈，实现高性能合约；控制台

区块链浏览器 669 19 运维部署工具 693 20 数据治理通用组件 745 21 多方协作治理组件 751 22 区块链应用开发组件 759 i 23 整体架构 767 24 区块链交易流程 773 25 数据结构与编码协议 779 26 核心模块设计解析 783 27 MVP 867 28 贡献者 871 29 合作伙伴 879 30 深入浅出FISCO BCOS 903 搭建第一个区块链网络 • 开发第一个区块链应用 • 关键概念 • 区块链网络搭建 • 区块链应用开发 • FISCO BCOS Java SDK • 问题排查 • 整体架构 • 共识算法 • 交易并行 • 分布式存储 • 预编译合约 • 更多设计文档 • Github主页 • 深度解析系列文章 • 贡献代码 • 反馈问题 • 应用案例集 • 微信群 、公众号 • FISCO 共识，从而快速丰富业务场景、扩大业务 规模，且大幅简化链的部署和运维成本。 两翼指的是支持并行计算模型和分布式存储，二者为群组架构带来更好的扩展性。前者改变了区块中按 交易顺序串行执行的做法，基于DAG（有向无环图）并行执行交易，大幅提升性能；后者支持企业（节 点）将数据存储在远端分布式系统中，克服了本地化数据存储的诸多限制。 多引擎是一系列功能特性的总括，比如预编译合约能够突破EVM的性能瓶颈，实现高性能合约；控制台

区块 块 块链 链 链应 应 应用 用 用开 开 开发 发 发组 组 组件 件 件 729 i 23 整 整 整体 体 体架 架 架构 构 构 735 24 区 区 区块 块 块链 链 链交 交 交易 易 易流 流 流程 程 程 741 25 数 数 数据 据 据结 结 结构 构 构与 与 与编 编 编码 码 码协 协 协议 议 议 747 26 核 核 核心 心 心模 模 模块 块 块设 设 搭建第一个区块链网络 • 开发第一个区块链应用 • 关键概念 • 区块链网络搭建 • 区块链应用开发 • FISCO BCOS Java SDK • 问题排查 • 整体架构 • 共识算法 • 交易并行 • 分布式存储 • 预编译合约 • 更多设计文档 • Github主页 • 深度解析系列文章 • 贡献代码 • 反馈问题 • 应用案例集 • 微信群 、公众号 平 平 平台 共识，从而快速丰富业务场景、扩大业务 规模，且大幅简化链的部署和运维成本。 两翼指的是支持并行计算模型和分布式存储，二者为群组架构带来更好的扩展性。前者改变了区块中按 交易顺序串行执行的做法，基于DAG（有向无环图）并行执行交易，大幅提升性能；后者支持企业（节 点）将数据存储在远端分布式系统中，克服了本地化数据存储的诸多限制。 多引擎是一系列功能特性的总括，比如预编译合约能够突破EVM的性能瓶颈，实现高性能合约；控制台

Extension) 是一套管理 FISCO-BCOS联盟链的工具集。WeBASE提供了图形化的管理界面，屏蔽了 区块链底层的复杂度，降低区块链使用的门槛，大幅提高区块链应用的开 发效率，包含节点前置、节点管理、交易链路，数据导出，Web管理平台 等子系统。 区块链浏览器：区块链数据浏览工具 区块链浏览器将区块链中的数据可视化，并进行实时展示。方便用户以 Web页面的方式，浏览当前区块链中的信息。本浏览器版本适配FISCO ev-SCGP）和应用开 发脚手架（SmartDev-Scaffold）。开发者可根据自己的情况自由选择相应 的开发工具，提升开发效率。 系统设计 整体架构 共识算法 交易并行 分布式存储 预编译合约 更多设计文档 社区资源 Github主页 [https://github.com/FISCO-BCOS/FISCO-BCOS/tree/master-2 关键特性 整体架构 架构模型 一体两翼多引擎 群组架构 支持链内动态扩展多群组 分布式存储 支持海量数据存储 并行计算 支持块内交易并行执行 节点类型 共识节点、观察节点 计算模型 排序-执行-验证 系统性能 峰值TPS 2万+ TPS（PBFT） 交易确认时延 秒级 硬件推荐配置 CPU 2.4GHz * 8核 内存 8GB 存储 4TB 网络带宽 10Mb 账本模型 数据结构

Extension) 是一套管理 FISCO-BCOS联盟链的工具集。WeBASE提供了图形化的管理界面，屏蔽了 区块链底层的复杂度，降低区块链使用的门槛，大幅提高区块链应用的开 发效率，包含节点前置、节点管理、交易链路，数据导出，Web管理平台 等子系统。 区块链浏览器：区块链数据浏览工具 区块链浏览器将区块链中的数据可视化，并进行实时展示。方便用户以 Web页面的方式，浏览当前区块链中的信息。本浏览器版本适配FISCO ev-SCGP）和应用开 发脚手架（SmartDev-Scaffold）。开发者可根据自己的情况自由选择相应 的开发工具，提升开发效率。 系统设计 整体架构 共识算法 交易并行 分布式存储 预编译合约 更多设计文档 社区资源 Github主页 [https://github.com/FISCO-BCOS/FISCO-BCOS/tree/master-2 关键特性 整体架构 架构模型 一体两翼多引擎 群组架构 支持链内动态扩展多群组 分布式存储 支持海量数据存储 并行计算 支持块内交易并行执行 节点类型 共识节点、观察节点 计算模型 排序-执行-验证 系统性能 峰值TPS 2万+ TPS（PBFT） 交易确认时延 秒级 硬件推荐配置 CPU 2.4GHz * 8核 内存 8GB 存储 4TB 网络带宽 10Mb 账本模型 数据结构

Extension) 是一套管理 FISCO-BCOS联盟链的工具集。WeBASE提供了图形化的管理界面，屏蔽了 区块链底层的复杂度，降低区块链使用的门槛，大幅提高区块链应用的开 发效率，包含节点前置、节点管理、交易链路，数据导出，Web管理平台 等子系统。 区块链浏览器：区块链数据浏览工具 区块链浏览器将区块链中的数据可视化，并进行实时展示。方便用户以 Web页面的方式，浏览当前区块链中的信息。本浏览器版本适配FISCO ev-SCGP）和应用开 发脚手架（SmartDev-Scaffold）。开发者可根据自己的情况自由选择相应 的开发工具，提升开发效率。 系统设计 整体架构 共识算法 交易并行 分布式存储 预编译合约 更多设计文档 社区资源 Github主页 [https://github.com/FISCO-BCOS/FISCO-BCOS/tree/master-2 关键特性 整体架构 架构模型 一体两翼多引擎 群组架构 支持链内动态扩展多群组 分布式存储 支持海量数据存储 并行计算 支持块内交易并行执行 节点类型 共识节点、观察节点 计算模型 排序-执行-验证 系统性能 峰值TPS 2万+ TPS（PBFT） 交易确认时延 秒级 硬件推荐配置 CPU 2.4GHz * 8核 内存 8GB 存储 4TB 网络带宽 10Mb 账本模型 数据结构