java - 我怎样才能干净地关闭 Spring Rabbit 中的 RabbitTemplate？

Question

我编写了一个脚本，它使用 Spring Rabbit 将大量消息放入 Rabbit 队列中，使用 RabbitTemplate.convertAndSend ，然后退出。但是，即使在消息入队后，Rabbit 连接似乎仍能使应用程序保持 Activity 状态。我还没有找到一种方法来清楚地告诉 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 管理 beans，您可以在完成后close() 应用程序上下文。

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

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

您需要一个确认回调来确认 rabbit 收到了发送。