java - 当rabbit最初关闭时，Bean无法初始化

Question

org.springframework.web.context.ContextLoader | localhost-startStop-1 |     Context initialization failed
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'simpleListenerContainer' defined
 in class path resource [com/company/product/api/config/amqp/InternalAmqpConfiguration.class]: Bean instantiation v
ia factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate

如果在我的 Spring MVC 应用程序启动之前 Rabbit 已关闭，则依赖于 CachingConnectionFactory 的许多 Bean 将无法初始化。就像下面这样:

 @Autowired
@Bean
public SimpleRabbitListenerContainerFactory simpleistenerContainer(
    @Qualifier("internal") CachingConnectionFactory connectionFactory,
    RabbitAdmin admin) {

    for(Listeners listener : Listeners.values()) {
        Queue q = new Queue(listener.queue, true, true, true);
        admin.declareQueue(q);
        admin.declareBinding(
            BindingBuilder.bind(q)
                .to(new TopicExchange(listener.exchange, true, false))
                .with((listener.appendWildcard) ? listener.routingKey + ""
                    + ".*" : listener.routingKey)
        );
    }

    SimpleRabbitListenerContainerFactory listenerContainerFactory = new
        SimpleRabbitListenerContainerFactory();

    listenerContainerFactory.setConnectionFactory(connectionFactory);

    return listenerContainerFactory;
}

此操作失败并且无法恢复，因为缺少此依赖项之一而导致 Bean 未初始化。我考虑过在 CachingConnectionFactory 上设置 ConnectionListener，但这些对象将无法作为 bean 访问。任何的意见都将会有帮助。我确信可能有一个简单的解决方案。

Answer 1

只需将您的绑定(bind)等添加为 @Bean，而不是自己声明它们。

添加一个RabbitAdmin @Bean，它会在建立连接时自动执行声明。

编辑:

回应您的评论...

但是，您正在执行自己的声明:

admin.declareQueue(q);
admin.declareBinding(...

如果代理不可用，除非您添加 try/catch，否则这些操作将会失败。您还可以在管理员上设置 ignoreDeclarationExceptions，但您实际上不需要自己执行这些声明。一旦容器建立连接，管理员就会自动声明它们。

编辑2:

Why would they get declared? ...

因为这就是它的设计方式；请阅读the documentation向下滚动查看Binding等的java配置

RabbitAdmin(如果在上下文中声明)将自身注册为连接监听器。建立连接后，管理员会在上下文中查找所有 Queue、Exchange 和 Binding @Bean，并在建立连接时声明它们。

您通过直接从 bean 定义进行绑定(bind)来破坏此“惰性”声明，这要求代理可用，并且如果没有连接，上下文将无法初始化。

只需在上下文中声明您所需的Binding，管理员就会在代理可用时为您处理。监听器容器将根据其 recoveryInterval 继续尝试连接，并且最终成功时将发生声明。