买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网恭喜深圳数智欣成科技有限公司申请的专利基于事务组实现的消息队列消费者处理方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN118885308B 。

龙图腾网通过国家知识产权局官网在2025-03-28发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202311497034.1，技术领域涉及：G06F9/54；该发明授权基于事务组实现的消息队列消费者处理方法是由赖志远设计研发完成，并于2023-11-10向国家知识产权局提交的专利申请。

本基于事务组实现的消息队列消费者处理方法在说明书摘要公布了：本发明提供了一种基于事务组实现的消息队列消费者处理方法，包括：将订单签收消息处理定义为事务组；按照外部调用接口维度拆分为多个子级调用，并为每个子级定义对应的消息类型，消息类型定义如下：父级根方法、修改单据签收数量、调用SAP系统确认签收收入、调用积分系统新增签收积分、调用结算系统新增签收流水、调用库存系统新增签收流水。本发明将一个大的消息处理拆分为多个小的子级，每个子级有独立的处理状态，当父级对子级依次调用，如果中途子级执行失败，后续重试程序会跳过成功的子级，只对处理状态为失败的子级进行重试，大大提升重试效率，降低服务资源压力。

本发明授权基于事务组实现的消息队列消费者处理方法在权利要求书中公布了：1.一种基于事务组实现的消息队列消费者处理方法，其特征在于，包括：将订单签收消息处理定义为事务组；按照外部调用接口维度拆分为多个子级调用，并为每个子级定义对应的消息类型，消息类型定义如下：父级根方法、修改单据签收数量、调用SAP系统确认签收收入、调用积分系统新增签收积分、调用结算系统新增签收流水、调用库存系统新增签收流水；当从消息队列消费到新的消息时，首先创建第一条根父级消息日志对象,处理状态初始态为失败；父级方法依次对子方法进行调用，每次调用子级分别创建对应的子级消息日志对象、分别对应数据库消息日志表一条记录；每次子级调用成功后，则将处理状态标为成功，当所有子级执行成功后，所有子级和父级的处理状态变为成功；当依次执行过程中，执行到某个子级如果发生异常，则对外抛出异常，仅将当前子级和父级标为失败，前面执行成功的子级处理状态仍然为成功；所述方法首先进入父级模块，父级模块依次执行的以下步骤：步骤S100，执行父级define单元，用于定义消费接口；步骤S110，执行父级begin单元，用于开始消息事务，创建事务组上下文、入栈；步骤S120，执行父级doWork单元，用于执行父级业务方法，步骤S120之后进入子级模块，并根据子级模块的结果分别执行以下父级单元：步骤S130，执行父级commit单元,用于执行业务方法到成功时，提交事务、出栈；步骤S140，执行父级rollback单元,用于执行业务方法失败时，回滚事务、出栈；步骤S150，执行父级clear单元,用于清除事务组上下文；其中，步骤S100包括：为某个消息消费事务组定义好一组消息类型枚举；事务组父级对应一个方法，或称之为根方法，每个子级对应一个方法，父级方法内对每个子级方法按业务顺序同步调用.事务组内的所有相关方法必须注解上设定好的消息事务AOP切面注解,并将消息类型定义到对应方法注解的消息类型属性上；事务组内的所有相关方法必须入参一个消息提供器对象参数，该消息提供器对象参数必须要实现设定好的一个消息提供器接口，该接口定义四个必须要子类实现的方法，用于获取消息报文、消息类型、消息ID和业务关键字；如果事务组涉及集群多节点部署架构情况下，还需要在事务组根方法上注解上分布式锁模块注解，来避免多节点并发调用；定义好程序后，当接收到新的消息时，将触发首先判断是否注解了分布式锁，如果是,则通过指定的锁键尝试获取分布式锁，如果获取锁失败，则报错结束，如果获取锁成功则继续往下执行；基于AOP切面获取当前执行方法中消息提供器对象，如果获取不到对象则报错结束，日志打印告知其不符合定义的要求；如果获取到则继续，后续阶段通过消息提供器对象获取核心字段内容：消息报文、消息类型、消息ID和关键业务Key。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人深圳数智欣成科技有限公司，其通讯地址为：518000 广东省深圳市南山区西丽街道曙光社区中山园路1001号TCL科学园区F2栋A201；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。