RabbitMQ 消息在没有订阅者的情况下还能存活多久？

Question

我正在使用 MassTransit 和 RabbitMQ 创建一个简单的发布者/订阅者。发布者有以下代码来初始化总线：

/** create the bus */
var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    var host = cfg.Host(new Uri("rabbitmq://localhost/"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });
});

/** start the bus and publish */
bus.Start();
bus.Publish<IPersonLogin>(new {FirstName = "John", LastName = "Smith"});

订阅者有这个初始化代码：

var bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    var host = cfg.Host(new Uri("rabbitmq://localhost/"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });

    cfg.ReceiveEndpoint(host, "person_login", e =>
    {
        e.Consumer<PersonLoginConsumer>();
    });
});

如果我关闭订阅者并发布 2 条消息，则消息不会丢失，一旦订阅者恢复生机，消息就会得到处理。

所以我的问题是：

1. 我如何确保消息保留在 RabbitMQ 的队列中，直到一个订阅者出现并拿起它？
2. 如果服务器重新启动并且某些消息没有被任何订阅者处理，它们会丢失还是在订阅者重新启动后立即被处理？
3. 这是确保处理每条消息的正确模式还是我应该使用不同的策略？

Answer 1

默认情况下，队列中的任何消息都将保留在那里，直到发生以下三种情况之一：

1. 消息被消费
2. 消息“生存时间”到期（默认为永远生存）
3. 服务器崩溃或重新启动

如果您有一个装满消息的队列，这些消息通常会一直存在，直到这三件事之一发生。希望您能让您的消费者尽快上线，以便您可以使用消息并处理它们。

如果您希望消息在一段时间后自动删除（假设它们没有先被消耗），则只能设置生存时间（ttl）

对于崩溃...如果您使消息持久保存到磁盘，则消息可以在崩溃/重新启动后继续存在。但是，如果在消息从交换器路由到队列之前服务器崩溃，消息仍有可能丢失。