是否可以直接从命令行查看RabbitMQ消息内容?
sudo rabbitmqctl list_queues
列出了队列。
有没有像sudo rabbitmqctl list_queue_messages queue_name
这样的命令命令?
您应该启用管理插件。
rabbitmq-plugins enable rabbitmq_management
看这里:
http://www.rabbitmq.com/plugins.html
这里是管理的具体细节。
http://www.rabbitmq.com/management.html
最后设置完成后,您需要按照以下说明安装和使用rabbitmqadmin工具。这可以用来与系统完全交互。 http://www.rabbitmq.com/management-cli.html
例如:
rabbitmqadmin get queue=<QueueName> requeue=false
将为您提供队列中的第一条消息。
以下是我用来获取队列内容的命令:
使用https://www.rabbitmq.com/management-cli.html在Fedora linux上使用RabbitMQ 3.1.5版
这是我的交流:
eric@dev ~ $ sudo python rabbitmqadmin list exchanges
+-------+--------------------+---------+-------------+---------+----------+
| vhost | name | type | auto_delete | durable | internal |
+-------+--------------------+---------+-------------+---------+----------+
| / | | direct | False | True | False |
| / | kowalski | topic | False | True | False |
+-------+--------------------+---------+-------------+---------+----------+
这是我的队列:
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 |
+-------+----------+-------------+-----------+---------+------------------------+---------------------+--------+----------+----------------+-------------------------+---------------------+--------+---------+
将一些物品塞进myqueue:
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查看队列中的消息:
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 |
+-------------+----------+---------------+---------------------------------------+---------------+------------------+------------+-------------+
我编写了rabbitmq-dump-queue,它允许将来自RabbitMQ队列的消息转储到本地文件,并按原始顺序重新排列消息。
示例用法(转储队列incoming_1
的前50条消息):
rabbitmq-dump-queue -url="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=50 -output-dir=/tmp
您可以使用RabbitMQ API来获取计数或消息:
/api/queues/vhost/name/get
从队列中获取消息。 (这不是HTTP GET,因为它会改变队列的状态。)你应该发布一个看起来像的身体:
{"count":5,"requeue":true,"encoding":"auto","truncate":50000}
count控制要获取的最大消息数。如果队列无法立即提供,则可能会收到比此更少的消息。
requeue确定是否将从队列中删除消息。如果requeue为true,它们将被重新排队 - 但是它们的redelivered标志将被设置。 encoding必须是“auto”(在这种情况下,如果有效负载将是有效的UTF-8,则返回为字符串,否则为base64编码)或“base64”(在这种情况下,有效负载将始终为base64编码)。如果存在truncate,它将截断消息有效负载,如果它大于给定的大小(以字节为单位)。 truncate是可选的;所有其他密钥是强制性的。
请注意,HTTP API中的发布/获取路径用于注入测试消息,诊断等 - 它们不实现可靠的传递,因此应被视为sysadmin的工具,而不是用于消息传递的通用API。
http://hg.rabbitmq.com/rabbitmq-management/raw-file/rabbitmq_v3_1_3/priv/www/api/index.html
有点晚了,但是是的,rabbitmq有一个内置的跟踪器,可以让你在日志中看到崩溃的消息。启用后,您可以通过tail -f /var/tmp/rabbitmq-tracing/.log
(在Mac上)观看消息。
详细说明在这里qazxsw poi