RabbitMQのは、打ち上げ

Question

上のキューからメッセージを一つ取る作業員がオフのとき、私はRabbitMQの中に私のキューに多くのメッセージを公開します。 そして、私は私の労働者を起動して、彼はキューからすべてのメッセージを受け取り、彼は正常に動作しているが、彼が終了する前に、私は私のワーカープロセスへを停止すると、すべてのメッセージがキューから削除されます。 私が同じ仕事を2番目に開始した場合、彼は取るべきメッセージがありません。

$channel->queue_declare($action, false, false, false, false); 

$channel->basic_qos(null, 1, null); 
$channel->basic_consume($action, '', false, true, false, false, $callback); 

私は私の作業者に行うことができますが、キューからのスタートに一つだけのメッセージを受け取り、労働者が停止して開始したとき、彼は彼が停止したキューからメッセージを受け取り続ける方法

？

Answer 1

メッセージを取るために残されたメッセージがない場合は、すでに確認されています。

は無効にする必要があります。これは、メッセージの消費を完了するために確認応答を明示的に手動で送り返す必要があります（つまり、すべての作業が完了した後）。

$no_ack = false; # If no_ack is true the server does NOT expect a 
       # basic.ack response and will dequeue the message immediately! 
$channel->basic_consume($action, '', false, $no_ack, false, false, $callback); 

PHP tutorial on the RabbitMQ siteは、コールバック内からackを送信する方法を示しています。

の前にのackが送信されている間は、接続が閉じられたときにメッセージが再び利用可能になり、他のコンシューマーが取り上げることができます。 Message Acknowledgementsを参照してください。

具体的には、WRT no-ackビット：

このフィールドは、サーバーがメッセージに対する確認応答を期待していない（真）に設定されている場合。つまり、メッセージがクライアントに配信されると、サーバーは配信が成功したものとみなしてすぐにデキューします。この機能はパフォーマンスを向上させる可能性がありますが、信頼性を犠牲にします。クライアントがアプリケーションに配信される前に死亡した場合、メッセージが失われる可能性があります。