RabbitMQ 远程连接

2016/03/17 02:07
阅读数 1.3K

 

默认情况下,rabbitmq使用guest来连接本地(localhost)的server,当需要远程连接时,就会失效。

"guest" user can only connect via localhost

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

如果必须使用guest用户来进行远程登录,需要修改配置

 

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

 

(1)那么首先需要创建并添加一个用户test,让其具有管理员权限

  • rabbitmqctl add_user admin admin

  • rabbitmqctl set_user_tags admin administrator

  • rabbitmqctl set_permissions -p / admin "." "." ".*"

(2)修改配置文件

 

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

 

(3)重启rabbitmq-server

 

1
/etc/init.d/rabbitmq-server restart

 

(4)修改host

修改远程客户端机器上的/etc/hosts,添加rabbit-server的IP

 

1
xx.xx.xx.xx rabbit-server

 

(5)认证

原文:https://pika.readthedocs.org/en/0.9.14/modules/parameters.html
pika提供了两种认证方式:ConnectinParameters和URLParameters。

ConnectionParameters

 

1
2
3
4
5
6
7
8
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

 

1
2
3
4
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 = 1def 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()

         

 

 

#rabbitmq                  

python 对象                      

memcache 内存管理                      

 

 

展开阅读全文
打赏
1
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
1
分享
返回顶部
顶部