Python RabbitMQ 实现远程消息处理与返回示例

本文档详细介绍了如何在Python中利用RabbitMQ服务器实现远程消息队列的通信，并特别关注于处理消息发送后的结果返回。作者在Ubuntu 14.04操作系统上使用Python 2.7.4版本和Pika库来操作RabbitMQ。在实际应用中，通常情况下，消息发送者（如控制中心）需要接收来自接收者（如计算节点）的处理结果，这就涉及到消息的双向通信。 首先，为了在Python环境中安装和使用RabbitMQ，用户需要通过命令行工具`sudo apt-get install rabbitmq-server`安装RabbitMQ服务器，然后通过`sudo pip install pika`安装Pika库，这是一个Python客户端库，用于与RabbitMQ进行交互。 在处理远程结果返回时，作者提出了一个常见的策略：在发送消息前，创建一个临时队列作为接收结果的地方。这样，发送端（控制中心）不仅要发送消息，还要创建并监听这个临时队列，以便在计算节点完成任务后接收响应。在这个例子中，作者以控制中心（center.py）和计算节点（compute.py）之间的交互为例： 1. `compute.py`脚本首先建立与RabbitMQ的连接，并声明一个名为`compute_queue`的队列。它定义了一个函数`increase(n)`，用于将接收到的数字`n`加1。当收到消息时，它会打印一条消息确认正在处理，并调用`increase()`函数得到结果。 2. 当计算节点接收到控制中心发送的`n`值后，它会调用`request(ch, method, properties, body)`函数，其中`body`参数包含了`n`的值。这个函数内部调用`increase()`函数处理数据，并将结果转换为字符串。 3. 接着，计算节点通过`ch.basic_publish()`方法，将处理后的结果（字符串形式的`response`）发送回控制中心。发送消息时，使用了`exchange=''`表示发送到默认交换器，`routing_key=properties.reply_to`指定接收消息的队列（即控制中心的临时队列），最后通过`basic_ack()`确认消息已成功发送。 总结来说，这篇文档讲解了如何在Python中通过Pika库操作RabbitMQ，实现一个简单的消息通信场景，其中包括消息的发送、接收以及处理后的结果返回。这种设计模式有助于在分布式系统中保持异步通信，并确保消息的可靠传输。同时，它强调了在实际应用中发送端和接收端角色的动态变化，需要根据具体需求灵活调整。