一、分组消费
1、依照8802克隆出一个8803
cloud-stream-rabbitmq-consumer8803
2、运行发现问题
启动服务注册eureka7001、rabbitmq、消息生产者8801、消息消费者8802、8803
访问 http://localhost:8801/sendMessage 刷新两次,发送两条消息
可以看到,8802和8803都收到了消息。
但事实上一条消息只能由一个消费者消费,这就是重复消费问题。
3、如何解决
进入rabbitmq的exchanges中可以看到,我们的8802和8803默认在不同的分组.
微服务应用放置于同一个group中,就能够保证消息只会被其中一个应用消费一次。
不同的组是可以消费的,同一个组内会发生竞争关系,只有其中一个可以消费。
假如我们不想让8802和8803重复接到消息,只想让消息被他们其中的一个接收,只需要为他们指定相同的分组即可。
再次测试:
可以看到,生产者8801发出的消息只会被8802和8803中的一个接收(默认为轮询)。
二、消息持久化
现在我们将8802中的分组去掉,保留8803中的分组 。然后关闭8802和8803,只剩下eureka7001和生产者8801在运行。
此时刷新 http://localhost:8801/sendMessage 4次。
然后再运行消费者8802和8803。
可以看到,即使在8801发送消息的时候8803并没有运行,但有分组属性的8803后台还是打印出了消息;
而没有分组属性的8802则没有打印出消息。
这个现象就被成为消息持久化。