Python 发送rabbitmq消息 消息头为字典

可以使用 Python 中的 pika 库来发送 RabbitMQ 消息。下面是一个示例代码，其中消息头为一个字典：

import pika
import json

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

# 定义消息头
headers = {"Content-Type": "application/json"}

# 将消息头转为 JSON 格式
headers_json = json.dumps(headers)

# 发送消息
channel.basic_publish(
    exchange='',
    routing_key='my_queue',
    body='Hello World!',
    properties=pika.BasicProperties(
        headers=headers_json
    )
)

# 关闭连接
connection.close()

在上面的代码中，我们首先连接了 RabbitMQ，然后定义了一个字典类型的消息头，并将其转换为 JSON 格式。接着使用 `basic_publish()` 方法发送消息，将消息头以 `properties` 参数的形式传入。

注意，在接收消息时，需要先将 JSON 格式的消息头解码为字典类型。可以使用以下代码获取消息头：

headers_json = properties.headers
headers = json.loads(headers_json)

希望这可以帮助到你！