(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210168682.1 (22)申请日 2022.02.23 (71)申请人 盈立数智科技 （深圳） 有限公司 地址 518000 广东省深圳市南 山区粤海街 道科技园社区科苑路15号科兴科学园 B栋B4-10 03 (72)发明人 王伏根　 (74)专利代理 机构 深圳市深可信专利代理有限 公司 44599 专利代理师 刘昌刚 (51)Int.Cl. G06Q 40/04(2012.01) G06F 16/23(2019.01) G06F 16/2455(2019.01) G06F 9/54(2006.01) (54)发明名称 一种行情榜单生成方法及系统 (57)摘要 本发明提供了一种行情榜单生成方法及系 统， 涉及行情数据处理技术领域， 该方法包括以 下的步骤:S1、 行情消费线程根据配置的市场信 息， 从kafka中订阅该市场的实时行情消息， 更新 到行情缓存； S2、 排序线程基于所述行情缓存和 外部的证券基础信息生成行情榜单列表， 写入至 榜单缓存； S3、 接口线程接收到外部服务的GRPC 请求后， 返回榜单缓存中的数据， 实现实时行情 接收、 缓存、 行情指标计算、 排序以及接口输出。 权利要求书2页 说明书4页 附图1页 CN 114723558 A 2022.07.08 CN 114723558 A 1.一种行情榜单生成方法， 其特 征在于： 包括以下的步骤： S1、 行情消费线程根据配置的市场信息， 从kafka中订阅该市场的实时行情消息， 更新 到行情缓存； S2、 排序线程基于所述行情缓存和外部的证券基础信息生成行情榜单列表， 写入至榜 单缓存； S3、 接口线程接收到 外部服务的GRPC请求后， 返回榜单缓存中的数据。 2.如权利要求1所述的一种行情榜单生成方法， 其特征在于： 所述步骤S1， 包括以下的 步骤： S11、 行情消费线程收到kafka推送的实时行情消息后， 将实时行情消息数据反序列化 为pb消息对象； S12、 使用所述pb消息对象中的字段更新数据至行情缓存， 该更新的数据为快照数据， 包括最新价、 昨日收盘价、 最高价、 最低价、 成交量和成交额。 3.如权利要求2所述的一种行情榜单生成方法， 其特征在于： 所述步骤S2， 包括以下的 步骤： S21、 排序线程定时访问外部基础信息服务， 获取证券基础信息， 即每支证券代码的静 态信息， 同时重新构建每 个榜单包 含的证券代码列表； S22、 将所有快照数据以及实时计算生成的新排序指标定时写入到榜单缓存中对应每 支证券代码的数据结构； S23、 获取所述证券代码列表， 以及每支证券代码对应的榜单缓存， 针对每一个排序指 标， 获取榜单缓存中相应的数据值， 按照由低到高的顺序进 行排列， 得到每一种排序指标对 应的代码列表， 生成行情排行榜至榜单缓存。 4.如权利要求3所述的一种行情榜单生成方法， 其特征在于： 所述步骤S3， 包括以下的 步骤： S31、 接口线程接收来自外 部服务的GRPC请求， GRPC即 Google的远程过程调用系统； S32、 根据GRPC请求的证券市场、 榜单类型、 排序指标、 递增或递减方向， 将榜单缓存中 的行情排行榜数据以分页的方式返回。 5.如权利要求3所述的一种行情榜单生成方法， 其特征在于： 所述步骤S1， 还包括以下 的步骤： S103、 行情消费线程将行情缓存中的最新行情数据异步刷新至历史缓存文件,生成历 史行情数据。 6.如权利要求5所述的一种行情榜单生成方法， 其特征在于： 所述步骤S22中， 所述新排 序指标通过以下的方式计算： 根据最新快照数据计算； 和/或通过最 新快照数据和证券基础信息计算； 和/或通过最 新快照数据和所述历史行情数据计算。 7.一种行情榜单生成系统， 其特 征在于： 包括行情消费线程、 排序线程和接口线程， 行情消费线程用于根据配置的市场信息， 从kafka中订阅该市场的实时行情消息， 更新 到行情缓存； 排序线程用于根据所述行情缓存和外部的证券基础信 息生成行情榜单列表， 写入至榜 单缓存；权　利　要　求　书 1/2 页 2 CN 114723558 A 2接口线程用于 接收外部服务的GRPC请求， 并返回榜单缓存中的数据。 8.如权利要求7所述的一种行情榜单生成系统， 其特征在于： 行情消费线程还用于将行 情缓存中的最 新行情数据异步刷新至历史缓存文件,生成历史行情数据。 9.如权利要求8所述的一种行情榜单生成系统， 其特征在于： 行情消费线程还用于将根 据历史行情数据计算得到的排序指标保存至历史缓存文件。 10.如权利要求7所述的一种行情榜单生成系统， 其特征在于： 还包括主线程， 主线程用 于定时将榜单缓存中的数据写入本地文件； 主线程还用于在系统重启时优先读取本地文件中的榜单缓存数据。权　利　要　求　书 2/2 页 3 CN 114723558 A 3