Как сделать exponential backoff в rabbitmq?

Question

[raiboon]

Не могу найти в апи, как сделать отложенный retry.

Вот получил сообщение, обработать его не получилось, делаю nack и то же сообщения сразу поступает снова.

Но это ж хреновое поведение по-умолчанию. Должен же быть способ настроить таймауты.

Answer 1

[Иван Шумов]

Казалось бы при чем тут rabbimq? Он пассивный и сам ни к кому не обращается. Ему неоткуда иметь exponential back-off или retry. Это FIFO queue с фичами. Сообщение должно или быть успешно обработанным или быть признано не обработанным, но в любом случае быть или убрано из очереди или оставаться там до обработки

Comments

[raiboon]

Кафки/sqsы позволяют при ошибке отложить момент, когда сообщение снова станет доступным для обработки.

Либо я не умею гуглить, либо rabbit - самая ограниченная из попадавшихся мне очередей.

[Иван Шумов]

raiboon,

Кафки/sqsы позволяют при ошибке отложить момент, когда сообщение снова станет доступным для обработки.

это не совсем так. Kafka и SQS FIFO используют Head of Blocking операции и вообще останавливают топик/очередь на fetch. Есдинственный кто так умеет - SQS Standard queue, но это сделано с определенными оговорками, а также семантикой at least one delivery. Есть случаи когда в таком раскладе сообщение присылается и 2 и 3 раза. Разбирайся потом с консистентностью. И работает это только по-тому что это stateless distributed queue.

Советую разобраться в предметной области получше. И вообще, если возникла такая проблема в проекте то чтоит задуматься "что мы делаем не так"

[raiboon]

Иван Шумов, можете пояснить про "не так"?
Что может быть естественен, чем не долбиться в упавшее апи, а сделать отложенный ретрай, пока оно не восстановится?

Это основа основ распределенных систем, если вы не хотите, чтобы в один прекрасный момент все сложилось, как карточный домик.

[Иван Шумов]

raiboon, не так в понимании как работают эти системы. Они сами никуда ничего не отправляют. они 100% пассивны. К брокеру обращается. consumer на получение сообщений и это ответственность consumer'а в имплементации логики обработки. Если нужно делать ретраи по тому что куда-то не получается досылать - делаем самостоятельно

Answer 2

[Сергей]

Если очень надо, чтобы "таймауты" делал RabbitMQ, то в ограниченной форме на помощь может придти расширение DLX, но нужны ещё дополнительные очереди для отстойников. RabbitMQ это универсальная очередь, он не может решать микро-требования для каждого варианта использования.