SpringCloudStream消息驱动

SpringCloudStream

1. 引入maven依赖

      <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
      </dependency>

2. 新增配置文件
   destination: minestream 通过这个配置吧输出和输入队列保持在一个主题上
   group分组 我们经常会遇到一个场景 abc 全是订单服务 order 他的前置服务发出一个消息我们通常只需要一个服务来消费这个消息 这时候我们就需要把这个3个服务配置成一个组 每当有消息来的时候 stream会帮我们把消息发给一个服务

   stream:
    bindings:
      #消息分组  是自定义命名和Streamclient里面保持一致
      myInPut:
        #指定输入通道对应的主题名
        destination: minestream
        #配置组
        group: order
      myOutPut:
        #指定输入通道对应的主题名
        destination: minestream
        #使消息在mq中存储为application/json的格式
        #content-type: application/json

3. 使用
   添加一个接口
   
   如何消费
   首先用注解绑定刚才写的接口（@EnableBinding（xxx.class））
   然后在方法上监听输入队列(@StreamLstener（输入队列）)
   
   如何发送消息
   把写的接口注入进来调用output().send(使用MessageBuild创建message)方法