# 環(huán)境為CentOS 7
yum install rabbitmq-server # 安裝RabbitMQ
systemctl start rabbitmq-server # 啟動(dòng)
systemctl enable rabbitmq-server # 開機(jī)自啟
systemctl stop firewall-cmd  # 臨時(shí)關(guān)閉防火墻

pip3 install pika

#!/usr/bin/env python3
# coding=utf-8
# @Time : 2017/6/13 19:25
# @Author : Shawn
# @Blog : https://blog.just666.cn
# @Email : shawnbluce@gmail.com
# @purpose : RabbitMQ_Producer
import pika
# 創(chuàng)建連接對象
connection = pika.BlockingConnection(pika.ConnectionParameters(host='115.xx.xx.xx'))
# 創(chuàng)建頻道對象
channel = connection.channel()
# 指定一個(gè)隊(duì)列，如果該隊(duì)列不存在則創(chuàng)建
channel.queue_declare(queue='test_queue')
# 提交消息
for i in range(10):
 channel.basic_publish(exchange='', routing_key='test_queue', body='hello,world' + str(i))
 print("sent...")
# 關(guān)閉連接
connection.close()

#!/usr/bin/env python3
# coding=utf-8
# @Time : 2017/6/13 19:40
# @Author : Shawn
# @Blog : https://blog.just666.cn
# @Email : shawnbluce@gmail.com
# @purpose : RabbitMQ_Consumer
import pika
credentials = pika.PlainCredentials('guest', 'guest')
# 連接到RabbitMQ服務(wù)器
connection = pika.BlockingConnection(pika.ConnectionParameters('115.xx.xx.xx', 5672, '/', credentials))
channel = connection.channel()
# 指定一個(gè)隊(duì)列，如果該隊(duì)列不存在則創(chuàng)建
channel.queue_declare(queue='test_queue')
# 定義一個(gè)回調(diào)函數(shù)
def callback(ch, method, properties, body):
 print(body.decode('utf-8'))
# 告訴RabbitMQ使用callback來接收信息
channel.basic_consume(callback, queue='test_queue', no_ack=False)
print('waiting...')
# 開始接收信息，并進(jìn)入阻塞狀態(tài)，隊(duì)列里有信息才會(huì)調(diào)用callback進(jìn)行處理。按ctrl+c退出。
channel.start_consuming()

#!/usr/bin/env python3
# coding=utf-8
# @Time : 2017/6/13 20:21
# @Author : Shawn
# @Blog : https://blog.just666.cn
# @Email : shawnbluce@gmail.com
# @purpose : RabbitMQ_Publisher
import pika
# 創(chuàng)建連接對象
connection = pika.BlockingConnection(pika.ConnectionParameters(host='115.xx.xx.xx'))
# 創(chuàng)建頻道對象
channel = connection.channel()
# 定義交換機(jī)，exchange表示交換機(jī)名稱，type表示類型
channel.exchange_declare(exchange='my_fanout',
       type='fanout')
message = 'Hello Python'
# 將消息發(fā)送到交換機(jī)
channel.basic_publish(exchange='my_fanout', # 指定exchange
      routing_key='', # fanout下不需要配置，配置了也不會(huì)生效
      body=message)
connection.close()

#!/usr/bin/env python3
# coding=utf-8
# @Time : 2017/6/13 20:20
# @Author : Shawn
# @Blog : https://blog.just666.cn
# @Email : shawnbluce@gmail.com
# @purpose : RabbitMQ_Subscriber
import pika
credentials = pika.PlainCredentials('guest', 'guest')
# 連接到RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('115.xx.xx.xx', 5672, '/', credentials))
channel = connection.channel()
# 定義交換機(jī)，進(jìn)行exchange聲明，exchange表示交換機(jī)名稱，type表示類型
channel.exchange_declare(exchange='my_fanout',
       type='fanout')
# 隨機(jī)創(chuàng)建隊(duì)列
result = channel.queue_declare(exclusive=True) # exclusive=True表示建立臨時(shí)隊(duì)列，當(dāng)consumer關(guān)閉后，該隊(duì)列就會(huì)被刪除
queue_name = result.method.queue
# 將隊(duì)列與exchange進(jìn)行綁定
channel.queue_bind(exchange='my_fanout',
     queue=queue_name)
# 定義回調(diào)方法
def callback(ch, method, properties, body):
 print(body.decode('utf-8'))
# 從隊(duì)列獲取信息
channel.basic_consume(callback,
      queue=queue_name,
      no_ack=True)
channel.start_consuming()