Python basic_consume 回调函数的用法
时间: 2023-06-28 09:03:50 浏览: 66
在使用Python连接RabbitMQ进行消费者订阅时,可以使用basic_consume()方法注册一个回调函数,用于接收消费者接收到的消息。
使用basic_consume()方法时,需要传入两个参数:
1. queue:要从中消费消息的队列的名称。
2. on_message_callback:每次接收到消息时要执行的回调函数。
下面是一个示例代码,演示了如何使用basic_consume()方法注册回调函数:
```python
import pika
def callback(ch, method, properties, body):
print("Received message:", body)
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='my_queue')
channel.basic_consume(queue='my_queue', on_message_callback=callback, auto_ack=True)
channel.start_consuming()
```
上述代码中,我们定义了一个名为callback的回调函数,该函数将在每次接收到消息时执行。使用basic_consume()方法注册回调函数时,我们将其作为on_message_callback参数传递,并设置auto_ack=True以确认消息已经被消费。
当程序运行时,它将等待从名为my_queue的队列中接收消息,并使用callback函数处理每个接收到的消息。