(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111497576.X (22)申请日 2021.12.09 (71)申请人 盈立数智科技 （深圳） 有限公司 地址 518000 广东省深圳市南 山区粤海街 道科技园社区科苑路15号科兴科学园 B栋B4-10 03 (72)发明人 张成坤　 (74)专利代理 机构 深圳市深可信专利代理有限 公司 44599 代理人 周刘佳 (51)Int.Cl. G06Q 40/04(2012.01) G06Q 10/10(2012.01) G06F 16/242(2019.01) G06F 16/28(2019.01) (54)发明名称 一种易于控制的清盘行情发送方法及系统 (57)摘要 本发明提供了一种易于控制的清盘行情发 送方法及系统， 涉及行情数据处理技术领域， 该 方法包括以下的步骤:S1、 配置行情日历； S2、 定 期读取行情日历， 保存开盘时间； S3、 校验开盘时 间， 构造清盘行情； S4、 推送清盘行情给用户,可 在正常情况时， 于正常时间发送清盘行情给用 户， 并且可在异常情况导致不能正常开盘时通过 人工配置开盘时间， 灵活、 及时地应对开市时间 调整， 实现灵活发送 清盘行情给用户。 权利要求书2页 说明书4页 附图1页 CN 114331715 A 2022.04.12 CN 114331715 A 1.一种易于控制的清盘行情发送方法， 其特 征在于： 包括以下的步骤： S1、 配置行情日历； S2、 定期读取 行情日历， 保存开盘时间； S3、 校验开盘时间， 构造清盘行情； S4、 推送清盘行情给用户。 2.如权利要求1所述的一种易于控制的清盘行情发送方法， 其特征在于： 所述步骤S1， 包括以下的步骤： S11、 通过网页浏览器打开行情日历配置界面， 在行情日历配置界面填写配置参数， 参 数包括日期和开盘时间， 然后以POST请求 提交参数， POST是一种HT TP请求方法； S12、 后台服务系统收到网页浏览器的请求后， 解析出所述参数， 参数包括日期和开盘 时间， 然后调用Mys ql客户端库连接Mysql， 将日期和开盘时间作为记录插入到Mysql， M ysql 是一种开源的关系型 数据库。 3.如权利要求2所述的一种易于控制的清盘行情发送方法， 其特征在于： 所述步骤S2， 包括以下的步骤： S21、 行情解码服务系统开启第一线程， 每隔一定时间， 以今天的日期作为请求参数， 向 行情日历服 务系统发送grpc请求， grpc是一种谷 歌开源的远程调用框架； S22、 行情日历服务系统收到所述grpc请求后， 调用Mysql客户端连接Mysql数据， 以所 述请求参数中的日期作为条件， 执行SQL， 查询今天的开盘时间， 将查询到的结果返回给行 情解码服 务系统， SQ L是一种用于访问和处 理数据库的计算机语言； S23、 行情解码服 务系统收到返回结果， 并从结果中得到开盘时间。 4.如权利要求3所述的一种易于控制的清盘行情发送方法， 其特征在于： 所述步骤S3， 包括以下的步骤： S31、 行情解码服 务系统开启第二线程， 第二线程于每天固定时间触发定时器； S32、 第二线程触发定时器时判断所述开盘时间是否为正常开盘时间， 如果不是， 则结 束清盘流程， 如果是， 则构造清盘行情， 并转化为Pb数据格式， 发送到Kafka， Pb即protobuf， 是一种Go ogle开源的实现数据自动序列化和反序列化的机制。 5.如权利要求4所述的一种易于控制的清盘行情发送方法， 其特征在于： 所述步骤S4， 包括以下的步骤： S41、 行情推送服 务系统从Kafka消费Pb数据， 调用Pb库解析 出清盘行情数据； S42、 将清盘行情数据 通过TCP连接推送给用户， TCP是一种面向连接的、 可靠的、 基于字 节流的传输层通信协议。 6.一种易于控制的清盘行情 发送系统， 其特征在于： 包括后台服务系统、 行情解码服务 系统、 行情日历服 务系统和行情推送服 务系统， 后台服务系统用于解析在行情日历配置界面中填写配置的参数， 所述参数包括日期和 开盘时间， 然后调用Mysql 客户端库连接 Mysql， 将日期和开盘时间作为记录插 入到Mysql； 行情解码服务系统与行情日历服务系统连接， 用于开启第 一线程， 每隔一定时间， 以今 天的日期作为请求参数， 向行情日历服务系统发送grpc请求； 行情解码服务系统还用于接 收行情日历服 务系统的返回结果， 并从结果中得到开盘时间； 行情日历服务系统用于在收到所述grpc请求后， 调用Mysql客户端连接Mysql数据， 以权　利　要　求　书 1/2 页 2 CN 114331715 A 2所述请求参数中的日期作为条件， 执行SQL， 查询今天的开盘时间， 将查询到的结果返回给 行情解码服 务系统； 行情解码服务系统还用于开启第二线程， 第二线程于每天固定时间触发定时器， 第二 线程触发定时器时判断所述开盘时间是否为正常开市时间， 如果不是， 则结束清盘流程， 如 果是， 则构造清盘行情， 并转 化为Pb数据格式， 发送到Kafka； 行情推送服务系统用于从Kafka消费Pb数据， 调用Pb库 解析出清盘行情数据， 并将清盘 行情数据通过TCP连接推送给用户。权　利　要　求　书 2/2 页 3 CN 114331715 A 3