php - rabbitmq 设置消息属性 php

Question

我正在尝试使用 RabbitMQ Bundle 设置消息属性在 Symfony 中，但我不知道在哪里/如何做到这一点。以下是我在 RabbitMQ 管理 UI 中的操作方式

Properties expiration: 50000 是我想要设置的。

我该怎么做？

Answer 1

自 2014 年 1 月 8 日起，您使用 RabbitMQ Bundle 设置消息属性，您可以查看提交 here

现在，当您发布一条消息时，您可以设置数组 $additionalProperties

public function publish($msgBody, $routingKey = '', $additionalProperties = array())

您可以找到支持的消息属性 here

例如:

$msg = ['arg1' => 'val1'];
$queue->setContentType('application/json');
$queue->publish(
        json_encode($msg),
        "",
        ['expiration' => '50000']
);

如果要为自定义 header 使用“ header ”，则有点复杂，因为您必须为每个值定义数据类型。发送，例如$headers['arg1'] = "val1"就像一个字符串，你必须做这样的事情:

$msg = ['arg1' => 'val1'];
$queue->setContentType('application/json');
$queue->publish(
        json_encode($msg),
        "",
        ["application_headers" => ["arg1" => ["S", "val1"]]]
);

有效的数据类型是:

S - 字符串

I - 整数

D - 十进制

T - 时间戳

F - 表格

A - 数组