问题标签 [activemq]

我有一个通过 java 代码完全配置的嵌入式代理（没有可部署的 xml 文件）。当我将浏览器指向 Web 控制台时，我只得到 404，并且 lsof 显示 8161 上没有任何内容正在监听。是否可以仅使用 Java 代码使用 Web 控制台？我可以使用 ActiveMQ 附带的网络服务器，我可以使用 8161 端口。

我一直在评估 ActiveMQ 作为候选消息代理。我编写了一些测试代码来尝试了解 ActiveMQ 的性能限制。

我可以通过尽可能快地发送消息来在代理中产生失败状态，如下所示：

我很惊讶这条线

当代理进入失败状态时阻塞。我希望会抛出一些异常，所以会有一些迹象表明经纪人失败了。

我意识到我的测试代码正在向代理发送垃圾邮件，并且我希望代理会失败。但是，我更希望经纪人“大声”失败，而不是简单地阻止。

这是不切实际的期望吗？

更新：

Uri 的回答引用了 3 月份提交的 ActiveMQ 错误报告。错误描述包括一个听起来像我正在寻找的提案：“如果传输上的请求有超时（这是为了捕获失败场景，所以一些不应该合理发生的事情），事情就会出错而不是而不是建立等待线程。”

但是，在 8 个月后，该错误目前已通过单次投票取消分配。所以我想问题仍然存在，这是 ActiveMQ 应该（将会？）实现的吗？

我有一个 ActiveMQ 实例在面向外部的服务器上运行并公开一个 STOMP 接口。

我希望能够确保外部连接的客户端只能接收主题通知，而不会向主题本身发送任何内容。任何内部连接的客户端都可以接收和发送。

我希望我可以在主题或服务器级别设置一些规则，根据 IP 规则定义对主题的权限，但我找不到对此的任何参考。

有没有人对我如何做到这一点有任何建议，或者可能有其他方法来达到预期的效果？

我正在使用 ActiveMQ 5.2，我的应用程序需要大量主题，大约 500,000 个。当我运行我的应用程序时，只创建了大约 1000 个主题后，ActiveMQ 会引发 OutOfMemoryException。

期望 ActiveMQ 支持这么多主题是不是很不合理？

这种用法是否有最佳配置？

该线程详细说明了该问题： http: //www.nabble.com/java.lang.OutOfMemoryError%3A-unable-to-create-new-native-thread-on-AMQ-5.0-td17005441.html

好吧，也许不是所有 4 件事，但这是我的情况：

我有一个 ActiveMQ 后端（在我的桌面 Mac 上运行）。这是我拥有的库存 Apache ActiveMQ 服务器，我基本上将其用作回显服务器来跟踪日志并调试我的客户端。客户端是一个 iPhone 项目，它使用 AsyncSocket 进行了破解 Stomp.framework 实现。

我需要使用 AsyncSocket Cocoa 库与我或多或少工作的 Stomp 服务器对话。我可以将消息发送到队列，并将它们读回，所以我认为我在那里很好。

但是，当我尝试将所有内容设置为使用 SSL（也是一项要求）时，我从 NSError 对象中得到以下错误描述：

我一生都无法弄清楚这个错误代码是什么。有人有线索吗？

这是我为 AsyncSocket 设置 SSL 的方法：

编辑：在此处添加了正确的代码。注意自签名证书。

}

有人有想法么？我想我正确设置了流属性。也许这与 ActiveMQ 设置有关？除了在 ActiveMQ 中启用 SSL over Stomp 协议外，我没有进行任何配置。我没有证书或类似的东西。也许这就是问题所在？

任何见解表示赞赏！

我们已经建立了一个基于 ActiveMQ 的应用程序基础设施。

我们可以很好地发送和接收消息，并且在大多数情况下，事情非常快而且还可以。

但是，我们注意到，如果我们“一次”提交一批消息，比如 5,000 条消息 - ActiveMQ 将很快将消息发送到另一端的第 3 方应用程序，并且该应用程序也将很快处理，并且它也会将回复排队快速返回给经纪人，比如不到一分钟。

但是由于某种原因，我们最初生成消息的 VB.NET EXE 似乎只是在处理它收到的返回消息不规律，有时大约每秒处理一个，有时会中断一个小时左右，然后返回每秒一个。

接收器正在等待可能 9 个月前从 ActiveMQ 下载的 C# 代码中的事件 MessageListener：

我认为发生的事情是 MessageListener 只给我们一条消息 (NMS.IMessage) 来咀嚼，所以这就是我们处理的。

有没有办法说“在 MessageListener 事件中，请查看队列中是否还有其他消息并全部执行”？

我正在将 JSON 格式的消息发送到 ActiveMQ 服务器。我正在尝试使用 JMS 转换将 JSON 编码对象转换为真正的 Java 对象，希望能够在内部数据上使用选择器。

这是 Stomp 和消息转换文档的链接。 这是一个关于补丁讨论的链接，其中有人展示了一个合法 JSON 对象的示例

我发送的 JSON 对象的格式（漂亮的印刷品）与此类似：

消息到达消息队列，但转换错误属性设置为“msg：msg”。

我有一个使用 ActiveMQ 客户端的 .NET 服务。我已经实现了一个带有事务连接的 MessageListener 来使用消息。

有时，我会以不同的顺序将消息放入队列中。

使用 MessageListner 有错吗？有没有办法保留消息顺序？

仅供参考：有一个生产者将消息放入队列，一个消费者将消息从队列中拉出。

如文档中所述，我通过在 activemq.xml（ActiveMQ 版本 5.2.0）中配置它来设置队列。

我正在尝试使用以下代码从java（在同一主机上）访问它：

我收到以下错误，尽管队列在 jconsole（树/org.apache.activemq/队列）中可见：

请告诉我我做错了什么。非常感谢！

我希望设置一个 ActiveMQ 实例（主要作为 STOMP 服务器），它将为来自两种类型的客户端的请求提供服务：

1. 可以读取和写入主题的经过身份验证的用户
2. 只能从主题中读取的未经身份验证的用户

到目前为止，我一直在使用 SimpleAuthenticationBroker，无论如何我都看不到配置上述情况，也看不到代码中识别通配符以供用户通过身份验证的任何位。

如果我将服务器配置为使用身份验证代理，它将期望所有连接都进行身份验证，这是我不想要的。

我认为我能看到的唯一解决方案是提供我自己的实现来支持我需要的功能，但我很想找到一些内置到服务器中的方法。