Spring Boot使用RabbitTemplate后如何正确终止RabbitMQ连接

问题根因 #

Spring Boot 2.x版本自动配置的RabbitTemplate默认使用CachingConnectionFactory管理连接，连接和信道会被工厂缓存复用，仅调用RabbitTemplate的stop()/destroy()方法只会停止模板自身的生命周期组件，不会触发连接工厂释放缓存的底层连接，因此连接会一直保持。

正确的关闭方式 #

方法1：主动重置连接工厂（推荐） #

直接操作CachingConnectionFactory强制释放所有缓存连接，步骤如下：

1. 构造函数中同时注入RabbitTemplate和ConnectionFactory
2. 所有消息处理完成后，先停止RabbitTemplate，再调用连接工厂的resetConnection()方法强制关闭连接

示例代码：

private final RabbitTemplate rabbitTemplate;
private final CachingConnectionFactory connectionFactory;

// 构造函数注入
public 你的业务类名(RabbitTemplate rabbitTemplate, ConnectionFactory connectionFactory) {
    this.rabbitTemplate = rabbitTemplate;
    // Spring Boot默认自动配置的连接工厂就是CachingConnectionFactory，可直接强转
    this.connectionFactory = (CachingConnectionFactory) connectionFactory;
}

public void 消息处理方法() {
    rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
    Object msg = getMessage();
    while (msg != null) {
        try {
            String name = ((LinkedHashMap) msg).get(propertyName).toString();
            //business logic
            logger.debug("added_" + name);
        } catch (Exception e) {
            logger.error("" + e.getMessage());
        }
        msg = getMessage();
    }
    // 停止RabbitTemplate
    rabbitTemplate.stop();
    // 强制关闭所有缓存的连接，断开与RabbitMQ的连接
    connectionFactory.resetConnection();
}

private Object getMessage() {
    try {
        return rabbitTemplate.receiveAndConvert(queueName);
    } catch (Exception e) {
        logger.error("" + e.getMessage());
        return null;
    }
}

方法2：关闭Spring应用上下文（适合拉完消息直接退出的场景） #

如果你的应用处理完消息后就要整体终止，直接关闭Spring上下文即可，Spring会自动销毁所有生命周期Bean，包括RabbitTemplate和连接工厂，自动断开连接：

// 注入ApplicationContext
private final ApplicationContext applicationContext;

// 处理完所有消息后调用
SpringApplication.exit(applicationContext, () -> 0);

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