RabbitMQ python模塊pika生產者消費者輪詢模型。

完整代碼如下：

生產者，producer

import pika
connection = pika.BlockingConnection(
    pika.ConnectionParameters('localhost'))#建立一個最基本的socket
chanel = connection.channel()#聲明一個管道

chanel.queue_declare(queue='name')#給管道創建一個隊列，參數是管道隊列名。

chanel.basic_publish(exchange='',
                     routing_key='name',
                     body ='HELLO WORD!')#要發送的消息。
print( '發出一個消息')
connection.close()#關閉

 消費者:

import pika,time

consumer = pika.BlockingConnection\
    (pika.ConnectionParameters('localhost'))#創建socket連接
channel = consumer.channel()#創建管道
channel.queue_declare(queue='name')

def backcall(ch,method,properties,body):#參數body是發送過來的消息。
    print(ch,method,properties)
    time.sleep(15)
    print('[x] Received %r'%body)

channel.basic_consume(backcall,#回調函數。執行結束后立即執行另外一個函數返回給發送端是否執行完畢。
                      queue='name',
                      no_ack=True#不會告知服務端我是否收到消息。一般注釋。
                       )#如果注釋掉，對方沒有收到消息的話不會將消息丟失，始終在隊列里等待下次發送。

print('waiting for message To exit   press CTRL+C')
channel.start_consuming()#啟動后進入死循環。一直等待消息。