如何在保留Spring Boot自动配置的前提下配置Rabbit连接工厂

问题根因 #

• 第一种ConnectionFactoryCustomizer方案失效原因：该接口回调传入的是RabbitMQ原生客户端com.rabbitmq.client.ConnectionFactory实例，而Spring封装的CachingConnectionFactory自身已经持有从配置文件、自动配置默认值注入的host、端口等属性，创建连接时会用自身的属性覆盖原生连接工厂的配置，因此修改原生工厂的属性不会生效。
• 第二种SmartInitializingSingleton方案失效原因：该回调执行时机晚于Bean初始化阶段，如果项目中存在提前实例化的RabbitTemplate、Rabbit监听容器等Bean，会在回调触发前就完成连接创建，此时再修改CachingConnectionFactory的属性已经无法作用于已创建的连接；即使没有提前创建连接，该方案也无法保证在所有连接触发逻辑前执行。

正确实现方案 #

最稳妥的方式是通过BeanPostProcessor在CachingConnectionFactory属性注入完成后、初始化完成前修改目标属性，完全保留Spring Boot自动配置和配置文件的其他属性值，且执行时机早于任何连接创建逻辑：

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanPostProcessor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitCustomConfig {

    @Bean
    public BeanPostProcessor rabbitConnectionFactoryPostProcessor() {
        return new BeanPostProcessor() {
            @Override
            public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
                if (bean instanceof CachingConnectionFactory) {
                    CachingConnectionFactory connectionFactory = (CachingConnectionFactory) bean;
                    // 仅覆盖需要修改的属性，其余配置全部保留
                    connectionFactory.setHost("anotherhost");
                    // 按需修改其他属性，例如：
                    // connectionFactory.setPort(5672);
                    // connectionFactory.setVirtualHost("/custom");
                }
                return bean;
            }
        };
    }
}

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