RabbitMQ服务或队列异常时保障应用A正常启动的快速容错方案问询

兄弟，我完全懂你这种急着救火的场景——依赖的Rabbit服务挂了或者队列被删了，整个应用A直接启动失败，又没时间拆LibA，得先搞个快速方案顶过去。下面这几个方法都是不用动应用A代码、只改LibA就能搞定的：

1. 把Rabbit相关Bean改成懒加载，彻底隔离启动流程 #

默认情况下Spring会在启动时初始化所有非懒加载的Bean，RabbitTemplate、队列声明、监听器容器这些Bean一初始化就会尝试连Rabbit，连不上直接崩。给LibA里所有Rabbit相关的Bean（包括ConnectionFactory、RabbitTemplate、RabbitAdmin、各种监听器容器、队列/交换机Bean）加上@Lazy注解，这样这些Bean只会在第一次被实际调用时才会初始化，完全不会影响应用A的启动流程。

比如给RabbitTemplate加懒加载：

@Lazy
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
    return new RabbitTemplate(connectionFactory);
}

2. 禁用启动时的队列声明与监听器自动启动 #

如果LibA里用了RabbitAdmin来自动声明队列、交换机，默认它会在启动时就去Rabbit上创建资源，Rabbit不可用就会失败。给RabbitAdmin设置autoStartup = false，让它不要在启动时执行声明操作：

@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
    RabbitAdmin admin = new RabbitAdmin(connectionFactory);
    // 关闭启动时自动执行队列/交换机声明
    admin.setAutoStartup(false);
    return admin;
}

同时给所有消息监听器容器也设置autoStartup = false，避免启动时就尝试连接Rabbit创建监听通道：

@Bean
public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setQueueNames("your-target-queue");
    container.setMessageListener(yourMessageListener());
    // 启动时不启动监听器
    container.setAutoStartup(false);
    return container;
}

3. 给连接工厂加自动重试与快速超时配置 #

即使后来真的要用到Rabbit，也得避免因为临时网络波动或者Rabbit重启导致操作失败。给ConnectionFactory加上自动恢复和短超时配置，让它自己重试连接，不用把异常抛到应用层：

@Bean
public ConnectionFactory connectionFactory() {
    CachingConnectionFactory factory = new CachingConnectionFactory();
    factory.setHost("your-rabbit-host");
    factory.setPort(5672);
    factory.setUsername("rabbit-username");
    factory.setPassword("rabbit-password");
    // 开启连接自动恢复
    factory.setAutomaticRecoveryEnabled(true);
    // 开启拓扑（队列/交换机绑定）自动恢复
    factory.setTopologyRecoveryEnabled(true);
    // 设置短连接超时，避免卡住等待
    factory.setConnectionTimeout(3000);
    // 设置重试间隔，比如每5秒重试一次
    factory.setRecoveryInterval(5000);
    return factory;
}

4. 运行时调用RabbitTemplate时加异常捕获降级 #

如果应用A运行中需要调用RabbitTemplate发消息，一定要在调用处（或者在LibA里给RabbitTemplate加个包装类）捕获所有Amqp相关异常，做降级处理——比如把消息存到本地临时文件、数据库，或者直接打日志跳过，绝对不能让Rabbit的异常导致应用A的业务流程崩溃：

// 比如在LibA里封装一个容错的RabbitTemplate工具类
public class FaultTolerantRabbitTemplate {
    private final RabbitTemplate rabbitTemplate;
    private final Logger log = LoggerFactory.getLogger(FaultTolerantRabbitTemplate.class);
    private final LocalMessageRepository localMessageRepository;

    public FaultTolerantRabbitTemplate(RabbitTemplate rabbitTemplate, LocalMessageRepository localMessageRepository) {
        this.rabbitTemplate = rabbitTemplate;
        this.localMessageRepository = localMessageRepository;
    }

    public void sendMessage(String exchange, String routingKey, Object message) {
        try {
            rabbitTemplate.convertAndSend(exchange, routingKey, message);
        } catch (AmqpException e) {
            // 这里做降级处理，比如存本地文件或者记告警日志
            log.error("Rabbit发送消息失败，已触发降级", e);
            // 可选：把消息存入本地消息表，后续手动重试
            localMessageRepository.save(new LocalMessage(exchange, routingKey, message));
        }
    }
}

可选：隔离Rabbit对应用健康检查的影响 #

如果你们用了Spring Boot Actuator的健康检查，默认Rabbit的状态会影响整个应用的健康状态，可能导致K8s之类的编排工具把应用A杀掉重启。可以在配置文件里关闭Rabbit健康检查，或者自定义健康指示器，不让Rabbit的问题影响应用的整体健康状态：

# 关闭默认的Rabbit健康检查
management.health.rabbit.enabled=false

备注：内容来源于stack exchange，提问作者Дамир Эсенов