如何配置rabbit连接工厂但保持Spring Boot自动配置？

Question

我想以编程方式设置org.springframework.amqp.rabbit.connection.CachingConnectionFactory上的主机属性。我想保留Spring Boot自动配置的默认值和来自我的应用程序的值-｛profile name｝。yml文件，因此出于这些原因，我不想简单地创建自己的cachingConnectionFactorybean。

我找到了org.springframework.boot.autoconfigure.amqp。ConnectionFactoryCustomizer类，看起来非常有前途，因为我看到了如何在RabbitAutoConfiguration类中调用它来配置底层com.rabbitmq.client。spring框架中的ConnectionFactory CachingConnectionFactory。但是，我不知道如何创建我的ConnectionFactoryCustomizer实例并将其注册为回调，以及如何以正确的顺序调用它（我认为是最后调用的）。

我尝试了这个，但是仍然连接到“localhost”：

@Bean
@Order(Integer.MAX_VALUE)
public ConnectionFactoryCustomizer myConnectionFactoryCustomizer() {
    return factory -> {
        factory.setHost("anotherhost");
    };
}

我也尝试了这种方法，我从另一个stackoverflow帖子中得到了启发，并提出了一个有点类似的问题：如何为RabbitMQ连接设置自定义名称？

@Bean
public SmartInitializingSingleton configureConnectionFactory(final CachingConnectionFactory factory) {
    factory.setHost("anotherhost");
    return () -> {
        factory.setHost("anotherhost");
    };
}

但是这两种方法都不起作用。正在执行调用factory.setHost的代码，所以我显然做错了什么。我的日志输出仍然是这样的：

2021-10-17 13：45：24，271|信息||myContainer-3|org.springframework.amqp.rabbit.connection.CachingConnectionFactory|正在尝试连接到：[本地主机：5672]

那么，在连接工厂中以编程方式重写host等值的正确方法是什么呢？(当然，在创建任何连接之前)

Answer 1

Boot 配置 CachingConnectionFactory.addresses 属性（将覆盖主机）。

试试这个。。。

@Bean
@Order(Integer.MAX_VALUE)
public ConnectionFactoryCustomizer myConnectionFactoryCustomizer() {
    return factory -> {
        factory.setHost("anotherhost");
    };
}

@Bean
ApplicationRunner runner(CachingConnectionFactory ccf) {
    ccf.setAddresses(null);
    return args -> {
    };
}

它可以在任何其他bean定义中完成（不一定是运行器），但不能在myConnectionFactoryCustomizerbean中完成，因为存在循环引用。

或

@Bean
ApplicationRunner runner(CachingConnectionFactory ccf) {
    ccf.setAddresses(null);
    ccf.setHost("another");
    return args -> {
    };
}