Основные команды RabbitMQ для управления очередями: объявление, список, удаление

Управление очередями в RabbitMQ выглядит просто, пока вы не делаете это во время инцидента. У очереди есть имя, виртуальный хост, аргументы, потребители, привязки, сообщения, а иногда и политики, наложенные сверху. Удаление неправильной очереди или объявление её с неправильными свойствами может сломать приложение так же быстро, как и отключение брокера.

Приведенные ниже команды сосредоточены на повседневной работе: объявить очередь, когда нужно подготовить инфраструктуру, вывести список очередей, когда нужно понять состояние брокера, и удалить или очистить очереди, когда вы намеренно хотите что-то убрать. В примерах используется rabbitmqctl, но та же осторожность применяется, если вы используете веб-интерфейс управления или HTTP API.

---

Предварительные требования и инструмент rabbitmqctl

Для выполнения команд, описанных в этой статье, у вас должен быть доступ к командной строке на машине, где установлены инструменты управления RabbitMQ, или где rabbitmqctl может подключиться к целевому кластеру. Для выполнения этих административных операций обычно требуются соответствующие разрешения.

Общий синтаксис команд rabbitmqctl:

rabbitmqctl <команда> [аргументы]

Все приведенные ниже примеры предполагают виртуальный хост по умолчанию (/). Если очередь находится в другом vhost, добавьте -p <имя_vhost>. Это важно, потому что orders в /prod и orders в /staging — это разные очереди.

1. Объявление новых очередей (declare_queue)

Объявление очереди — это процесс создания очереди на брокере. Хотя очереди обычно объявляются клиентскими приложениями при подключении, административное объявление через rabbitmqctl полезно для настройки, тестирования или определения узкоспециализированных очередей до установления клиентских подключений.

Команда declare_queue позволяет определить основные свойства очереди, такие как долговечность, эксклюзивность и автоудаление.

Базовое объявление очереди

Самая простая команда объявляет очередь с настройками по умолчанию. В текущем синтаксисе CLI RabbitMQ свойства очереди передаются в виде пар ключ-значение:

rabbitmqctl declare_queue name=my_new_queue durable=false

Определение свойств очереди

Ключевые параметры используются для управления сохранностью и жизненным циклом очереди:

Параметр	Описание	По умолчанию	Обоснование
durable	Если true, определение очереди сохраняется после перезапуска брокера.	false	Критически важно для очередей, которые должны переживать сбои системы.
exclusive	Если true, очередь может потребляться только объявившим подключением и удаляется при закрытии этого подключения.	false	Используется для временных, частных ресурсов.
auto_delete	Если true, очередь удаляется, когда последний потребитель отключается.	false	Полезно для недолговечных, эфемерных очередей.

Пример: Объявление долговечной очереди

Определение долговечной очереди сохраняется после перезапуска брокера. Сохранность сообщений также зависит от режима доставки сообщений и поведения хранилища, поэтому не рассматривайте долговечную очередь как гарантию того, что каждое сообщение является постоянным.

rabbitmqctl declare_queue name=production_durable_queue durable=true

Пример: Объявление временной очереди с автоудалением

rabbitmqctl declare_queue name=temp_worker_queue auto_delete=true

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

Эта ошибка полезна. Если приложение ожидает долговечную очередь кворума, а оператор случайно объявляет временную классическую очередь с тем же именем, RabbitMQ должен отклонить несоответствие вместо того, чтобы молча изменить семантику.

2. Вывод списка и проверка очередей (list_queues)

Мониторинг состояния очередей — частая административная задача. Команда list_queues очень гибкая, позволяя указать именно те метрики, которые вам нужны, избегая информационной перегрузки.

Базовый вывод списка

По умолчанию list_queues показывает общие столбцы, такие как имя очереди, общее количество сообщений и потребители. Для операционной работы лучше запрашивать именно те столбцы, которые вам нужны.

rabbitmqctl list_queues

Пример вывода:

Timeout: 60.0 seconds...
Listing queues for vhost /
name    messages    consumers
my_new_queue	0	1
production_durable_queue	150	2

Вывод списка определенных свойств очереди

Для получения более глубокой операционной информации вы можете указать разделенный пробелами список имен столбцов. Это крайне важно для устранения неполадок с большим количеством сообщений или использованием памяти.

Основные столбцы для мониторинга:

