Как обеспечить отказоустойчивость в RabbitMQ

Для обеспечения отказоустойчивости в RabbitMQ можно использовать несколько подходов:

1. Кластеризация - объединение нескольких нод RabbitMQ в кластер для репликации данных. Если одна нода падает, другие продолжают работать.

# Пример объявления очереди с durable=True
channel.queue_declare(queue='task_queue', durable=True)

2. Зеркалирование очередей - настройка политик для репликации очередей между нодами:

rabbitmqctl set_policy ha-all "^ha\." '{"ha-mode":"all"}'

3. Подтверждение обработки (acknowledgments) - гарантирует, что сообщение не потеряется, если worker упадет:

channel.basic_consume(queue='task_queue', 
                     on_message_callback=callback,
                     auto_ack=False)  # важно отключить auto_ack

4. Сохраняемые сообщения - маркировка сообщений как persistent:

properties=pika.BasicProperties(
    delivery_mode=2,  # делает сообщение persistent
)

5. Резервный брокер - настройка HAProxy для переключения на standby-сервер при падении основного.

Дополнительно стоит мониторить состояние очередей и настраивать алерты при достижении лимитов.