全网唯一标准王
(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211262498.X (22)申请日 2022.10.14 (71)申请人 中国农业银行股份有限公司 地址 100005 北京市东城区建国门内大街 69号 (72)发明人 贺丹丹 黄从颉  (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 李礼 (51)Int.Cl. H04L 67/62(2022.01) G06F 16/27(2019.01) (54)发明名称 一种有序发送信息的方法、 装置、 设备及介 质 (57)摘要 本发明公开了一种有序发送信息的方法、 装 置、 设备及介质。 该方法应用于基于 Kafka建立的 信息管理系统, 该方法包括: 基于任务请求和任 务信息流的特征, 确定任务信息流中任务信息的 时间间隔、 预发送顺序和任务信息的主题, 其中, 任务信息中包含初始产生时间; 若主题对应多种 不同的主题类型, 则基于时间间隔、 预发送顺序 和初始产生时间, 确定任务信息的目标产生时 间, 并将任务信息写入待发送信息表中; 根据目 标产生时间确定发送顺序, 并根据发送顺序发送 待发送信息表中的任务信息。 本发 明实施例的技 术方案, 实现了当Producer产生多个不同的 Topic消息时, 有序的发送不同Topic信息的效 果。 权利要求书2页 说明书10页 附图3页 CN 115550455 A 2022.12.30 CN 115550455 A 1.一种有序发送信息的方法, 其特征在于, 应用于基于Kafka建立的信息管理系 统, 所 述方法包括: 基于任务请求和任务信息流的特征, 确定所述任务信息流中任务信息的时间间隔、 预 发送顺序和所述任务信息的主题, 其中, 所述任务信息中包 含初始产生时间; 若所述主题对应多种不同的主题类型, 则基于所述时间间隔、 所述预发送顺序和所述 初始产生时间, 确定所述任务信息的目标产生时间, 并将所述任务信息写入待发送信息表 中; 根据所述目标产生 时间确定发送顺序, 并根据所述发送顺序发送所述待发送信 息表中 的任务信息 。 2.根据权利要求1所述的方法, 其特征在于, 所述根据所述目标产生时间确定发送顺 序, 包括: 确定所述待发送信息表的扫描时间间隔, 并每经过所述扫描时间间隔, 扫描一次所述 待发送信息表, 以确定所述待发送信息表中的任务信息的发送顺序, 其中, 所述扫描时间间 隔小于或等于所述时间 间隔。 3.根据权利要求1所述的方法, 其特征在于, 所述基于任务请求和任务信息流的特征, 确定所述任务信息流中任务信息的时间 间隔、 预发送顺序和所述任务信息的主题, 包括: 根据任务请求, 确定任务信息流中每个任务信息的初始产生时间、 时间间隔和预发送 顺序, 其中, 所述任务信息流中包 含多个任务信息; 根据所述任务信 息流中每个任务信 息的特征, 确定所述任务信 息流中每个任务信 息的 主题。 4.根据权利要求3所述的方法, 其特征在于, 所述若所述主题对应多种不同的主题类 型, 则基于所述时间间隔、 所述预发送顺序和所述初始产生时间, 确定所述任务信息的目标 产生时间, 并将所述任务信息写入待发送信息表中, 包括: 若所述主题对应多种不同的主题类型且所述 时间间隔大于零, 则根据 所述任务信 息的 时间间隔和所述预发送顺序, 确定所述多个任务信息中的第一任务信息; 基于所述时间 间隔调整所述第一任务信息的初始产生时间, 得到目标产生时间; 将所述第 一任务信 息和第二任务信 息, 写入待发送信息表中, 其中, 所述任务信 息包括 所述第一任务信息和所述第二任务信息, 所述第二任务信息为未经过所述调整的产生时间 对应的任务信息 。 5.根据权利要求 4所述的方法, 其特 征在于, 还 包括: 若所述主题对应多种不同的主题类型且所述 时间间隔等于零, 则将所述主题的任务信 息存入待发送信息表中; 当所述任务信息的初始产生时间相同时, 同时发送所述待发送信息表中的任务信息 。 6.根据权利要求1所述的方法, 其特征在于, 在所述发送所述待发送信 息表中的任务信 息之后, 还 包括: 生成所述任务信息的实 际发送时间, 将所述任务信息从所述待发送信息表中删除, 并 将所述实际发送时间和所述任务信息添加至已发送历史表中。 7.根据权利要求4所述的方法, 所述基于所述时间间隔调整所述第一任务信息的初始 产生时间, 得到目标产生时间, 包括:权 利 要 求 书 1/2 页 2 CN 115550455 A 2当所述多个任务信 息的初始产生 时间相同时, 计算所述第 一任务信 息的初始产生 时间 和所述时间 间隔的和, 得到目标产生时间。 8.一种有序发送信息的装置, 其特征在于, 配置于基于Kafka建立的信息管理系 统, 所 述装置包括: 主题确定模块, 用于基于任务请求和任务信息流的特征, 确定所述任务信息流中任务 信息的时间间隔、 预发送顺序和所述任务信息的主题, 其中, 所述任务信息中包含初始产生 时间; 信息写入模块, 用于若所述主题对应多种不同的主题类型, 则基于所述 时间间隔、 所述 预发送顺序和所述初始产生时间, 确定所述任务信息的目标产生时间, 并将所述任务信息 写入待发送信息表中; 信息发送模块, 用于根据所述目标产生时间确定发送顺序, 并根据所述发送顺序发送 所述待发送信息表中的任务信息 。 9.一种电子设备, 其特 征在于, 所述电子设备包括: 至少一个处 理器; 以及 与所述至少一个处 理器通信连接的存 储器; 其中, 所述存储器存储有可被所述至少一个处理器执行的计算机程序, 所述计算机程序被所 述至少一个处理器执行, 以使所述至少一个处理器能够执行权利要求1 ‑7中任一项所述的 有序发送信息的方法。 10.一种计算机可读存储介质, 其特征在于, 所述计算机可读存储介质存储有计算机指 令, 所述计算机指令用于使处理器执行时实现权利要求1 ‑7中任一项所述的有序发送信息 的方法。权 利 要 求 书 2/2 页 3 CN 115550455 A 3

.PDF文档 专利 一种有序发送信息的方法、装置、设备及介质

文档预览
中文文档 16 页 50 下载 1000 浏览 0 评论 309 收藏 3.0分
温馨提示:本文档共16页,可预览 3 页,如浏览全部内容或当前文档出现乱码,可开通会员下载原始文档
专利 一种有序发送信息的方法、装置、设备及介质 第 1 页 专利 一种有序发送信息的方法、装置、设备及介质 第 2 页 专利 一种有序发送信息的方法、装置、设备及介质 第 3 页
下载文档到电脑,方便使用
本文档由 人生无常 于 2024-03-18 00:49:24上传分享
友情链接
站内资源均来自网友分享或网络收集整理,若无意中侵犯到您的权利,敬请联系我们微信(点击查看客服),我们将及时删除相关资源。