MQ接收了多次,

来源:7-5 Spring Cloud Stream的使用(下)

阿刚Ace

2019-11-20

师兄好:
这边检测到MQ接收了多次,造成我后续的处理做了多次,这个时候该怎么处理,SpringCloud框架或者RabbitMQ中有相应的配置吗?

写回答

2回答

阿刚Ace

提问者

2019-11-22

这是我发送mq的方法,发给两个服务,一个叫market一个叫msg:

amqpTemplate.convertAndSend("paySuccess", "market", JsonUtil.toJson(mqDto));
amqpTemplate.convertAndSend("paySuccess", "msg", JsonUtil.toJson(mqDto));


然后下边是我接收mq的方法,这里只贴了一个,两个服务接收都是一样的,key和queue名不一样:

//img.mukewang.com/szimg/5dd73e7809fad3fe11840461.jpg

0
1
廖师兄
你能给个demo吗
2019-11-27
共1条回复

廖师兄

2019-11-21

用amqptemplate,用一个队列就行。stream用分组功能,也可以解决重复问题,课程里有讲

0
10
阿刚Ace
回复
廖师兄
No,不想让你看?
2019-11-25
共10条回复

SpringCloud Finchley(M2+RELEASE+SR2)微服务实战

SpringCloud组件实现微服务,【已升级Finchley.Release】

5672 学习 · 2489 问题

查看课程