rabbitmq 常用命令及远程连接方法

1. rabbitmq 用户角色分类
none、management、policymaker、monitoring、administrator

2.RabbitMQ各类角色描述：
none
不能访问 management plugin

management
用户可以通过AMQP做的任何事外加：
列出自己可以通过AMQP登入的virtual hosts  
查看自己的virtual hosts中的queues, exchanges 和 bindings
查看和关闭自己的channels 和 connections
查看有关自己的virtual hosts的“全局”的统计信息，包含其他用户在这些virtual hosts中的活动。

policymaker 
management可以做的任何事外加：
查看、创建和删除自己的virtual hosts所属的policies和parameters

monitoring 
management可以做的任何事外加：
列出所有virtual hosts，包括他们不能登录的virtual hosts
查看其他用户的connections和channels
查看节点级别的数据如clustering和memory使用情况
查看真正的关于所有virtual hosts的全局的统计信息

administrator   
policymaker和monitoring可以做的任何事外加:
创建和删除virtual hosts
查看、创建和删除users
查看创建和删除permissions
关闭其他用户的connections

3.创建用户并分配角色
(1).添加用户
# rabbitmqctl add_user username password
(2).删除用户
# rabbitmqctl delete_user username
(3).修改密码
# rabbitmqctl change_password username newpassword
(4).列出所有用户
# rabbitmqctl list_users
(5).为用户分配角色
# rabbitmqctl set_user_tags username  rolename

4.权限控制
默认用户：guest  默认virtual host："/" guest具有"/"上的全部权限，仅能有localhost访问RabbitMQ包括Plugin，建议删除或更改密码。
(1).创建虚拟主机
# rabbitmqctl add_vhost vhostpath
(2).删除虚拟主机
# rabbitmqctl delete_vhost vhostpath
(3).列出所有虚拟主机
# rabbitmqctl list_vhosts
(4).设置用户权限
# rabbitmqctl set_permissions [-p vhostpath] username regexp regexp regexp
rabbitmqctl set_permissions -p az guest ".*" ".*" ".*"  --赋予全部权限
(5).清除用户权限
# rabbitmqctl clear_permissions [-p vhostpath] username
(6).列出虚拟主机上的所有权限
# rabbitmqctl list_permissions [-p vhostpath]
(7).列出用户权限

# rabbitmqctl list_user_permissions username

 

5.代码实例

# _*_coding:utf-8_*_
__author__ = 'Alex Li'
import pika

credentials = pika.PlainCredentials('admin', '1231')
connection = pika.BlockingConnection(pika.ConnectionParameters(host='109.115.12.55',credentials=credentials,virtual_host='az'))
channel = connection.channel()

channel.exchange_declare(exchange='logs',type='fanout')

result = channel.queue_declare(exclusive=True)  # 不指定queue名字,rabbit会随机分配一个名字,exclusive=True会在使用此queue的消费者断开后,自动将queue删除
queue_name = result.method.queue #获得上面随机生成的queue名

channel.queue_bind(exchange='logs',queue=queue_name)

print(' [*] Waiting for logs. To exit press CTRL+C')

def callback(ch, method, properties, body):
    print(" [x] %r" % body)

channel.basic_consume(callback,queue=queue_name,no_ack=True)
channel.start_consuming()

import pika
import sys

credentials = pika.PlainCredentials('admin', '1231')
connection = pika.BlockingConnection(pika.ConnectionParameters(host='109.115.12.55',credentials=credentials,virtual_host='az'))
channel = connection.channel()

channel.exchange_declare(exchange='logs',
                         type='fanout')

message = ' '.join(sys.argv[1:]) or "info: Hello World!"
channel.basic_publish(exchange='logs',
                      routing_key='',
                      body=message)
print(" [x] Sent %r" % message)
connection.close()