消息处理方法、装置、设备及存储介质.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115757494A(43)申请公布日2023.03.07(21)申请号202211449776.2(22)申请日2022.11.18(71)申请人中国农业银行股份有限公司地址100005北京市东城区建国门内大街69号(72)发明人刘帅张津(74)专利代理机构北京品源专利代理有限公司11332专利代理师孔凡红(51)Int.Cl.G06F16/2455(2019.01)G06F16/2457(2019.01)权利要求书2页说明书11页附图4页(54)发明名称消息处理方法、装置、设备及存储介质(57)摘要本申请公开了一种消息处理方法、装置、设备及存储介质，涉及计算机技术领域，可以提高消费者对同一任务的执行次数，从而可以提高任务执行成功的几率，改善用户的使用体验。该方法包括：在接收到目标消费者的第一读取指令的情况下，基于第一读取指令从消息队列中确定目标消息；生成目标消息的标识符，并将目标消息和标识符的对应关系缓存至历史消息记录中；向目标消费者返回第一读取信息；第一读取信息中包含标识符和目标消息，用于指示目标消费者读取并执行目标消息中的消息内容，并在执行失败的情况下发起第二读取指令；第二读取指令，至少携带有标识符，用于重新获取目标消息，且读取并执行。CN115757494ACN115757494A权利要求书1/2页1.一种消息处理方法，其特征在于，包括：在接收到目标消费者的第一读取指令的情况下，基于所述第一读取指令从消息队列中确定目标消息；生成所述目标消息的标识符，并将所述目标消息和所述标识符的对应关系缓存至历史消息记录中；向所述目标消费者返回第一读取信息；所述第一读取信息中包含所述标识符和所述目标消息，用于指示所述目标消费者读取并执行所述目标消息中的消息内容，并在执行失败的情况下发起第二读取指令；所述第二读取指令，至少携带有所述标识符，用于重新获取所述目标消息，且读取并执行。2.根据权利要求1所述的消息处理方法，其特征在于，所述向所述目标消费者返回第一读取信息之后，所述方法还包括：在接收到所述目标消费者的第二读取指令的情况下，基于所述标识符从所述历史消息记录中查找所述目标消息；向所述目标消费者返回第二读取信息；所述第二读取信息中至少包含所述目标消息，用于指示所述目标消费者再次读取并执行所述目标消息中的消息内容。3.根据权利要求2所述的消息处理方法，其特征在于，所述第二读取信息还用于指示所述目标消费者在二次执行失败的情况下，返回失败反馈信息；所述向所述目标消费者返回第二读取信息之后，所述方法还包括：在接收到所述目标消费者返回的所述失败反馈信息的情况下，基于所述失败反馈信息中携带的所述标识符，从所述历史消息记录中查找对应的所述目标消息；向所述目标消息对应的目标生产者返回所述目标消息，用于指示所述目标生产者对所述目标消息进行回滚操作。4.根据权利要求2所述的消息处理方法，其特征在于，所述标识符包含标志位，所述标志位用于表征所述目标消息的被执行次数，所述标志位的初始值为预设值；所述基于所述标识符从所述历史消息记录中查找所述目标消息，包括：确定所述标志位是否满足预设条件；在确定所述标志位满足所述预设条件的情况下，基于所述标识符从所述历史消息记录中查找所述目标消息；所述向所述目标消费者返回第二读取信息，包括：对所述标志位进行更新，并根据更新后的标志位对所述历史消息记录中的所述标识符进行更新，且向所述目标消费者返回所述第二读取信息；所述第二读取信息还包括更新后的标识符，还用于指示所述目标消费者在执行失败的情况下再次发起所述第二读取指令。5.根据权利要求4所述的消息处理方法，其特征在于，所述确定所述标志位是否满足预设条件之后，所述方法还包括：在确定所述标志位不满足所述预设条件的情况下，向所述目标消息对应的目标生产者返回所述目标消息，用于指示所述目标生产者对所述目标消息进行回滚操作。6.根据权利要求3或5所述的消息处理方法，其特征在于，所述向所述目标消息对应的目标生产者返回所述目标消息之后，所述方法还包括：删除缓存至所述历史消息记录中的所述目标消息和所述标识符的对应关系。7.根据权利要求1所述的消息处理方法，其特征在于，所述标识符中还包括所述目标消2CN115757494A权利要求书2/2页息的执行状态；所述第一读取信息还用于指示所述目标消费者在执行成功的情况下，返回成功反馈信息；所述方法还包括：在接收到所述目标消费者返回的所述成功反馈信息的情况下，更新所述执行状态。8.一种消息处理装置，其特征在于，包括：确定模块，用于在接收到目标消费者的第一读取指令的情况下，基于所述第一读取指令从消息队列中确定目标消息；缓存模块，用于生成所述目标消息的标识符，并将所述目标消息和所述标识符的对应关系缓