java api 开发中使用 hornetq 进行消息处理
随着互联网的快速发展，大量的信息交互涌现出来，消息队列成为解决高并发、高可用、异步处理等问题的重要手段。HornetQ 是由 JBoss 开发的基于 JMS 协议的高性能、高可用的开源消息中间件。本文将介绍如何在 java api 开发中使用 hornetq 进行消息处理。
一、快速入门
- 下载 HornetQ
HornetQ的官网（http://hornetq.apache.org/downloads.html）提供了多种格式的下载包，这里选择 HornetQ-2.4.0.Final-bin.tar.gz。
- 安装 HornetQ
下载完成后，将 HornetQ-2.4.0.Final-bin.tar.gz 解压缩到本地文件夹中。
立即学习“Java免费学习笔记（深入）”；
- 启动 HornetQ
进入 HornetQ 的 bin 目录，执行以下命令：
./run.sh
出现以下日志信息则表示成功启动 HornetQ 服务：
11:14:21,867 INFO [ServerImpl] Starting HornetQ Server
11:14:21,986 INFO [JournalStorageManager] Using NIO Journal
11:14:22,626 INFO [NettyAcceptor] Started Netty Acceptor version #{version}
11:14:22,697 INFO [HornetQServerImpl] HornetQ Server version #{version} [${name}] started
- 部署 HornetQ 控制台
将 HornetQ 的 hornetq-console.war 放入 Tomcat 的 webapps 目录下，启动 Tomcat，通过 http://localhost:8080/hornetq-console 访问 HornetQ 控制台。
二、HornetQ 的使用
- 发布和接收消息
HornetQ 的发布订阅模式是基于 Topic 的，发布端向某个 Topic 发布消息，而多个接收端可以同时订阅这个 Topic，接收端就可以接收到多个发布端发布的消息。
（1）消息发布端
先创建一个发布端（Publisher）发送消息，代码如下：
public class Publisher {
public static void main(String[] args) throws Exception {
// 初始化连接工厂等配置信息
ConnectionFactory connectionFactory = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(NettyConnectorFactory.class.getName()));
JMSContext jmsContext = connectionFactory.createContext();
// 发送消息
JMSProducer producer = jmsContext.createProducer();
Destination destination = HornetQJMSClient.createTopic("exampleTopic");
producer.send(destination, "Hello, HornetQ!");
// 关闭连接
jmsContext.close();
}
}（2）消息接收端
再创建一个接收端（Subscriber）去接收消息，并将消息打印出来，代码如下：
public class Subscriber {
public static void main(String[] args) throws Exception {
// 初始化连接工厂等配置信息
ConnectionFactory connectionFactory = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(NettyConnectorFactory.class.getName()));
JMSContext jmsContext = connectionFactory.createContext();
// 创建消费者
Destination destination = HornetQJMSClient.createTopic("exampleTopic");
JMSConsumer consumer = jmsContext.createConsumer(destination);
// 接收消息并打印
String message = null;
do {
message = consumer.receiveBody(String.class, 1000);
System.out.println("Received message: " + message);
} while (message != null);
// 关闭连接
jmsContext.close();
}
}在运行发布端和接收端之后，可以在 HornetQ 控制台上查看发布端发送的消息，如下图所示：
- 消息持久化
HornetQ 支持将消息进行持久化存储，这意味着即使 HornetQ 宕机了，也能保证消息不丢失。
（1）发送者
dmSOBC SHOP网店系统由北京时代胜腾信息技术有限公司（http://www.webzhan.com）历时6个月开发完成，本着简单实用的理念，商城在功能上摒弃了外在装饰的一些辅助功能，尽可能的精简各项模块开发，做到有用的才开发，网店V1.0.0版本开发完成后得到了很多用户的使用并获得了好评，公司立即对网店进行升级，其中包括修正客户提出的一些意见和建议，现对广大用户提供免费试用版本，如您在使用
我们需要将消息的持久性设置为 DeliveryMode.PERSISTENT，如下所示：
public class Publisher {
public static void main(String[] args) throws Exception {
ConnectionFactory connectionFactory = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(NettyConnectorFactory.class.getName()));
JMSContext jmsContext = connectionFactory.createContext();
// 设定持久性
JMSProducer producer = jmsContext.createProducer();
destination = HornetQJMSClient.createTopic("exampleTopic");
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
// 发送消息
producer.send(destination, "Hello, HornetQ!");
jmsContext.close();
}
}（2）接收者
HornetQ 默认已将消息持久化存储，因此不需要在接收者端进行特定的配置，继续使用上一节中的 Subscriber 类即可。
- 集群模式
HornetQ 具有高可用性的特点，可以以集群模式运行，以确保消息的可靠性和高并发性。以下是实现 HornetQ 集群模式的步骤：
（1）拷贝 HornetQ 目录并新建文件夹
将 HornetQ 目录拷贝一份并重命名为 HornetQ2，然后新建一个名为 cluster 的文件夹，并将 HornetQ2 目录下的 data 目录、log 目录、tmp 目录等文件夹全部复制到 cluster 文件夹下。
（2）修改配置文件
在 HornetQ 目录下的 examples/configs/clustered 配置文件夹中，将 hq-configuration.xml 文件及 server0 和 server1 文件夹复制到 HornetQ2 目录中，并按照下面的方式修改 server0 文件夹中的 hornetq-configuration.xml 文件：
（a）将节点名修改为 server0
（b）将 cluster-connections 中的 server-username 和 server-password 修改为"guest"
（c）修改 connector 地址为本机 IP 地址，如 192.168.1.1
（d）将 jms-configuration 下的 use-ha 设为 true
如下所示：
guest ${data.dir:../data}/paging ${data.dir:../data}/bindings ${data.dir:../data}/journal ${data.dir:../data}/large-messages NIO true 2 10 10240 28000 1 5000 90 true 120000 60000 HALT 1628000 100Mb org.hornetq.core.remoting.impl.netty.NettyConnectorFactory org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory jms netty 500 true true 1 netty true 5000 1000000 true
然后再按照同样的方式修改 server1 文件夹中的 hornetq-configuration.xml 文件，其中将 server0 改为 server1。
（3）启动 HornetQ
依次在 HornetQ 和 HornetQ2 的 bin 目录下执行 run.sh 命令启动 HornetQ 进程，此时两个 HornetQ 节点即形成了一个集群，可以通过 HornetQ 控制台查看。
三、总结
通过本文的介绍，我们了解了 HornetQ 的基本使用和集群模式的配置方法。使用 HornetQ 可以方便地解决消息交互的问题，提高系统的健壮性和并发能力。同时，HornetQ 还支持多种消息传递模式、丰富的消息持久化机制和扩展插件等特性，可以根据实际需求进行选择和配置。
