spring Cloud Stream 实战应用深度讲解

Spring Cloud Stream 是一个构建消息驱动微服务的框架。以下是一个简单的Spring Cloud Stream应用程序的示例，它将从一个源中消费消息，并将其生产到另一个目标。

1. 首先，在pom.xml中添加Spring Cloud Stream和相应的消息中间件绑定器（如RabbitMQ或Kafka）依赖：

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

2. 配置application.yml来定义Spring Cloud Stream绑定器和目标：

spring:
  cloud:
    stream:
      binders:
        defaultRabbit:
          type: rabbit
          environment:
            spring:
              rabbitmq:
                host: localhost
                port: 5672
                username: guest
                password: guest
      bindings:
        input:
          destination: input-topic
          binder: defaultRabbit
          group: stream-group
        output:
          destination: output-topic
          binder: defaultRabbit

3. 创建一个接收消息的服务类：

@EnableBinding(value = {Processor.class})
public class MessageReceiver {
 
    @StreamListener(Processor.INPUT)
    public void receive(String payload) {
        // 处理接收到的消息
        System.out.println("Received: " + payload);
    }
}

4. 创建一个发送消息的服务类：

@EnableBinding(value = {Processor.class})
public class MessageSender {
 
    @Autowired
    private MessageChannel output;
 
    public void send(String payload) {
        output.send(MessageBuilder.withPayload(payload).build());
    }
}

以上代码展示了如何使用Spring Cloud Stream来创建一个简单的消息接收和发送的应用程序。MessageReceiver类使用@StreamListener注解监听一个名为input-topic的输入消息通道，并打印接收到的消息。MessageSender类使用注入的MessageChannel发送消息到名为output-topic的输出通道。

在实际应用中，你需要根据具体的消息中间件配置和业务需求来调整配置文件和服务类。