spring-cloud-stream如何为exchange绑定alternate exchange备用交换器

3.2.2版本未内置alternate exchange（备用交换器，简称AE）的自动配置能力，直接通过Spring AMQP提供的扩展点自定义声明即可，和Spring Cloud Stream（简称SCS）原有组件声明逻辑完全兼容，无版本冲突。

具体实现 #

1. 声明备用交换器与未路由消息存储队列 #

单独定义配置类，声明AE、AE绑定的持久化队列、二者的绑定关系，这部分组件不会和SCS自动创建的组件重名冲突：

import org.springframework.amqp.core.*;
import org.springframework.boot.autoconfigure.amqp.ExchangeCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class BizAlternateExchangeConfig {
    // 自定义备用交换器名称
    private static final String BIZ_AE_NAME = "biz.common.alternate.exchange";
    // 绑定到AE的未路由消息持久化队列
    private static final String UNROUTED_QUEUE_NAME = "biz.common.queue.unrouted";

    // 声明备用交换器，推荐使用fanout类型，无需匹配路由键即可投递到所有绑定队列
    @Bean
    public FanoutExchange bizAlternateExchange() {
        return ExchangeBuilder.fanoutExchange(BIZ_AE_NAME)
                .durable(true)
                .build();
    }

    // 声明未路由消息存储队列
    @Bean
    public Queue unroutedMessageQueue() {
        return QueueBuilder.durable(UNROUTED_QUEUE_NAME)
                .build();
    }

    // 绑定队列到备用交换器
    @Bean
    public Binding aeQueueBinding(Queue unroutedMessageQueue, FanoutExchange bizAlternateExchange) {
        return BindingBuilder.bind(unroutedMessageQueue).to(bizAlternateExchange);
    }
}

2. 给业务目标交换器追加AE配置 #

SCS会根据配置自动创建业务生产端对应的交换器，不需要重复声明，直接通过3.2.x版本原生提供的ExchangeCustomizer扩展点，在交换器初始化时追加AE参数即可，不会覆盖SCS原有配置：

@Bean
public ExchangeCustomizer bizExchangeAeCustomizer() {
    return exchange -> {
        // 匹配你业务生产端绑定对应的目标交换器名称，即配置项spring.cloud.stream.bindings.<你的binding名>.destination的值
        if (exchange.getName().equals("你的业务目标交换器名称")) {
            exchange.getArguments().put("alternate-exchange", BIZ_AE_NAME);
        }
    };
}

注意事项 #

• 不要手动重新声明SCS自动管理的业务主交换器，否则会覆盖框架默认配置的死信、延迟等参数，用ExchangeCustomizer修改参数是侵入性最低的实现方式
• 备用交换器本身不要配置alternate-exchange、死信、消息过期等规则，避免未路由消息出现二次投递丢失
• AE绑定的未路由消息队列建议单独配置消费逻辑，做异常告警、消息补偿，不要仅存储不做处理
• 该实现和RabbitMQ生产者return机制不冲突，可同时开启spring.rabbitmq.publisher-returns=true获取未路由消息的本地回调

功能验证 #

启动应用后，向业务交换器发送一个路由键不存在对应绑定关系的测试消息，消息会自动投递到AE绑定的未路由队列中，不会直接丢弃，可覆盖“消费者未启动、队列未创建时首批生产消息丢失”的场景。

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