(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210743961.6 (22)申请日 2022.06.28 (71)申请人 上海中汇亿达金融信息技 术有限公 司 地址 201203 上海市浦东 新区张东路1387 号18幢02单 元 (72)发明人 刘国强　黄汉辉　楼康华　汪宏斌　 姬小朋　 (74)专利代理 机构 上海专利商标事务所有限公 司 31100 专利代理师 顾嘉运　亓云 (51)Int.Cl. G06F 16/25(2019.01) G06F 9/54(2006.01) G06Q 40/04(2012.01) (54)发明名称 统一标准行情平台 (57)摘要 本申请涉及一种统一标准行情平台， 包括： 数据分层模块， 被配置为将来自各个行情数据源 的行情数据存储在统一标准行情平台的各数据 分层中； 主题发布模块， 被配置为将接入的所述 行情数据以行情主题形式发布到所述各数据分 层； 数据核心处理模块， 被配置为管理行情主题， 并提供对所述行情主题的注册、 订阅和消费服 务； 统一API接入包模块， 被配置为将行情订阅服 务的各种功能统一封装在API接入包中以方便下 游订阅和消费行情； 以及数据存储模块， 被配置 为根据统一规划， 将接入的所述行情数据存储到 不同的数据库。 权利要求书2页 说明书9页 附图2页 CN 115033632 A 2022.09.09 CN 115033632 A 1.一种统一标准行情平台， 包括： 数据分层模块， 被配置为将来自各个行情数据源的行情数据存储在所述统一标准行情 平台的各 数据分层中； 主题发布模块， 被配置为将接入的所述行情数据以行情主题形式发布到所述各数据分 层； 数据核心处理模块， 被配置为管理所述行情主题， 并提供对所述行情主题的注册、 订 阅 和消费服务； 统一API接入包模块， 被配置为将行情订阅服务的各种功能统一封装在API接入包中以 方便下游订阅和 消费行情； 以及 数据存储模块， 被配置为根据统一 规划将接入的所述行情数据存 储到不同的数据库。 2.如权利要求1所述的统一标准行情平台， 其特征在于， 所述数据分层包括基于Kafka 平台的K1层和K2层； 其中， 所述K1层存 储了全量的行情数据， 用于解决全量行情消费； 其中， 所述K2层存储了活跃行情资产标的的行情数据， 用于解决活跃度高的资产标的 消费； 其中， 所述K2层存 储的行情数据是由所述K1层转发的。 3.如权利要求2所述的统一标准行情平台， 其特征在于， 在所述K1和K2层中采用主题方 式来组织行情资产标的， 并针对订阅服务分别定义了ID和IP:PORT构成的配置信息， 所述数 据核心处理模块以ID： IP： PORT向注册 中心注册主题， 并且如果出现主题的变动， 则将所述 变动实时更新到所述注 册中心。 4.如权利要求2所述的统一标准行情平台， 其特征在于， 所述数据核心 处理模块根据 下 游订阅是否多次订阅活跃资产标的来判断是否要将K1层的资产标的主题再转发到K2的主 题。 5.如权利要求3所述的统一标准行情平台， 其特征在于， 所述统一API接入包模块包括 实现下述功能的API： 1)资源侦听和汇总， 其中API与注册中心保持常连接， 以实时获取主题服务列表、 订阅 服务的ID以及订阅服 务所在的IP/PORT； 2)提供行情订阅、 取消、 回调的接口； 3)提供断线重连机制和心跳 机制。 6.如权利要求1所述的统一标准行情平台， 其特征在于， 所述行情订阅服务实时把内存 存储的数据延迟写入到共享磁盘， 这样， 当出现异常或者服务器迁移时， 在进程恢复之后， 从所述共享磁 盘装载所述数据。 7.如权利要求1所述的统一标准行情平台， 其特征在于， 所述数据存储模块进一步包括 数据字典， 所述数据字典具有下述功能： 1)统一规划各行情品种的业 务要素， 定义 其唯一的K ey值； 2)统一规划各数据源的数据定义， 维护CIC与数据源、 主题服 务之间的关联关系； 3)数据字典方便上、 下游对接， 并使得 所述统一行情平台对业 务脱敏。 8.如权利要求1所述的统一标准行情平台， 其特征在于， 所述主题的注册服务执行下述 流程：权　利　要　求　书 1/2 页 2 CN 115033632 A 2订阅服务启动时， 向注册中心发布主题的逻辑ID、 实际IP、 实际PORT， 以及可提供的数 据服务主题， 这些 数据主题信息都会保存到所述注 册中心的内存中； 订阅服务在运行时， 保持对实际P ORT的侦听， 接收下游API的数据订阅或者取消订阅的 业务逻辑处 理。 9.如权利要求1所述的统一标准行情平台， 其特征在于， 所述主题的订 阅服务执行下述 流程： 检查主题的CIC的合法性； 获取所述CIC的属性； 检查所述CIC订阅状况； 依据所述主题， 检查 订阅服务的连接状况； 向订阅服 务发起连接； 以及 向订阅服 务发起订阅。 10.如权利要求2所述的统一标准行情平台， 其特 征在于， 订阅的行情消费流 程： 接收K1层的主题消息， 根据所述主题消息确定是活跃 行情主题还是全量行情消息； 如果接收的是活跃行情主题， 则把所述主题消息推送到所述K2层的对应主题以在所述 K2层进行 行情消费； 而如果接收的是全量行情消息， 则所述消息被直接推送给 所述K1层以直接消费。权　利　要　求　书 2/2 页 3 CN 115033632 A 3