一、分组消费

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则没有打印出消息。

这个现象就被成为消息持久化。