问题标签 [apollo]

在我的应用程序中，我有 Apache Apollo 消息从客户端发送到服务器，反之亦然，但是 Apollo 服务器默认的 Web 服务器是 Jetty，我找不到如何集成 Tomcat 和 Apache Apollo。

我在这里找到了有关将 Tomcat 与 ActiveMQ 集成的信息：http: //activemq.apache.org/tomcat.html

Apollo 相比 ActiveMQ 更新了源代码和 Scala 架构，我想知道如何将 Tomcat 与 Apache Apollo 集成。

我已经设置了一个 Apache Apollo 实例，并且我连接了一个 JavaScript 客户端并订阅了“chat.general”。这在 Apollo [web] 控制台中显示为“主题”。

我正在尝试使用 Java 客户端向该主题发布消息，以便我的 JavaScript 客户端可以接收它。我尝试使用 netty-tools 没有运气，我能够连接到 apollo 然后发送一条消息，但它似乎从未到达 Apollo 并且我从未收到任何错误。

现在我正在尝试使用async-http-client来解决同样的问题，我可以连接，但我的消息似乎没有到达 chat.general 主题。

我正在使用以下 URI 使用 async-http-client（链接到上面）设置“WebSocket”：

有没有其他人幸运地从 Java 客户端发布到 Apache Apollo 上的 WebSocket 主题？如果是这样，如何:)

ActiveMQ Apollo 是否自动在连接的客户端协议之间转换消息？

我想要做的是让一个生产者使用一种协议（STOMP 或任何其他），但让消费者根据需要选择他们的协议，所以他们可以是 MQTT、STOMP、AMQP、OpenWire 等。

Apollo 可以根据消费者实现的协议转换消息吗？如果没有，有没有一种不同的方法，而不是必须将所有协议作为不同主题的生产者来实现，并根据协议告诉客户端哪个是他们的队列，比如

话题/跺脚/聊天话题/mqtt/聊天

谢谢！

任何人都可以提供来自 JAVA 的 Apache Apollo Queue 生产者和消费者的示例吗？之前我使用的是 Apache ActiveMQ，但现在我想迁移。

我是 Active MQ 的新手。我想知道在 Active MQ（或 Apollo）中是否可以进行以下操作。

本质上，我有一个进程会生成消息以启用或禁用特定站点。当消息（启用/禁用）发送到 ActiveMQ 时，该消息可能有多个消费者，具体取决于消息的路由键。例如，如果消息是启用站点 A，则路由键将是 site.A.enable。并且正在监视其站点 A 队列的站点 A 将收到此消息以及监视所有启用/禁用消息的系统范围的处理器。

现在，我认为这在 Active MQ 中使用主题是可行的。SiteA 将订阅 的所有主题，site.A.*系统进程将订阅 和 的所有site.*.enable主题site.*.disable。 这是在 ActiveMQ 中做到这一点的最佳方式吗？

我还想确保 siteA 不能订阅site.B.*或site.C.*主题。他们只能接收来自 的消息site.A.*。并且系统进程可以访问所有site.*.*主题。我也认为这可以通过安全插件来完成。我只需更新配置文件并为每个站点主题指定读/写/管理访问权限，并将其连接到用户/通行证或 ldap 以识别正在连接的站点。 那是对的吗？如果站点是外部的，这会起作用吗？

我希望能够以最少的配置/设置添加新站点。当 siteX 上线时，发布者代码将像所有其他的一样发布消息，除了它将是在site.X.*发布第一条消息时动态创建的主题。消费者也可以从site.X动态开始消费。

这就是我的问题所在。如何添加站点 X 只能“动态”访问 site.X 主题的安全性？ 我想我必须编辑配置文件并为新站点添加安全内容。然后我将不得不停止/启动服务器以获取新设置。我也许可以编辑服务器上的配置，但我认为我们不能在每次添加新站点时都停止/启动。

有没有更好的方法来实现这一点？

谢谢！

我正在研究 ActiveMQ-Apollo 安装中的一些示例，并使用示例/websocket。

在这个文件中，Stomp.js 被用来建立连接：

该示例运行良好，我能够看到正在发送和接收的消息。问题是 Stomp 使用默认的 WebSocket，有时可能不可用。所以，我想与 SockJS 客户端库集成。根据此页面上的 StompJS 示例（http://jmesnil.net/stomp-websocket/doc/），应该可以使用以下代码：

上面的代码似乎可以正确执行，但是，后来我看到以下错误：

然后，我看到调试窗口显示此消息：

我从 mylocaldomain.com:80 提供页面，ActiveMQ Apollo 服务器在同一台机器上运行，但监听端口 61623。我还获取了最新版本的 StompJS（来自 github 上的 dist 目录）以及 SockJS直接来自 cdn.sockjs.org。

我在最新的 Chrome 和 Firefox（在 OSX 上）上尝试了这个例子，同样的事情发生了。没有建立连接。

再次，回到 Apollo 附带的标准示例，它工作正常，但我想找出为什么 StompJS 而不是 StockJS 失败。

有没有人看到这个问题？

谢谢。-AP_

我正在尝试在 Apollo 1.6 上设置一个队列，该队列将使用 STOMP 从 PHP 写入，并由 Java 使用 ActiveMQ openwire 客户端使用。

我可以从 Java 读取和写入我的队列，我可以从 PHP 读取和写入它，我可以使用 Java 编写消息并使用 PHP 读取它们，但是我不能从 PHP 编写消息并使用 Java 读取它们，这就是我真的很想做。

当我使用 Apollo 的管理 UI 查看队列时，我可以在我创建的测试队列中看到我使用 PHP/STOMP 和 Java/ActiveMQ 发布的所有消息。php 消息的编解码器是 stomp，而 java 消息的编解码器是 openwire。我的 php 客户端读取这两种类型的消息，但我的 java 客户端不读取 stomp 消息。

这是一个提炼示例的要点：

• Apollo.java 读写测试队列
• send.php 写入测试队列
• recv.php 从测试队列中读取
• apollo.xml 是用于设置测试队列的 apollo 配置。

我打印了 php 收到的 StompFrames，第一个是 java/openwire 发布的，第二个是 php/stomp 发布的：

https://github.com/fusesource/mqtt-client

我有一个启动后台服务的 android 应用程序，在该服务中我启动了与 apollo 代理的 mqtt 连接。当调用 startService 时，我从 onStartCommand 设置主机名、端口用户名、密码等启动 MQTT。然后

连接成功，我可以清楚地看到我的主题“uniqueId”有一个消费者。

但是当我向我的主题发送消息时，侦听器从不调用onPublish .. 另一个奇怪的情况是，如果我失去与代理的连接，例如，我关闭代理以便活动连接断开，当 mqtt-client重新连接，它似乎调用了侦听器和 onPublish，因为这样我堆积在我的持久订阅者主题上的所有消息都被传递了..我在这里遗漏了关于侦听器的任何内容吗？

不是因为connection.subscribe而主动消费主题吗？

我正在尝试在 CentOS 上安装 Apache Apollo，我得到以下信息：

我将 keytool 添加到我的路径中，我可以从命令行运行 keytool，但由于某种原因，Apollo 安装找不到它。有任何想法吗？

有什么方法可以使用 stomp.py 库连接到 Apollo MQ 认证通道？

我们从 ActiveMQ 迁移到 ApolloMQ，我们所有的监听器都无法连接到 Apollo 队列。