rabiit mq 消费怎么写

RabbitMQ消费的代码示例可以参考以下Python代码：

import pika

# 连接RabbitMQ服务器
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明队列
channel.queue_declare(queue='hello')

# 定义消息处理函数
def callback(ch, method, properties, body):
    print("Received %r" % body)

# 消费消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

在上述代码中，我们首先连接了RabbitMQ服务器，然后声明了一个名为“hello”的队列。接下来，我们定义了一个名为“callback”的函数，用于处理收到的消息。最后，我们通过调用basic_consume()方法开始消费消息。

需要注意的是，这里的auto_ack参数设置为True，表示消费者会自动确认收到的消息。如果设置为False，则需要在处理完消息后手动确认消息。