RabbitMQ 如何决定何时删除消息？

Question

我想了解RabbitMQ中消息删除的逻辑。

我的目标是即使没有连接到读取它们的客户端也使消息持久化，以便当客户端重新连接时消息正在等待它们。我可以使用持久的惰性队列，以便将消息持久化到磁盘，并且我可以使用 HA 复制来确保多个节点获得所有排队消息的副本。

我希望使用主题或标头路由将消息发送到两个或多个队列，并让一个或多个客户端读取每个队列。

我有两个队列，A 和 B，由标头交换提供。队列 A 获取所有消息。队列 B 仅获取带有“归档”标头的消息。队列 A 有 3 个消费者正在阅读。队列 B 有 1 个消费者。如果 B 的消费者死了，但是 A 的消费者继续确认消息，RabbitMQ 会删除这些消息还是继续存储它们？在重新启动 B 之前，队列 B 不会有任何人使用它，我希望消息保持可用以供以后使用。

到目前为止，我已经阅读了大量文档，但仍然没有找到明确的答案。

Answer 1

RabbitMQ 将在确认后决定何时删除消息。

假设您有一个消息发送者：

var factory = new ConnectionFactory() { HostName = "localhost", Port = 5672, UserName = "guest", Password = "guest" };
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare(queue: "hello",
                         durable: true,
                         exclusive: false,
                         autoDelete: false,
                         arguments: null);

    string message = "Hello World!";
    var body = Encoding.UTF8.GetBytes(message);

    channel.BasicPublish(exchange: "",
                         routingKey: "hello",
                         basicProperties: null,
                         body: body);
    Console.WriteLine(" [x] Sent {0}", message);
}

这将创建一个持久队列“hello”并发送消息“Hello World！” 到它。这就是向队列发送一条消息后队列的样子。

现在让我们设置两个消费者，一个确认收到消息，一个不确认。

channel.BasicConsume(queue: "hello",
                    autoAck: false,
                    consumer: consumer);

和

channel.BasicConsume(queue: "hello",
                    autoAck: true,
                    consumer: consumer);

如果你只运行第一个消费者，消息永远不会从队列中删除，因为消费者声明只有客户端手动确认消息才会从队列中消失：https : //www.rabbitmq.com/confirms。 html

然而，第二个消费者会告诉队列它可以安全地自动/立即删除它收到的所有消息。

如果您不想自动删除这些消息，则必须禁用 autoAck 并使用文档进行一些手动确认：

http://codingvision.net/tips-and-tricks/c-send-data-between-processes-w-memory-mapped-file（向下滚动到“手动确认”）。

channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);

Answer 2

简单的答案是，从一个队列消耗的消息对另一个队列中的消息没有影响。一旦您发布消息，代理就会将副本分发到适当数量的队列 - 但它们是消息的真实副本，并且从那时起就代理而言绝对无关。

排队到持久队列中的消息将一直保留，直到它们被队列上的使用者拉取，并可选择进行确认。

请注意，特定的队列级别和消息级别 TTL 设置可能会影响这一点。例如，如果队列有 TTL，并且消费者在过期之前没有重新连接，则队列将与其所有消息一起消失。类似地，如果消息已使用特定 TTL 入队（也可以将其设置为特定队列上所有消息的默认值），那么一旦该 TTL 通过，该消息将不会传递给使用者。

次要注意事项如果消息由于 TTL 而在队列中过期，则该消息实际上会保留在队列中，直到下次传送。