rabbitmq(中间消息代理)在python中的使用详解

在之前的有关线程，进程的博客中，我们介绍了它们各自在同一个程序中的通信方法。但是不同程序，甚至不同编程语言所写的应用软件之间的通信，以前所介绍的线程、进程队列便不再适用了；此种情况便只能使用socket编程了，然而不同程序之间的通信便不再像线程进程之间的那么简单了，要考虑多种情况（比如其中一方断线另一方如何处理；消息群发，多个程序之间的通信等等），如果每遇到一次程序间的通信，便要根据不同情况编写不同的socket，还要维护、完善这个socket这会使得编程人员的工作量大大增加，也使得程序更易崩溃。所以，一般遇到这种情况，便使用消息队列MQ(Message Queue)，那么问题来了。

1. 什么是消息队列MQ？

MQ是一种应用程序对应用程序的通信方法。应用程序通过读出（写入）队列的消息（针对应用程序的数据）来通信，而无需使用专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，排队指的是应用程序通过 队列来通信。队列的使用排除了接收和发送应用程序同时执行的要求。

2. 什么是rabbitmq？如何使用它？

RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。

RabbitMQ也是前面所提到的生产者消费者模型，一端发送消息（生产任务），一端接收消息（处理任务）。

rabbitmq的详细使用（包括各种系统的安装配置）可参见其官方文档：http://www.rabbitmq.com/documentation.html

由于应用程序之间的通信情况异常复杂，rabbitmq支持的编程语言有10多种，所以在此博客中不可能完全演示rabbitmq的所有使用。本片博客将会介绍rabbitmq在python中的基本使用，如果你只想使用rabbitmq完成一些简单的任务，则本篇博客足以满足你的需求；如果你想深入学习了解rabbitmq的工作原理，那么读完本篇博客，你可以更容易的读懂rabbitmq的官方文档；当然这些只限于你在使用python编程。

在python中我们使用pika(第三方模块，使用pip安装即可使用)模块进行rabbitmq的操作，接下来，使用python实现一个rabbitmq最简单的通信。

In the diagram below, "P" is our producer and "C" is our consumer. The box in the middle is a queue - a message buffer that RabbitMQ keeps on behalf of the consumer.

Our overall design will look like:

Producer sends messages to the "hello" queue. The consumer receives messages from that queue.

例一（简单的消息收发）：

Sending

Our first programsend.pywill send a single message to the queue. The first thing we need to do is to establish a connection with RabbitMQ server.