RabbitMQ使用AMQP通信協(xié)議（AMQP是一個(gè)提供統(tǒng)一消息服務(wù)的應(yīng)用層標(biāo)準(zhǔn)協(xié)議，基于此協(xié)議的客戶端與消息中間件可傳遞消息，并不受客戶端/中間件不同產(chǎn)品，不同開發(fā)語言等條件的限制。）。

安裝

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

安裝python的開發(fā)庫(kù)

sudo pip install pika==0.9.8

安裝rabbitmq服務(wù)

sudo apt-get install rabbitmq-server

啟動(dòng)rabbit服務(wù)

rabbitmq-server start

Hello World

發(fā)送

• 通過使用pika第三方庫(kù)來連接，本例中為localhost本地連接。?
• 通過queue_declare來創(chuàng)建一個(gè)消息隊(duì)列
• 發(fā)送消息basic_publish
• 關(guān)閉鏈接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第三方庫(kù)來連接，本例中為localhost本地連接。?
• 通過queue_declare來創(chuàng)建一個(gè)消息隊(duì)列（推薦，由于接收之前消息隊(duì)列有可能并沒有創(chuàng)建過）
• 指定消息隊(duì)列和回調(diào)函數(shù)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點(diǎn)點(diǎn)?創(chuàng)作，采用?知識(shí)共享 署名-非商業(yè)性使用-相同方式共享 3.0 中國(guó)大陸 許可協(xié)議進(jìn)行許可。歡迎轉(zhuǎn)載，請(qǐng)注明出處：
轉(zhuǎn)載自：cococo點(diǎn)點(diǎn)?http://www.cnblogs.com/coder2012

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。