本月初，我在ComoRichWeb上的RabbitMQ上做了一個演講，與會人員提出的一個問題是“是否可以發(fā)布一條消息供以后使用？” 我回答說，就我所知，這是不可能的，但是可能會有一些技巧來實現(xiàn)它。 好吧，今天晚上，在試圖弄清楚如何使用推送與輪詢模型進行定時通知時，我發(fā)現(xiàn)了使用臨時隊列，x-message-ttl和死信交換的巧妙技巧。

其背后的主要思想是利用2.8.0中可用的新功能， 即死信交換 。 此AMQP擴展允許您在隊列中指定一個交換，當消息過期或被拒絕且requeue設(shè)置為false時，應(yīng)將該消息發(fā)布到該隊列上。

考慮到這一點，我們可以為要稍后發(fā)送的消息創(chuàng)建一個隊列，將x-message-ttl設(shè)置為我們希望在發(fā)送之前等待的持續(xù)時間。 為了確保將消息傳輸?shù)搅硪粋€隊列，我們??只需將x-dead-letter-exchange定義為我們創(chuàng)建的交換（在這種情況下，我將其稱為即時交換），并將隊列綁定到該交換（“ right.now。隊列”）。

在帶有node-amqp的coffeescript中，這看起來像這樣：

amqp = require 'amqp' conn = amqp.createConnection()key = "send.later.#{new Date().getTime()}" conn.on 'ready', ->'conn.queue key, {arguments:{"x-dead-letter-exchange":"immediate", "x-message-ttl": 5000}}

接下來，我定義立即交換，將隊列綁定到它并訂閱。

conn.exchange 'immediate'conn.queue 'right.now.queue', {autoDelete: false, durable: true}, (q) ->q.bind('immediate', 'right.now.queue')q.subscribe (msg, headers, deliveryInfo) ->console.log msgconsole.log headers

最后，在定義了我先前創(chuàng)建的隊列之后，我們要在其上發(fā)布一條消息。 因此，為了重新訪問之前的隊列定義，我們添加了一個publish調(diào)用，以直接發(fā)布到隊列（使用默認交換）。

conn.on 'ready', ->conn.queue key, {arguments:{"x-dead-letter-exchange":"immediate", "x-message-ttl": 5000}}, ->conn.publish key, {v:1}, {contentType:'application/json'}

運行此命令的結(jié)果是我們將等待5秒鐘，然后將消息內(nèi)容和標頭轉(zhuǎn)儲到控制臺。 由于該隊列僅在這種情況下臨時使用，因此我還將隊列的x-expires屬性設(shè)置為在消息過期后的合理時間內(nèi)過期。 這樣可以確保我們不會在周圍坐滿大量未使用的隊列。

這是整個練習的結(jié)果。

amqp = require 'amqp' events = require 'events' em = new events.EventEmitter() conn = amqp.createConnection()key = "send.later.#{new Date().getTime()}" conn.on 'ready', ->conn.queue key, {arguments:{"x-dead-letter-exchange":"immediate", "x-message-ttl": 5000, "x-expires": 6000}}, ->conn.publish key, {v:1}, {contentType:'application/json'}conn.exchange 'immediate'conn.queue 'right.now.queue', {autoDelete: false, durable: true}, (q) ->q.bind('immediate', 'right.now.queue')q.subscribe (msg, headers, deliveryInfo) ->console.log msgconsole.log headers

您可以在github上完整地獲得此練習。

這非常有趣，我計劃在我的生產(chǎn)node.js應(yīng)用程序之一中利用它進行進一步實驗，該應(yīng)用程序使用基于間隔的輪詢來觸發(fā)計劃的事件。

參考： 敏捷開發(fā)人員博客的Rants and Musings中我們的JCG合作伙伴 James Carr 使用RabbitMQ進行的預(yù)定消息傳遞 。

翻譯自: https://www.javacodegeeks.com/2012/04/rabbitmq-scheduled-message-delivery.html

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ：计划邮件传递的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。