问题标签 [stomp]

我正在尝试在 ActiveMQ 中测试以下场景。

1. 建立/打开与 ActiveMQ 的连接
2. 验证“Queue_name”在 ActiveMQ 中是否可用
3. 如果找到，打印“队列”中可用的实体数
4. 验证并打印来自“队列”的消息

我不关心数据是如何发布的。我已经寻找使用 stomp ruby​​ 客户端访问队列并从中读取数据的方法，但找不到明确的答案。我在网上找到的大多数示例都是用于发布和订阅事件的。

真的非常感谢解决这个问题的任何帮助。

我正在尝试使用 EventMachine 编写聊天服务器。如何以线程安全的方式将消息从一个 EventMachine 连接传递到另一个？

我看到支持消息传递协议 (Stomp)，但我不知道如何使用它。任何帮助表示赞赏。

EventMachine 中的 Stomp - http://eventmachine.rubyforge.org/EventMachine/Protocols/Stomp.html

我有一个 WebSocket 服务器，它将通过来自客户端的 WebSocket 消息接收 STOMP。真正的客户正在使用 javascript 来执行此操作。但我想用 Java 创建我的测试客户端（我不太了解 javascript）。问题是我为 Java 找到的 STOMP 客户端库，例如来自 ActiveMQ 和 stompj 的客户端库似乎不支持使用 WebSockets。我对 STOMP 和 STOMP over WebSockets 的概念完全陌生，所以我想知道我是否遗漏了什么，或者是否真的没有公众支持这样做。谢谢。

当我使用 Stomp 从 AMQ 读取一条消息时，我得到 3 或 4 条消息出队，不知道为什么。

填充 AMQ 的代码：

读取 AMQ 的代码：

踩下 readFrame() 代码：

我 100% 确定代码只执行一次，但结果是：

Var_dumped 消息：

有谁知道这种行为的原因是什么？

注意事项：

• 没有消息确认，因此甚至一条消息都不应该出队：|
• ACK 处于客户端模式
• 预取大小设置为 1

我正在通过 Stomp 将 Web 客户端注册到 ActiveMQ 消息传递服务器。客户端有一个用户名并通过设置一个选择器注册到一个共同的主题。

客户端通过在标头中设置“to”属性来发送消息。是否也可以使用更复杂的选择器接收广播消息？我正在寻找类似的东西

接收发给所有用户的消息。

我正在对消息传递中间件和协议进行基准测试。
我想写一个关于我正在测试的每个协议的摘要。除了许可证，我没有找到任何关于 STOMP 的信息。官网极其稀少，wikipedia term 是个stub，网上搜索也一无所获。

谁拥有和维护协议？谁发布规格？最好有一些关于协议演变的历史事实。

我有一个 iOS 客户端，它通过 STOMP 协议连接到多个 ActiveMQ 主题和队列。当我连接到服务器时，我发送以下消息：

然后，我使用以下消息订阅了几个主题：

我面临着 ActiveMQ 服务器的两个问题。每次连接时，Number of ConsumersWeb 界面中的列都会增加，所以我只有一个真正的消费者，但数量大约是 50 个消费者。但最成问题的问题是，当我将另一台 iOS 设备插入笔记本电脑以测试消息传递环境时，连接到 ActiveMQ 时出现以下错误：

这似乎是通过 STOMP 与 ActiveMQ 断开连接无法正常工作，因为此日志记录尝试是在其他设备未运行应用程序时进行的。为了解决这个问题，我尝试了以下方法：

• 尝试订阅主题时始终注销。
• 订阅

我目前正在使用 v5.6.0 在我的笔记本电脑上执行服务器。

我使用 node.js 作为 jms 主题的客户端。有两种协议可用于在主题上建立连接。论文是 Stomp 和 AMQP。我在http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol 和http://en.wikipedia.org/wiki/Streaming_Text_Oriented_Messaging_Protocol阅读了关于它们的简要介绍。两者似乎都是线路级协议，即作为八位字节流通过网络发送的数据。我没有找到任何应​​该首选的具体原因。如果有人可以阐明它，那将很有帮助。

另一点是协议都以声明它们是可互操作的为荣。互操作性术语是否意味着如果有人想取消特定的消息代理实现说 apache active MQ 而想要插入 Websphere MQ ，转换将是平滑的（前提是同时支持 AMQP/STOMP 或任何其他有线 levl 协议）？

我设法让 ActiveMQ 通过 WebSockets 与 Stomp 一起工作https://github.com/jmesnil/stomp-websocket但我遇到了一个与多个消费者/订阅者共享相同 IP/路由器有关的奇怪问题。

我们的 ActiveMQ 服务器位于我们的办公室外。当办公室的两个订阅者连接到队列时，分派到队列的消息一次只发送给一个订阅者，但不会同时发送给两个消费者。

当我查看 ActiveMQ 管理面板上的连接选项卡时，我看到以下内容：

ID：ip-10-32-59-175-56297-1352930853863-2:199 StompSocket_565594188 true false

ID：ip-10-32-59-175-56297-1352930853863-2:370 StompSocket_350506451 真假

我是否在 ActiveMq 配置方面遗漏了什么，这与 Stomp JS 库有关还是其他什么？

谢谢。

我有以下控制台程序，它在 ActiveMQ Stomp 服务器上侦听目标（队列或主题，没关系），并将它收到的消息简单地记录到控制台：

当我启动它时，它工作正常，只要我继续发送消息。但是当有 30 秒不活动时，我得到一个异常。即使没有向队列发送消息也会发生这种情况：

通过谷歌搜索和阅读 Apache.NMS 源代码，我发现它必须对“InactivityMonitor”做一些事情，显然，当我transport.useInactivityMonitor=false在连接字符串上指定参数时，我没有得到异常，一切运行良好。

但据我想我了解一切，inactivityMonitor 有一个目的：确保检测到“死”连接并正确清理。

所以肯定有其他问题！我在上面的代码中添加了一个简单的控制台跟踪器，这是不带transport.useInactivityMonitor=false参数连接时的输出：

所以我认为我的客户因为太长时间不活动而被经纪人“踢”了。但是我真的不明白为什么，从上面的日志中，我的客户实际上正在发送“keepalive”消息，这是应该的。所以它不应该是不活动的。

我没有选择如何继续处理这个问题。如果有人对此有所了解，将不胜感激！

更新：
版本号：

• 库：Apache.NMS.Stomp v1.5.3
• 代理：Apache ActiveMQ 5.6.0