天天看点

25_springcloud Stream——分组消费与持久化

Stream 分组消费与持久化

新建了一个module cloud-stream-rabbitmq-consumer8803,作为消息接收模块(参考8802)

这一块是根据新建的这个进行的演示:

现在就是这样的架构:

比如在如下场景中,订单系统我们做集群部署,都会从RabbitMQ中获取订单信息,那如果一个订单同时被两个服务获取到,那么就会造成数据错误,我们得避免这种情况,这时我们就可以使用Stream中的消息分组来解决。

25_springcloud Stream——分组消费与持久化

注意在Stream中处于同一个group中的多个消费者是竞争关系,就能够保证消息只会被其中一个应用消费一次。

不同组是可以全面消费的(重复消费),同一组内会发送竞争关系,只有其中一个可以消费。

目前遇到的问题:

目前是8802/8803同时都收到消息了,存在重复消费问题。

分组:

原理:

微服务应用放置在同一个group中,就能够保证消息只会被其中一个应用消费一次。

不同的组是可以消费的,同一个组内会发生竞争关系,只有其中一个可以消费。

把8802/8803都变成不同组,group两个不同

修改8802/8803的yml配置文件

25_springcloud Stream——分组消费与持久化

结论:还是重复消费。

分布式微服务应用为了实现高可用和负载均衡,实际上都会部署多个实例,本次启动了两个消费微服务8802/8803

多数情况下,生产者发送消息给某一个具体的微服务时只希望被消费一次,按照上面我们启动两个应用的例子,虽然他们同属一个应用。

但是这个消费出现了被重复消费两次的情况,为了解决这个问题,在spring cloud Stream中提供了消费组的概念。

怎么实现这一消费组:

8802/8803实现了轮询分组,每一次只有一个消费者

8801模块发送的消息只能被8802或者8803其中一个接受到,这样避免了重复消费。

8802/8803都变成相同组,group两个相同。

怎么设置?

在8802和8803消费者上面设置一样的分组group

25_springcloud Stream——分组消费与持久化

结论:

这样8802和8803消费者上面分别收到了一个消息,这样就避免了重复消费的问题。

同一个组会竞争资源,轮询。不同组会重复消费。

持久化

关于自定义分组

**场景:**停止8802/8803并且去除掉8802的分组group:atguiguA

注意:8803的分组没有去掉。

结果:

如果8802去掉分组,而8803不去掉,当8802/8803都关闭服务,8801这时候发送消息,8802再启动的时候不会重新获得未曾获得的消息并消费,而8803重启后会获得8801之前发送的消息并消费。

所以group分组属性在消息重复消费和消息持久化消费 避免消息丢失是非常重要的属性

就是默认的分组不会保留未曾获得的消息,自定义的分组会保留。