Spring Cloud Stream如何实现分区分组原理,图解详解?

2026-05-28 04:390阅读0评论SEO教程
  • 内容介绍
  • 文章标签
  • 相关推荐

本文共计676个文字,预计阅读时间需要3分钟。

Spring Cloud Stream如何实现分区分组原理,图解详解?

消息分组+通常在生产环境中,我们的每个服务都不会以单点方式运行在环境中。当同一服务启动多个实例时,这些实例都会绑定到同一个消息通信的目标主题(Topic)上。

消息分组

通常在生产环境,我们的每个服务都不会以单节点的方式运行在生产环境,当同一个服务启动多个实例的时候,这些实例都会绑定到同一个消息通道的目标主题(Topic)上。默认情况下,当生产者发出一条消息到绑定通道上,这条消息会产生多个副本被每个消费者实例接收和处理,但是有些业务场景之下,我们希望生产者产生的消息只被其中一个实例消费,这个时候我们需要为这些消费者设置消费组来实现这样的功能。

当把消费者复制一份,发现2个都能收到消息

2个消费者都加入同一个消费者

发现只有一个能收到

Spring Cloud Stream如何实现分区分组原理,图解详解?

消息分区

有一些场景需要满足, 同一个特征的数据被同一个实例消费, 比如同一个id的传感器监测数据必须被同一
个实例统计计算分析, 否则可能无法获取全部的数据。

阅读全文

本文共计676个文字,预计阅读时间需要3分钟。

Spring Cloud Stream如何实现分区分组原理,图解详解?

消息分组+通常在生产环境中,我们的每个服务都不会以单点方式运行在环境中。当同一服务启动多个实例时,这些实例都会绑定到同一个消息通信的目标主题(Topic)上。

消息分组

通常在生产环境,我们的每个服务都不会以单节点的方式运行在生产环境,当同一个服务启动多个实例的时候,这些实例都会绑定到同一个消息通道的目标主题(Topic)上。默认情况下,当生产者发出一条消息到绑定通道上,这条消息会产生多个副本被每个消费者实例接收和处理,但是有些业务场景之下,我们希望生产者产生的消息只被其中一个实例消费,这个时候我们需要为这些消费者设置消费组来实现这样的功能。

当把消费者复制一份,发现2个都能收到消息

2个消费者都加入同一个消费者

发现只有一个能收到

Spring Cloud Stream如何实现分区分组原理,图解详解?

消息分区

有一些场景需要满足, 同一个特征的数据被同一个实例消费, 比如同一个id的传感器监测数据必须被同一
个实例统计计算分析, 否则可能无法获取全部的数据。

阅读全文