Wichtige RabbitMQ-Befehle für das Queue-Management: Deklarieren, Auflisten, Löschen

Das Queue-Management in RabbitMQ erscheint einfach, bis man es während eines Incidents durchführt. Eine Queue hat einen Namen, einen virtuellen Host, Argumente, Consumer, Bindungen, Nachrichten und manchmal zusätzlich Richtlinien (Policies). Das Löschen der falschen Queue oder das Deklarieren mit falschen Eigenschaften kann eine Anwendung genauso schnell beeinträchtigen wie ein Broker-Ausfall.

Die folgenden Befehle konzentrieren sich auf die tägliche Arbeit: Deklarieren einer Queue, wenn Sie die Infrastruktur vorbereiten müssen, Auflisten von Queues, wenn Sie den Broker-Status verstehen müssen, und Löschen oder Leeren von Queues, wenn Sie absichtlich etwas entfernen möchten. Die Beispiele verwenden rabbitmqctl, aber die gleiche Vorsicht gilt, wenn Sie die Management-UI oder die HTTP-API verwenden.

---

Voraussetzungen und das rabbitmqctl-Tool

Um die in diesem Artikel beschriebenen Befehle auszuführen, benötigen Sie Befehlszeilenzugriff auf einen Rechner, auf dem die RabbitMQ-Verwaltungstools installiert sind, oder auf dem rabbitmqctl eine Verbindung zum Zielcluster herstellen kann. Für diese administrativen Operationen sind in der Regel entsprechende Berechtigungen erforderlich.

Die allgemeine Syntax für rabbitmqctl-Befehle lautet:

rabbitmqctl <Befehl> [Argumente]

Alle folgenden Beispiele gehen vom Standard-Virtual-Host (/) aus. Befindet sich die Queue in einem anderen Vhost, fügen Sie -p <vhost_name> hinzu. Dies ist wichtig, da orders in /prod und orders in /staging unterschiedliche Queues sind.

1. Deklarieren neuer Queues (declare_queue)

Die Queue-Deklaration ist der Prozess zum Erstellen einer Queue auf dem Broker. Obwohl Queues normalerweise von Client-Anwendungen bei der Verbindungsaufnahme deklariert werden, ist die administrative Deklaration über rabbitmqctl nützlich für die Einrichtung, das Testen oder die Definition hochspezifischer Queues, bevor Client-Verbindungen hergestellt werden.

Der Befehl declare_queue ermöglicht es Ihnen, wesentliche Queue-Eigenschaften wie Haltbarkeit (Durability), Exklusivität und automatische Löschung zu definieren.

Grundlegende Queue-Deklaration

Der einfachste Befehl deklariert eine Queue mit Standardeinstellungen. In der aktuellen RabbitMQ-CLI-Syntax werden Queue-Eigenschaften als Schlüssel-Wert-Paare übergeben:

rabbitmqctl declare_queue name=my_new_queue durable=false

Definieren von Queue-Eigenschaften

Wichtige Parameter steuern die Persistenz und den Lebenszyklus der Queue:

Parameter	Beschreibung	Standard	Begründung
durable	Wenn true, überlebt die Queue-Definition einen Broker-Neustart.	false	Entscheidend für Queues, die Systemausfälle überstehen müssen.
exclusive	Wenn true, kann die Queue nur von der deklarierenden Verbindung konsumiert werden und wird gelöscht, wenn diese Verbindung geschlossen wird.	false	Wird für temporäre, private Ressourcen verwendet.
auto_delete	Wenn true, wird die Queue gelöscht, wenn der letzte Consumer die Verbindung trennt.	false	Nützlich für kurzlebige, ephemere Queues.

Beispiel: Deklarieren einer dauerhaften Queue

Eine dauerhafte Queue-Definition überlebt einen Broker-Neustart. Das Überleben von Nachrichten hängt auch vom Nachrichten-Übermittlungsmodus und dem Speicherverhalten ab. Behandeln Sie eine dauerhafte Queue daher nicht als Garantie dafür, dass jede Nachricht persistent ist.

