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>
2、配置yml 文件:
如果用内置接口,不会用到下面的 myoutput: 这个配置,可以删除,
3、定义消息发送接口, spring 内置的一个消息发送接口已经有一个:
public interface Source {
String OUTPUT = "output";
@Output("output")
MessageChannel output();
}
4、发送消息
二、消息消费者
1、引入和消息生产者一样的依赖
2/消费者中的对应配置
3、定义消息接收接口, spring 内置的一个消息接收接口已经有一个:
public interface Sink {
String INPUT = "input";
@Input("input")
SubscribableChannel input();
}
4、接收消息: