问题标签 [hornetq]

我正在为一个应用程序构建一个高流量的聊天组件，并决定在消息队列上构建它，我将其缩小到这两个：Hornetq 和 Rabbitmq。

1. 有没有人对哪个是更好的选择有任何意见？（我还计划编写一个服务器，该服务器将使用 java nio 在队列和用户之间进行 websocket 和 comet 任务）

2. 谁能告诉我一些关于使用这些技术的消息限制算法的好信息？

目前我正在努力学习HornetQ。从理论上讲，事情似乎很简单，但是即使是最基本的示例，我也很难运行。

到目前为止，我已经尝试将 HornetQ 作为独立服务器启动，并连接一个简单的客户端，该客户端发送一条消息然后接收它。

我遵循的步骤是：（根据 HornetQ 文档 http://hornetq.sourceforge.net/docs/hornetq-2.0.0.GA/user-manual/en/html/using-jms.html）

- 下载最新版本的HornetQ (2.2.5) 并解压。- 修改 INSTALL_DIRECTORY\config\stand-alone\non-clustered\hornetq-jms.xml 文件来创建我需要的对象，下面是内容：

- 文件 INSTALL_DIRECTORY\config\stand-alone\non-clustered\hornetq-beans.xml 包含启动 JNDI 服务所需的 bean。

- 在 INSTALL_DIRECTORY\config\stand-alone\non-clustered\ 文件夹中还有一个名为 jndi.properties 的文件

客户端代码如下：

然而，每当我运行它时，它都会崩溃并出现以下异常：

我想我已经尝试了一切以使其运行，但它仍然使我无法理解我做错了什么。非常感谢您对此事的任何建议！

我正在尝试在 JBoss AS 7 应用程序中使用 JMS。发布正常消息似乎工作正常，但是当我尝试使用 hornetq 特定功能（排除重复消息）时，会引发异常。这是代码：

这是堆栈跟踪：

我相信我已经正确配置了standalone.xml 配置文件，因为标准 JMS 代码可以正常工作。要访问 HornetQ 的特定功能，我需要做些什么特别的事情吗？

更新：担心与我正在使用的 RestEasy 东西有关，所以搬到了独立的 Servlet，但仍然有同样的问题。下面的代码和异常

这是一个例外：

进一步更新：改用字符串值让它工作，但我认为这并不理想，属性键不能保证永远是字符串。

知道正确的方法吗？

更新：感谢@Vadzim 为我指明了正确的方向。对于其他在这个特定问题上苦苦挣扎的人，我更新了 Manifest.MF 如下：

请注意，（因为我为此苦苦挣扎了一段时间），这个文件的解析非常“脆弱”。'Class-Path:' 输入行之后的空格是必不可少的。

“HornetQ Rest”是否支持发布者-订阅者消息传递？

我想尝试了解 JMS 的工作原理。我正在阅读教程并创建了生产者/消费者 java 类，但不确定如何创建 JMS 队列。我下载了我相信有 HornetQ 的 jboss-as-web-7.0.2.Final。到目前为止，我一无所获，因为我不知道如何添加队列。

根据此文档https://docs.jboss.org/author/display/AS7/Messaging+configuration，可以使用 add-jms-queue 命令添加队列。我试过了，但它会产生错误。

我也找不到通过 GUI 上的管理控制台添加队列的选项。

有任何想法吗？

谢谢

我尝试根据这些博客为 Hornetq 放置 Apache JNDI：http ://wash-inside-out.blogspot.com/2010/08/hornetq-jms-integration-with-tomcat.html 。但我现在收到此错误：

如何找出哪个jar文件有那个类？

我正在尝试运行一个简单的 JMS“Hello world”应用程序。我想在 JBoss Application Server 7 上试用它，但我无法运行它。Jboss as HornetQ 嵌入其中，我使用以下命令启动它：

我认为问题很可能出在我在 JBoss 中配置队列的方式上。这是我做的步骤。

• 配置队列

队列名称：testQueue JNDI 名称：队列/测试

队列配置有一个“选择器”选项。这可以留空吗？如果不能，这个字段是什么？

• 代码

这是我用作发件人的代码。我现在不担心接收者，因为我只想先开始发送消息。

当我运行上述类时，出现以下错误：

上面的类究竟是如何知道 Provider(JBoss) 正在 localhost 机器上运行的？我不需要在某处指定IP地址吗？有任何想法吗？

编辑

大多数文档似乎都引用了 JBoss AS 6。我更新了代码片段以包含以下内容：

我现在收到 classNotFound 异常。我认为它需要一个额外的 jar 文件才能添加到类路径中，但是是哪一个？？？

当我运行独立的 Hornetq 时出现此错误，我试图从 tomcat 连接到它。我收到此错误：

我正在尝试运行 HornetQ 2.2.5 最终版本附带的队列示例代码。路径是 $INSTALL_ROOT/examples/jms/queue。

当我在 localhost 上运行所有内容时，此示例运行良好。但是，当我更改配置以使 JMS 服务器位于远程主机上时，我收到来自 HornetQConnectionFactory 的会话错误。客户端在远程主机上找到 JNDI 服务，但在尝试建立 JMS 连接时失败。以下是错误堆栈。

以下是托管在远程 JMS 服务器上的 hornetq-jms.xml 配置文件。

以下是远程 JMS 服务器上的 hornetq-configuration.xml 配置文件。

当我尝试远程托管队列时，为什么示例不起作用？

1. 我想通过 Internet 发送 JMS 消息，也想从其他客户端接收 JMS 消息。如果没有公共（静态）IP 地址，这可能吗？
2. 有没有办法限制其他用户向我的系统发送 JMS 消息（有没有办法进行身份验证？）未经身份验证的用户应该无法向我的系统发送 JMS 消息。
3. 如何为我的 JMS 通信启用 SSL？
4. 我使用 JMS 模板来发送 JMS 消息。如何启用确认？