构建一个基于 HornetQ 的异步消息系统涉及多个步骤，包括环境设置、HornetQ 安装和配置、客户端编程等。虽然 HornetQ 作为独立项目已经合并到 WildFly 应用服务器中并被 ActiveMQ 取代，但你仍然可以学习如何设置一个基础的 HornetQ 系统。以下是一个简单的指南：

环境准备

1. 安装 Java 开发套件 (JDK):
   确保你的系统上安装了 JDK 7 或更高版本。

2. 下载 HornetQ:
   虽然 HornetQ 项目已不再作为独立项目更新，但可以通过 JBoss Community 找到旧版本。

3. 解压缩 HornetQ:
   将下载的 HornetQ 压缩包解压到你的服务器或本地开发环境上。

配置 HornetQ 服务器

1. 配置 HornetQ Server:

   • 导航到解压后的 HornetQ 目录，例如 hornetq-2.x.x.Final.
   • 进入 config 目录，选择一个示例配置文件作为基础（例如，stand-alone）。
   • 在 hornetq-configuration.xml 中，配置地址、连接器、和集群设置。

2. 配置日志:

   • 在 logging.properties 文件中，可以调整日志级别以便更清楚地了解服务器活动。

3. 启动 HornetQ 服务器:

   • 通过命令行进入 bin 目录，运行 ./run.sh（Linux/Unix/Mac）或 run.bat（Windows）以启动服务器。

客户端应用编程

1. 设置 Maven 项目:

   • 创建一个新的 Maven 项目。

   • 在 pom.xml 文件中添加 HornetQ 依赖（注意版本号应与你下载的版本一致）：

     <dependency>  
      <groupId>org.hornetq</groupId>  
      <artifactId>hornetq-core-client</artifactId>  
      <version>2.x.x.Final</version>  
     </dependency>  
     <dependency>  
      <groupId>org.hornetq</groupId>  
      <artifactId>hornetq-jms-client</artifactId>  
      <version>2.x.x.Final</version>  
     </dependency>  

2. 编写生产者和消费者:

• 消息生产者

  ```
  import javax.jms.*;
  import org.hornetq.jms.client.HornetQConnectionFactory;

  public class Producer {
  public static void main(String[] args) throws JMSException {
  ConnectionFactory connectionFactory = new HornetQConnectionFactory();
  Connection connection = connectionFactory.createConnection();
  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  Destination destination = session.createQueue("TestQueue");

       MessageProducer producer = session.createProducer(destination);  
       TextMessage message = session.createTextMessage("Hello HornetQ!");  
       producer.send(message);  
       System.out.println("Message sent.");  
       session.close();  
       connection.close();  
   }  

  }
  ```

• 消息消费者

  ```
  import javax.jms.*;
  import org.hornetq.jms.client.HornetQConnectionFactory;

  public class Consumer {
  public static void main(String[] args) throws JMSException {
  ConnectionFactory connectionFactory = new HornetQConnectionFactory();
  Connection connection = connectionFactory.createConnection();
  connection.start();
  Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  Destination destination = session.createQueue("TestQueue");

       MessageConsumer consumer = session.createConsumer(destination);  
       TextMessage message = (TextMessage) consumer.receive(1000);  
       System.out.println("Received: " + message.getText());  
       session.close();  
       connection.close();  
   }  

  }
  ```

3. 运行生产者和消费者：
   • 先启动 HornetQ 服务器，然后运行生产者和消费者测试消息的发送和接收。

注意事项

• HornetQ 项目已经合并到 ActiveMQ 中（ActiveMQ Artemis），你可能更倾向于直接使用 ActiveMQ Artemis 来构建新项目。
• 注意处理异常和资源释放，确保连接关闭等清理操作在生产环境中正确实现。
• 如果需要高级功能或集成，建议查看 ActiveMQ Artemis 的文档。

通过这些步骤，你应该能够配置一个基础的 HornetQ 异步消息系统。如果你需要更广泛的功能和支持，考虑迁移到更新的消息队列系统如 ActiveMQ Artemis。