RabbitMQ使用AMQP通信協議（AMQP是一個提供統一消息服務的應用層標準協議，基于此協議的客戶端與消息中間件可傳遞消息，并不受客戶端/中間件不同產品，不同開發語言等條件的限制。）。

安裝

具體教程參考：http://www.rabbitmq.com/tutorials/tutorial-one-python.html

安裝python的開發庫

sudo pip install pika==0.9.8

安裝rabbitmq服務

sudo apt-get install rabbitmq-server

啟動rabbit服務

rabbitmq-server start

Hello World

發送

• 通過使用pika第三方庫來連接，本例中為localhost本地連接。?
• 通過queue_declare來創建一個消息隊列
• 發送消息basic_publish
• 關閉鏈接close

#!/usr/bin/env python # coding=utf-8import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel()channel.queue_declare(queue='hello')channel.basic_publish(exchange='', routing_key='hello', body='hello world!')print 'Sent "hello world"'connection.close()

接收

• 通過使用pika第三方庫來連接，本例中為localhost本地連接。?
• 通過queue_declare來創建一個消息隊列（推薦，由于接收之前消息隊列有可能并沒有創建過）
• 指定消息隊列和回調函數basic_consume
• 開始接受消息start_consuming

#!/usr/bin/env python # coding=utf-8import pikadef callback(ch, method, properties, body): print 'receive %r'%bodyconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel()channel.queue_declare(queue='hello')channel.basic_consume(callback, queue='hello', no_ack=True)channel.start_consuming()

?

本文?由?cococo點點?創作，采用?知識共享 署名-非商業性使用-相同方式共享 3.0 中國大陸 許可協議進行許可。歡迎轉載，請注明出處：
轉載自：cococo點點?http://www.cnblogs.com/coder2012

總結

以上是生活随笔為你收集整理的RabbitMQ -- Hello world的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。