node-amqp，限制监听事件的套接字时间

Question

假设我喜欢我的 rabbitmq 队列上的 100000 个事件，限制系统串联处理它们而不是尝试一次消耗所有事件的最佳方法是什么？

我正在尝试几个选项，但是，机器在尝试一次处理所有选项时冻结。

Answer 1

您可以这样做（假设您使用的是 amqplib）

channel.get('queueName', (err, msgOrFalse) => {
    if (err) { 
        // Handle err
    } else if (msgOrFalse) {
       // Handle message
    }
};

这会一一获取消息，因此不是一次全部。你当然需要反复调用。

Answer 2

我找到了答案，我只需要使用prefetch 来确保我可以一次处理n 个值。