Spring Cloud Stream 是一个构建消息驱动的微服务架构的框架，它可以很好地集成与Apache Kafka和RabbitMQ这样的消息中间件。
以下是一个使用Spring Cloud Stream的简单例子：
- 添加依赖到你的
pom.xml：
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.SR2</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>- 配置application.yml：
spring:
cloud:
stream:
binders:
defaultRabbit:
type: rabbit
environment:
spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
bindings:
input:
destination: my-input-topic
binder: defaultRabbit
content-type: application/json
output:
destination: my-output-topic
binder: defaultRabbit
content-type: application/json- 创建接收消息的服务类：
@EnableBinding(Sink.class)
public class MessageReceiver {
@StreamListener(Sink.INPUT)
public void handleMessage(String message) {
System.out.println("Received: " + message);
}
}- 创建发送消息的服务类：
@EnableBinding(Source.class)
public class MessageSender {
@Autowired
private MessageChannel output;
public void sendMessage(String message) {
this.output.send(MessageBuilder.withPayload(message).build());
}
}在这个例子中，我们定义了一个输入通道input和一个输出通道output，并且指定了消息的内容类型为JSON。MessageReceiver类中的handleMessage方法使用@StreamListener注解来监听输入通道上的消息，并处理它们。MessageSender类中的sendMessage方法使用自动装配的MessageChannel发送消息到输出通道。
这个简单的例子展示了如何使用Spring Cloud Stream来创建消息驱动的微服务。通过这种方式，你可以很容易地与消息中间件集成，并发送、接收消息，而不用担心底层消息中间件的实现细节。