Как гарантировать доставку сообщения в RabbitMQ, если сервис-потребитель упал?

RabbitMQ позволяет построить надёжную систему доставки сообщений даже при сбоях:

1. Настройка очереди:

• Очередь должна быть durable — сохраняется при перезапуске брокера

• Сообщения должны быть persistent:

  var properties = channel.CreateBasicProperties();
  properties.Persistent = true;

2. Управление подтверждениями:

• Не использовать autoAck = true

• После обработки сообщения вручную отправить BasicAck

  channel.BasicAck(deliveryTag, false);

3. Поведение при сбое:

• Если потребитель упал до вызова BasicAck, сообщение остаётся в очереди и будет передано другому потребителю

4. Dead-letter:

• Настройка DLX (Dead Letter Exchange) помогает отследить сообщения, которые не удаётся доставить

Резюме:

Это поведение соответствует стратегии at-least-once, т.е. сообщение точно будет обработано, но возможны повторы.