【Java】已解决：com.rabbitmq.client.ShutdownSignalException

屿小夏

发布于 2024-07-27 10:50:00

4900

发布于 2024-07-27 10:50:00

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

一、分析问题背景

com.rabbitmq.client.ShutdownSignalException 是在使用 RabbitMQ 进行消息传递时常见的异常。这通常发生在连接关闭或通道关闭的情况下，可能是由于网络问题、RabbitMQ 服务器重启或代码逻辑错误引起的。以下是一个可能的场景：

场景：在一个消息驱动的微服务架构中，服务 A 通过 RabbitMQ 向服务 B 发送消息。当服务 B 接收消息时，突然抛出了 ShutdownSignalException 异常，导致消息处理中断。

示例代码片段：

import com.rabbitmq.client.*;

public class MessageReceiver {
    
    private final static String QUEUE_NAME = "exampleQueue";

    public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println("Waiting for messages...");

        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println("Received: " + message);
        };
        channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
    }
}

在上述代码中，连接和通道的关闭可能会导致 ShutdownSignalException 异常。

二、可能出错的原因

导致 com.rabbitmq.client.ShutdownSignalException 报错的原因主要有以下几点：

网络问题：网络连接不稳定或断开，导致 RabbitMQ 连接中断。
RabbitMQ 服务器重启：服务器重启或崩溃，导致现有连接失效。
代码逻辑错误：错误地关闭连接或通道，或在连接未建立时尝试使用通道。
资源限制：RabbitMQ 服务器达到连接或通道的资源限制，导致关闭现有连接。

三、错误代码示例

以下是一个可能导致该报错的代码示例，并解释其错误之处：

import com.rabbitmq.client.*;

public class MessageReceiver {

    private final static String QUEUE_NAME = "exampleQueue";

    public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        
        // 在连接和通道关闭后尝试使用它们
        connection.close();
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        
        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println("Received: " + message);
        };
        channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
    }
}

错误分析：

错误关闭顺序：在声明队列之前关闭了连接，导致通道不可用。
资源管理不当：没有正确管理连接和通道的生命周期。

四、正确代码示例

为了正确解决该报错问题，我们需要确保在正确的时机关闭连接和通道，并且在使用通道时确保其处于打开状态。以下是正确的代码示例：

import com.rabbitmq.client.*;

public class MessageReceiver {

    private final static String QUEUE_NAME = "exampleQueue";

    public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println("Waiting for messages...");

            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String message = new String(delivery.getBody(), "UTF-8");
                System.out.println("Received: " + message);
            };
            channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { });
        } catch (ShutdownSignalException e) {
            System.err.println("Connection or channel was closed unexpectedly: " + e.getMessage());
        }
    }
}

通过使用 try-with-resources 语句，我们可以确保在代码块结束时正确关闭连接和通道。此外，我们还可以捕获 ShutdownSignalException 以处理异常情况。