(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210638959.2 (22)申请日 2022.06.08 (71)申请人 国泰君安证券股份有限公司 地址 200041 上海市 静安区南京西路768号 国泰君安大厦20层 (72)发明人 俞枫　叶振博　赵振江　龚恩照　 胡爽　 (74)专利代理 机构 上海智信专利代理有限公司 31002 专利代理师 王洁　郑暄 (51)Int.Cl. G06Q 40/04(2012.01) G06F 16/215(2019.01) G06F 16/23(2019.01) G06F 16/24(2019.01)G06F 16/25(2019.01) (54)发明名称 针对多源实时行情数据实现高可用 接收及 处理的系统 (57)摘要 本发明涉及一种针对多源实时行情数据实 现高可用接收及处理的系统， 包括数据接收适配 模块对接多路行情数据， 将行情数据转换为统一 格式； 数据中转模块将数据维护至多个主题中； 业务服务模块根据需要对各类业务数据进行计 算处理及提供相应API； 数据存储模块缓存和持 久化数据； 数据访问模块为客户端提供数据访问 服务。 采用了本发明的针对多源实时行情数据实 现高可用接收及处理的系统， 通过多个接收节点 间的协作实现数据接收环节的热备和故障自动 切换， 保障多路数据源的高可用接收； 充分利用 Pulsar作为数据中转， 将数据处理划分为多个相 对独立的模 块， 架构灵活， 扩展方便； 通过P ulsar 可靠传输到远端云机机房， 支持轻量化部署， 具 有高可用、 高性能、 易扩 展的特征。 权利要求书2页 说明书7页 附图1页 CN 115018642 A 2022.09.06 CN 115018642 A 1.一种针对多源实时行情数据实现高可用接收及处理的系统， 其特征在于， 所述的系 统包括： 数据接收适配模块， 用于对接多路行情数据， 进行协议解析和数据格 式转换， 将行情数 据转换为统一格式， 并根据市场类型或合约类型分别发送至数据中转模块； 数据中转模块， 与所述的数据接收适配模块相连接， 用于对多路数据进行自动去重和 归并， 并将数据维护至多个主题中； 业务服务模块， 与所述的数据中转模块相连接， 用于读取统一格式的行情结构体数据， 根据需要对各类业 务数据进行计算处 理及提供相应API， 并封装业 务相关的API接口； 数据存储模块， 与所述的业务服务模块相连接， 用于缓存和持久化中间数据、 结果数据 和行情快照数据； 数据访问模块， 输入端与所述的数据中转模块、 业务服务模块相连接， 输出端与客户端 相连接， 用于为客户端提供数据访问服务， 并接收客户端的主题订阅请求建立长连接， 向客 户端实时推送相应数据。 2.根据权利要求1所述的针对多源实时行情数据实现高可用接收及处理的系统， 其特 征在于， 所述的数据接收适配模块包括： 数据接收单 元， 用于对接多路实时行情数据源及其 他行情数据源； 数据解析单元， 与所述的数据接收单元相连接， 用于解析行情数据源， 并从每帧实时行 情数据中提取多条 数据； 结构转换单元， 与所述的数据解析单元相连接， 用于根据数据源的接入要求进行协议 适配并数据转换， 提取 数据所属类型； 初始化单元， 与所述的结构转换单元相连接， 用于提取毫秒级时间戳用作消息数据的 序列ID属性 值； 转发单元， 与所述的初始化单 元相连接， 用于转发给对应生产者单 元。 3.根据权利要求1所述的针对多源实时行情数据实现高可用接收及处理的系统， 其特 征在于， 所述的数据中转模块包括： 数据去重单元， 与所述的数据接收适配模块相连接， 用于根据序列ID对数据进行自动 去重； 数据中转单元， 与所述的数据去重单元相连接， 用于根据数据类型将行情数据维护在 多个主题中。 4.根据权利要求1所述的针对多源实时行情数据实现高可用接收及处理的系统， 其特 征在于， 所述的业务服务模块从数据中转模块 获取上游数据， 进 行数据计算及加工处理， 将 加工后的数据存 储到缓存或 持久化到数据库， 或者将加工后的数据发送至对应主题。 5.根据权利要求1所述的针对多源实时行情数据实现高可用接收及处理的系统， 其特 征在于， 所述的数据访问模块接收客户端的用户请求， 提供数据订阅和数据查询的服务； 将 用户请求转 发至业务服务模块提供的各种API， 并将结果返回至客户端； 接收客户端的主题 订阅请求， 建立长连接并向客户端实时推送相应数据。 6.根据权利要求1所述的针对多源实时行情数据实现高可用接收及处理的系统， 其特 征在于， 所述的系统还包括多个云机房子系统， 每个所述的云机房子系统包括数据中转模 块复制节点和云机房的数据访问模块， 多个所述的数据中转模块复制节点的输入端均与所权　利　要　求　书 1/2 页 2 CN 115018642 A 2述的数据中转模块相连接， 云机房的数据访问模块与该云机房子系统的数据中转模块复制 节点相连接， 多个所述的云机房的数据访问模块的输出端均 与客户端相连。权　利　要　求　书 2/2 页 3 CN 115018642 A 3