Comandi Essenziali di RabbitMQ per la Gestione delle Code: Dichiarare, Elencare, Eliminare

La gestione delle code in RabbitMQ sembra semplice finché non la si esegue durante un incidente. Una coda ha un nome, un virtual host, argomenti, consumatori, binding, messaggi e talvolta policy sovrapposte. Eliminare la coda sbagliata o dichiararla con proprietà errate può rompere un'applicazione tanto rapidamente quanto un'interruzione del broker.

I comandi seguenti si concentrano sul lavoro quotidiano: dichiarare una coda quando è necessario preparare l'infrastruttura, elencare le code quando è necessario comprendere lo stato del broker, ed eliminare o svuotare le code quando si desidera intenzionalmente rimuovere qualcosa. Gli esempi utilizzano rabbitmqctl, ma la stessa cautela vale se si utilizza l'interfaccia di gestione o l'API HTTP.

---

Prerequisiti e lo Strumento rabbitmqctl

Per eseguire i comandi descritti in questo articolo, è necessario avere accesso alla riga di comando su una macchina dove sono installati gli strumenti di gestione di RabbitMQ, o dove rabbitmqctl può connettersi al cluster di destinazione. Di solito sono richiesti permessi per eseguire queste operazioni amministrative.

La sintassi generale per i comandi rabbitmqctl è:

rabbitmqctl <comando> [argomenti]

Tutti gli esempi seguenti presuppongono il virtual host predefinito (/). Se la coda si trova in un altro vhost, aggiungere -p <nome_vhost>. Questo è importante perché orders in /prod e orders in /staging sono code diverse.

1. Dichiarare Nuove Code (declare_queue)

La dichiarazione di una coda è il processo di creazione di una coda sul broker. Sebbene le code siano solitamente dichiarate dalle applicazioni client al momento della connessione, la dichiarazione amministrativa tramite rabbitmqctl è utile per la configurazione, i test o la definizione di code altamente specifiche prima che vengano stabilite le connessioni client.

Il comando declare_queue consente di definire proprietà essenziali della coda, come durabilità, esclusività ed eliminazione automatica.

Dichiarazione Base di una Coda

Il comando più semplice dichiara una coda con impostazioni predefinite. Nella sintassi corrente della CLI di RabbitMQ, le proprietà della coda vengono passate come coppie chiave-valore:

rabbitmqctl declare_queue name=my_new_queue durable=false

Definizione delle Proprietà della Coda

I parametri chiave vengono utilizzati per controllare la persistenza e il ciclo di vita della coda:

Parametro	Descrizione	Predefinito	Motivazione
durable	Se true, la definizione della coda persiste ai riavvii del broker.	false	Fondamentale per le code che devono sopravvivere a interruzioni di sistema.
exclusive	Se true, la coda può essere consumata solo dalla connessione dichiarante e viene eliminata quando tale connessione si chiude.	false	Utilizzato per risorse temporanee e private.
auto_delete	Se true, la coda viene eliminata quando l'ultimo consumatore si disconnette.	false	Utile per code effimere e di breve durata.

Esempio: Dichiarare una Coda Durevole

Una definizione di coda durevole sopravvive al riavvio del broker. La sopravvivenza dei messaggi dipende anche dalla modalità di consegna e dal comportamento di archiviazione, quindi non trattare una coda durevole come una garanzia che ogni messaggio sia persistente.

rabbitmqctl declare_queue name=production_durable_queue durable=true

Esempio: Dichiarare una Coda Temporanea con Eliminazione Automatica

rabbitmqctl declare_queue name=temp_worker_queue auto_delete=true

Suggerimento: Se la coda esiste già, declare_queue avrà successo solo se le proprietà specificate corrispondono a quelle della coda esistente. Se le proprietà differiscono, il comando fallirà, prevenendo una configurazione errata accidentale.

Questo fallimento è utile. Se un'applicazione si aspetta una coda di quorum durevole e un operatore dichiara accidentalmente una coda classica transitoria con lo stesso nome, RabbitMQ dovrebbe rifiutare la discrepanza invece di cambiare silenziosamente la semantica.

2. Elencare e Ispezionare le Code (list_queues)

Monitorare lo stato delle code è un'attività amministrativa frequente. Il comando list_queues è altamente flessibile e consente di specificare esattamente quali metriche si desidera vedere, evitando un sovraccarico di informazioni.

Elenco Base

Per impostazione predefinita, list_queues mostra colonne comuni come nome della coda, messaggi totali e consumatori. Per il lavoro operativo, è meglio richiedere le colonne esatte di cui si ha bisogno.

rabbitmqctl list_queues

Esempio di Output:

Timeout: 60.0 seconds...
Elenco delle code per vhost /
nome    messaggi    consumatori
my_new_queue	0	1
production_durable_queue	150	2

Elenco di Proprietà Specifiche della Coda

