statrer引入

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <version>2.2.3</version>
        </dependency>

 starter 2.0.2对应rocketmq 4.4.0
 starter 2.1.0对应rocketmq 4.6.0

4.X版本的mq还有一年多停止支持,尽快升级到5.X的版本吧。

从starter 2.1.0开始, rocketMQTemplate.sendMessageInTransaction()的第一个参数txProducerGroup就移除了。

那么如果一个项目中需要执行多个mq事务该怎么做呢,靠以前的定义多个txProducerGroup不管用了,官网文档给出了解决方案,那就是定义多个extra RocketMQTemplate

文档地址:https://github.com/apache/rocketmq-spring/wiki/FAQ

相关章节如下

定义一个extra RocketMQTemplate

使用extra RocketMQTemplate发送事务消息

为何移除,参见https://github.com/apache/rocketmq-spring/pull/179

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