使用 pecl-amqp 防止在 get() 上确认消息

Question

我正在尝试将 pecl-amqp 用于我的项目。但我在 ACK 过程中遇到了困难。我需要手动确认从队列中收到的每条消息，但在检索消息时，这些消息似乎会自动确认。

我已将队列设置为 AMQP_NOACK 并使用 AMQPQueue->get(AMQP_NOACK) 但似乎没有任何影响，消息仍然从队列中删除，而无需我发送 AMQPQueue->ack()。

如果有人对 pecl-amqp 有任何经验，我将不胜感激。

Answer 1

我也遇到了同样的问题，但已经设法使用 Consumer 方法让确认机制正常工作。使用rabbitmqctl列出队列中的条目似乎工作正常，尽管我似乎以与发送消息的顺序不同的顺序将消息从队列中取出——这会破坏队列的对象。我的代码如下：

// Create the queue to be:
//      AMQP_DURABLE - messages will withstand a broker restart (i.e. they are written to disk).
//      AMQP_NOACK - when consumed messages will not be marked as delivered until an explicit ACK is received.
$q->declare($queueName, AMQP_DURABLE | AMQP_NOACK );

// Bind it on the exchange to routing key.
$q->bind($exchangeName, $routingKey);

// Set the options for our consumption of the messages:
//  Get a minimum of 0 msg.
//  Get a maximum of 1 msg.
//  Don't ACK the message on consumption i.e. explicitly acknoledge later.
$options = array(
 'min' => 0,
 'max' => 1,
 'ack' => false
);
// Get the messages
$results_array = $q->consume($options);

// show the message
print_r($results_array);
$delivery_tag =  $results_array[0]['delivery_tag'];
echo 'delivery_tag: [' . $delivery_tag . "].\r\n";

// Acknowledge receipt of the message.
$q->ack($delivery_tag);

Answer 2

作为参考，AMQP 扩展未正确支持 AMQP_NOACK。你可以让它做你想做的事，但它并不漂亮。我现在正在努力解决这个问题。仅供参考，AMQP_NOACK 意味着您稍后不必返回确认消息，即服务器将消息发送到客户端后，服务器会将消息标记为已确认。围绕这个问题有些困惑，所以我想澄清一下。