如何使用NodeJs（amqplib）获取RabbitMQ队列的未确认消息计数
如何使用NodeJs (amqplib)获得RabbitMQ队列的未确认消息计数？
我们可以使用 checkQueue 或 assertQueue 方法轻松获取队列的总消息数。
我有很多动态队列，这些队列被多个消费者使用，我想在所有作业处理后删除队列。
问题是，当消费者连接到队列时，我会检查消息计数是否为零，如果消息计数为零，我会删除该队列，但此时如果该队列中有一些未确认的消息，但消息计数为0，那么我该如何处理。
共有1个答案
在这种情况下，您可以在创建时将自动删除标志设置为队列，并在消耗时检查队列大小。
当队列大小为 0 时，您只需停止此使用者的使用进程并关闭此使用者的通道。当所有消费者关闭他们的频道队列时，RabbitMQ 会自动删除。
-
问题内容： 我们正在使用amqplib来发布/使用消息。我希望能够读取队列中的消息数（理想情况下是已确认和未确认）。这将使我能够向管理员用户显示良好的状态图，并检测某个组件是否无法满足负载需求。 我在amqplib文档中找不到有关读取队列状态的任何信息。 有人可以指出我正确的方向吗？ 问题答案： 使用皮卡： 使用PyRabbit： 使用HTTP 句法： 例： 注意：默认虚拟主机是需要转义为 使用C
-
问题内容： 我的Java应用程序将消息发送到RabbitMQ交换，然后交换将消息重定向到绑定队列。我将RabbitMQ与Springframework AMQP java插件一起使用。 问题：消息进入队列，但消息始终处于“未确认”状态，永远不会变为“就绪”状态。 可能是什么原因？ 问题答案： 一条未确认的消息表示您的使用者已经读取了该消息，但是该使用者从未将ACK发送回RabbitMQ代理以表示它
-
在队列选项卡的rabbitMQ web界面上，我看到了“概述”面板，我在其中找到了以下内容： 排队消息： 准备好了 未确认 总数 我猜“总数”是多少。但什么是“准备就绪”和“未确认”？“准备好了”——传递给消费者的信息？“未确认”-？ 消息费率： 发表 交付 重新交付 承认 这些信息是什么？尤其是“重新交付”和“确认”？这是什么意思？
-
好吧，我不需要详细介绍我设置的整个系统， 我遇到的问题是，当使用者取消(amqpchannel->basic_cancel)对队列的监听时，会留下一个额外的消息未被这个工作者确认。它也不会触发正常的回调来处理此消息。 队列正在阻塞（使用wait) 预取为1，这是您所能拥有的最小值 使用者可以动态侦听() 使用者可以动态忘记() 我不会告诉给定使用者使用或取消给定队列的确切方式。但这一切都是完美的工
-
（在iQueueBrowser.GetEnumerator上进行了探索，但它会将消息下载到客户端。）
-
我在Weblogic 12c上部署了一个MDB，它从JMS队列（UDQ）读取消息。MDB正在读取消息，但它没有从JMS队列中删除，这导致消息被重复读取。所以，我想知道MDB何时确认JMS队列它成功读取了消息，并且队列应该删除该消息。
-
我将不折不扣地学习以下教程：https://www.rabbitmq.com/tutorials/tutorial-two-java.html。 我以这样的方式启动RabbitMQ服务器： 我生成了两个消费者，当我Ctrl+C其中一个时，另一个正在运行的消费者不会接收到最初发往前一个消费者的消息。如何在Ctrl+C'ing从一个消费者中重新传递消息？ 编辑：我现在正在通过'brew'安装Rabbi
-
我有一个应用程序，它使用spring AMQP向其他应用程序消费和生成消息。我有一个场景，其中发生了一些异常，我需要重新排队回到RabbitMQ。对于一些例外情况，我需要忽略（基本上我需要忽略消息，无需重新查询） 目前在下面的代码中，我已经将配置设置为 工厂setDefaultRequeueRejected（假）； 但我的要求是动态拒绝某些消息，并将某些消息重新排队回RabbitMQ。 请建议