使用Spring Cloud Stream时，如何通过Binder抽象实现消息中间件（如Kafka、RabbitMQ）的切换，而不修改业务代码？

Question

使用Spring Cloud Stream时，如何通过Binder抽象实现消息中间件（如Kafka、RabbitMQ）的切换，而不修改业务代码？

Answer 1

阿里嘎多学长整理AIGC生成，因移动端显示问题导致当前答案未能完全显示，请使用PC端查看更加详细的解答过程

使用Spring Cloud Stream实现消息中间件切换

Spring Cloud Stream提供了Binder抽象，允许我们通过配置切换不同的消息中间件，如Kafka、RabbitMQ等，而不修改业务代码。

步骤

1. 添加依赖

在pom.xml中添加Spring Cloud Stream和对应的Binder依赖：

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

1. 配置Binder

在application.properties中配置Binder：

spring:
  cloud:
    stream:
      binders:
        myKafkaBinder:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: localhost:9092
        myRabbitBinder:
          type: rabbit
          environment:
            spring:
              cloud:
                stream:
                  rabbit:
                    binder:
                      addresses: localhost:5672

1. 使用Binder

在业务代码中使用Binder：

@SpringBootApplication
@EnableBinding(Sink.class)
public class MyApplication {
    
    @Bean
    public Function<String, String> myFunction() {
        return message -> {
            // 处理消息
            return message;
        };
    }
    
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

1. 切换Binder

通过配置切换Binder，例如从Kafka切换到RabbitMQ：

spring:
  cloud:
    stream:
      binders:
        myKafkaBinder:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: localhost:9092
        myRabbitBinder:
          type: rabbit
          environment:
            spring:
              cloud:
                stream:
                  rabbit:
                    binder:
                      addresses: localhost:5672

注意

• Binder的类型（kafka或rabbit）需要与对应的依赖匹配。
• Binder的配置需要与对应的中间件匹配。
• 业务代码不需要修改，切换Binder只需要修改配置即可。