我正在使用rabbitmq和amqp protocol在我的應用程序中進行聊天。我想獲得acknowledgement成功發送給發件人的消息。使用amqp從rabbitmq隊列收到的消息的確認
形成的通道
channel = AMQP.channel
創建於RabbitMQ的一個隊列
channel.queue(receiver_id, :auto_delete => false, durable: true)
通道扇出
sender_exchange = channel.fanout(sender_id+"exchange")
渠道發佈
channel.publish(message)
現在我想acknowledged的消息使用Ruby on Rails的接收發送器，讓我知道我使用哪種方法來獲得acknowledgement。
答案真的取決於「確認收到的消息」應該在您的應用程序中的含義。這裏有兩種可能性：
在你的聊天功能獲得，應該確認的意思選項1（消息是從你的客戶端到服務器）還是選項2（消息是從你的客戶端到另外一個或多個客戶端）？
Confirms (Publisher Acknowledgements)是RabbitMQ的一項功能，該功能擴展了AMQP以確認發佈者已收到經紀人的消息。這可能是選項1的最佳解決方案。它可能不是您想要的選項2，因爲它將確認即使該消息未被路由到任何消費者。請參閱「何時會確認消息？」部分在上面鏈接的文檔中。
選項2有點像電子郵件客戶端中的「已讀回執」。它將要求接收者在收到消息並顯示消息後發送收據消息。
要在rails中實現確認，假設您使用Bunny作爲您的AMQP客戶端，請遵循Publisher確認示例here。它可能是這個樣子：
# wherever I create my channel
channel.confirm_select
# publish my messages
channel.wait_for_confirms
如果你想在被消費者（它聽起來並不像你知道當它是由經紀人收到後收到消息知道;如果所以，@Ryan Hoegg的答案會爲你提供你所需要的），你需要做一個高度異步的變體RPC pattern。
RPC通常是同步的：你發送一個命令（在這種情況下通過RabbitMQ隊列），並在運行完成後立即得到響應。在「閱讀回執」的情況下，該命令將來可能會執行很長時間。
如果你堅持使用RabbitMQ，下面是你如何在概念上實現讀 - 收據。這需要更多的代碼，因爲RabbitMQ不會自動支持/很長一段時間沒有原始語言，請看是否收到了某些東西。閱讀回執可以使用一個隊列（以及恆定的空間;每個聊天（對等對）沒有備份的讀取通知消息填充RabbitMQ）來實現。
說愛麗絲希望從她的消息發送給鮑勃的讀收據。
message_id字段非常適合此目的。 Alice應該用增加的ID手動「標記」每條消息。實施例（愛麗絲）：
message_number = message_number + 1
sender_exchange.publish(message_body, :message_id => message_number)
alice_bob_read_receipts（或對應於receiver_id變量的東西;只要它是唯一的）。宣言應該是冪等的/無條件的。應該聲明該隊列的x-max-length爲1和x-overflow的drop-head（如果在老版本的RabbitMQ上，x-overflow可能不被支持，但默認行爲將是你想要的）。實施例（愛麗絲）：
read_receipt_queue = channel.queue(
"#{receiver_id}_#{sender_id}_read_receipts",
:arguments => {
"x-max-length".to_sym => 1,
"x-overflow".to_sym => "drop-head"
})
alice_bob_read_receipts隊列。 RabbitMQ元數據字段旨在用於這樣的用途，所以它可以用來存儲Bob讀取的消息ID。實施例（鮑勃）：
read_receipt_queue = channel.queue(
"#{receiver_id}_#{sender_id}_read_receipts",
:arguments => {
"x-max-length".to_sym => 1,
"x-overflow".to_sym => "drop-head"
})
exchange = read_receipt_queue.default_exchange
# Assume we've got a list of messages Bob has "read" somewhere
# and each item in that list is the exact same triple as received
# by the Queue#consume method's block:
# http://rubybunny.info/articles/queues.html#handling_messages_with_a_block
viewed_messages.each do |delivery_info, properties, payload|
exchange.publish("", :correlation_id => properties.message_id)
end
Queue#pop，但效率較低，可能會阻止你的程序）。如果消費者獲得任何數據，則愛麗絲應設置她的「鮑勃已經讀取了高達此數字的消息」，以抵消彈出消息correlation_id中收到的值，然後更新UI /讀取回執狀態。只有在收到的值大於Alice以前知道的已讀狀態（因爲郵件可能丟失或重新發送）時才應該執行此更新。實施例：
read_receipt_queue.subscribe(...) do |delivery_info, properties, payload|
if properties.correlation_id > known_messages_bob_read
known_messages_bob_read = properties.correlation_id
end
end
有改善 「讀回執」 圖案的可靠性和/或行爲的幾種方法：