正确关闭 RabbitMQ 通道和连接

Question

我目前正在运行一个基本的 RabbitMQ 主题发布，每 3 秒发布一次。

我的班级是这样的：

import com.rabbitmq.client.*;

import java.io.IOException;

public class EmitLogTopic {

    private static final String EXCHANGE_NAME = "topic_logs";

    @Scheduled(fixedRate = 3000)
    public void publish(String[] argv)
                  throws Exception {

        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        channel.exchangeDeclare(EXCHANGE_NAME, "topic");

        String routingKey = getRouting(argv);
        String message = getMessage(argv);

        channel.basicPublish(EXCHANGE_NAME, routingKey, null, message.getBytes());
        System.out.println(" [x] Sent '" + routingKey + "':'" + message + "'");

        channel.close();
        connection.close();
    }
    //...
}

我希望每次运行方法发布时，它都会发布，然后通道和连接都关闭，防止每 3 秒有一个新的通道和连接卡在内存中。

但是，当我查看我的 RabbitMQ 管理界面（在概览页面）时，全局计数部分显示连接总数和通道总数都在不断增加。

最终，由于达到了 Socket 限制和内存限制，我的应用程序崩溃了。

所以看起来 close() 并没有删除使用的通道和连接，并且仍然将它们保留在内存中，最终导致所有内存被消耗。在通道和连接上使用什么正确方法来确保他们不会这样做？

Answer 1

但是，当我查看我的 RabbitMQ 管理界面时（在概览 页），全局计数部分显示，两者的总数 连接和渠道不断增加。

我认为你的连接有问题。

检查您操作系统中的 TCP 连接，例如：

1. netstat -anp | grep :5672 | grep ESTABLISHED | wc -l

还可以使用命令行工具检查您的连接：

2. rabbitmqctl list_connections 如果您在1 和2 中有很多连接，则意味着您没有以正确的方式关闭连接/通道。

如果您需要处理大量连接，您可以增加文件描述符配置：

例如https://www.rabbitmq.com/install-debian.html

使用 systemd（最近的 Linux 发行版）

在使用 systemd 的发行版上，操作系统限制通过 配置文件在 /etc/systemd/system/rabbitmq-server.service.d/limits.conf，用于 示例：

[服务] LimitNOFILE=300000

编辑

您发布的代码很好，close() 方法是关闭连接的正确方法。

如果您执行代码，您应该在您的真实代码中进行调查。

如果有，还要检查日志内部：

=INFO REPORT==== 22-Aug-2017::09:23:28 ===
connection <0.383.0> ([::1]:60590 -> [::1]:5672): user 'guest' authenticated and granted access to vhost '/'

=INFO REPORT==== 22-Aug-2017::09:23:37 ===
closing AMQP connection <0.383.0> ([::1]:60590 -> [::1]:5672, vhost: '/', user: 'guest')

closing AMQP connection 是关闭连接