Spring Boot 2升级至3：Spring Cloud Stream的MessageChannel能否继续使用？

官方升级方向 #

Spring Cloud Stream 4.x（适配Spring Boot 3）中，@EnableBinding已被标记为废弃，官方明确推荐迁移到函数式编程模型或使用StreamBridge发送消息，这是后续版本的主流方案。

能否继续使用MessageChannel？ #

可以保留MessageChannel接口发送消息，但需调整代码与配置——旧的@EnableBinding机制不再自动创建MessageChannel的实现Bean，这正是你升级后出现找不到Bean错误的原因。

调整方案（保留MessageChannel） #

1. 移除@EnableBinding(MessageChannels.class)注解，手动注册MessageChannel Bean：

@Configuration
public class ChannelConfig {
    @Bean
    public MessageChannel customOutputChannel() {
        return new DirectChannel();
    }
}

2. 在配置文件中绑定该通道到RabbitMQ目标：

spring.cloud.stream.bindings.customOutputChannel.destination=your-exchange-name
spring.cloud.stream.bindings.customOutputChannel.binder=rabbit

3. 注入该Bean后即可正常调用send()方法发送消息。

推荐迁移到StreamBridge #

如果是升级重构或新项目，更建议改用官方推荐的StreamBridge，代码更简洁且适配新模型：

@Service
public class MessageService {

    private final StreamBridge streamBridge;

    // 构造注入（推荐替代@Autowired）
    public MessageService(StreamBridge streamBridge) {
        this.streamBridge = streamBridge;
    }

    public void send(String id, Map<String, Object> data, String targetChannel, MessageType messageType, String messageTypeHeader) {
        MessageDTO message = new MessageDTO();
        message.setId(id);
        message.setData(data);
        message.setMessageType(messageType);

        Message<?> m = MessageBuilder.withPayload(message)
                .setHeader("messageType", messageTypeHeader)
                .setHeader("messageSourceType", MessageSourceType.PLATFORM.name())
                .build();

        // 发送到指定通道
        streamBridge.send(targetChannel, m);
    }
}

配置文件中只需声明通道的目标绑定即可，无需手动注册通道Bean：

spring.cloud.stream.bindings.<targetChannel>.destination=your-exchange-name

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