(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211177328.1 (22)申请日 2022.09.26 (71)申请人 昆仑数智科技有限责任公司 地址 100007 北京市东城区青龙胡同1号歌 华大厦15 01室 申请人 中国石油天然气集团有限公司 (72)发明人 王浩　元红萍　杨剑锋　韩丽敏　 袁朝贵　张岩　陈炼　 (74)专利代理 机构 北京三高永信知识产权代理 有限责任公司 1 1138 专利代理师 侯晓雅 (51)Int.Cl. G06F 9/54(2006.01) G06F 9/445(2018.01) G06Q 30/02(2012.01)G06Q 10/06(2012.01) (54)发明名称 微服务数据传输系统、 方法及存 储介质 (57)摘要 本申请公开了一种微服务数据传输系统、 方 法及存储介质， 属于计算机技术领域。 所述系统 包括多个业务服务器、 多个积分管理服务器和中 间服务器， 所述多个业务服务器与所述中间服务 器连接， 所述多个积分管理服务器与所述中间服 务器连接， 所述中间服务器配置有数据队列； 所 述业务服务器， 用于将待发送的积分数据写入所 述中间服务器的数据队列； 所述积分管理服务 器， 用于从所述数据队列中读取所述积分数据， 基于读取的积分数据进行积分管 理。 该系统中积 分管理服务器不再被调用， 而是主动从中间服务 器中读取积分数据， 能够有效减 轻积分管理服务 器的压力， 从而减少了积分管 理服务器宕机的情 况， 能够更加准确地进行积分管理。 权利要求书4页 说明书13页 附图3页 CN 115525449 A 2022.12.27 CN 115525449 A 1.一种微服务数据传输系统， 其特征在于， 所述系统包括多个业务服务器、 多个积分管 理服务器和中间服务器， 所述多个业务服务器与所述中间服务器连接， 所述多个积分管理 服务器与所述中间服 务器连接， 所述中间服 务器配置有数据队列； 所述业务服务器， 用于将待发送的积分数据写入所述中间服 务器的数据队列； 所述积分管理服务器， 用于从所述数据队列中读取所述积分数据， 基于读取的积分数 据进行积分管理。 2.根据权利要求1所述的系统， 其特 征在于， 所述积分管理服务器， 用于从所述数据队列中读取第一积分数据之后， 将所述第一积 分数据存储到积分数据库中， 并将所述积分数据库中的所述第一积分数据标记为未处理， 对所述第一积分数据进行 处理， 处理完成后将所述积分数据库中的所述第一积分数据的标 记修改为已处 理， 所述第一积分数据为所述数据队列中的任一积分数据。 3.根据权利要求2所述的系统， 其特 征在于， 所述积分管理服务器， 还用于对所述积分数据库进行查询， 在从所述积分数据库中查 询到被标记为未处理且存储时长超过第一时长的第二积分数据时， 对所述第二积分数据进 行处理， 处理完成后将所述积分数据库中的所述第二积分数据的标记修改为已处 理。 4.根据权利要求3所述的系统， 其特 征在于， 所述积分管理服务器， 还用于每隔所述第一 时长， 确定第 一目标时间段， 对所述积分数 据库中所述第一目标时间段内存储的积分数据进 行查询， 在查询到标记为未处理的第二积 分数据时， 对所述第二积分数据进行处理， 所述第一 目标时间段 的终止时间点为当前时间 点前所述第一时长的时间点， 所述第一目标时间段的起始时间点为所述 终止时间点前所述 第一时长的时间点。 5.根据权利要求2所述的系统， 其特 征在于， 所述积分管理服 务器， 还用于将所述第一积分数据写入内存中； 所述积分管理服务器， 还用于启动处理线程， 通过所述处理线程对所述内存中的所述 第一积分数据进行处 理； 所述积分管理服务器， 还用于在处理完所述第一积分数据之后， 将所述内存中的所述 第一积分数据删除。 6.根据权利要求1所述的系统， 其特 征在于， 所述多个积分管理服 务器， 用于对所述数据队列进行监听； 最先监听到最新写入的第 三积分数据的积分管理服务器， 用于从所述数据队列中读取 所述第三积分数据。 7.根据权利要求6所述的系统， 其特 征在于， 所述业务服务器， 还用于将第 四积分数据写入所述数据队列之后， 将所述数据队列中 的所述第四积分数据标记为未处 理， 所述第四积分数据为任一待发送的积分数据； 最先监听到标记为未处理的所述第四积分数据的积分管理服务器， 用于将所述数据队 列中监听到的第四积分数据标记为处理中， 以使其他积分管理服务器不再读取所述第四积 分数据； 所述积分管理服务器， 还用于从所述数据队列中读取并处理监 听到的所述第四积分数 据， 读取并处 理完成后将所述数据队列中的所述第四积分数据的标记修改为已处 理。权　利　要　求　书 1/4 页 2 CN 115525449 A 28.根据权利要求7 所述的系统， 其特 征在于， 所述中间服务器， 用于对所述数据队列进行查询， 在从所述数据队列中查询到被标记 为处理中且存储时长超过第二时长的第五积分数据时， 向任一积分管理服务器发送数据处 理请求， 所述数据 处理请求携带所述第 五积分数据， 所述数据 处理请求用于请求所述任一 积分管理服 务器处理所述第五积分数据。 9.根据权利要求8所述的系统， 其特 征在于， 所述中间服务器， 用于每隔第 一时长， 确定第 二目标时间段， 对所述数据队列中所述第 二目标时间段内写入的积分数据进行查询， 在查询 到标记为处理中的第 五积分数据时， 向 任一积分管理服务器发送所述第五积分数据， 所述第二目标时间段的终止时间点为当前时 间点前所述第二时长的时间点， 所述第二目标时间段的起始时间点为所述终止时间点前所 述第一时长的时间点， 所述第二时长不小于所述第一时长的两倍。 10.根据权利要求1至9任一项所述的系统， 其特 征在于， 所述业务服务器， 还用于将第 四积分数据存储到业务数据库中， 并将所述业务数据库 中的所述第四积分数据标记为未发送， 所述第四积分数据为任一待发送的积分数据； 所述业务服务器， 还用于在将所述第 四积分数据写入所述数据队列完成之后， 将所述 业务数据库中的所述第四积分数据的标记修改为已发送。 11.根据权利要求10所述的系统， 其特 征在于， 所述业务服务器， 还用于对所述业务数据库进行查询， 在从所述业务数据库中查询到 被标记为未发送且存储时长超过第三时长的第六积分数据时， 将所述第六积分数据写入所 述数据队列， 写入完成后将所述 业务数据库中的所述第六积分数据的标记修改为已发送。 12.根据权利要求1 1所述的系统， 其特 征在于， 所述业务服务器， 还用于每隔所述第 三时长， 确定第 三目标时间段， 对所述业务数据库 中第三目标时间段内存储的积分数据进行查询， 在查询到标记为未发送的第六积分数据 时， 将所述第六积分数据写入所述数据队列， 所述第三 目标时间段的终止时间点为当前时 间点前所述第三时长的时间点， 所述第三目标时间段的起始时间点为所述终止时间点前所 述第三时长的时间点。 13.一种微服务数据传输方法， 其特征在于， 由微服务数据传输系统执行， 所述微服务 数据传输系统包括多个业务服务器、 多个积分管理服务器和中间服务器， 所述多个业务服 务器与所述中间服务器连接， 所述多个积分管理服务器与所述中间服务器连接， 所述中间 服务器配置有数据队列； 所述方法包括： 所述业务服务器将待发送的积分数据写入所述中间服 务器的数据队列； 所述积分管理服务器从所述数据队列中读取所述积分数据， 基于读取的积分数据进行 积分管理。 14.根据权利要求13所述的方法， 其特征在于， 所述基于读取的积分数据进行积分管 理， 包括： 所述积分管理服务器从所述数据队列中读取第 一积分数据之后， 将所述第 一积分数据 存储到积分数据库中， 并将所述积分数据库中的所述第一积分数据标记为未处理， 对所述 第一积分数据进 行处理， 处理完成后 将所述积分数据库中的所述第一积分数据的标记修改 为已处理， 所述第一积分数据为所述数据队列中的任一积分数据。权　利　要　求　书 2/4 页 3 CN 115525449 A 3