终端上添加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