Rabbitmq pika.BasicProperties不在消息中发送属性

2024-10-02 12:28:14 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在使用pika向rabbitmq发送消息。 我需要发送其他属性,所以我使用pika.BasicProperties,但当我在Wireshark中看到此消息时,没有添加任何属性

我的代码:

import pika, uuid

connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='test_60', durable=True, arguments={'x-message-ttl' : 21600000})

routingKey = "test_server"
message = '{"test_int":268,"Timestamp":1610022012203}'

correlation_id = str(uuid.uuid4())
reply_to = "test_60"
message_type = "SendRequest"

channel.basic_publish(exchange='',routing_key=routingKey,
                body=message,properties=pika.BasicProperties(
                headers={"testId": "60"},
                delivery_mode=2,
                correlation_id = correlation_id,
                reply_to = reply_to,
                type = message_type))

print('message sent')
print(correlation_id)

在Wireshark中,这个消息看起来像这样,所以没有属性,我也不知道这个示例有什么问题

enter image description here


Tags: totestid消息message属性uuidtype
1条回答
网友
1楼 · 发布于 2024-10-02 12:28:14
 prop = pika.BasicProperties(
            content_type='application/json',
            content_encoding='utf-8',
            headers={'key': 'value'},
            delivery_mode = 1,
        )

        channel.basic_publish(
                exchange='',
                routing_key=qname,
                properties=prop,
                body='{message: hello}'
            )

用户界面:

enter image description here

Wireshark:

enter image description here

相关问题 更多 >

    热门问题