Pika使用入门(二)【连接到RabbitMQ与回调传递风格】

连接到RabbitMQ与回调传递风格

当您使用异步适配器连接到RabbitMQ时，您正在编写面向事件的代码。 连接适配器将阻塞正在观看的IOLoop，当pika应从其读取数据并向RabbitMQ写入数据时。 因为您现在阻止了IOLoop，所以当特定事件发生时，您将收到回拨通知。

示例代码

在这个例子中，有三个步骤发生：

1.设置与RabbitMQ的连接

2.启动IOLoop

3.一旦连接，Pika将使用on_open方法调用连接的句柄。 在这种方法中，将在连接上打开一个新的通道。

4.渠道打开后，您可以执行其他操作，无论是发布消息，消费消息还是其他与RabbitMQ相关的活动：

import pika

# 步骤3
def on_open(connection):
connection.channel(on_channel_open)

# 步骤4
#basic_publish的properties参数指定message的属性
#pika.BasicProperties中的delivery_mode=2指明message为持久的
def on_channel_open(channel):
channel.basic_publish('',
'siso',
'HahaMessage',
pika.BasicProperties(content_type='text/plain', type='json'))

# 步骤1: 连接到RabbitMQ
#scheme://username:password@host:port/virtual_host?key=value&key=value
#amqp://guest:guest@localhost:5672/%2F
parameters = pika.URLParameters('amqp://wu:123456@localhost:5672/simple')
connection = pika.SelectConnection(parameters=parameters,on_open_callback=on_open)

try:
# 步骤2 - 在IOLoop阻塞
connection.ioloop.start()

#捕获键盘中断以确保连接被干净地关闭
except KeyboardInterrupt:
#正常关闭连接
connection.close()
# 再次启动IOLoop，以便Pika可以进行通信，当连接关闭时，它将自行停止
connection.ioloop.start()