Имя столбца	Описание
messages_ready	Сообщения, готовые к доставке (готовы к потреблению).
messages_unacknowledged	Сообщения, доставленные, но еще не подтвержденные потребителем.
consumers	Количество активных потребителей, подключенных к очереди.
memory	Примерное использование памяти очередью на узле (в байтах).
policy	Имя любой политики, примененной к очереди.
state	Рабочее состояние очереди (например, running, flow, idle).
type	Тип очереди, например, классическая или кворумная, в версиях RabbitMQ, которые его отображают.

Пример: Детальная проверка очереди

Чтобы проверить текущий бэклог, состояние потребителей и применение политики, используйте:

rabbitmqctl list_queues name messages_ready messages_unacknowledged consumers memory policy

Читайте цифры вместе. Очередь с высоким messages_ready и нулевым количеством потребителей обычно означает, что потребитель не подключен. Очередь с низким количеством готовых сообщений, но высоким messages_unacknowledged указывает на потребителей, которые получили сообщения, но не подтверждают их. Это может быть медленная работа, упавшие воркеры, слишком большой предварительный выбор (prefetch count) или ошибка, из-за которой никогда не вызывается ack/nack.

Вывод списка очередей в определенном виртуальном хосте

Если вам нужно проверить очереди за пределами виртуального хоста по умолчанию, используйте флаг -p.

rabbitmqctl list_queues -p /api_vhost name messages consumers

3. Удаление и очистка очередей (delete_queue и purge_queue)

Когда очередь устарела или ее нужно сбросить, у вас есть два основных варианта: удаление всей структуры очереди или очистка ее содержимого с сохранением структуры.

Удаление очереди (delete_queue)

Команда delete_queue навсегда удаляет очередь и все сообщения, хранящиеся в ней в данный момент. Это действие необратимо.

rabbitmqctl delete_queue my_old_queue

Предупреждение: Риск потери данных Всегда проверяйте, что очередь пуста или что ее содержимое больше не нужно, перед выполнением. Удаление очереди с ожидающими сообщениями приводит к немедленной и безвозвратной потере этих сообщений.

Очистка содержимого очереди (purge_queue)

Если структура очереди (привязки, долговечность, политики) должна остаться, но вам нужно очистить все сообщения (например, чтобы очистить бэклог ошибочных заданий), используйте purge_queue.

rabbitmqctl purge_queue my_stuck_queue

Эта команда удаляет готовые сообщения из очереди, не удаляя определение очереди. Сообщения, уже доставленные потребителям и ожидающие подтверждения, не просто стираются очисткой. Если эти потребители отключатся или отклонят сообщения с включенным повторным помещением в очередь, некоторые сообщения могут появиться снова. Во время серьезной очистки сначала остановите или отключите потребителей, чтобы знать, что вы очищаете.

Обработка очередей в разных VHost

Чтобы убедиться, что вы удаляете или очищаете правильную очередь, всегда указывайте виртуальный хост, если очередь не находится в контексте по умолчанию.

# Удаление очереди в определенном виртуальном хосте
rabbitmqctl delete_queue -p /testing_vhost temp_test_queue

Перед удалением я обычно запускаю:

rabbitmqctl list_queues -p /testing_vhost name messages_ready messages_unacknowledged consumers

Эта одна проверка выявляет многие ошибки: неправильный vhost, неожиданные потребители или очередь, в которой все еще есть работа в процессе.

Сводка основных команд

В этой таблице приведены основные команды управления очередями, используемые в повседневных операциях RabbitMQ:

Действие	Команда	Назначение
Объявление	rabbitmqctl declare_queue name=Q durable=true	Создает новую очередь с заданными свойствами.
Проверка	rabbitmqctl list_queues name messages consumers	Выводит список очередей и определенные операционные метрики.
Удаление	rabbitmqctl delete_queue Q	Навсегда удаляет очередь и ее готовые сообщения.
Очистка	rabbitmqctl purge_queue Q	Очищает готовые сообщения из очереди, сохраняя структуру.

Безопасная привычка проста: всегда указывайте vhost, если есть сомнения, проверяйте перед разрушительными командами и помните, что объявление очереди — это часть контракта вашего приложения. Тип очереди, долговечность, поведение автоудаления и аргументы следует рассматривать как схему, а не как случайную деталь времени выполнения.