初探 RabbitMQ （二）

Hello World 测试

实验内容

通过一个程序发送 “Hello world”，另一个程序接受消息并且打印到屏幕上。

生产者（Producer）把消息发送到一个名为 “hello” 的队列中。消费者（Consumer）从这个队列中获取消息。

安装 RabbitMQ 库

RabbitMQ 使用的是 AMQP 协议。要使用 rabbitmq，你需要一个库来解读这个协议。几乎所有的编程语言都有可选择的库。python 也是一样，可以从以下几个库中选择，他们都可以实现 python 与 rabbitmq 的对接：

这次实验我们用 pika 来做演示，通过 pip 来安装：

# 更新软件包列表
$ sudo apt-get update

# 安装所需要的依赖
$ sudo apt-get install -y python-pip git-core  

# 更新 pip
$ sudo pip install --upgrade pip

# 安装 pika
$ sudo pip3 install pika

发送数据

send

#!/usr/bin/env python3
import pika

#创建连接
connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()
#声明一个名为 hello 的队列
channel.queue_declare(queue='hello')
#在 RabbitMQ 中，消息是不能直接发送到队列，它需要发送到交换机（exchange）中，它使用一个空字符串来标识。交换机允许我们指定某条消息需要投递到哪个队列。 routing_key 参数必须指定为队列的名称
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()

获取数据

receive

#!/usr/bin/env python3
import pika

# 创建连接
connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()
#声明 hello 队列
channel.queue_declare(queue='hello')
#定义一个回调函数
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
#订阅某 hello 队列中的消息收下一条消息
#auto_ack 是否自动确认消息,true自动确认
#on_message_callback 绑定消息回调函数为 callback
channel.basic_consume(queue='hello',
                      auto_ack=True,
                      on_message_callback=callback)
#打印一条提示信息
print(' [*] Waiting for messages. To exit press CTRL+C')
#开始接收 hello 队列中的消息
channel.start_consuming()