RabbitMQ 发布到交易所确认

Question

我想在关闭 AMQP 连接之前返回一个确认消息已成功发布到交换器的检索。目前，我正在使用超时功能来允许在关闭连接之前发布消息。这不是正确的方法。有人可以帮助检索确认，以便我可以根据成功发布关闭连接吗？

我使用的代码如下：

function toExchange(msg)
{
    amqp.connect('amqp://localhost:5672', function(err, conn) //local connection
    {
        conn.createChannel(function(err, ch)
        {
            var exchange = 'MessageExchange';
            ch.assertExchange(exchange, 'fanout', {durable: true});
            ch.publish(exchange, '', new Buffer(msg));
            console.log("Sent to Exchange: %s", msg);
        });
        setTimeout(function() { conn.close(); }, 5000);
    });
}

Answer 1

您可以使用名为“Publisher Confirms”的 RabbitMQ 扩展。这里有更多信息：https://www.rabbitmq.com/confirms.html#publisher-confirms。

消息发布到交换器时不会通知您，但发布并路由到所有队列时：https://www.rabbitmq.com/confirms.html#when-publishes-are-confirmed

如果您在 nodeJS 中使用 amqplib，您可以使用以下 sn-p 代码：https://www.squaremobius.net/amqp.node/channel_api.html#confirmchannel

它使用回调#waitForConfirms(function(err) {...})，当所有发布的消息都被确认时触发。