java - Spring Integration RabbitTemplate 默认情况下是否发布到持久队列？

Question

我有一个计划任务，它执行以下代码:

    try {
        rabbitTemplate.convertAndSend("TEST");
        if (!isOn()) {
            turnOn();
        }
    }
    catch (AmqpException e) {
        if (isOn()) {
            turnOff();
        }
    }

一切都很好。它将这条消息发送到默认的“AMQP default”交换。我的另一端没有消费者来消费这些消息，因为我只是确保服务器仍然存在。这些消息会随着时间的推移而累积并导致内存泄漏吗？

谢谢!K

Answer 1

你们有 RabbitMQ 用户界面吗？您应该能够看到正在创建的队列以及它们是否是持久的。上次我检查过，Spring AMQP 的默认行为是创建持久队列。

看看 RabbitMQ 管理插件:http://www.rabbitmq.com/management.html使用 RabbitMQ 管理插件，您还可以使用通过代码发布的消息。

关于消息发生的情况，它们只会堆积起来，直到 RabbitMQ 达到其极限，然后它将不再接受消息，直到您清除队列或消耗这些消息。使用默认的 RabbitMQ 设置，我能够在队列开始阻塞之前向队列发送大约 400 万条简单文本消息。