SpringCloud Stream使用解析

下面用RabbitMQ来说明使用！案例之消息驱动之生产者1.建一个项目，并添加如下的依赖：2.编写下面的yml文件3.编写service，下面仅展示实现类：4.编写controller案例之消息驱动消费者1.写pom，加上下面的依赖2.编写yml，和生产者唯一的区别在于，下面是input3.编写controller，该controller不向外界暴露端口，起到实时监控消息管道的作用！测试启动rabbitMQ和上面的两个项目，访问补充说明我们打开rabbitmq的监控界面：发现默认是帮我们分组的想要自定义分组只需要在消费者的yml文件中加上下面的一行：如果有多个消费者，为了避免出现重复消费的问题，应将组名设置成一样的。一个组的成员轮循消费，不同组的成员进行相同的消费。