原文： https://howtodoinjava.com/hornetq/basic-jms-messaging-example-using-hornetq-stand-alone-server/

    HornetQ 是一个开放源代码项目，旨在构建多协议，可嵌入，非常高性能的集群异步消息传递系统。 HornetQ 支持 JMS 1.1 API，并且还定义了自己的消息传递 API，以实现最佳性能和灵活性。 HornetQ 一流的高性能日志以非持久消息传递通常看到的速度提供持久消息传递性能。 HornetQ 提供服务器复制和自动客户端故障转移功能，以消除服务器故障时丢失或重复的消息。

    在上一篇文章中，我们了解了有关配置独立 hornetq 服务器和基本配置的信息。 让我们继续举例。

    在本文中，我们将学习将 JMS 消息发送到 hornetq 服务器上的队列的机制，然后检索这些消息。

    步骤 1）使用以下命令创建一个 maven 项目并将其转换为 Eclipse Java 项目

    1. mvn archetype:generate -DgroupId=com.howtodoinjava -DartifactId=HornetQHelloWorld
    2. -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false
    4.  cd HornetQHelloWorld
    6.  mvn eclipse:eclipse

    步骤 2）更新pom.xml文件并更新项目依赖项

    pom.xml

    1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    2.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
    3.   <modelVersion>4.0.0</modelVersion>
    4.   <groupId>com.howtodoinjava</groupId>
    5.   <artifactId>HornetQHelloWorld</artifactId>
    6.   <packaging>jar</packaging>
    7.   <version>1.0-SNAPSHOT</version>
    8.   <name>HornetQHelloWorld</name>
    9.   <url>http://maven.apache.org</url>
    10.   <dependencies>
    11.     <dependency>
    12.       <groupId>junit</groupId>
    13.       <artifactId>junit</artifactId>
    14.       <version>3.8.1</version>
    15.       <scope>test</scope>
    16.     </dependency>
    17.   <dependency>
    18.      <groupId>org.hornetq</groupId>
    19.      <artifactId>hornetq-core</artifactId>
    20.      <version>2.0.0.GA</version>
    21.      <scope>compile</scope>
    22.   </dependency>
    23.   <dependency>
    24.      <groupId>org.hornetq</groupId>
    25.      <artifactId>hornetq-jms</artifactId>
    26.      <version>2.0.0.GA</version>
    27.      <scope>compile</scope>
    28.   </dependency>
    29.   <dependency>
    30.      <groupId>org.hornetq</groupId>
    31.      <artifactId>hornetq-logging</artifactId>
    32.      <version>2.0.0.GA</version>
    33.      <scope>compile</scope>
    34.   </dependency>
    35.   <dependency>
    36.      <groupId>org.hornetq</groupId>
    37.      <artifactId>hornetq-transports</artifactId>
    38.      <version>2.0.0.GA</version>
    39.      <scope>compile</scope>
    40.   </dependency>
    41.   <dependency>
    42.      <groupId>org.jboss.netty</groupId>
    43.      <artifactId>netty</artifactId>
    44.      <version>3.1.0.GA</version>
    45.   </dependency>
    46.   <dependency>
    47.      <groupId>org.jboss.javaee</groupId>
    48.      <artifactId>jboss-jms-api</artifactId>
    49.      <version>1.1.0.GA</version>
    50.      <scope>compile</scope>
    51.   </dependency>
    53.   </dependencies>
    54. </project>

    步骤 3）将基本的 hornetq 配置文件放在类路径中。

    hornetq-configuration.xml

    1. <?xml version="1.0"?>
    2. <configuration xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"
    3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:hornetq">
    4.     <connectors>
    5.         <connector name="netty-connector">
    6.             <factory-class>org.hornetq.integration.transports.netty.NettyConnectorFactory
    7.             </factory-class>
    8.         </connector>
    9.     </connectors>
    10.     <acceptors>
    11.         <acceptor name="netty-acceptor">
    12.             <factory-class>org.hornetq.integration.transports.netty.NettyAcceptorFactory
    13.             </factory-class>
    14.         </acceptor>
    15.     </acceptors>
    16.     <security-enabled>false</security-enabled>
    17. </configuration>

    步骤 4）配置连接器工厂，并将配置文件放置在classpath中。

    hornetq-jms.xml

    1. <?xml version="1.0"?>
    2. <configuration xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"
    3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="urn:hornetq">
    4.     <!--the connection factory used by the example -->
    5.     <connection-factory name="ConnectionFactory">
    6.         <connectors>
    7.             <connector-ref connector-name="netty-connector" />
    8.         </connectors>
    9.         <entries>
    10.             <entry name="ConnectionFactory" />
    11.         </entries>
    12.     </connection-factory>
    13.     <queue name="exampleQueue">
    14.         <entry name="exampleQueue" />
    15.     </queue>
    16. </configuration>

    步骤 5）启动服务器并测试消息传递代码

    HornetQMessageQueueDemo.java

    1. package com.howtodoinjava;
    3. import java.util.HashMap;
    4. import java.util.Map;
    6. import javax.jms.Connection;
    7. import javax.jms.ConnectionFactory;
    8. import javax.jms.MessageConsumer;
    9. import javax.jms.MessageProducer;
    10. import javax.jms.Queue;
    11. import javax.jms.Session;
    12. import javax.jms.TextMessage;
    14. import org.hornetq.api.core.TransportConfiguration;
    15. import org.hornetq.api.jms.HornetQJMSClient;
    16. import org.hornetq.core.config.impl.FileConfiguration;
    17. import org.hornetq.core.server.HornetQServer;
    18. import org.hornetq.core.server.HornetQServers;
    19. import org.hornetq.integration.transports.netty.NettyConnectorFactory;
    20. import org.hornetq.integration.transports.netty.TransportConstants;
    21. import org.hornetq.jms.server.JMSServerManager;
    22. import org.hornetq.jms.server.impl.JMSServerManagerImpl;
    24. public class HornetQMessageQueueDemo {
    26.     static void startServer()
    27.     {
    28.         try
    29.           {
    30.              FileConfiguration configuration = new FileConfiguration();
    31.              configuration.setConfigurationUrl("hornetq-configuration.xml");
    32.              configuration.start();
    34.              HornetQServer server = HornetQServers.newHornetQServer(configuration);
    35.              JMSServerManager jmsServerManager = new JMSServerManagerImpl(server, "hornetq-jms.xml");
    36.              //if you want to use JNDI, simple inject a context here or don't call this method and make sure the JNDI parameters are set.
    37.              jmsServerManager.setContext(null);
    38.              jmsServerManager.start();
    39.              System.out.println("Server started !!");
    40.           }
    41.           catch (Throwable e)
    42.           {
    43.              System.out.println("Damn it !!");
    44.              e.printStackTrace();
    45.           }
    46.     }
    48.     public static void main(String[] args) throws Exception
    49.     {
    50.         //Start the server
    51.         startServer();
    53.         Connection connection = null;
    54.         try 
    55.         {
    56.             // Step 1\. Directly instantiate the JMS Queue object.
    57.             Queue queue = HornetQJMSClient.createQueue("exampleQueue");
    59.             // Step 2\. Instantiate the TransportConfiguration object which
    60.             // contains the knowledge of what transport to use,
    61.             // The server port etc.
    63.             Map<String, Object> connectionParams = new HashMap<String, Object>();
    64.             connectionParams.put(TransportConstants.PORT_PROP_NAME, 5445);
    66.             TransportConfiguration transportConfiguration = new TransportConfiguration(
    67.                                                                 NettyConnectorFactory.class.getName(), connectionParams);
    69.             // Step 3 Directly instantiate the JMS ConnectionFactory object
    70.             // using that TransportConfiguration
    71.             ConnectionFactory cf = HornetQJMSClient.createConnectionFactory(transportConfiguration);
    73.             // Step 4.Create a JMS Connection
    74.             connection = cf.createConnection();
    76.             // Step 5\. Create a JMS Session
    77.             Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
    79.             // Step 6\. Create a JMS Message Producer
    80.             MessageProducer producer = session.createProducer(queue);
    82.             // Step 7\. Create a Text Message
    83.             TextMessage message = session.createTextMessage("How to do in java dot com");
    85.             System.out.println("Sent message: " + message.getText());
    87.             // Step 8\. Send the Message
    88.             producer.send(message);
    90.             // Step 9\. Create a JMS Message Consumer
    91.             MessageConsumer messageConsumer = session.createConsumer(queue);
    93.             // Step 10\. Start the Connection
    94.             connection.start();
    96.             // Step 11\. Receive the message
    97.             TextMessage messageReceived = (TextMessage) messageConsumer.receive(5000);
    99.             System.out.println("Received message: " + messageReceived.getText());
    100.         } 
    101.         finally
    102.         {
    103.             if (connection != null) {
    104.                 connection.close();
    105.             }
    106.         }
    107.     }
    108. }
    110. Output in console:
    112. 22 Mar, 2013 2:23:36 PM org.hornetq.core.logging.impl.JULLogDelegate info
    113. INFO: live server is starting..
    114. 22 Mar, 2013 2:23:36 PM org.hornetq.core.logging.impl.JULLogDelegate warn
    115. WARNING: AIO wasn't located on this platform, it will fall back to using pure Java NIO. If your platform is Linux, install LibAIO to enable the AIO journal
    116. 22 Mar, 2013 2:23:36 PM org.hornetq.core.logging.impl.JULLogDelegate info
    117. INFO: Using NIO Journal
    118. 22 Mar, 2013 2:23:36 PM org.hornetq.core.logging.impl.JULLogDelegate warn
    119. WARNING: Security risk! It has been detected that the cluster admin user and password have not been changed from the installation default. Please see the HornetQ user guide, cluster chapter, for instructions on how to do this.
    120. 22 Mar, 2013 2:23:36 PM org.hornetq.core.logging.impl.JULLogDelegate info
    121. INFO: Started Netty Acceptor version 3.1.5.GA-r1772
    123. Server started !!
    125. 22 Mar, 2013 2:23:36 PM org.hornetq.core.logging.impl.JULLogDelegate info
    126. INFO: HornetQ Server version 2.0.0.GA (Hornet Queen, 113) started
    128. Sent message: How to do in java dot com
    129. Received message: How to do in java dot com

    下载源代码

    祝您学习愉快！