rabbitmq消费者接受消息代码

RabbitMQ是一种流行的开源消息队列系统，用于分布式应用程序之间的通信。在Python中，使用pika库来操作RabbitMQ，下面是创建一个简单的消费者来接收消息的基本代码：

import pika

# 创建连接到RabbitMQ服务器的链接
def connect_rabbitmq():
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    return connection

# 创建消费者并绑定到特定交换机和路由键
def create_consumer(channel):
    channel.basic_consume(queue='your_queue_name', on_message_callback=on_message, auto_ack=True)

def on_message(ch, method, properties, body):
    print(f"Received message: {body.decode('utf-8')}")
    # 这里处理接收到的消息逻辑

# 主函数
if __name__ == "__main__":
    connection = connect_rabbitmq()
    channel = connection.channel()

    create_consumer(channel)
    print("Consumer started, awaiting messages...")
    channel.start_consuming()

# 关闭连接时记得释放资源
def stop_consumption():
    if connection.is_open:
        channel.stop_consuming()
        connection.close()

# 结束程序时调用停止消费
atexit.register(stop_consumption)

在这个示例中，你需要将`your_queue_name`替换为你实际的队列名称。消费者会一直监听该队列，直到接收到消息才会执行`on_message`回调函数中的逻辑。