Exchange, очереди и маршрутизация, подтверждения, повторы — классический брокер.
Практика. Реализовать отложенные повторы обработки через очереди с TTL и dead letter exchange.
Издатель публикует в exchange, привязки (bindings) по routing key решают, в какие очереди попадут копии, потребители читают очереди и подтверждают.
Kafka — распределённый журнал: сообщения хранятся заданное время независимо от чтения, потребители сами двигают offset и могут перечитать. RabbitMQ — классический брокер очередей…
Очередь задач — RabbitMQ (или SQS): подтверждение каждого сообщения, повторы, DLX, приоритеты, отложенная доставка, медленная задача не блокирует остальные. Шина событий — Kafka…
Издатель публикует в exchange с routing key; exchange по bindings решает, в какие очереди положить копии. Потребители читают очереди.
Полученное сообщение SQS не удаляется, а становится невидимым на время visibility timeout. Если потребитель не удалил его за это время, оно снова видно и уйдёт другому — повтор.
Publisher confirms — брокер подтверждает издателю, что сообщение принято (а для persistent в durable-очереди — записано на диск). Без них о сохранности отправки судить нельзя.
Модель exchange/binding/queue, ack/nack и publisher confirms, prefetch, DLQ через DLX, отложенные сообщения, SQS Standard vs FIFO и visibility timeout.
На живом собеседовании sotto слышит вопрос интервьюера и показывает короткий ответ и план. Оставьте контакт — пришлём доступ и промокод.
sotto