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）认证
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()