Per ottenere approfondimenti operativi più approfonditi, è possibile specificare un elenco separato da spazi di nomi di colonna. Questo è fondamentale per risolvere problemi di conteggi elevati di messaggi o utilizzo della memoria.

Colonne Essenziali per il Monitoraggio:

Nome Colonna	Descrizione
messages_ready	Messaggi disponibili per la consegna (pronti per essere consumati).
messages_unacknowledged	Messaggi consegnati ma non ancora riconosciuti da un consumatore.
consumers	Il numero di consumatori attivi collegati alla coda.
memory	Utilizzo stimato della memoria della coda sul nodo (in byte).
policy	Il nome di qualsiasi policy applicata alla coda.
state	Lo stato operativo della coda (ad esempio, running, flow, idle).
type	Tipo di coda, come classic o quorum, sulle versioni di RabbitMQ che lo espongono.

Esempio: Ispezione Dettagliata della Coda

Per controllare l'arretrato corrente, la salute dei consumatori e l'applicazione delle policy, utilizzare:

rabbitmqctl list_queues name messages_ready messages_unacknowledged consumers memory policy

Leggi i numeri insieme. Una coda con messages_ready alto e zero consumatori di solito significa che nessun consumatore è collegato. Una coda con pochi messaggi pronti ma messages_unacknowledged alto indica consumatori che hanno ricevuto messaggi ma non li stanno riconoscendo. Potrebbe trattarsi di lavoro lento, worker crashati, un prefetch count eccessivo o un bug che non chiama mai ack/nack.

Elenco delle Code su un Virtual Host Specifico

Se è necessario controllare le code al di fuori del virtual host predefinito, utilizzare il flag -p.

rabbitmqctl list_queues -p /api_vhost name messages consumers

3. Eliminare e Svuotare le Code (delete_queue e purge_queue)

Quando una coda è deprecata o deve essere resettata, hai due opzioni principali: eliminare l'intera struttura della coda o svuotarne il contenuto mantenendo la struttura intatta.

Eliminare una Coda (delete_queue)

Il comando delete_queue rimuove permanentemente la coda e tutti i messaggi attualmente memorizzati al suo interno. Questa azione è irreversibile.

rabbitmqctl delete_queue my_old_queue

Attenzione: Rischio di Perdita di Dati Assicurati sempre che la coda sia vuota o che il suo contenuto non sia più necessario prima dell'esecuzione. Eliminare una coda con messaggi in sospeso comporta una perdita di dati immediata e permanente per quei messaggi.

Svuotare il Contenuto della Coda (purge_queue)

Se la struttura della coda (binding, durabilità, policy) deve rimanere, ma è necessario cancellare tutti i messaggi (ad esempio, per cancellare un arretrato di lavori errati), utilizzare purge_queue.

rabbitmqctl purge_queue my_stuck_queue

Questo comando rimuove i messaggi pronti dalla coda senza eliminare la definizione della coda. I messaggi già consegnati ai consumatori e in attesa di riconoscimento non vengono semplicemente cancellati da uno svuotamento. Se quei consumatori si disconnettono o rifiutano i messaggi con il riaccodamento abilitato, alcuni messaggi possono riapparire. Durante una pulizia seria, ferma o drena prima i consumatori in modo da sapere cosa stai svuotando.

Gestione delle Code in VHost Diversi

Per assicurarti di eliminare o svuotare la coda corretta, specifica sempre il virtual host se la coda non è nel contesto predefinito.

# Eliminare una coda in un virtual host specifico
rabbitmqctl delete_queue -p /testing_vhost temp_test_queue

Prima di eliminare, di solito eseguo:

rabbitmqctl list_queues -p /testing_vhost name messages_ready messages_unacknowledged consumers

Questo singolo controllo cattura molti errori: vhost sbagliato, consumatori inaspettati o una coda che ha ancora lavoro in sospeso.

Riepilogo dei Comandi Essenziali

Questa tabella riassume i comandi principali di gestione delle code utilizzati nelle operazioni quotidiane di RabbitMQ:

Azione	Comando	Scopo
Dichiarazione	rabbitmqctl declare_queue name=Q durable=true	Crea una nuova coda con proprietà definite.
Ispezione	rabbitmqctl list_queues name messages consumers	Elenca le code e metriche operative specifiche.
Eliminazione	rabbitmqctl delete_queue Q	Rimuove permanentemente la coda e i suoi messaggi pronti.
Pulizia	rabbitmqctl purge_queue Q	Cancella i messaggi pronti da una coda mantenendo la struttura.

L'abitudine sicura è semplice: includi sempre il vhost quando c'è qualche dubbio, ispeziona prima dei comandi distruttivi e ricorda che la dichiarazione della coda fa parte del contratto della tua applicazione. Il tipo di coda, la durabilità, il comportamento di eliminazione automatica e gli argomenti dovrebbero essere trattati come uno schema, non come un dettaglio di runtime casuale.