终端上添加RabbitMQ 队列
Eave
2016.08.18
下载rabbitmqadmin插件
下载地址:http://127.0.0.1:15672/cli/rabbitmqadmin
wget -O /usr/local/rabbitmq/sbin/rabbitmqadmin http://127.0.0.1:15672/cli/rabbitmqadmin
chmod 755 /usr/local/rabbitmq/sbin/rabbitmqadmin
01、查看所有交换机
/usr/local/rabbitmq/sbin/rabbitmqadmin list exchanges
02、查看所有队列
/usr/local/rabbitmq/sbin/rabbitmqadmin list queues
03、查看所有Binding
/usr/local/rabbitmq/sbin/rabbitmqadmin list bindings
04、查看所有虚拟主机
/usr/local/rabbitmq/sbin/rabbitmqadmin list vhosts
05、查看所有用户信息
/usr/local/rabbitmq/sbin/rabbitmqadmin list users
06、查看所有权限信息
/usr/local/rabbitmq/sbin/rabbitmqadmin list connections
07、查看所有通道信息
/usr/local/rabbitmq/sbin/rabbitmqadmin list channels
08、创建交换机
/usr/local/rabbitmq/sbin/rabbitmqadmin declare exchange name=Exchange type=direct/fanout/x-delayed-message durable=true auto_delete=false arguments='{"x-delayed-type":"direct"}'
09、删除交换机
/usr/local/rabbitmq/sbin/rabbitmqadmin delete exchange name=Exchange
10、创建队列
/usr/local/rabbitmq/sbin/rabbitmqadmin declare queue name=Queue durable=true auto_delete=false
11、删除队列
/usr/local/rabbitmq/sbin/rabbitmqadmin delete queue name=Queue # --vhost=/ -u admin -p 123456
12、交换机和队列绑定
/usr/local/rabbitmq/sbin/rabbitmqadmin declare binding source=Exchange destination=Queue routing_key=Routing
13、删除交换机和队列绑定
/usr/local/rabbitmq/sbin/rabbitmqadmin delete binding source=Exchange destination=Queue properties_key=Routing destination_type=queue
14、查看队列中的消息不消费
/usr/local/rabbitmq/sbin/rabbitmqadmin get queue=Queue
15、查看队列中的消息并消费
/usr/local/rabbitmq/sbin/rabbitmqadmin get queue=Queue requeue=false
16、清空队列中的消息
/usr/local/rabbitmq/sbin/rabbitmqadmin purge queue name=Queue
17、添加延迟队列
/usr/local/rabbitmq/sbin/rabbitmqadmin declare exchange name=x.delayed.message type=x-delayed-message durable=true auto_delete=false arguments='{"x-delayed-type":"direct"}'
/usr/local/rabbitmq/sbin/rabbitmqadmin declare queue name=delayed.message.queue durable=true auto_delete=false
/usr/local/rabbitmq/sbin/rabbitmqadmin declare binding source=x.delayed.message destination=delayed.message.queue routing_key=delayed.message.routing