请求将Spring Boot 2的Spring Cloud Stream RabbitMQ接收代码转为Spring Boot 3函数式风格

转换后的核心代码 #

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.function.Consumer;

@Configuration
public class RabbitMQReceiverConfig {

    // 对应原代码中的INPUT通道名input234242，作为函数Bean的名称
    @Bean
    public Consumer<String> input234242() {
        return message -> {
            System.out.println("Received message: " + message);
        };
    }
}

必要的配置（以application.yml为例） #

spring:
  cloud:
    stream:
      bindings:
        # 绑定规则：<函数Bean名称>-in-0（Consumer是输入类型，后缀为-in-0）
        input234242-in-0:
          destination: your-exchange-name  # 替换为实际的RabbitMQ交换机名称
          group: your-consumer-group       # 必填：指定消费组，避免重复消费
      rabbit:
        bindings:
          input234242-in-0:
            consumer:
              auto-bind-dlq: true  # 可选：自动绑定死信队列，处理消费失败的消息

关键变化说明 #

• 移除了@EnableBinding和@StreamListener注解：Spring Cloud Stream 4.x（适配Spring Boot 3）已废弃原有注解式编程模型，全面转向函数式编程
• 无需自定义MySink接口：函数Bean的名称直接对应原通道名，绑定关系通过配置文件指定
• 强制要求消费组：必须配置group属性，否则应用启动会报错，同时保证同一应用多实例下消息只被消费一次
• 绑定命名规则：输入绑定格式为<函数Bean名>-in-0，输出绑定为<函数Bean名>-out-0，遵循Spring Cloud Stream函数式编程的命名规范

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