ActiveMQ:调度的队列包含的消息多于预取大小
ActiveMQ是一个开源的消息中间件，它实现了Java Message Service (JMS) API，提供了可靠的消息传递机制。它使用队列和主题的方式来进行消息的发布和订阅。
ActiveMQ的调度队列是用于存储消息的地方，当消息生产者发送消息时，消息会被存储在调度队列中，等待消费者来消费。调度队列可以包含多个消息，而预取大小是指消费者一次从调度队列中预取的消息数量。
预取大小的设置可以影响消息消费的性能和吞吐量。如果调度队列包含的消息多于预取大小，消费者可以一次性获取多个消息进行处理，从而提高处理效率。然而，如果预取大小设置过大，可能会导致消费者一次性获取过多的消息，造成资源浪费和处理延迟。
ActiveMQ的优势在于其稳定性、可靠性和灵活性。它支持多种消息传递模式，包括点对点和发布/订阅模式，可以满足不同场景下的需求。同时，ActiveMQ提供了丰富的功能和管理工具，如消息持久化、消息过滤、事务支持等，使得开发者可以更方便地使用和管理消息队列。
在云计算领域，ActiveMQ可以被广泛应用于各种场景，如分布式系统的消息通信、异步任务处理、日志收集和分析等。它可以作为微服务架构中的消息中间件，实现不同服务之间的解耦和异步通信。此外，ActiveMQ还可以与其他云计算服务相结合，如云数据库、云存储等，实现更复杂的应用场景。
腾讯云提供了一个与ActiveMQ类似的消息队列服务，称为消息队列 CMQ。CMQ是一种高可靠、高可用、高性能的分布式消息队列服务，可以满足各种消息通信需求。您可以通过腾讯云的CMQ产品页面了解更多信息：https://cloud.tencent.com/product/cmq
相关·内容
我将预取大小设置为1(url中的jms.prefetchPolicy.all=1)。在web控制台中，我可以看到所有消费者的预取都是1。一个客户卡住了，他的分派队列-see my 上有67条消息
你能告诉我这是怎么发生的吗？我已经阅读了很多关于这方面的文章，我的理解是Dispatch queue大小应该达到预取大小</e
浏览 18提问于2018-12-14得票数 0
回答已采纳
我们有一个典型的场景，其中我们必须对一组克隆的消费者应用程序进行负载平衡，每个应用程序都运行在不同的物理服务器上。在这里，我们应该能够动态添加更多的服务器以实现可伸缩性。但我们不希望服务器中的长时间运行作业导致消息在其队列中等待消费。
为了解决这个问题，我们考虑为每个服务器应用程序配置2个concurrentConsumers。当较旧的消息被线程处理时，新消息到达时，第二个线程将从队列中使用新<em
浏览 0提问于2013-01-24得票数 0
我使用的是最新版本的ActiveMQ Artemis。 我的用例非常简单。代理向消费者发送大量消息-单个队列。我每个队列有2个消费者。消费者被设置为使用消息的默认预取大小(1000)。有没有办法监控从每个消费者预取和处理了多少消息？
浏览 30提问于2021-08-06得票数 0
回答已采纳
根据我的理解，如果我将activemq值=1分配给消费者A，我会阅读有关prefetch buffer.As的文档。Activemq向A推送一条消息activemq A向Prefetch发送确认，然后仅.once向A推送另一条消息。谢谢。
浏览 2提问于2013-09-05得票数 11
1回答
在ActiveMQ中有一个与50+使用者一起的队列，是否有一种方法可以以每秒最多1个事件的速度向消费者发送？这是为了控制大量的事件调度。我的jms预取策略配置为5，我不想在几秒钟内向消费者发送100条消息。相反，我希望它是一个稳定的流动。
如何将队列使用
浏览 5提问于2017-12-10得票数 1
我有一个要求，当客户端应用程序在5秒的时间跨度内发送超过1000个请求时，我需要通过整形(排队)入站流量来限制。我遵循的解决方案是:我有一个camel:throttle，将最大请求数设置为1000，timespan设置为5秒。当超过阈值时，我将捕获节流异常，并且在onException块中，我将节流消息发送到ActiveMQ请求队列，以便稍后进一步处理，因为根据1000请求/5秒配置，Camel过载。我成功地实现了上述，但我希望骆驼消费者以后进一步处理不是所有来自ActiveMQ</em
浏览 8提问于2016-03-07得票数 2
我使用Apache.NMS.AMQP (v1.8.0)连接到AWS托管ActiveMQ (v5.15.9)代理，但在为连接/消费者/目的地设置预取大小(无法为它们设置自定义值)时遇到问题。在深入研究时，我发现默认的预取值(DEFAULT_CREDITS)设置为200。
为了测试这种行为，我编写了测试，将220条消息排在一个队列上，创建两个使用者，然后使用消息。其结果是，如预期的那样，第一消费者将2
浏览 3提问于2020-01-08得票数 0
回答已采纳
1回答
我正在通过STOMP与ActiveMQ交互。我有一个发布消息的进程和多个订阅和处理消息的进程(大约10个并行实例)。在阅读一条消息后，我希望确保如果由于某种原因，我的应用程序失败/崩溃，消息将不会丢失。因此，我自然而然地转向了事务。不幸的是，我发现一旦消费者将消息作为事务的一部分读取，下面的所有消息都不会发送给其他消费者，直到事务结束。
测试用例：abc队列</e
浏览 2提问于2013-02-27得票数 0
我使用的是Jboss-fuse-6.3，带有外部Apache-activemq-5.15.2。我在一个队列上绑定了50个消费者，在“活动消费者”页面的活动MQ门户上，我注意到所有50个消费者都是绑定的，但队列上的消息分布并不相同。即时消息从Apache Camel Route进入队列</em
浏览 33提问于2017-12-19得票数 0
回答已采纳
我是一个activeMQ新手。是否可以在activeMQ xml配置中添加一些内容，以便在(例如)某个特定队列中已经有100条消息时，强制队列停止接受消息？
浏览 2提问于2010-08-30得票数 0
我是一个相当新的ActiveMQ用户，我正在寻找一种方法来获得队列连接客户端的详细调试信息。我的问题是:我有一个通过队列向客户端发送消息的服务器。使用与代理相关联的管理网页，我可以验证以下内容:队列已创建，存在与队列相关联的使用者，消息已入队，消息已被调度，调度的队列
浏览 0提问于2011-03-31得票数 3
我用的是activemq，骆驼和弹簧的组合。对于队列，我们在它们上有多个消费者；在一些队列使用者上，我们看到有挂起的消息(高达100条，这与预取相同)，而且它们根本没有被处理，但是对于同一个队列的其他消费者，它是正常的。我更深入地了解了发生了什么，并发现spring缓存连接工厂可能导致了这个问题--我们怀疑这个缓存连接工厂可能使一些客户端处于非活动状态，而预<em
浏览 1提问于2017-08-07得票数 2
回答已采纳
我有消费者处理需要大量时间和资源的工作。因此，消费者一次处理一个以上的工作是不合理的。我的问题是：
使用者可能会从多个队列预取消息。当它可以处理其中一条消息时，另一条<e
浏览 5提问于2022-08-02得票数 0
回答已采纳
我在Apache中使用ActiveMQ。现在，我正在经历这样的问题:在ActiveMQ中，有大量的待定消息。消息处于挂起状态，排队列过程非常缓慢。我的理解是，通常有那么多挂起的消息，每个消费者的分派队列的大小应该已经接近默认的预
浏览 0提问于2018-03-05得票数 2
我们试图在ActiveMQ 5.9.1之上构建一个作业队列系统。我们在activemq中使用AMQP1.0支持，目前客户端代码使用qpid jms库。对于作业队列系统来说，重要的是我们可以将预取设置为1-我们希望我们的工作人员一次只能得到一个任务，竞争的消费者模式。clientid=job-manager&remote-host=default&max-prefetch=1
然而，ActiveMQ似乎
浏览 6提问于2014-06-10得票数 0
回答已采纳
1回答
我使用的是当前的Apache.NMS 1.7.1和Apache.NMS.ActiveMQ 1.7.2。testQueue包含>>20_000消息。在等待了几秒钟之后，_collection包含了所有的消息，而我没有确认其中的任何消息。
如果我对的理解是正确的，我最多应该得到1000英镑，直到我开始承认它们。一旦代理向使用者发送了预取限制数量的<
浏览 3提问于2017-04-19得票数 0
2回答
我们是否可以将ActiveMQ配置为每个应用程序实例只发送一条消息？实际上，我在集群模式下安装了tomcat。
我使用Spring JMS模板作为消费者。
浏览 1提问于2014-11-17得票数 0
我有以下用于从队列中消费消息的配置。我需要确保任务执行器一次只执行一个任务，因此我也配置了任务执行器，如下所示。corePoolSize" value="1" /></bean>
当我按照上面的方式配置任务执行器时，每次会消耗10条消息(队列中有大量消息流)，容器停止
浏览 4提问于2013-05-17得票数 1
在MassTransit中，我想做一个ASP .NET核心健康检查，当“预取缓冲区”已满，并且每秒消耗的量足够低时，它会认为我的应用程序处于“降级健康”状态。换句话说，如果队列上仍有消息，而消费者速度很慢。然后，我将使用它来配置AWS，以基于健康状况自动缩放我的消费者。 有没有办法从外部访问已预取的消息数量？或者这完全封装在MassTransit中？我使用ActiveMQ作为底层传
浏览 17提问于2021-01-27得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
