异常消息处理方法、装置、设备、介质及产品.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115801680A(43)申请公布日2023.03.14(21)申请号202211183345.6(22)申请日2022.09.27(71)申请人中国农业银行股份有限公司地址100005北京市东城区建国门内大街69号(72)发明人刘秀娟(74)专利代理机构北京同立钧成知识产权代理有限公司11205专利代理师张芳黄健(51)Int.Cl.H04L47/12(2022.01)H04L51/18(2022.01)权利要求书3页说明书14页附图8页(54)发明名称异常消息处理方法、装置、设备、介质及产品(57)摘要本申请提供一种异常消息处理方法、装置、设备、介质及产品，其中方法包括获取待处理异常消息的类型信息，是否属于有序消息、是否存在与其它消息的依赖关系以及是否可恢复，根据待处理异常消息的类型信息，确定待处理异常消息的类型；所述类型包括无序且不可恢复、无序且可恢复、有序无依赖且不可恢复、有序无依赖且可恢复、有序有依赖且可恢复以及有序有依赖且不可恢复，基于各类型对应的处理策略，采用所述待处理异常消息的类型对应的处理策略，对所述异常消息执行相应处理，本申请的方案能够避免消息队列中的消息拥堵与资源浪费，提高处理消息的效率。CN115801680ACN115801680A权利要求书1/3页1.一种异常消息处理方法，其特征在于，所述方法包括：获取待处理异常消息的类型信息，所述类型信息包括是否属于有序消息、是否存在与其它消息的依赖关系以及是否可恢复；根据所述待处理异常消息的类型信息，确定所述待处理异常消息的类型；所述类型包括无序且不可恢复、无序且可恢复、有序无依赖且不可恢复、有序无依赖且可恢复、有序有依赖且可恢复以及有序有依赖且不可恢复；基于各类型对应的处理策略，采用所述待处理异常消息的类型对应的处理策略，对所述异常消息执行相应处理。2.根据权利要求1所述的方法，其特征在于，所述基于各类型对应的处理策略，采用所述待处理异常消息的类型对应的处理策略，对所述待处理异常消息执行相应处理，包括：若所述待处理异常消息的类型为无序且不可恢复，则将所述待处理异常消息通过消息发送器推送至消费用户进行处理；以及，指示消息处理器对消息队列中所述待处理异常消息之后的消息进行处理；若所述待处理异常消息的类型为无序且可恢复，则调用重试器再次处理所述待处理异常消息；以及，指示消息处理器对消息队列中所述待处理异常消息之后的消息进行处理；若所述待处理异常消息的类型为有序无依赖且不可恢复，则将所述待处理异常消息以及与所述待处理异常消息存在顺序关系的第一消息，通过消息发送器推送至消费用户进行处理；以及，指示消息处理器对消息队列中所述待处理异常消息和所述第一消息之后的消息进行处理；若所述待处理异常消息的类型为有序无依赖且可恢复，则调用重试器再次处理所述待处理异常消息，若处理成功，则向消息处理器返回成功结果，若处理失败，则从消息队列获取所述第一消息中的最新消息进行处理；若所述待处理异常消息的类型为有序依赖且可恢复，则调用重试器再次处理所述待处理异常消息，若处理成功，向消息处理器返回成功结果后，并指示所述消息处理器对消息队列中所述待处理异常消息之后的消息进行处理；若所述待处理异常消息的类型为有序依赖且不可恢复，则将所述待处理异常消息通过消息发送器推送至消费用户进行处理，若处理成功，向消息处理器返回成功结果后，并指示所述消息处理器对消息队列中所述待处理异常消息之后的消息进行处理。3.根据权利要求2所述的方法，其特征在于，若所述待处理异常消息的类型为无序且不可恢复或者有序无依赖且不可恢复，则所述将所述待处理异常消息通过消息发送器推送至消费用户进行处理，包括：将所述待处理异常消息存储至异常消息存储器；若当前所述异常消息存储器中的消息数据达到设定的阈值，则将所述异常消息存储器中包括所述待处理异常消息在内的所有消息，通过消息发送器推送至消费用户进行处理。4.根据权利要求3所述的方法，其特征在于，所述方法还包括：若所述异常消息存储器中的消息被推送至消费用户进行处理，则从所述异常消息存储器中删除该消息。5.根据权利要求2‑4任一项所述的方法，其特征在于，若所述待处理异常消息的类型为无序且可恢复或者有序依赖且可恢复，则所述调用重试器再次处理所述待处理异常消息，2CN115801680A权利要求书2/3页包括：若所述待处理异常消息的类型为无序且可恢复或者有序依赖且可恢复，则调用重试器再次处理所述待处理异常消息，直至处理成功或者直至所述待处理异常消息被所述重试器重复处理的次数达到设定的次数阈值，则通过所述消息发送器推送至消费用户进行处理。6.一种异常消息处理装置，其特征在于，所述装置包括：获取模块，用于获取待处理异常消息的类型信息，所述类型