为 AMQP (RabbitMQ) 设置交付模式

Question

The docs说：

public bool AMQPExchange::publish ( string $message , string $routing_key [, int $params = 0 [, array $attributes ]] )

所以我有这个

 $this->exchange->publish(serialize($queue_message), $routing_key,AMQP_MANDATORY,array('delivery_mode' => '2'));

我正在尝试让交易所继续尝试传递消息？

Answer 1

您不能告诉交易所继续尝试传递您的消息。

通常，消息的接收者要么自动确认消息，要么在成功处理后确认消息。我推荐这两个选择中的第二个。如果一条消息没有被确认，那么它将被重新排队，如果队列中有多个订阅者，则可能会有不同的订阅者处理它。

我的经验全是主题交换（通过让多个队列订阅相同的 routing_key 来实现扇出。我总是使用 delivery_mode 2 并将队列声明为持久的。

如果在消息发布之前队列不存在，那么它们会默默地消失。

我怀疑您的问题出在字符串'2' 上。您是否尝试过使用号码 2 代替？在数组中指定 content_type 也是一个好主意。这样就可以了

$this->exchange->publish(serialize($queue_message),
            $routing_key,AMQP_MANDATORY,array('delivery_mode' => 2,
                                              'content_type' => 'text/json'));