有没有办法限制一个队列在RabbitMQ中可以容纳的最大消息数？
例如，如果此数字设置为10，而当前大小为10，则在将新消息推送到队列(FIFO)时，最旧的消息将被丢弃。
浏览 14提问于2017-06-29得票数 3
回答已采纳
我希望我的pub/sub只将最后可用的消息存储在通道上，并转储由于用户太慢(或暂停)而不会被消耗的所有先前的消息。ZMQ有选项，但是RabbitMQ在Python (pika)上有类似的选项吗？发布服务器以50 to进行更新，而一些订阅者处理的速度却不太快(在10到50 to之间)。我不希望他们处理队列中最古老的消息(这意味着处理已经过时的数据)；当它准备使用时，它必须只
浏览 1提问于2018-05-01得票数 0
回答已采纳
我在rabbitmq上用芹菜。我已经向队列发送了数千条消息，这些消息正在成功处理，一切工作正常。然而，几个rabbitmq队列中的消息数量增长得相当大(队列中有数十万个项目)。这些队列被命名为celeryev.[...] (参见下面的屏幕截图)。这是适当的行为吗？这些队列的用途是什么?不应该定期清除它们吗？有没有</em
浏览 5提问于2013-07-22得票数 17
回答已采纳
9回答
有没有人知道有没有办法从客户端应用程序检查RabbitMQ队列中的消息数量？
我正在使用.NET客户端库。
浏览 1提问于2009-06-24得票数 57
回答已采纳
我有一个带有RabbitMQ的应用程序，其中我使用HTTP API (/api/ queue /vhost/name)获取Rabbit队列中的消息数量。我认为信息总是最新的，而且是管理页面在给定的时间间隔内更新。谢谢
浏览 0提问于2017-08-31得票数 0
我正在通过单个进程(多进程)启动rabbitmq使用者的多个实例(相同的队列)。在中断时，我希望所有的消费者都正常地关机。我的意思是，如果从队列中获取的进程已经在运行，请让它完成，然后停止消耗更多的请求并停止队列。
有没有一种方法可以知道队列是否正在执行某件事，然后等待它完成，然后停止队列？
浏览 1提问于2018-06-21得票数 1
1回答
使用用于Node和RabbitMQ的AMQP模块，有没有办法知道队列中有多少订阅者？有没有办法计算一个队列中的订阅者数量？
我们设置了心跳，因此服务
浏览 0提问于2013-05-03得票数 5
回答已采纳
我们决定使用spring websocket实现和RabbitMQ作为消息代理。在我们的应用程序中，每个用户都需要订阅其用户队列/exchange/amq.direct/update以及其他用户也可以订阅/topic/someUniqueName的另一个队列。在第一次性能测试中，我们采用了简单的方法，每个用户都订阅两个新队列。
当运行测试时，当同时连接大约800个用户
浏览 3提问于2018-05-28得票数 0
回答已采纳
1回答
我正在设置一个金字塔的web服务。典型的视图请求将非常长，大约需要15分钟才能完成。因此，我的想法是使用芹菜和rabbitmq代理对作业进行排队。我想知道什么是最好的方法来确保不会发生糟糕的事情。具体地说，我希望防止任务队列溢出。然而，我不能预测涉及的I的数量，所以这不能
浏览 3提问于2013-04-18得票数 4
回答已采纳
因此，我已经声明了一个长度为1的队列，而发布者不是自动地对消息进行自动编码，这意味着我有ack每一条消息，我receive.So，在这里，没有被加标的消息会发生什么呢？当新消息到达队列时，旧的未加标记消息会发生什么情况？channel.queueDeclare("myqueue", false, false, false, args);
channel.basicConsume("myqueue"
浏览 2提问于2015-06-22得票数 1
我使用的是RabbitMq的Prometheus插件，它可以跟踪发布到不同队列的消息数量。在RabbitMq中，默认情况下，每个队列都会有一个与之配对的错误队列。因此，如果原始队列被称为ConnectionQueue，那么将会有一个用于错误的ConnectionQueue_Error队列。所以我们的即时向量看起
浏览 40提问于2020-06-18得票数 1
我计划使用Kafka在队列中存储消息，并在特定队列中的消息数量达到某个限制(例如1000)时获取消息。
有没有办法让Kafka服务器在队列达到极限时通知消费者？
浏览 0提问于2014-05-27得票数 1
1回答
我正在开发一个使用Micronaut的应用程序，它需要使用RabbitMQ队列中的消息。问题是队列可以提供很多消息，所以我希望有一个参数化的消费者实例数量。TestQueue") // some treatment } 有没有办
浏览 22提问于2021-07-02得票数 0
回答已采纳
我已经运行了几个月的RabbitMQ服务器。今天早上，我无法连接到它，我的应用程序超时，管理客户端没有响应。重启了机器。申请仍在超时。我能够登录到Management客户端，但我看到了以下消息：
** Generic server &
浏览 0提问于2018-09-11得票数 9
回答已采纳
我有一个RabbitMQ设置，其中(java)生产者向扇出交换发送消息，这些消息由消费者处理。如果消息在消费者死亡时丢失是没有问题的，所以为了提高性能，我在消费者端设置了autoAck=true。现在我正在调查一种情况，在这种情况下，消费者可以处理消息的速率低于发送消息的速率。
过了一段时间，一定会有(大量)积压的消息在某处排队。有没有办法了解这个待办事项？使用i
浏览 0提问于2014-10-14得票数 4
我很惊讶地在rabbitmq文档上看到，拥有非常大的队列大小会对队列性能产生负面影响。我有一个作业分派器，它可以潜在地将30k+消息排入队列供作业使用者使用，并且即使在增加了使用者的数量之后，我也注意到性能很差。然后我从发布端编写代码来检查队列的大小，如果太大，休眠一段时间，直到队列变小。
我发现这可以提高性能，但我质疑这背后的逻辑。出版商不得不意识到排队系统的如此详细，以至于它不
浏览 0提问于2019-01-01得票数 0
2回答
当我在Redis后端运行Celery时，有没有办法限制队列大小？ 类似于rabbitmq的队列预声明中的x-max-length
浏览 27提问于2019-10-09得票数 4
在我的项目中，当数据进入队列时，我将使用rabbitMQ来处理一些数据。我正在使用兔子创业板，一个RabbitMq客户端，它提供与rabbitMQ交互的接口。我的问题是，每当出现异常或服务器在处理队列中的数据时意外停止时，来自队列的消息就会丢失。
我想知道人们如何处理rabbitMQ队列中丢失的</em
浏览 1提问于2016-10-16得票数 0
回答已采纳
1回答
我有一个交换，并且只有一个队列绑定到它。当消息发布速率超过某个上限时，rabbitmq会自动限制传入消息速率。我的消息不是持久的，所以
浏览 2提问于2019-07-23得票数 1
1回答
我正在寻找Max消息允许在RabbitMQ中的队列中使用，我从一些链接中了解到，除非我们指定，否则这是没有限制的。一段时间以来一直在搜索一些授权的/来自RabbitMQ的信息，但没有找到以下链接以外的确切信息。那么，对于我的场景，我没有指定最大限制，现在我想知道，如果队列中允许的最大消息是无限的，那么
浏览 3提问于2016-11-24得票数 1
云服务器
ICP备案
即时通信 IM
云直播
对象存储
腾讯云开发者
