我刚帮几个团队完成过Spring Cloud Stream从@Output/@StreamListener到Supplier/Consumer模式的迁移，给你整理一套实用的步骤和细节，应该能帮你顺利过渡：

首先要确保你的Spring Cloud版本支持新的函数式编程模型（一般Spring Cloud 2020.0.x+就开始主推，2022.0.x+完全废弃旧注解）。修改pom.xml：

• 保留spring-cloud-stream和对应binder依赖（比如RabbitMQ的spring-cloud-stream-binder-rabbit）
• 彻底移除旧的@EnableBinding相关依赖（如果有的话）
• 确保Spring Boot和Spring Cloud版本匹配（比如Spring Boot 3.x对应Spring Cloud 2022.0.x+）

示例依赖：

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

旧模式的@EnableBinding、@Output、@StreamListener全部废弃，换成函数式的Supplier（生产者）和Consumer（消费者）。

1. 生产者迁移 #

场景1：定时/自动发送消息

用Supplier定义生产逻辑，Spring Cloud Stream会自动绑定并触发：

@Component
public class MessageProducer {
    // 方法名会作为绑定标识的一部分，比如messageSupplier-out-0
    @Bean
    public Supplier<String> messageSupplier() {
        // 这里可以返回静态消息，或者结合业务逻辑生成
        return () -> "New message from Supplier";
    }
}

场景2：主动触发发送（比如接口调用）

如果需要手动控制发送时机，用StreamBridge替代原来的MessageChannel：

@Component
public class MessageProducer {
    private final StreamBridge streamBridge;

    // 构造注入，不用@Autowired
    public MessageProducer(StreamBridge streamBridge) {
        this.streamBridge = streamBridge;
    }

    public void sendMessage(String content) {
        // 第一个参数是绑定名称（对应配置里的xxx-out-0），第二个是消息内容
        streamBridge.send("messageSupplier-out-0", content);
    }
}

2. 消费者迁移 #

用Consumer定义消息处理逻辑，自动监听绑定的队列：

@Component
public class MessageConsumer {
    // 方法名对应绑定标识：messageConsumer-in-0
    @Bean
    public Consumer<String> messageConsumer() {
        return message -> {
            // 替换成你的业务处理逻辑
            System.out.println("Received message: " + message);
        };
    }
}

旧模式的output/input绑定名要替换成函数式的绑定规则：

• 生产者绑定名：{beanName}-out-0（比如上面的messageSupplier-out-0）
• 消费者绑定名：{beanName}-in-0（比如上面的messageConsumer-in-0）

示例application.yml配置：

spring:
  cloud:
    stream:
      bindings:
        # 生产者绑定
        messageSupplier-out-0:
          destination: my-business-exchange # 对应RabbitMQ的交换机
          binder: rabbit
        # 消费者绑定
        messageConsumer-in-0:
          destination: my-business-exchange
          binder: rabbit
          group: my-consumer-group # 指定消费组，避免重复消费
      rabbit:
        bindings:
          # 生产者RabbitMQ特定配置
          messageSupplier-out-0:
            producer:
              exchangeType: topic # 交换机类型，按需选direct/topic/fanout
              routingKey: business.routing.key
          # 消费者RabbitMQ特定配置
          messageConsumer-in-0:
            consumer:
              bindingRoutingKey: business.routing.key # 绑定路由键
              queueNameGroupOnly: true # 自定义队列名时开启，队列名会变成my-business-exchange.my-consumer-group

• 彻底移除旧注解：所有@EnableBinding、@StreamListener、@Output、@Input都要删掉，避免和新模式冲突
• 绑定名称规则：如果有多个输出/输入，可以用Supplier<Flux<String>>（批量发送），或者定义多个@Bean的Supplier/Consumer，每个对应不同的绑定名
• 版本兼容性：不要混用新旧模式，确保Spring Cloud版本足够新（建议直接升级到最新稳定版）
• 测试技巧：单元测试可以用@SpringBootTest(classes = TestChannelBinderConfiguration.class)，模拟绑定通道，不用启动真实的RabbitMQ

内容的提问来源于stack exchange，提问作者Marx