如何在 Spring Rabbit 中干净地关闭 RabbitTemplate？

Question

我编写了一个脚本，它使用 Spring Rabbit 将一些消息放在使用 RabbitTemplate.convertAndSend 的 Rabbit 队列中，然后退出。但是，即使在消息已入队后，Rabbit 连接似乎仍使应用程序保持活动状态。我还没有找到一种方法来干净地告诉 Rabbit 服务器在消息入队后停止。

我能想到的最佳解决方案是将我的 convertAndSend 调用更改为 convertSendAndReceive，以便我知道消息已成功入队，然后使用 System.exit(0) 退出。我切换到 convertSendAndReceive，因为它似乎 convertAndSend 发生在后台线程或类似的线程中，因为如果我在执行多次这些调用后执行 System.exit(0)，那么只有前这么多会成功。

请注意，仅创建 RabbitTemplate 不会导致此行为；通过“发送”方法之一使用它。

以下代码说明了这个问题。

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;

import static issues.RabbitSettings.*; //Static fields containing my test Rabbit connection info

public class RabbitTemplateShutdownIssue {
    public static void main(String[] args) {
        RabbitTemplate rabbitTemplate = createRabbitTemplate();
        rabbitTemplate.convertAndSend(ROUTING_KEY, "Test"); // Or convertSendAndReceive
        // The app never exits
    }

    private static RabbitTemplate createRabbitTemplate() {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(getConnectionFactory());
        rabbitTemplate.setExchange(EXCHANGE);
        rabbitTemplate.setMandatory(true);
        return rabbitTemplate;
    }

    private static ConnectionFactory getConnectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(HOSTNAME);
        connectionFactory.setPublisherConfirms(true);
        connectionFactory.setVirtualHost(VIRTUAL_HOST);
        connectionFactory.setUsername(USERNAME);
        connectionFactory.setPassword(PASSWORD);
        return connectionFactory;
    }
}

有没有办法告诉 Rabbit 客户端关闭，最好是在所有消息都入队之后？

Answer 1

如果让 Spring 管理 bean，则完成后可以close() 应用程序上下文。

您现在配置它的方式（没有 Spring 上下文），您可以在连接工厂上调用 destroy()，一切都会关闭。

对这样的事情使用静态方法是一种反模式；您需要将工厂存储在静态字段中，以便您可以销毁模板正在使用的工厂。

你需要一个确认回调来确认兔子收到了发送。