MQ接收了多次，

Question

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

Answer 1

提问者 阿刚Ace 2019-11-22 09:48:45

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

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

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

• 廖师兄 #1

  你能给个demo吗

Answer 2

廖师兄 2019-11-21 11:38:45

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

• 提问者 阿刚Ace #1

  我用的你水果的那个例子，Exchange，你课程里讲的是一个服务部署多台，然后会往每台都发吧。我这个是一个服务就一台，然后一直发。我查了下rabbitMq有确认机制，但是我不会用，看不太明白。

• 廖师兄 回复 提问者 阿刚Ace #2

  那你试下用amqptemplate，用同一个队列即可

• 提问者 阿刚Ace 回复 廖师兄 #3

  但是我现在就要用Exchange啊，一个消息发送给多个服务。

点开查看后面7条评论