【Java】已解决：org.springframework.amqp.AmqpApplicationContextClosedException

屿小夏

发布于 2024-09-16 08:13:20

13600

代码可运行

文章被收录于专栏：IT杂谈学习IT杂谈学习

运行总次数：0

代码可运行

已解决：org.springframework.amqp.AmqpApplicationContextClosedException

在Spring框架中使用AMQP（Advanced Message Queuing Protocol）进行消息传递时，有时会遇到org.springframework.amqp.AmqpApplicationContextClosedException异常。本文将对这一异常进行详细分析，并提供解决方案。

一、分析问题背景

1.1 问题描述

在使用Spring AMQP框架与RabbitMQ进行消息通信时，应用在关闭时抛出了org.springframework.amqp.AmqpApplicationContextClosedException异常。这通常发生在消息生产者或消费者试图在应用上下文已经关闭的情况下发送或接收消息。

1.2 出现问题的场景

这种错误通常在以下场景中出现：

应用程序关闭时，仍然有未处理完的消息。
消费者在处理消息的过程中，应用程序被关闭。

1.3 代码片段

以下是一个可能导致该异常的代码片段：

@Component
public class MessageProducer {

    @Autowired
    private AmqpTemplate amqpTemplate;

    public void sendMessage(String message) {
        amqpTemplate.convertAndSend("exchange", "routingKey", message);
    }
}

在应用上下文关闭时，如果此代码片段被调用，则会抛出AmqpApplicationContextClosedException异常。

二、可能出错的原因

2.1 应用上下文关闭

在Spring应用中，如果应用上下文（ApplicationContext）已经关闭，则任何依赖于上下文的操作都会失败。对于AMQP来说，连接和通道会在上下文关闭时被关闭，因此试图发送或接收消息会导致异常。

2.2 资源清理不当

在应用关闭过程中，资源（如RabbitMQ连接）未被正确清理，导致未完成的操作抛出异常。

2.3 不正确的关闭顺序

在某些情况下，Spring容器在关闭时的顺序不正确，导致消息处理器在资源被清理后仍在尝试处理消息。

三、错误代码示例

以下是一个可能导致该报错的代码示例：

@SpringBootApplication
public class AmqpApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(AmqpApplication.class, args);

        MessageProducer producer = context.getBean(MessageProducer.class);
        producer.sendMessage("Test Message");

        context.close();
    }
}

在这个示例中，context.close()在发送消息之后立即被调用，可能导致异常抛出。

四、正确代码示例

要解决这个问题，可以在应用关闭之前确保所有消息已经处理完毕，或者在应用关闭时正确处理资源清理。以下是修改后的正确代码示例：

@SpringBootApplication
public class AmqpApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext context = SpringApplication.run(AmqpApplication.class, args);

        MessageProducer producer = context.getBean(MessageProducer.class);
        producer.sendMessage("Test Message");

        // 优雅关闭应用程序，确保所有消息处理完毕
        context.registerShutdownHook();
    }
}

@Component
public class MessageProducer {

    @Autowired
    private AmqpTemplate amqpTemplate;

    public void sendMessage(String message) {
        try {
            amqpTemplate.convertAndSend("exchange", "routingKey", message);
        } catch (AmqpApplicationContextClosedException e) {
            System.err.println("Application context is closed. Cannot send message: " + e.getMessage());
        }
    }
}

在这个示例中，使用了context.registerShutdownHook()来优雅地关闭应用程序，确保所有消息处理完毕。此外，在发送消息时捕获了AmqpApplicationContextClosedException异常，并进行了相应处理。