java - 即使一个 bean 在运行时出现错误，也确保 Spring 应用程序的其余部分运行

Question

现在我正在开发一个包含多个组件的 Spring 应用程序，其中包括一个 RabbitMQ 组件。

RabbitMQ 连接的初始化是通过配置 bean 进行的，这些配置 bean 在应用程序启动时自动变为 Activity 状态。

下面是我的 RabbitMQ 配置文件:

@Configuration
@PropertySources({
        @PropertySource("classpath:message.properties"),
        @PropertySource("classpath:rabbitmq.properties")
})
@EnableRabbit
public class MessageConfiguration {

    private static final String MESSAGE_HOST_PROPERTY = "message.host";

    private static final String FACTORY_USERNAME_PROPERTY = "rabbitmq.username";
    private static final String FACTORY_PASSWORD_PROPERTY = "rabbitmq.password";


    private Environment environment;



    @Autowired
    public MessageConfiguration(Environment environment) {
        this.environment = environment;
    }


    @Bean
    public AmqpTemplate publishTemplate() {
        RabbitTemplate result = new RabbitTemplate(connectionFactory());
        return result;
    }


    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(environment.getProperty(MESSAGE_HOST_PROPERTY));
        connectionFactory.setUsername(environment.getProperty(FACTORY_USERNAME_PROPERTY));
        connectionFactory.setPassword(environment.getProperty(FACTORY_PASSWORD_PROPERTY));
        return connectionFactory;
    }
}

在 Bean connectionFactory 中，如果我提供错误的用户名和密码，我的应用程序将遇到身份验证错误:

Caused by: org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.amqp.rabbit.config.internalRabbitListenerEndpointRegistry'; nested exception is org.springframework.amqp.AmqpIllegalStateException: Fatal exception on listener startup
    Caused by: org.springframework.amqp.AmqpIllegalStateException: Fatal exception on listener startup
    Caused by: org.springframework.amqp.rabbit.listener.exception.FatalListenerStartupException: Authentication failure
    Caused by: org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.

同时，与 RabbitMQ 无关的应用程序的其余部分将无法运行。

有没有办法将 RabbitMQ bean 错误仅包含在其自身而不是所有其他组件中，以便应用程序的其余部分可以运行？

Answer 1

身份验证错误被认为是致命的。

对于暂时性错误(例如代理未运行)，应用程序将启动并尝试重新连接。

FatalListenerStartupException

您不会显示监听器配置，但您可以通过 autoStartup 属性将监听器容器配置为不自动启动。如果为 false，则上下文将始终加载正常。

然后，您可以尝试在代码中start() 容器并捕获异常。