rabbitmqctl declare_queue name=production_durable_queue durable=true

Beispiel: Deklarieren einer temporären, automatisch löschenden Queue

rabbitmqctl declare_queue name=temp_worker_queue auto_delete=true

Tipp: Wenn die Queue bereits existiert, wird declare_queue nur dann erfolgreich sein, wenn die angegebenen Eigenschaften mit den Eigenschaften der vorhandenen Queue übereinstimmen. Unterscheiden sich die Eigenschaften, schlägt der Befehl fehl und verhindert so eine versehentliche Fehlkonfiguration.

Dieser Fehler ist nützlich. Wenn eine Anwendung eine dauerhafte Quorum-Queue erwartet und ein Operator versehentlich eine flüchtige klassische Queue mit demselben Namen deklariert, sollte RabbitMQ die Nichtübereinstimmung zurückweisen, anstatt stillschweigend die Semantik zu ändern.

2. Auflisten und Inspizieren von Queues (list_queues)

Die Überwachung des Status von Queues ist eine häufige administrative Aufgabe. Der Befehl list_queues ist sehr flexibel und ermöglicht es Ihnen, genau die Metriken anzugeben, die Sie sehen müssen, um eine Informationsüberflutung zu vermeiden.

Grundlegende Auflistung

Standardmäßig zeigt list_queues gängige Spalten wie Queue-Name, Gesamtnachrichten und Consumer an. Für den Betrieb ist es besser, die genauen benötigten Spalten anzufordern.

rabbitmqctl list_queues

Beispielausgabe:

Timeout: 60.0 Sekunden...
Auflisten von Queues für Vhost /
name    messages    consumers
my_new_queue	0	1
production_durable_queue	150	2

Auflisten spezifischer Queue-Eigenschaften

Um tiefere betriebliche Einblicke zu gewinnen, können Sie eine durch Leerzeichen getrennte Liste von Spaltennamen angeben. Dies ist entscheidend für die Fehlerbehebung bei hohen Nachrichtenzahlen oder Speichernutzung.

Wesentliche Spalten für das Monitoring:

Spaltenname	Beschreibung
messages_ready	Nachrichten, die zur Zustellung bereit sind (bereit zum Konsumieren).
messages_unacknowledged	Nachrichten, die zugestellt, aber noch nicht von einem Consumer bestätigt wurden.
consumers	Die Anzahl der aktiven Consumer, die an der Queue angeschlossen sind.
memory	Geschätzte Speichernutzung der Queue auf dem Knoten (in Bytes).
policy	Der Name einer auf die Queue angewendeten Richtlinie (Policy).
state	Der Betriebszustand der Queue (z. B. running, flow, idle).
type	Queue-Typ, z. B. classic oder quorum, auf RabbitMQ-Versionen, die ihn anzeigen.

Beispiel: Detaillierte Queue-Inspektion

Um den aktuellen Rückstand, die Consumer-Gesundheit und die Richtlinienanwendung zu überprüfen, verwenden Sie:

rabbitmqctl list_queues name messages_ready messages_unacknowledged consumers memory policy

Lesen Sie die Zahlen zusammen. Eine Queue mit hohem messages_ready und null Consumern bedeutet normalerweise, dass kein Consumer angeschlossen ist. Eine Queue mit wenigen bereiten Nachrichten, aber hohem messages_unacknowledged, deutet auf Consumer hin, die Nachrichten erhalten, aber nicht bestätigen. Das könnte an langsamer Arbeit, abgestürzten Workern, einer zu großen Prefetch-Anzahl oder einem Bug liegen, der nie ack/nack aufruft.

Auflisten von Queues auf einem bestimmten virtuellen Host

Wenn Sie Queues außerhalb des Standard-Virtual-Hosts überprüfen müssen, verwenden Sie das Flag -p.

