javascript - 为什么带有amqplib消耗功能的nodejs是闭包的？

我使用nodejs amqplib模块连接Rabbitmq。
我发现消耗函数变成了闭包函数，但是我不明白为什么。我没有使用闭包。

我的代码如下。我发现returnOK中的corr仍然获得第一次值。当我第二次触发此功能时。 corr还是第一次值。
我认为这很奇怪。有人可以解释吗？

  const corr = new Date().getTime();
  try {
    const params = JSON.stringify(req.body);
    console.log('corr first =', corr);
    await ch.sendToQueue(q, Buffer.from(params), {
      deliveryMode: true,
      correlationId: corr.toString(),
      replyTo: queue.queue,
    });

    const returnOK = (msg) => {
      if (msg.properties.correlationId === corr.toString()) {
        console.info('******* Proxy send message done *******');
        res.status(HTTPStatus.OK).json('Done');
      }
    };
    await ch.consume(queue.queue, returnOK, { noAck: true });
  } catch (error) {
    res.status(HTTPStatus.INTERNAL_SERVER_ERROR).json(error);
  }

最佳答案

似乎您在每个请求上都调用ch.consume，实际上每次都会创建一个新的使用者。您只能这样做一次。

发生的情况是，第一个消费者正在接收消息。

要解决此问题，您可能希望将ch.consume移动到请求处理程序之外。