Spring Cloud构建微服务架构：消息驱动的微服务（消费分区）【Dalston版】

内容简介：Spring Cloud构建微服务架构：消息驱动的微服务（消费分区）【Dalston版】

通过上一篇 《消息驱动的微服务（消费组）》 的学习，我们已经能够在多实例环境下，保证同一消息只被一个消费者实例进行接收和处理。但是，对于一些特殊场景，除了要保证单一实例消费之外，还希望那些具备相同特征的消息都能够被同一个实例进行消费。这时候我们就需要对消息进行分区处理。

使用消息分区

在Spring Cloud Stream中实现消息分区非常简单，我们可以根据消费组示例做一些配置修改就能实现，具体如下：

• 在消费者应用 SinkReceiver 中，我们对配置文件做一些修改，具体如下：

spring.cloud.stream.bindings.input.group=Service-A

spring.cloud.stream.bindings.input.destination=greetings
spring.cloud.stream.bindings.input.consumer.partitioned=true
spring.cloud.stream.instanceCount=2
spring.cloud.stream.instanceIndex=0

从上面的配置中，我们可以看到增加了这三个参数：

1. spring.cloud.stream.bindings.input.consumer.partitioned ：通过该参数开启消费者分区功能；

2. spring.cloud.stream.instanceCount ：该参数指定了当前消费者的总实例数量；

3. spring.cloud.stream.instanceIndex ：该参数设置当前实例的索引号，从0开始，最大值为 spring.cloud.stream.instanceCount 参数 - 1。我们试验的时候需要启动多个实例，可以通过运行参数来为不同实例设置不同的索引值。

• 在生产者应用 SinkSender 中，我们对配置文件也做一些修改，具体如下：

spring.cloud.stream.bindings.output.destination=greetings
spring.cloud.stream.bindings.output.producer.partitionKeyExpression=payload
spring.cloud.stream.bindings.output.producer.partitionCount=2

从上面的配置中，我们可以看到增加了这两个参数：

spring.cloud.stream.bindings.output.producer.partitionKeyExpression
spring.cloud.stream.bindings.output.producer.partitionCount

到这里消息分区配置就完成了，我们可以再次启动这两个应用，同时消费者启动多个，但需要注意的是要为消费者指定不同的实例索引号，这样当同一个消息被发给消费组时，我们可以发现只有一个消费实例在接收和处理这些相同的消息。

以下专题教程也许您会有兴趣

• Spring Boot基础教程
• Spring Cloud基础教程

本文内容部分节选自我的《Spring Cloud微服务实战》，稍作改变和内容升级

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网

关注我们，获取更多IT资讯^_^

查看所有标签

• Centos服务器如何分区挂载第二块磁盘详细图解教程
• 服务器字符集对DM7中List分区表使用中文的影响
• db2 定义分区表和分区键
• HBase漫谈 | HBase分区过多影响&合理分区数量
• 大数据开发学习之Hive的静态分区与动态分区
• 好程序员大数据培训之掌握Hive的静态分区与动态分区

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。