全网唯一标准王
(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211025546.3 (22)申请日 2022.08.25 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 滕建德 王欣 王增峰 何怀莹  曹仰止  (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 薛平 陶海萍 (51)Int.Cl. G06F 9/54(2006.01) G06Q 40/02(2012.01) (54)发明名称 MQ消息丢失场景的处 理方法及装置 (57)摘要 本发明公开了一种MQ消息丢失场景的处理 方法及装置, 涉及人工智 能领域, 其中该方法包 括: 从发送方预先建立的第一临时队列中读取第 一消息, 从接收方预先建立的第二临时队列中读 取第二消息; 其中, 从第一临时队列中读取的第 一消息为发送方组装完消息在传送至传输队列 之前先传送至第一临时队列的消息, 从第二临时 队列中读取的第二消息为接收方在从接收队列 中读取到消息后先传送至第二临时队列的消息; 将从第一临时队列中读取出的第一消息与从第 二临时队列中读取出的第二消息进行匹配; 若匹 配不成功, 说明第一消息丢失, 通知发送方重新 将第一消息重发至接收方。 本发明可以针对MQ消 息丢失的场景, 通过建立临时队列重发消息, 保 证消息的完整性。 权利要求书2页 说明书7页 附图3页 CN 115357411 A 2022.11.18 CN 115357411 A 1.一种MQ消息 丢失场景的处 理方法, 其特 征在于, 包括: 从发送方预先建立的第 一临时队列中读取第 一消息, 从接收方预先建立的第 二临时队 列中读取第二消息; 其中, 从第一临时队列中读取 的第一消息为发送方组装完消息在传送 至传输队列之前先传送至第一临 时队列的消息, 从第二临时队列中读取的第二消息为接收 方在从接收队列中读取到消息后先传送至第二临时队列的消息; 将从第一临时队列中读取出的第一消息与从第二临时队列中读取出的第二消息进行 匹配; 若匹配不成功, 说明第一消息 丢失, 通知发送方将第一消息 重新发送至 接收方。 2.如权利要求1所述的MQ消息 丢失场景的处 理方法, 其特 征在于, 还 包括: 循环执行从发送方的第 一临时队列中读取下一条消息, 将该下一条消息与 所述第二消 息进行匹配, 直至匹配成功。 3.如权利要求1所述的MQ消息丢失场景的处理方法, 其特征在于, 还包括: 若匹配成功, 直接匹配下一条消息 。 4.如权利要求1所述的MQ消息丢失场景的处理方法, 其特征在于, 还包括: 若从发送方 的第一临 时队列中所读取的第一消息为最后一条消息, 从接收方的第二临时队列中读取的 第二消息不 为最后一条消息, 说明第一消息已丢失, 直接通知发送方重发。 5.如权利要求1所述的MQ消息丢失场景的处理方法, 其特征在于, 将从第 一临时队列中 读取出的第一消息与从第二临时队列中读取出 的第二消息进行匹配, 包括: 根据预先为消 息设置的顺序标识, 将从第一临 时队列中读取出的第一消息与从第二临 时队列中读取出的 第二消息进行匹配。 6.一种MQ消息 丢失场景的处 理装置, 其特 征在于, 包括: 读取单元, 用于从发送方预先建立的第一临时队列中读取第一消息, 从接收方预先建 立的第二临时队列中读取第二消息; 其中, 从第一临时队列中读取 的第一消息为发送方组 装完消息在传送至传输队列之前先传送至第一临 时队列的消息, 从第二临时队列中读取的 第二消息为接收方在从接收队列中读取到消息后先传送至第二临时队列的消息; 匹配单元, 用于将 从第一临时队列中读取出的第 一消息与从第 二临时队列中读取出的 第二消息进行匹配; 处理单元, 用于若 匹配不成功, 说明第一消息丢失, 通知发送方将第 一消息重新发送至 接收方。 7.如权利要求6所述的MQ消息丢失场景的处理装置, 其特征在于, 所述处理单元还用 于: 循环执行从发送方的第一临时队列中读取下一条消息, 将该下一条消息与所述第二消 息进行匹配, 直至匹配成功。 8.如权利要求6所述的MQ消息丢失场景的处理装置, 其特征在于, 所述处理单元还用 于: 若匹配成功, 直接匹配下一条消息 。 9.如权利要求6所述的MQ消息丢失场景的处理装置, 其特征在于, 所述处理单元还用 于: 若从发送方的第一临时队列中所读取 的第一消息为最后一条消息, 从接 收方的第二临 时队列中读取的第二消息不 为最后一条消息, 说明消息已丢失, 直接通知发送方重发。 10.如权利要求6所述的MQ消息丢失场景的处理装置, 其特征在于, 所述匹配单元具体 用于: 根据预先为消息设置的顺序标识, 将从第一临时队列中读取出 的第一消息与从第二权 利 要 求 书 1/2 页 2 CN 115357411 A 2临时队列中读取 出的第二消息进行匹配。 11.一种计算机设备, 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序, 其特征在于, 所述处理器执行所述计算机程序时实现权利要求1至5任一所述方 法。 12.一种计算机可读存储介质, 其特征在于, 所述计算机可读存储介质存储有计算机程 序, 所述计算机程序被处 理器执行时实现权利要求1至 5任一所述方法。 13.一种计算机程序产品, 其特征在于, 所述计算机程序产品包括计算机程序, 所述计 算机程序被处 理器执行时实现权利要求1至 5任一所述方法。权 利 要 求 书 2/2 页 3 CN 115357411 A 3

PDF文档 专利 MQ消息丢失场景的处理方法及装置

文档预览
中文文档 13 页 50 下载 1000 浏览 0 评论 0 收藏 3.0分
温馨提示:本文档共13页,可预览 3 页,如浏览全部内容或当前文档出现乱码,可开通会员下载原始文档
专利 MQ消息丢失场景的处理方法及装置 第 1 页 专利 MQ消息丢失场景的处理方法及装置 第 2 页 专利 MQ消息丢失场景的处理方法及装置 第 3 页
下载文档到电脑,方便使用
本文档由 SC 于 2024-03-03 12:15:45上传分享
友情链接
站内资源均来自网友分享或网络收集整理,若无意中侵犯到您的权利,敬请联系我们微信(点击查看客服),我们将及时删除相关资源。