引言
代码已提交至Github，有兴趣的同学可以下载来看看：https://github.com/ylw-github/SpringCloud-Stream-Demo
在上一篇博客《微服务技术系列教程（34） - SpringCloud-消息驱动实现（RabbitMQ）》，讲解了简单的SpringCloud消息驱动模式，使用默认消息中间件RabbitMQ实现生产者发送消息到消费者。
但是有一个问题，在现实的业务场景中，每一个微服务应用为了实现高可用和负载均衡，都会集群部署，按照上面我们启动了两个应用的实例，消息被重复消费了两次。
在RabbitMQ控制台也可以看到两个消费者绑定了两个队列：
但是实际微服务架构场景中，消费者集群部署，只能允许一个消费者获取消息，那么该如何解决呢？
解决方案
为解决这个问题，Spring Cloud Stream 中提供了消费组，通过配置 spring.cloud.stream.bindings.myInput.group 属性为应用指定一个组名，这样实现了消费者轮询获取消息。修改每个消费者配置文件，内容如下：
server: port: 9002 spring: application: name: spingcloud-stream-consumer rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guest cloud: stream: bindings: my_msg: ###指定 管道名称 #指定该应用实例属于 stream 消费组 group: stream
启动消费者集群和生产者后，在Rabbit控制台，可以发现，只有一个队列：
启动生产者，浏览器输入http://localhost:9001/sendMsg发送消息，可以看到只有一个消费者能消费信息。
继续刷新浏览器，可以看到另外一个消费者消费了消息（通过轮询机制）：
本文完！
