问题标签 [apollo]

我有一个 Apache Apollo 服务器，并且我通过使用 amqp 的 java 客户端成功地生成和使用主题消息。

现在我想通过 websocket（stomp-websocket 库）使用 stomp 连接到这些相同的主题。我设置了示例聊天页面并使用 java 客户端和 stomp 客户端成功连接到同一主题（apollo 管理页面列出了 3 个消费者 - 一个 java 客户端和两个在不同选项卡中的 stomp 客户端）。

当我在 stomp 客户端中发送消息时，另一个 stomp 客户端会收到消息，但 java 没有（生产者计数增加到 1）。当我通过 java 生产者发送消息时，所有客户端都会根据连接显示收到一条消息，但这些消息不会显示在 stomp 客户端中。

这是来自 stomp 客户端的消息：

<<< MESSAGE 订阅：sub-0 message-id:bad_santa-82a4 目的地：/topic/chat.general

asfdae

以下是 stomp 客户端调试区域中显示的来自 java 客户端的消息：

<<< 消息订阅：sub-0 目的地：内容长度：174 内容类型：协议/amqp-1.0 消息 ID：bad_santa-82a5

SpÀBPSrÁ£ x-opt-to-type¡topicSsÀM $bd28666a-d496-4ccb-82a9-bbc3c2782b02@¡topic://chat.general@@@@@@@B¸ëìåStÁSw¡postman messageSxÁ£origin¡ bad_santa-82c

到底是怎么回事？

我正在为 STOMP (Apollo) 创建自己的 PHP 网关，因为所有现有的解决方案要么太糟糕，要么太复杂。

因此，当我将消息发送到没有交易（但有收据）的队列时，一切正常，请参阅日志：

但是当涉及到事务时，我得到了这个（我删除了握手日志，别担心）：

然后什么都没有。我的包装器尝试接收接收帧，但只有一个 fgets 超时，看起来代理等待更多的 SEND 帧数据，但生成帧的过程是相同的，只是多了一个标头（事务）。所有必要的 EOL 和空八位字节都在它们的位置上。

阿波罗 v1.6，STOMP v1.2。

会是什么呢？..

更新：源代码

我目前正在尝试使用 Scala 向 ApolloMQ 代理发送 CONNECT Stomp 帧。我正在执行以下操作：

如果我然后尝试连接并写入

它似乎在写，但没有返回任何内容，并且连接立即断开。如果我倒带第ByteBuffer一个

看起来连接正在命中 Apollo，但抛出了以下内容

我四处搜索，但找不到任何关于为什么会发生这种情况的信息。

我正在尝试找出满足我要求的最佳 MQ 选项。我需要能够在地理上不同的数据中心内和跨数据中心以高可靠性传输文本和二进制消息。快速很好，但缩放也是一种选择。与 RabbitMQ 一样，支持很好。

以下是一些假设：

1. 使用联合或铲除消息在数据中心之间推送相同的消息。
2. 使用 AMQP 传输二进制消息，因为我们是 .Net/Python 商店。

我想确保我的假设是有效的，并且需要帮助来选择哪个 MQ。我过去使用过 ActiveMQ+MySQL，但我喜欢 Mnesia 的选项，用于持久性消息传递。另外，使用 AMQP 0.9 代替 1.0 可以吗？看起来 RabbitMQ 通过插件支持 1.0。

感谢我能得到的任何替代建议。

我刚刚从官方 git 存储库下载了 Apollo 音乐播放器源代码，并将项目导入到我的 Eclipse ADT 中。如果我尝试在模拟器中运行该项目，则会收到以下错误：

我已经尝试清理重建项目，并使用具有多个 API 的不同模拟器运行，但错误仍然存​​在。AndroidManifest 似乎没问题，它设置了“package-name”，主要活动名称以点（“.”）开头。欢迎任何提示。

我想要一堆数百个客户端应用程序在中间件的一个实例上创建和使用临时队列。

为什么我不应该使用临时队列，是否有一些关于性能的缺点？是否有限制，例如多少温度。每个 HornetQ 实例可以创建队列吗？

我需要在 C# 4.5 中使用 STOMP 和队列。（我以前从未使用过 STOMP 或队列）。在 .Net 中使用队列发送和接收 STOMP 消息的“推荐”方式是什么？

到目前为止，我找到了一个 C# 示例，它使用 Apache.NMS 和 Apache.NMS.Stomp 向/从 Apollo 消息代理发送和接收消息。Apollo 看起来不错（除了它是 java^^），但是 Apache.NMS/Stomp 的最新版本是 2013 年的……这个项目还活着吗？

我正在使用带有 RabbitMQ 的 Spring-AMQP 库进行生产。我想编写一些可以“干净”工作的测试，并且我正在考虑使用嵌入式代理并模拟响应。我知道我不能嵌入 Rabbit，但想知道 Spring AMQP 是否可以与 Apollo 或其他可以在 JVM 中工作的代理一起使用。

我可以只发布和订阅，并在需要时使用供应商特定的代码来设置队列。

谢谢！

从官方网站下载 Apollo 并安装在 Mac OS X 10.10.2 中后，如Apollo 1.7 MQTT 协议手册中所述，我在apache-apollo-1.7/bin/androidMQ/etc/apollo.xml中设置了 mqtt 的连接器：

<connector id="tcp" bind="tcp://0.0.0.0:61613" protocol="mqtt"/>

然后创建一个代理（androidMQ）并运行：

然后，我将它与 ruby​​ gem 一起使用：ruby-mqtt 和我的脚本是：

subsctibe.rb

发布.rb

运行时报错：</p>

当我将主机和端口更改为：

测试没问题，但是当我将主机更改为 localhost 并且无论我将端口更改为 1883 还是 61613 时，都会发生错误。我不知道现在该怎么办。

我以前没有任何使用 *MQs 的经验，我正在寻求建立关于 JMS 和消息队列的一般知识。那样的话，我想知道我是应该从 ActiveMQ 开始还是完全“忽略”它并从自学 Apollo 开始。Apollo 和 ActiveMQ 一样功能齐全吗？它是否实现了 JMS 2.0（我看到 ActiveMQ 被 1.1 卡住了）？我会错过一些非常重要的东西吗？

另外，Kafka 与这两种解决方案相比如何？