已解决org.springframework.amqp.AmqpApplicationContextClosedException异常的正确解决方法，亲测有效！！！

文章目录

引言

问题分析

报错原因

解决思路

解决方法

总结

---

引言

 在使用Spring框架进行消息驱动的应用程序开发过程中，我们可能会遇到一个令人困扰的异常：org.springframework.amqp.AmqpApplicationContextClosedException。这个异常通常在Spring管理的AMQP资源（如RabbitMQ）尝试在应用程序上下文关闭后发送或接收消息时被抛出。本篇博客将详细介绍这个问题的场景、报错原因以及提供一套可行的解决方案。

 

问题分析

 首先，我们来定义问题的背景。在基于Spring AMQP支持的应用中，我们通常会配置RabbitTemplate或者MessageListener容器来发送和接收消息。当Spring ApplicationContext关闭时，所有的单例bean都会被销毁，这包括了AMQP连接工厂以及与之相关的模板和监听器。如果在这个时候还有消息尝试通过已经关闭的上下文发送或接收，那么就会抛出org.springframework.amqp.AmqpApplicationContextClosedException异常。

 

报错原因

究其原因，该异常是由于资源已经不可用，但应用程序仍然尝试进行操作。这可能是因为：

1. ApplicationContext的生命周期管理没有恰当处理，比如在销毁前未能确保所有消息处理完毕。
2. 异步处理使得部分业务逻辑在ApplicationContext关闭之后仍然在执行，导致无法正常访问AMQP资源。
3. 配置错误，如使用了不恰当的生命周期管理策略，或者@Bean的destroyMethod属性设置不当造成的提前资源回收。

 

解决思路

要解决这个问题，我们需要确保在ApplicationContext关闭之前所有的消息都已经处理完毕，且没有新的消息发送或接收。具体思路如下：

1. 优雅地关闭Spring容器，确保在关闭前完成所有消息的处理。
2. 如果使用异步处理，确保任务队列中的任务在关闭前全部完成。
3. 检查并修正所有涉及AMQP资源的Bean的生命周期管理配置。
4. 在必要时通知其他系统组件，当前服务正在关闭，暂停发送消息。

 

解决方法

步骤1：优雅关闭Spring容器

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);
        context.registerShutdownHook();
        // 其他业务代码
    }
}

使用registerShutdownHook()方法可以注册一个JVM关闭的钩子，在JVM关闭之前，它会通知Spring容器调用destroy方法释放资源。

步骤2：确保异步任务完成 假设我们使用@Async注解进行异步任务处理，我们需要确保在关闭上下文之前等待这些任务完成。

@Component
public class AsyncTasksExecutor implements ApplicationListener {
    private final AsyncTaskExecutor executor;
    @Autowired
    public AsyncTasksExecutor(AsyncTaskExecutor executor) {
        this.executor = executor;
    }
    @Override
    public void onApplicationEvent(ContextClosedEvent event) {
        if (!executor.getThreadPoolExecutor().isShutdown()) {
            try {
                executor.getThreadPoolExecutor().shutdown();
                if (!executor.getThreadPoolExecutor().awaitTermination(30, TimeUnit.SECONDS)) {
                    System.err.println("Timed out waiting for executor tasks to finish");
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }
}

在这段代码中，我们实现了一个ApplicationListener来监听ContextClosedEvent事件，它会在上下文即将关闭时触发。我们在监听器中优雅地关闭了执行器，并等待所有任务完成。

步骤3：检查Bean的生命周期配置 检查并修正所有相关Bean的定义，如使用@Bean注解时指定destroyMethod，确保其符合实际应用场景。

@Bean(destroyMethod = "close")
public ConnectionFactory connectionFactory() {
    CachingConnectionFactory factory = new CachingConnectionFactory();
    // 配置连接工厂的设置
    return factory;
}

在这里，destroyMethod属性设为"close"意味着在Bean销毁时会调用ConnectionFactory的close方法来关闭连接。

步骤4：服务协同控制 如果我们的系统是分布式的，并且依赖多个微服务，那么需要在关闭前通知其他服务停止与当前服务交互。这可以通过注册中心的健康检查、服务网关的流量控制等机制来实现。

总结

org.springframework.amqp.AmqpApplicationContextClosedException异常虽然令人头疼，但只要我们能够理解其背后的生命周期管理原理，并采取合适的措施来确保资源的正确释放，就能有效地避免这类问题的发生。希望本文所提供的方法能帮助读者在遇到类似问题时迎刃有解。

以上是此问题报错原因的解决方法，欢迎评论区留言讨论是否能解决，如果本文对你有帮助 欢迎 关注 、点赞 、收藏 、评论， 博主才有动力持续记录遇到的问题！！！

博主v：XiaoMing_Java

 📫作者简介：嗨，大家好，我是 小明java问道之路，互联网大厂后端研发专家，2022博客之星TOP3 / 博客专家 / CSDN后端内容合伙人、InfoQ(极客时间)签约作者、阿里云签约博主、全网5万粉丝博主。

---

🍅 文末获取联系 🍅  👇🏻 精彩专栏推荐订阅收藏 👇🏻

专栏系列（点击解锁）	学习路线（点击解锁）	知识定位
🔥Redis从入门到精通与实战🔥	Redis从入门到精通与实战	围绕原理源码讲解Redis面试知识点与实战
🔥MySQL从入门到精通🔥	MySQL从入门到精通	全面讲解MySQL知识与企业级MySQL实战
🔥计算机底层原理🔥	深入理解计算机系统CSAPP	以深入理解计算机系统为基石，构件计算机体系和计算机思维
	Linux内核源码解析	围绕Linux内核讲解计算机底层原理与并发
🔥数据结构与企业题库精讲🔥	数据结构与企业题库精讲	结合工作经验深入浅出，适合各层次，笔试面试算法题精讲
🔥互联网架构分析与实战🔥	企业系统架构分析实践与落地	行业最前沿视角，专注于技术架构升级路线、架构实践
	互联网企业防资损实践	互联网金融公司的防资损方法论、代码与实践
🔥Java全栈白宝书🔥	精通Java8与函数式编程	本专栏以实战为基础，逐步深入Java8以及未来的编程模式
	深入理解JVM	详细介绍内存区域、字节码、方法底层，类加载和GC等知识
	深入理解高并发编程	深入Liunx内核、汇编、C++全方位理解并发编程
	Spring源码分析	Spring核心七IOC/AOP等源码分析
	MyBatis源码分析	MyBatis核心源码分析
	Java核心技术	只讲Java核心技术