springcloud stream 消息驱动

rabbitmq 与stream 结合入门应用举例：

一、消息生产者：

1、引入依赖：

<dependencies>

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-stream</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>

        </dependency>

        <dependency>

            <groupId>org.springframework.cloud</groupId>

            <artifactId>spring-cloud-stream-binder-rabbit</artifactId>

        </dependency>

    </dependencies>

producer pom文件

2、配置yml 文件：

如果用内置接口，不会用到下面的 myoutput: 这个配置，可以删除，

yml配置

3、定义消息发送接口， spring 内置的一个消息发送接口已经有一个：

public interface Source {    

String OUTPUT = "output";

@Output("output")  
MessageChannel output();

}

4、发送消息

发送消息

二、消息消费者

1、引入和消息生产者一样的依赖

消费者 pom

2/消费者中的对应配置

消费者yml中对应配置 消费者yml

3、定义消息接收接口， spring 内置的一个消息接收接口已经有一个：

public interface Sink {   

String INPUT = "input";

   @Input("input")    
SubscribableChannel input(); 

}

4、接收消息：

接收消息