如何使用 php 在 RabbitMQ 中检索相同的消息两次或更多次

Question

我在使用 php + RabbitMQ + MySQL 时遇到了一些问题。

我有 php 的工作人员，更新数据库中的一条记录。现在我试图纠正 如果服务器 MySQL 消失了就可以工作。

我在做什么： 我正在尝试重新连接到 DB 10 次，如果我不能 - 需要将此按摩返回给 RabbitMQ。

对于接受消息我使用 basic_ack，对于拒绝我使用 basic_nack。

---

示例：

    if ($can_accept_message) {
        $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);

    } else {
        $message->delivery_info['channel']->basic_nack($message->delivery_info['delivery_tag']);
    }

但是 basic_nack 从队列中删除了这条消息，我不能再重复它；(

尝试这样： https://github.com/php-amqplib/php-amqplib/blob/d2b8a292f709b79b1615bef87b1b89bde4c7c347/demo/basic_nack.php

阅读： https://github.com/php-amqplib/php-amqplib/issues/221

但还是不行。

怎么了？或许您还有其他想法？

Answer 1

似乎函数 basic_nack 定义如下：

/**
 * Rejects one or several received messages
 *
 * @param string $delivery_tag
 * @param bool $multiple
 * @param bool $requeue
 */
public function basic_nack($delivery_tag, $multiple = false, $requeue = false)

可以看到，第三个参数是$requeue = false

你应该试试

else {
    $message->delivery_info['channel']->basic_nack($message->delivery_info['delivery_tag'], false, true);
}