使用stream重构分布式事务项目启动异常

来源:8-28 熔断&降级

夏洛爱的不是秋雅

2021-12-17

视频中老师在配置文件中rocketmq增加bindings并指定producer的group为tx-add-bonus-group,本人和老师改动一致但是启动项目的时候出现异常,如下图所示:
图片描述
当然RocketMQTransactionListener的txProducerGroup = “tx-add-bonus-group”
图片描述

写回答

1回答

大目

2021-12-17

您好,请问您用的版本是?如果用的Spring Cloud Alibaba最新版本,那么事务消息稍有区别,配置不太一样:

https://github.com/alibaba/spring-cloud-alibaba/blob/master/spring-cloud-alibaba-docs/src/main/asciidoc-zh/rocketmq-new.adoc

详见这里,发送事务消息用producerType属性设置。

示例代码在这里:https://github.com/alibaba/spring-cloud-alibaba/blob/master/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-produce-example/src/main/resources/application.properties

相关配置是这仨:

spring.cloud.stream.rocketmq.bindings.output2.producer.producerType=Trans

spring.cloud.stream.rocketmq.bindings.output2.producer.group=myTxProducerGroup

spring.cloud.stream.rocketmq.bindings.output2.producer.transactionListener=myTransactionListener

----

如果不是最新版本,可以用我的代码试试哈(不过从您贴出来的代码来,代码是OK的,目前更倾向于怀疑版本上的问题):

https://git.imooc.com/coding-358/content-center-12/src/master/src/main/resources/application.yml


0
2
大目
您好,那可以对照我的代码看看哦
2021-12-17
共2条回复

Spring Cloud Alibaba微服务从入门到进阶

面向未来微服务:熟练掌握Spring Cloud Alibaba

3085 学习 · 1324 问题

查看课程