(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211144315.4 (22)申请日 2022.09.20 (71)申请人 中国银行股份有限公司 地址 100818 北京市西城区复兴门内大街1 号 (72)发明人 徐世泽　陈晓旋　陈晓霞　彭雨岚　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 孔祥贵 (51)Int.Cl. G06F 9/54(2006.01) G06Q 40/02(2012.01) (54)发明名称 一种消息处 理方法及相关装置 (57)摘要 本申请公开一种消息处理方法及相关装置， 可应用于 金融领域， 监听应用从消息队列获取第 一消息进行第一业务逻辑处理， 第一业务处理逻 辑包括m次业务逻辑处理， m为小于M的正整数， M 为大于1的正整数。 获取第一业务逻辑处理的第 一处理结果， 若第一处理结果为处理失败， 将第 一消息添加至延时队列， 监听应用继续从消息队 列中监听并获取第二消息进行第一业务逻辑处 理。 守护线程应用对延时队列中第一消息进行第 二业务逻辑处理， 完成处理失败的第一消息的再 处理， 得到第一消息的第二处理结果， 第二业务 逻辑处理包括M ‑m次业务逻辑处理。 由此能多消 息并发处理， 提升消息的处理效率， 避免消息堵 塞， 提高资源的利用率， 大大降低银行系统运行 崩溃的风险。 权利要求书2页 说明书10页 附图3页 CN 115543654 A 2022.12.30 CN 115543654 A 1.一种消息处 理方法， 其特 征在于， 所述方法包括： 通过监听应用从消息队列中获取第 一消息进行第 一业务逻辑处理， 所述第 一业务处理 逻辑包括m次业 务逻辑处 理， m为小于 M的正整数， M为大于1的正整数； 获取所述第一 业务逻辑处 理的第一处 理结果； 若所述第一处理结果为处理失败， 将所述第一消息添加至延时队列， 并通过所述监听 应用继续从所述消息队列中监听并获取第二消息进行所述第一业务逻辑处理， 所述第二消 息是所述消息队列中位于所述第一消息之后的消息； 通过守护线程应用对所述延时队列中所述第 一消息进行第 二业务逻辑处理， 得到所述 第一消息的第二处 理结果， 所述第二 业务逻辑处 理包括M‑m次业务逻辑处 理。 2.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 将所述第一消息插 入数据库中； 所述将所述第一消息添加至延时队列之前， 所述方法还 包括： 将所述数据库中所述第一消息的状态标注为待重试。 3.根据权利要求2所述的方法， 其特征在于， 所述将所述第一消息添加至延时队列， 包 括： 将状态为待重试的所述第 一消息添加至所述延时队列， 并将所述数据库中所述第 一消 息的状态从待重试修改为重试中。 4.根据权利要求1所述的方法， 其特征在于， 所述将所述第一消息添加至延时队列， 包 括： 获取所述延时队列中已有消息数量； 若所述已有消息数量小于限定阈值， 将所述第一消息添加至所述延时队列。 5.根据权利要求4所述的方法， 其特征在于， 若所述第一消息插入到数据库中， 且所述 第一消息的状态为待重试， 所述方法还 包括： 若所述已有消息数量达到所述限定 阈值， 将所述数据库中的所述第 一消息的状态从待 重试修改为失败待重试。 6.根据权利要求5所述的方法， 其特 征在于， 所述方法还 包括： 按照设定时间从所述数据库中提取n条状态为失败待重试的消息添加至所述延时队 列， 所述n条状态为失败待重试的消息中包括所述第一消息 。 7.根据权利要求1 ‑6任一项所述的方法， 其特征在于， 若所述第一消息插入到数据库 中， 所述方法还 包括： 若所述第二处理结果为处理失败， 将所述数据库中所述第 一消息的状态修改为重试次 数已满。 8.一种消息处 理装置， 其特 征在于， 所述装置包括： 处理单元， 用于通过监听应用从消息队列中获取第一消息进行第一业务逻辑处理， 所 述第一业务处理逻辑包括m次业 务逻辑处 理， m为小于 M的正整数， M为大于1的正整数； 获取单元， 用于获取 所述第一 业务逻辑处 理的第一处 理结果； 添加单元， 用于若所述第一处 理结果为处理失败， 将所述第一消息添加至延时队列； 所述处理单元， 还用于通过所述监 听应用继续从所述消息队列中监 听并获取第 二消息 进行所述第一业务逻辑处理， 所述第二消息是所述消息队列中位于所述第一消息之后的消权　利　要　求　书 1/2 页 2 CN 115543654 A 2息； 所述处理单元， 还用于通过守护线程应用对所述延时队列中所述第 一消息进行第 二业 务逻辑处理， 得到所述第一消息的第二处理结果， 所述第二业务逻辑处理包括M ‑m次业务逻 辑处理。 9.根据权利要求8所述的装置， 其特 征在于， 所述装置还 包括插入单元和标注单 元： 所述插入单元， 用于将所述第一消息插 入数据库中； 所述标注单元， 用于在将所述第一消息添加至延时队列之前， 将所述数据库中所述第 一消息的状态标注为待重试。 10.根据权利要求9所述的装置， 其特 征在于， 所述添加单 元， 具体用于： 将状态为待重试的所述第 一消息添加至所述延时队列， 并将所述数据库中所述第 一消 息的状态从待重试修改为重试中。权　利　要　求　书 2/2 页 3 CN 115543654 A 3