Python操作RabbitMQ初体验（一）

在MQ这个词汇映入眼帘的时候，我花了好几个小时去阅读什么是MQ，即Message Queue(消息队列）。顾名思义，消息队列，装满消息的队列，队列，数据结构名词，具备先进先出特性的一种数据结构。消息队列无非是用来传递消息的而已，那么其意义何在，应用场景又在哪里，具备什么特性，及其独特优势是什么，为什么要用，这些都是浮现在我脑海中的一连串问题。

经过一大串搜索，终于肤浅的理解消息队列是应用对应用的信息传递的通信方式。比如需要分析多台服务器的日志，完全可以每台服务器都用一个进程往一个Mysql数据库的表里面写入数据，即所需要的信息，然后再写几个进程，读取表里数据，进行数据分析不是挺好，不过很快，这种设计的丑陋之处就显现出来了…… 你想要多个程序从一个队列当中取数据来处理？没问题，我们硬编码程序的个数好了……什么？还要能够允许程序动态地增加和减少的时候动态进行压力分配？这是很流行的《RabbitMQ+Python入门经典 兔子和兔子窝》里面的例子。想想也是，当我的CDN传输来一大堆数据的时候，数据的分发，处理，所有的一切都会是问题。但是其实还是没明白，Rabbit到底是怎么样实现这些东西的。

概念上说，RabbitMQ是AMPQ（高级消息协议队列）的标准实现，据说不熟悉AMQP，会看不懂RabbitMQ的文档。但是也只能建大的理解关键概念了。整个RabbitMQ的实现原理模型见下图，其实就是一个带路由任务分发队列的生产者与消费者模型。如图所示，即生产者生产出相应的信息，发送给路由器，路由器根据信息中的关键Key信息，将信息分发到不同的消息队列中，再由消费者去不同的消息队列中读取数据的过程。

发送方即生产者，首先要创建与RabbitMQ服务器的连接，

#!/usr/bin/env pythonimport pikacOnnection= pika.BlockingConnection(pika.ConnectionParameters(              
 &＃39;localhost&＃39;))channel = connection.channel()

此处服务器连接本地localhost，也可以指定ip或者主机名。

其次发送方需要声明一个队列，比如命名为sayhello

channel.queue_declare(queue=&＃39;sayhello&＃39;)

此时我们就可以发送消息了。由于第一个小案例比较简单，没有经过路由器，因此发送消息时，指定路由为空即可。

channel.basic_publish(exchange=&＃39;&＃39;,                        
routing_key=&＃39;hello&＃39;,                                    
body=&＃39;hello world&＃39;)print "Sent ‘hello world&＃39;"

最后关闭连接即可。

connection.close()

接收方即消费者，需要从队列上获取数据，因此也需要绑定一个队列

channel.queue_declare(queue=&＃39;hello&＃39;)

同时，由于接收方的工作方式是基于队列的消息执行一个回调函数，当收到消息时，Pika就会执行相应的回调函数，因此我们需要定义此函数。

def callback(ch, method, properties, body):    print " [x] Received %r" % (body,)

接下来我们需要初始化这个消费者，并对消费者进行启动。

channel.basic_consume(callback,                      
queue=&＃39;hello&＃39;,                      
no_ack=True)print &＃39; [*] Waiting for messages. To exit press CTRL+C&＃39;channel.start_consuming()

OK执行成功。

接下来就逐步的深入体验RabbitMQ的独特魅力。

以上就是Python操作RabbitMQ初体验（一）的内容，更多相关内容请关注PHP中文网（www.php1.cn）！