Est-il possible de consulter directement le contenu des messages RabbitMQ à partir de la ligne de commande?

Question

Est-il possible de voir le contenu des messages RabbitMQ directement depuis la ligne de commande?

sudo rabbitmqctl list_queues liste les files d'attente.

Y a-t-il une commande comme sudo rabbitmqctl list_queue_messages ?

Answer 1

Vous devriez activer le plugin de gestion.

rabbitmq-plugins enable rabbitmq_management

Voir ici:

http://www.rabbitmq.com/plugins.html

Et ici pour les détails de la gestion.

http://www.rabbitmq.com/management.html

Enfin, une fois configuré, vous devrez suivre les instructions ci-dessous pour installer et utiliser l'outil rabbitmqadmin. Qui peut être utilisé pour interagir pleinement avec le système. http://www.rabbitmq.com/management-cli.html

Par exemple:

rabbitmqadmin get queue= requeue=false

vous donnera le premier message de la file d'attente.

Answer 2

Voici les commandes que j'utilise pour obtenir le contenu de la file d'attente :

RabbitMQ version 3.1.5 sur Fedora Linux en utilisant https://www.rabbitmq.com/management-cli.html

Voici mes échanges :

eric@dev ~ $ sudo python rabbitmqadmin list exchanges
+-------+--------------------+---------+-------------+---------+----------+
| vhost |        name        |  type   | auto_delete | durable | internal |
+-------+--------------------+---------+-------------+---------+----------+
| /     |                    | direct  | False       | True    | False    |
| /     | kowalski           | topic   | False       | True    | False    |
+-------+--------------------+---------+-------------+---------+----------+

Voici ma file d'attente :

eric@dev ~ $ sudo python rabbitmqadmin list queues
+-------+----------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------------+--------+---------+
| vhost |   name   | auto_delete | consumers | durable | exclusive_consumer_tag |     idle_since      | memory | messages | messages_ready | messages_unacknowledged |        node         | policy | status  |
+-------+----------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------------+--------+---------+
| /     | myqueue  | False       | 0         | True    |                        | 2014-09-10 13:32:18 | 13760  | 0        | 0              | 0                       |rabbit@ip-11-1-52-125|        | running |
+-------+----------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------------+--------+---------+

Insérez quelques éléments dans ma file d'attente :

curl -i -u guest:guest http://localhost:15672/api/exchanges/%2f/kowalski/publish -d '{"properties":{},"routing_key":"abcxyz","payload":"foobar","payload_encoding":"string"}'
HTTP/1.1 200 OK
Server: MochiWeb/1.1 WebMachine/1.10.0 (never breaks eye contact)
Date: Wed, 10 Sep 2014 17:46:59 GMT
content-type: application/json
Content-Length: 15
Cache-Control: no-cache

{"routed":true}

RabbitMQ voit les messages dans la file d'attente :

eric@dev ~ $ sudo python rabbitmqadmin get queue=myqueue requeue=true count=10
+-------------+----------+---------------+---------------------------------------+---------------+------------------+------------+-------------+
| routing_key | exchange | message_count |                        payload        | payload_bytes | payload_encoding | properties | redelivered |
+-------------+----------+---------------+---------------------------------------+---------------+------------------+------------+-------------+
| abcxyz      | kowalski | 10            | foobar                                | 6             | string           |            | True        |
| abcxyz      | kowalski | 9             | {'testdata':'test'}                   | 19            | string           |            | True        |
| abcxyz      | kowalski | 8             | {'mykey':'myvalue'}                   | 19            | string           |            | True        |
| abcxyz      | kowalski | 7             | {'mykey':'myvalue'}                   | 19            | string           |            | True        |
+-------------+----------+---------------+---------------------------------------+---------------+------------------+------------+-------------+

Answer 3

J'ai écrit rabbitmq-dump-queue qui permet de mettre en file d'attente les messages d'une file d'attente RabbitMQ dans des fichiers locaux et de remettre en file les messages dans leur ordre d'origine.

Exemple d'utilisation (pour mettre en file les 50 premiers messages de la file d'attente incoming_1):

rabbitmq-dump-queue -url="amqp://user:password@rabbitmq.example.com:5672/" -queue=incoming_1 -max-messages=50 -output-dir=/tmp

Answer 4

Si vous souhaitez obtenir plusieurs messages d'une file d'attente, disons 10 messages, la commande à utiliser est:

rabbitmqadmin get queue= ackmode=ack_requeue_true count=10

Voici à quoi cela ressemble sur l'interface frontale disponible sur http://localhost:15672 :

Si vous ne souhaitez pas que les messages soient réenfilés, il vous suffit de changer ackmode en ack_requeue_false.

Answer 5

Vous pouvez utiliser l'API RabbitMQ pour obtenir le nombre de messages :

/api/queues/vhost/name/get

Obtenez des messages à partir d'une file d'attente. (Il ne s'agit pas d'un HTTP GET car cela modifiera l'état de la file d'attente.) Vous devriez poster un corps ressemblant à ceci :

{"count":5,"requeue":true,"encoding":"auto","truncate":50000}

count contrôle le nombre maximal de messages à obtenir. Vous pouvez obtenir moins de messages que cela si la file d'attente ne peut pas les fournir immédiatement.

requeue détermine si les messages seront supprimés de la file d'attente. Si requeue est true, ils seront réenfilés - mais leur indicateur redelivered sera défini. encoding doit être soit "auto" (auquel cas la charge utile sera retournée sous forme de chaîne si elle est valide en UTF-8, et encodée en base64 sinon), soit "base64" (auquel cas la charge utile sera toujours encodée en base64). Si truncate est présent, il tronquera la charge utile du message si elle est plus grande que la taille donnée (en octets). truncate est facultatif; toutes les autres clés sont obligatoires.

Veuillez noter que les chemins de publication / récupération dans l'API HTTP sont destinés à injecter des messages de test, des diagnostics, etc. - ils n'implémentent pas de livraison fiable et doivent donc être considérés comme un outil d'administrateur système plutôt que comme une API générale pour la messagerie.

http://hg.rabbitmq.com/rabbitmq-management/raw-file/rabbitmq_v3_1_3/priv/www/api/index.html