积分购买功能RocketMQ实现事务，不起作用，不知道是配置不对还是为什么 监听好像没作用

Question

代码第247行：https://gitee.com/colta/spring-cloud-alibaba-we-chat-app/blob/master/content-center/src/main/java/com/colt/contentcenter/service/share/impl/ShareServiceImpl.java

mq消费积分事务监听：https://gitee.com/colta/spring-cloud-alibaba-we-chat-app/blob/master/content-center/src/main/java/com/colt/contentcenter/rocketmq/CostBonusTransactionListener.java
配置第27行开始：
https://gitee.com/colta/spring-cloud-alibaba-we-chat-app/blob/master/content-center/src/main/resources/application.yml

Answer 1

大目 2020-11-13 19:04:53

您好，可以正常进入监听哈。

你的代码没有问题。

我看你com.colt.contentcenter.service.share.impl.ShareServiceImpl#exchangeByIdMQ 里面的校验有点多，建议打个断点看看是不是代码根本没有执行到这边：

• 提问者 banrino #1

  麻烦老师了哈  今天才看到   功能是实现了   但是有点小问题   就是内容中心发送消息后   用户中心有时候会消费消息   有时候又没有消费消息   是什么原因呢

• 大目 回复 提问者 banrino #2

  有日志吗？可以搭个RocketMQ Console看下，看看消息有没有生产、有没有消费记录。

• 提问者 banrino 回复 大目 #3

  谢谢老师，已经解决了哈  是代码逻辑有点小毛病哈哈哈

点开查看后面1条评论

Answer 2

大目 2020-11-10 20:17:47

代码看着没啥问题。请问目前的具体现象是？

监听好像没作用

这个怎么理解？

• 提问者 banrino #1

  调用接口后 ，未能向rocketMQ发送消息，CostBonusTransactionListener 里的代码好像没有执行

• 提问者 banrino #2

  老师有空麻烦回复一下哦

• 大目 回复 提问者 banrino #3

  不好意思 最近双十一，有点忙，我最迟明天给你看下代码。