先安装erlang

rpm -Uvh http://www.rabbitmq.com/releases/erlang/erlang-18.1-1.el7.centos.x86_64.rpm

安装rabbitmq-server

rpm -Uvh http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.6/rabbitmq-server-3.5.6-1.noarch.rpm

查看rabbitmq-server有没有安装成功，能查到说明安装成功了

rpm -qa|grep rabbitmq

 

开启rabbit-server

service rabbitmq-server start

关闭服务

service rabbitmq-server stop

查看rabbit-server当前状态

rabbitmqctl status

安装好后

rabbitmq list_queues显示当前的队列列表

 

远程连接rabbitmq server的话，需要配置权限
首先在rabbitmq server上创建一个用户
sudo rabbitmqctl add_user yu yuhaha
同时还要配置权限，允许从外面访问（下面的命令相当于创建了一个管理员）
sudo rabbitmqctl set_permissions -p / yu ".*" ".*" ".*"

 

producer.py

 1 #!/usr/bin/env python
 2 # coding:utf8
 3 # author:Z time:2019/1/11
 4 import pika
 5 
 6 #建立连接
 7 #指定用户名
 8 credentials=pika.PlainCredentials('yu','yuhaha')
 9 parameters=pika.ConnectionParameters(host='192.168.1.103',credentials=credentials)
10 connection = pika.BlockingConnection(parameters)
11 channel = connection.channel()#队列连接通道
12 
13 # 声明queue
14 channel.queue_declare(queue='hello2')
15 
16 # n RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.
17 channel.basic_publish(exchange='',#消息过滤，为空表示默认
18                       routing_key='hello2',#路由，实际消息放到哪个队列由这个参数控制
19                       body='Hello World!2')#消息内容
20 print(" [x] Sent 'Hello World!'")
21 connection.close()

执行两次程序后，再次执行命令rabbitmq list_queues

 

 

consumer.py

 1 #!/usr/bin/env python
 2 # coding:utf8
 3 # author:Z time:2019/1/11
 4 import pika
 5 
 6 credentials=pika.PlainCredentials('yu','yuhaha')
 7 paramters=pika.ConnectionParameters(host='192.168.1.103',credentials=credentials)
 8 connection = pika.BlockingConnection(paramters)
 9 channel = connection.channel()#队列连接通道
10 
11 
12 def callback(ch, method, properties, body):#队列连接通道，请求方法，消息参数，消息内容
13     print(" [x] Received %r" % body)
14 
15 
16 channel.basic_consume(callback,#取到消息后，调用callback函数
17                       queue='hello',
18                       no_ack=True)
19 
20 print(' [*] Waiting for messages. To exit press CTRL+C')
21 channel.start_consuming()#开始消费，阻塞模式，没消息一直等，有消息就收，收完了继续等，是处于永远运行的状态

 运行consumer.py,成功取到两条消息