一、基本概念
SpringCloud Stream 消息驱动主要是简化了RabbitMQ、和Kafka的配置，把这俩种中间件进行了封装为同一种的API更换起来方便，并且只需要关注业务逻辑的实现，通过配置分组的机制可以实现启动多个服务实例轮询进行调用，还可以配置分区保证特殊的实例比如监控实例在分组后都能够被同一个实例进行消费，避免了轮询机制的不确定性。
二、实现原理
生产者output，通过通道发送消息，Binder封装了RabbitMQ及Kafka的api进行发送，消费者input通过监听同一个通道来读取消息。
三、代码配置
springCloud_eureka 服务端 8080
springCloud_eureka2 客户端 8081
springCloud_eureka3 服务端 8082
添加pom.xml
版权声明：本文为qq_17025903原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。