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()