为什么我的 RabbitMQ 通道不断关闭？

Question

我正在调试一些使用 Apache POI 从 Microsoft Office 文档中提取数据的 Java 代码。有时，它会遇到大文档，POI 会在内存不足时崩溃。此时，它会尝试将错误发布到 RabbitMQ，以便其他组件知道此步骤失败并采取适当的操作。但是，当它尝试发布到队列时，它会收到 com.rabbitmq.client.AlreadyClosedException（干净连接关闭；原因：尝试使用关闭通道）。

这是错误处理程序代码：

try {
    //Extraction and indexing code
}
catch(Throwable t) {
    // Something went wrong! We'll publish the error and then move on with
    // our lives
    System.out.println("Error received when indexing message: ");
    t.printStackTrace();
    System.out.println();
    String error = PrintExc.format(t);
    message.put("error", error);

    if(mime == null) {
        mime = "application/vnd.unknown";
    }

    message.put("mime", mime);
    publish("IndexFailure", "", MessageProperties.PERSISTENT_BASIC, message);
}

为了完整起见，这里是发布方法：

private void publish(String exch, String route, 
    AMQP.BasicProperties props, Map<String, Object> message) throws Exception{
    chan.basicPublish(exch, route, props, 
        JSONValue.toJSONString(message).getBytes());  
}

我在 try 块中找不到任何关闭 RabbitMQ 通道的代码。是否存在可以隐式关闭通道的情况？

编辑：我应该注意到 AlreadyClosedException 是由发布内的 basicPublish 调用引发的。

Answer 1

对于那些想知道为什么他们的消费通道关闭的人，请检查您是否多次尝试确认或拒绝交付。

在rabbitmq日志中你会看到如下消息：

操作basic.ack导致通道异常precondition_failed：
未知的交货标签...

Answer 2

我也遇到了这个问题。我的情况的原因是，首先我使用 Durable = false 构建了队列，并且在日志文件中，当我将 Durable 切换为 true 时，我收到了此错误消息：

“虚拟主机“/”中队列“logsQueue”的不等价参数“durable”：
收到“真”，但当前为“假””

然后，我更改了队列的名称，它对我有用。我假设 RabbitMQ 服务器将构建队列的记录保存在某处，并且它无法将状态从持久更改为非-durable，反之亦然。

我再次为新队列设置了durable=false，这次我得到了这个错误。

“虚拟主机“/”中队列“logsQueue1”的不等价参数“持久”：
收到“假”，但当前为“真””

我的假设是正确的。当我通过以下方式列出rabbitMQ服务器中的队列时：

rabbitmqctl list_queues 

我在服务器中看到了两个队列。

总而言之，有两种解决方案：
1.重命名队列的名称这不是一个好的解决方案
2.通过以下方式重置rabbitMQ：

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

Answer 3

AMQP 通道因通道错误而关闭。可能导致通道错误的两种常见情况：

• 尝试将消息发布到不存在的交换器
• 尝试发布带有立即标志集的消息，但该消息没有带有活动消费者集的队列

我会研究设置在您尝试使用的通道上启动 ShutdownListener 使用 addShutdownListener() 捕获关闭事件并查看导致的原因 它。

Answer 4

就我而言，另一个原因是我错误地确认了一条消息两次。这会导致第二次确认后日志中出现这样的 RabbitMQ 错误。

=ERROR REPORT==== 11-Dec-2012::09:48:29 ===
connection <0.6792.0>, channel 1 - error:
{amqp_error,precondition_failed,"unknown delivery tag 1",'basic.ack'}

在我删除重复的确认后，错误消失了，通道不再关闭，并且 AlreadyClosedException 也消失了。

Answer 5

我想为将搜索此主题的其他用户添加此信息

接收通道关闭异常的另一个可能原因是当发布者和消费者使用不同的队列声明/设置从 RabbitMQ 站点访问通道

队列

channel.queueDeclare("task_queue", durable, false, false, null);

/

channel.queueDeclare("task_queue", false, false, false, null);

时

RabbitMQ doesn't allow you to redefine an existing queue with different parameters and will return an error to any program that tries to do that

Answer 6

显然，AMQP 连接和/或通道突然关闭的原因有很多。就我而言，队列中有太多未确认的消息，因为消费者没有指定 prefetch_count< /a> 因此连接每约 1 分钟就会终止一次。通过将消费者的预取计数设置为非零值来限制未确认消息的数量解决了该问题。

channel.basicQos(100);