SpringCloud学习(二十一):Stream的分组消费与持久化

目录

一、分组消费

        1、依照8802克隆出一个8803 

        2、运行发现问题

        3、如何解决

二、消息持久化


一、分组消费

        1、依照8802克隆出一个8803 

        cloud-stream-rabbitmq-consumer8803 

        2、运行发现问题

        启动服务注册eureka7001、rabbitmq、消息生产者8801、消息消费者8802、8803 

        访问           http://localhost:8801/sendMessage        刷新两次,发送两条消息

SpringCloud学习(二十一):Stream的分组消费与持久化_第1张图片

SpringCloud学习(二十一):Stream的分组消费与持久化_第2张图片

SpringCloud学习(二十一):Stream的分组消费与持久化_第3张图片

        可以看到,8802和8803都收到了消息。

        但事实上一条消息只能由一个消费者消费,这就是重复消费问题。

        3、如何解决

        进入rabbitmq的exchanges中可以看到,我们的8802和8803默认在不同的分组.

SpringCloud学习(二十一):Stream的分组消费与持久化_第4张图片

        微服务应用放置于同一个group中,就能够保证消息只会被其中一个应用消费一次。
不同的组是可以消费的,同一个组内会发生竞争关系,只有其中一个可以消费。

        假如我们不想让8802和8803重复接到消息,只想让消息被他们其中的一个接收,只需要为他们指定相同的分组即可。

SpringCloud学习(二十一):Stream的分组消费与持久化_第5张图片

         再次测试: 

SpringCloud学习(二十一):Stream的分组消费与持久化_第6张图片

SpringCloud学习(二十一):Stream的分组消费与持久化_第7张图片

SpringCloud学习(二十一):Stream的分组消费与持久化_第8张图片

        可以看到,生产者8801发出的消息只会被8802和8803中的一个接收(默认为轮询)。

二、消息持久化

        现在我们将8802中的分组去掉,保留8803中的分组 。然后关闭8802和8803,只剩下eureka7001和生产者8801在运行。

        此时刷新        http://localhost:8801/sendMessage        4次。

SpringCloud学习(二十一):Stream的分组消费与持久化_第9张图片

        然后再运行消费者8802和8803。

        可以看到,即使在8801发送消息的时候8803并没有运行,但有分组属性的8803后台还是打印出了消息;

SpringCloud学习(二十一):Stream的分组消费与持久化_第10张图片

        而没有分组属性的8802则没有打印出消息。

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

你可能感兴趣的