如何使用NodeJs(amqplib)获取RabbitMQ队列的未确认消息计数



如何使用NodeJs(amqplib(获取RabbitMQ队列的未确认消息计数。

使用CCD_ 1或CCD_。

我有很多动态队列,这些队列由多个消费者使用,我想在处理完所有作业后删除队列。

问题是,当消费者连接到队列时,我会检查消息计数是否为零,如果消息计数为零,我会删除该队列,但此时如果该队列有一些未确认的消息,但消息计数为0,我该如何处理。

在这种情况下,您可以在创建时将自动删除标志设置为队列,并在消耗时检查队列大小。

当队列大小为0时,您只需停止此使用者的消费进程并关闭此使用者的通道。当所有消费者关闭他们的通道时,RabbitMQ将自动删除队列。

最新更新