rabbitmqctl list_queues -p /api_vhost name messages consumers

3. Löschen und Leeren von Queues (delete_queue und purge_queue)

Wenn eine Queue veraltet ist oder zurückgesetzt werden muss, haben Sie zwei Hauptoptionen: Löschen der gesamten Queue-Struktur oder Leeren ihres Inhalts unter Beibehaltung der Struktur.

Löschen einer Queue (delete_queue)

Der Befehl delete_queue entfernt die Queue und alle darin gespeicherten Nachrichten dauerhaft. Diese Aktion ist irreversibel.

rabbitmqctl delete_queue my_old_queue

Warnung: Datenverlustrisiko Stellen Sie vor der Ausführung immer sicher, dass die Queue leer ist oder ihr Inhalt nicht mehr benötigt wird. Das Löschen einer Queue mit ausstehenden Nachrichten führt zu sofortigem, dauerhaftem Datenverlust für diese Nachrichten.

Leeren des Queue-Inhalts (purge_queue)

Wenn die Queue-Struktur (Bindungen, Haltbarkeit, Richtlinien) erhalten bleiben muss, aber Sie alle Nachrichten löschen möchten (z. B. um einen Rückstand fehlerhafter Jobs zu beseitigen), verwenden Sie purge_queue.

rabbitmqctl purge_queue my_stuck_queue

Dieser Befehl entfernt bereite Nachrichten aus der Queue, ohne die Queue-Definition zu löschen. Nachrichten, die bereits an Consumer zugestellt wurden und auf eine Bestätigung warten, werden durch ein Purge nicht einfach gelöscht. Wenn diese Consumer die Verbindung trennen oder Nachrichten mit aktiviertem Requeue ablehnen, können einige Nachrichten wieder auftauchen. Stoppen oder entladen Sie während einer ernsthaften Bereinigung zuerst die Consumer, damit Sie wissen, was Sie leeren.

Umgang mit Queues in verschiedenen VHosts

Um sicherzustellen, dass Sie die richtige Queue löschen oder leeren, geben Sie immer den virtuellen Host an, wenn sich die Queue nicht im Standardkontext befindet.

# Löschen einer Queue in einem bestimmten virtuellen Host
rabbitmqctl delete_queue -p /testing_vhost temp_test_queue

Vor dem Löschen führe ich normalerweise Folgendes aus:

rabbitmqctl list_queues -p /testing_vhost name messages_ready messages_unacknowledged consumers

Diese eine Überprüfung fängt viele Fehler ab: falscher Vhost, unerwartete Consumer oder eine Queue, die noch in Bearbeitung befindliche Nachrichten hat.

Zusammenfassung der wesentlichen Befehle

Diese Tabelle fasst die wichtigsten Queue-Management-Befehle zusammen, die im täglichen RabbitMQ-Betrieb verwendet werden:

Aktion	Befehl	Zweck
Deklaration	rabbitmqctl declare_queue name=Q durable=true	Erstellt eine neue Queue mit definierten Eigenschaften.
Inspektion	rabbitmqctl list_queues name messages consumers	Listet Queues und spezifische Betriebsmetriken auf.
Löschung	rabbitmqctl delete_queue Q	Entfernt die Queue und ihre bereiten Nachrichten dauerhaft.
Bereinigung	rabbitmqctl purge_queue Q	Löscht bereite Nachrichten aus einer Queue, während die Struktur erhalten bleibt.

Die sichere Gewohnheit ist einfach: Geben Sie bei Zweifeln immer den Vhost an, überprüfen Sie vor destruktiven Befehlen, und denken Sie daran, dass die Queue-Deklaration Teil Ihres Anwendungsvertrags ist. Queue-Typ, Haltbarkeit, Auto-Delete-Verhalten und Argumente sollten wie ein Schema behandelt werden, nicht wie ein beiläufiges Laufzeitdetail.