问题标签 [activemq]

我在用 Java 模拟重载服务器时使用 ActiveMQ。主要是没问题，但是当我收到超过 600 个请求时，事情就发生了 WTF！

我认为瓶颈是我的主服务器，也就是下面的这个人。我已经在重用连接并创建各种会话来使用来自客户端的消息。就像我说的，我每个连接使用大约 50-70 个会话，重新利用连接和队列。知道我可以在下面重用/优化我的组件/侦听器吗？

架构如下：

* = 各种

客户端---> JMS MasterQueue ---> * Master ---> JMS SlavaQueue ---> * SlaveQueue

主要是我为 Master 的每个会话创建一个 Temp Queue --> Slave 通信，这对性能来说是个大问题吗？

我正在模拟服务器的过载，我收到了这个错误：

我已经阅读了这个页面http://activemq.apache.org/javalangoutofmemory.html，我可以增加内存大小。但是我该怎么做呢？我需要修改哪个文件，？我试图通过 bin/activemq 脚本传递参数，但没有运气。

我们正在评估 ActiveMQ，我想知道您对此有何看法。欢迎任何反馈。

编辑：

实际上，我需要知道以下内容：它是如何扩展的？稳定性怎么样？对于生产环境是否足够稳定？内存消耗等

我在使用 ActiveMQ 设置多播传输时遇到问题。我注意到 5.2 版有一个错误，它甚至无法构建正确的工厂（在 5.3 中修复）。这个错误存在的事实让我想知道是否有人在使用多播。当它最近才启用时，如何对其进行测试？

只要知道这是可能的，就会对我有很大帮助。谢谢。

编辑：

事实证明我一直在建立连接。setClientID 是一个同步调用，因此客户端会无限期地坐下来等待。这对于任何使用多播的人来说都是一个地雷，在 AMQConnection 对象中有许多调用调用ensureConnectionInfoSent()的调用会阻塞，直到它收到响应。这只是与多播不兼容。

我正在学习如何使用 ActiveMQ，现在我们面临以下问题。

假设我在 ActiveMQ 上有一个名为 topic.test 的主题，它有两个订阅者。在给定的时刻，我只有一个订阅者在等待消息，并且生产者为我上面提到的主题发送消息。

好的，已连接的订阅者收到消息，但其他订阅者不应该稍后在连接时收到该消息吗？好吧，就我而言，它没有发生：我的订阅者只在连接时接收消息。他们没有收到在未连接时发送的所有其他消息。我可能做错了什么？

这是我为测试 ActiveMQ 而编写的一些源代码。也许你会发现它有什么问题。

我的消费代码：

这是我的生产者代码：

我是否应该向 ActiveMQ 添加任何其他配置，以便我的消费者可以获得较旧的消息？

阅读 ActiveMQ 文档（我们使用的是 5.3 版本），我找到了有关在 ActiveMQ 中使用 JDBC 持久性适配器的可能性的部分。

有什么好处？它是否提供了性能或可靠性方面的任何收益？我应该什么时候使用它？

对于生产环境，Apache Geronimo 是否更适合使用 ActiveMQ、Derby、Solr 的应用程序？

我这样创建我的消费者（在 C# 中使用 NMS 库）：

当我收到一条消息并且不在会话上调用 Commit 时，它会返回到原始队列中。然后它会在被丢弃之前再尝试重新发送 5 次。为什么消息被丢弃而不是发送到 DLQ？！

我需要队列来执行不重复政策。可能吗？如果是这样，如何？（我已经搜索了几个小时......）

编辑：

ActiveMQSession 实现有以下几行：

ActiveMQMessageTransformation 是可插入的（您可以设置它），但下面的 if 语句是相当无可争议的。

任何想法，除了改变他们的代码？

我正在使用 activeMQ 5.3 通过 blazeds 3.2 向 flex 客户端发送消息。

当客户端第一次连接时，我可以看到对 activeMQ 代理的订阅。但是，在我终止运行客户端的浏览器后，即使不再使用任何消息，订阅仍保持打开状态。这最终导致 Web 服务器内存不足。从日志看来，Blazeds 正在退订订阅源。

当没有客户端连接时，blazeds 不应该停止订阅吗？他为什么不这样做？

您可以在下面找到日志文件的片段。

您可以在下面找到用于 ActiveMQ 的配置

最好的问候