ActiveMq，未消费的消息总是在broker的内存中？

发布于 2024-11-29 02:08:22 字数 516 浏览 1 评论 0原文

我正在使用 ActiveMQ，并且有一个问题：在等待消费者时，持久化消息如何以及何时真正交换到磁盘？

我正在使用虚拟主题，并创建队列消费者来接收来自它们的消息。所有消息都是持久化（我已经验证所有未消费消息的记录确实存在于持久性存储中）

我有多个定期上线和离线的消费者。将jconsole连接到activemq后，我注意到所有未使用的消息似乎都包含在代理的内存中。它们不会交换到磁盘，至少我无法验证这一点。设置memoryUsage或打开ProducerFlowControl - 没有任何效果。如果在流量控制打开的情况下达到内存使用限制，代理是否会被阻止，或者如果流量控制关闭，则内存百分比使用持续增加。

activemq 何时通过将消息存储到磁盘/持久性存储来释放内存？或者确实如此？当队列中有数百万条未消耗（待处理）消息时，如何验证磁盘空间而不是 RAM 会长期限制代理？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

半岛未凉 2024-12-06 02:08:22

请在打开内存使用情况下重新检查，您可以指定消息应持续存在的不同限制。在下面的示例中，当 64 MB 内存已满时，它将开始写入磁盘，最多可达 100 GB。

  <systemUsage>
   <systemUsage>
    <memoryUsage>
      <memoryUsage limit="64 mb" />
    </memoryUsage>
    <storeUsage>
      <storeUsage limit="100 gb" />
    </storeUsage>
  </systemUsage>
</systemUsage>

Please recheck with memoryUsage on, you can specify different limits at which message should persist.In the below example, when 64 mb of memory is full, it starts writing on to disk upto 100 gb.

  <systemUsage>
   <systemUsage>
    <memoryUsage>
      <memoryUsage limit="64 mb" />
    </memoryUsage>
    <storeUsage>
      <storeUsage limit="100 gb" />
    </storeUsage>
  </systemUsage>
</systemUsage>

回复收藏 0 原文

找个人就嫁了吧 2024-12-06 02:08:22

尝试使用storeCursor并在destinationPolicy中设置内存限制，这将对每个队列从磁盘拉入的内存/消息量实施限制...

   <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry queue=">" producerFlowControl="false" memoryLimit="100mb">
                    <pendingQueuePolicy>
                        <storeCursor/>
                    </pendingQueuePolicy>
                </policyEntry>
            </policyEntries>
        </policyMap>
    </destinationPolicy>

try using the storeCursor and setting the memory limit in the destinationPolicy, this will enforce a per queue limit to the amount of memory/messages it will pull in from disk...

   <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry queue=">" producerFlowControl="false" memoryLimit="100mb">
                    <pendingQueuePolicy>
                        <storeCursor/>
                    </pendingQueuePolicy>
                </policyEntry>
            </policyEntries>
        </policyMap>
    </destinationPolicy>

回复收藏 0 原文

~没有更多了~