当前位置: 首页 > 知识库问答 >
问题:

ActiveMQ、STOMP和Java示例

长孙沈义
2023-03-14

有人能给我指出一个不错Java例子吗?在这个例子中,践踏客户端被用来连接到ActiveMQ。我还对以下内容感兴趣:

  • 是否支持故障转移?
  • 如何创建持久订阅?
  • Stachp支持异步消息传递吗?示例?我想我必须为它实现MessageListener接口,但我找不到它的示例。

共有1个答案

杜焕
2023-03-14

如果你真的想从Java中使用STOMP,那么你可以看看StompJMS,它将相当多的JMS API映射到STOMP。它不支持故障转移,但是没有很多stomp客户端支持。当使用Java时,您最好使用ActiveMQ代理的本机JMS客户机,因为它将是您会发现的最健壮、功能最全的客户机库。

 类似资料:
  • 我们正在将SpringWebSockets集成到我们的应用程序中,我运行了HelloWorld示例,令人惊讶的是,spring为我们连接了一切,以便将服务器端通知推送到客户端。 不过,我有一些简单的问题 1) 队列是如何创建的?我使用的是ActiveMQ,队列名称与我在目的地中指定的不同(例如,像greetings-user3n9\u jn3i)。 2)目标名称是否不同于队列? 3) 我正在使用A

  • php STOMP连接和运行在不同服务器上的ActiveMQ代理之间的通信出现问题。布局如下; 服务器B有一个AMQ代理,运行以下transportConnector设置; 服务器B还有一个Java客户机,充当许多队列的使用者。 问题是,当我们在ServerA上运行脚本时,它会失败,出现以下错误; 致命错误:未捕获的异常“stompexception”,消息为“服务器没有响应” 在ServerB上

  • 我们计划将主动 MQ (STOMP) 用于我们的一个项目。其中一个要求是,如果我们发现用户不合适,就将其踢出/禁止。如何通过单板技术实现这一点?有点像在 IRC 中踢球的东西。

  • 试图通过<code>github连接到AWS上的ActiveMQ实例。com/go-stomp/stomplibrary。 以下代码抛出<code>无效命令

  • 这是我的蓝图代码。 内部消息工作。 外部消息不工作。 我在docker中运行Red Hat AMQ 7和Fuse 7。内部消息队列在服务之间正常工作。 使用AMQ 6,当在activemq中设置时,我能够向61613上的嵌入式代理发送和接收STOMP消息。xml 现在,我正在使用AMQ 7.0的默认设置,它将接受程序设置为0.0.0.0:61616和61613,这两个接受STOMP协议。 但是相同

  • 我用tomee创建了一个项目,我想使用stomp协议在我的web应用程序和使用ActiveMQ作为MOM的客户端之间交换消息,但当我运行tomee时,会出现以下异常: 线程“ActiveMQ传输服务器线程处理程序中出现异常:stomp://0.0.0.0:61222“java.lang.NoClassDefFoundError:com/thoughtworks/xstream/io/Hierarc