上一則文章講解了RabbitMQ的安裝和簡單一對一訊息通訊實現方法，具體可參考上一篇文章：http://blog.csdn.net/u012631731/article/details/72887588

這則文章講述一個生產者和多個消費者的訊息通訊。

直接上原始碼，在原始碼裡面進行註釋講述吧

client.py

#!/usr/bin/env python
import pika
import sys
#建立一個連線，目標地址為本機（localhost）
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
#建立一個訊息通道
channel = connection.channel()
#建立一個訊息佇列，訊息佇列的名稱為task_queue，
#這裡的第二個引數durable，是對訊息佇列的設定，
#使得RabbitMQ在發生異常退出時傳送的訊息不會被丟失，該訊息會被髮送給其他消費者
channel.queue_declare(queue='task_queue', durable=True)
message = ' '.join(sys.argv[1:]) or "Hello World!"
#設定轉換方式（預設），關聯訊息佇列（routing_key），繫結訊息體（body）
#delivery_mode 是設定訊息佇列的訊息持久化，=1是不持久化，=2是持久化
channel.basic_publish(exchange='',
                      routing_key='task_queue',
                      body=message,
                      properties=pika.BasicProperties(
                         delivery_mode = 2, # make message persistent
                      ))
print(" [x] Sent %r" % message)
#傳送完畢後關閉連線
connection.close()
 

server.py

#!/usr/bin/env python
import pika
import time
#不解釋
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
#不解釋
channel = connection.channel()
#不解釋
channel.queue_declare(queue='task_queue', durable=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
#在取訊息的這個回撥函式裡面加了一個sleep，這樣可以模擬不同消費者之間切換任務
#並且配置了訊息接受後的訊息確認，在一對一通訊時我們設定no_ack為true
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    time.sleep(body.count(b'.'))
    print(" [x] Done")
    ch.basic_ack(delivery_tag = method.delivery_tag)
#設定每一個消費者最大的訊息處理數量，這裡設定為兩個
channel.basic_qos(prefetch_count=2)
channel.basic_consume(callback,
                      queue='task_queue')
channel.start_consuming()