RabbitMQ：如果消費者永遠消失，請刪除一個隊列？

Question

想象一下，每個用戶都有自己的隊列。當用戶離線時，郵件會被放入隊列中，當他們重新連接時，郵件會收到所有這些郵件。

但是，如果客戶端離開並永不回來（停止使用該服務）會怎麼樣？如果消息在一段時間內沒有被消費，RabbitMQ是否有辦法刪除一個隊列？消息可能會進入，但它們不會熄滅，因爲客戶端不再處於活動狀態。我怎樣才能用amqp.node插件處理這個問題？

Answer 1

試想每個用戶都有自己的隊列。當用戶離線時，郵件會被放入隊列中，當他們重新連接時，郵件會收到所有這些郵件。

這是一個普遍的想法，但one with unfortunate consequences, that you should avoid。

，因爲我是掛在文章中寫道：

您可能會解決此通過在每個用戶的隊列。您 可能會設置您的代碼，以便Web服務器僅在用戶登錄且可用時爲用戶訂閱 隊列。

這並不能解決問題。

現在，您已經有30000條消息分佈在1000個隊列中 - 其本身就是一個不好的 情況。這需要RabbitMQ在隊列中保留隊列和消息。當所有1,000個用戶同時登錄到您的系統時會發生什麼？現在您的Web服務器有1000 隊列訂閱來處理。

當然，你可能會爭辯說，你不會有那麼多的用戶。但情況變得更糟。在你的情況下，你將無法自動地以你想要的方式刪除隊列。

您可以設置一個隊列，在所有使用者斷開連接後自動刪除。但保持隊列將需要每個用戶隊列的消費者，消費者在該用戶存在時連接到該隊列。如果應用程序崩潰，則隊列及其所有消息都將消失。

TTL只會做你想要的一部分。它會在隊列中放置一條消息並在該超時之後刪除該消息...但它不會刪除該隊列。

最終，你不想用RabbitMQ做到這一點。

再次

，從my article on the subject：

再回到原來的情況下，當 用戶不在線，你不能立即將消息發送到他們應該怎麼做？

將消息存儲在數據庫中。

將一個字段添加到數據庫記錄中，該字段說明此消息的來源爲 。當用戶稍後重新連接時，請查詢數據庫以獲取該用戶此時需要查看併發送的任何 消息。

全過程上面開始，然後變成這樣：

• 用戶的瀏覽器連接到SignalR/Socket.io /子彈頭/ WebSockets的網絡上服務器
• Web服務器檢查隊列的過程中所發生的更新長 運行的進程
• 當如果 用戶爲LO一個登錄用戶進來
  • 消息gged中，廣播通過WebSocket的消息給 用戶
  • 如果用戶沒有登錄，存儲信息的數據庫
• 當用戶再次登錄，查詢數據庫，並把所有的等待 消息

這就是你會做一個消息隊列 的想法來之前在玩，對吧？它應該是你現在要做的事，即你有一個消息隊列。

Answer 2

這似乎是可能的，但我沒有嘗試過自己。請參閱：在隊列TTL

https://www.rabbitmq.com/ttl.html

看一路下跌底部。 「這控制了隊列在被自動刪除之前可以不用的時間。」

要查看示例用法，本次測試的節點AMQP代碼庫可能是鼓舞人心：

https://github.com/postwait/node-amqp/blob/f64704d3727266230901598e2daf0fa780766feb/test/test-queue-args.js#L8