Channel.get 未触发

问题描述

我使用 RabbitMQ 队列在消费者之间发布和接收消息，主要问题是我想接收一条消息然后退出。从本网站上的其他答案中，我看到 channel.get 似乎是做到这一点的最佳方式。但是，我无法让它工作。 This 是我一直在使用的答案。

我当前的代码：

var amqpChannel = null;
var queue = "test";

amqp.connect(cluster,(error0,connection) => {
    if (error0) throw error0;

    connection.createChannel((error1,channel) => {
        if (error1) throw error1;

        amqpChannel = channel;
    });
});

var readMessage = function() {
    if (amqpChannel)
    {
        amqpChannel.get(queue,(err,msg) => {
            if (err) console.log(err);
            
            if (msg)
            {
                console.log("Message received: " + msg.content.toString());
                amqpChannel.ack(msg);
            }
        });
    }
}

setTimeout(readMessage,1000);

据我所知，它与上面接受的答案中的代码相同，但我似乎无法让它工作。我错过了什么？

编辑：额外信息

使用 channel.consume 对我有用，它可以获取队列中的任何消息。但是，使用 channel.get 方法不会产生任何结果。我使用 console.log 行来确保正确创建通道，但由于某种原因，channel.get 回调从未被触发。我知道所有连接和队列创建都在工作，我似乎根本无法触发 channel.get 方法。

编辑 2：我发现了问题

我的回调函数不正确。查看文档 here，channel.get 在回调之前需要一个 options 参数，并在修复我的问题中添加该参数。我的工作代码现在是：

var amqpChannel = null;
var queue = "test";

amqp.connect(cluster,{noAck: true},1000);

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

javascript node-amqplib