RabbitMQ（六）遠程鏈接

RabbitMQ（六）遠程鏈接

默認狀況下，rabbitmq使用`guest`來鏈接本地（localhost）的server，當須要遠程鏈接時，就會失效。

"guest" user can only connect via localhost

官方文檔： http://www.rabbitmq.com/access-control.html

若是必須使用`guest`用戶來進行遠程登陸，須要修改配置

[{rabbit, [{loopback_users, []}]}].

（1）那麼首先須要建立並添加一個用戶`test`，讓其具備管理員權限

rabbitmqctl add_user rootroot 
rabbitmqctl set_user_tags rootadministrator 
rabbitmqctl set_permissions -p / root".*" ".*" ".*"

（2）修改配置文件

[{rabbit, [{loopback_users, ["root"]}]}].

（3）重啓rabbitmq-server

/etc/init.d/rabbitmq-server restart

（4）修改host

修改遠程客戶端機器上的/etc/hosts，添加rabbit-server的IP

xx.xx.xx.xx rabbit-server

（5）認證

原文： https://pika.readthedocs.org/en/0.9.14/modules/parameters.html

pika提供了兩種認證方式：ConnectinParameters和URLParameters。

ConnectionParameters

import pika

# Set the connection parameters to connect to rabbit-server1 on port 5672# on the / virtual host using the username "guest" and password "guest"
credentials = pika.PlainCredentials('root', 'root')
parameters = pika.ConnectionParameters('rabbit-server1',
                                       5672,
                                       '/',
                                       credentials)

URLParameters

import pika

# Set the connection parameters to connect to rabbit-server1 on port 5672# on the / virtual host using the username "guest" and password "guest"
parameters = pika.URLParameters('amqp://guest:guest@rabbit-server1:5672/%2F')

例子

import pika

i = 1

def callback(ch, method, properties, body):
    global i
    #print 'receive %r'%body
    print 'receive %s'%i
    i += 1
    f = open('%s'%i, 'w+')
    f.write(body)
    f.close()

#第一種方法
#credentials = pika.PlainCredentials('mtest', 'root')
#connection = pika.BlockingConnection(pika.ConnectionParameters('rabbit-server', 5672, '/', credentials))
#第二種方法
parameters = pika.URLParameters('amqp://mtest:root@rabbit-server:5672/%2F')
connection = pika.BlockingConnection(parameters)

channel = connection.channel()

channel.queue_declare(queue='hello')

channel.basic_consume(callback, queue='hello1', no_ack=True)

channel.start_consuming()