ActiveMQ 非持久交付模式的限制？

Question

我在需要以下要求的地方使用 ActiveMQ

• 拥有非常快的消费者，因为我的生产者已经非常快了
• 需要每秒至少处理 2K 条消息
• 在服务器崩溃或其他故障的情况下不需要再次处理/使用消息。我可以再次触发整个过程。
• 需要运行非常正常的配置服务器 - 4Gib RAM

我已经配置了如下所示的 ActiveMQ

• 使用non-persistent delivery mode (vm://localhost)(http://activemq.apache.org/what-is-the-difference-between-persistent-and-non-persistent-delivery.html)
• 使用 Spring 集成在队列/通道中/从队列/通道中放置/获取消息。
• 将max-concurrent-consumers 与10 线程一起使用
• 假设所有其他配置默认使用 ActiveMQ 和 Sprig-integration。

问题/疑问

• 我不确定 ActiveMQ 如何在non-persistent delivery mode 的情况下存储消息，一旦我的队列大小超过某个限制，我的进程是否可能会因内存不足错误而失败？我问这个是因为很难为我测试整个过程。因此，在触发流程之前，我需要了解限制。
• 如果non-persistent delivery mode 不足以满足我的上述要求，是否有任何性能调整技巧可以通过persistent delivery mode (tcp://) 达到我的要求。我已经用这种模式进行了测试，但是这里的消费者似乎很慢。另外，我已经尝试使用DUPS_OK_ACKNOWLEDGE 让我的消费者快速使用persistent delivery mode，但没有运气。

注意：我使用的是最新的 ActiveMQ 版本5.14

Answer 1

我不确定 ActiveMQ 如何在非持久传递模式下存储消息

activemq首先将消息存储在内存中，它也会将其交换到磁盘（在activemq的数据路径中有一个tmp_storage文件夹）。

一旦我的队列大小超过某个限制，我的进程是否可能会因内存不足错误而失败

我从来没有遇到过activemq内存不足的情况，即使有大约一百万条消息。

您也可以通过生产者流量控制（http://activemq.apache.org/producer-flow-control.html）来确保。 当没有消费的消息太多时，您可以让生产者挂起。

关于持久交付的性能，我也没有什么好的方法。