如何将异步函数传递给 amqplib Channel#consume

Question

我使用 amqplib 的 nodejs 代码几乎与 recieve_logs_topic.js example 相同 它从 RabbitMQ 队列中读取数据，然后对其进行处理。示例中的处理函数是 logMessage()，它打印要记录的消息。这是一个同步操作。我的处理器是异步的和基于回调的。

查看channel_model.js 的代码会发现函数体中的以下注释：

// NB we want the callback to be run synchronously, so that we've   
// registered the consumerTag before any messages can arrive.

可以吗？

Answer 1

示例中的代码也是异步的，但基于 Promise。如果您需要使用基于回调的 API，请查看此处：https://github.com/squaremo/amqp.node/tree/master/examples/tutorials/callback_api