Close RabbitMQ channels and connections properly

Question

I am currently running a basic RabbitMQ topic publishing that publishes every 3 seconds.

My class looks like this:

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();
    }
    //...
}

I expect that every time when the method publish runs, it will publish and then the channel and connection both close, preventing a new channel and connection from stuck in the memory every 3 seconds.

However, when I look at my RabbitMQ admin interface (at the overview page), the Global Counts section shows that both the total number of connections and channels keep on increasing.

Eventually, my application crashes due to Socket limit and Memory limit being reached.

So it seems like close() doesn't delete the channel and connection used and still keep them in memory that eventually cause all the memory being consumed. What is proper method to use on the channel and connection to make sure that they don't do this?

Answer 1

However, when I look at my RabbitMQ admin interface (at the overview page), the Global Counts section shows that both the total number of connections and channels keep on increasing.

I think you have some problem with your connections.

Check your TCP connections in your OS, for example:

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

check also your connections using the command line tool:

2. rabbitmqctl list_connections if you have lot of connections in 1 and 2 means that you are not closing the connections/channels in the right way.

If you need to handle lot of connection you could increase the file descriptors configuration:

for example https://www.rabbitmq.com/install-debian.html

With systemd (Recent Linux Distributions)

On distributions that use systemd, the OS limits are controlled via a configuration file at /etc/systemd/system/rabbitmq-server.service.d/limits.conf, for example:

[Service] LimitNOFILE=300000

EDIT

The code you posted is fine, close() method is the right way to close the connection.

You should investigate in your real code if you execute the code.

Check also inside the log if there is:

=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 is the close connection