如何在RabbitMQ中将任意参数传递给回调函数？

import pika

def callback(ch, method, properties, body):
    # 获取消息属性
    param1 = properties.headers.get('param1')
    param2 = properties.headers.get('param2')

    # 在回调函数中使用获取到的参数
    print(f"Received message with param1={param1} and param2={param2}")

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

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

    # 设置消息属性
    properties = pika.BasicProperties(headers={'param1': 'value1', 'param2': 'value2'})

    # 发布消息
    channel.basic_publish(exchange='', routing_key='my_queue', body='Hello World!', properties=properties)

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

    # 开始消费
    channel.start_consuming()

if __name__ == '__main__':
    main()