具有Eclipse和嵌入式JBoss HornetQ Server的简单JMS 1.1生产者和使用者示例

Before going to through this post, please read my previous post at “JMS API 1.1 Producer and Consumer” to understand some baby steps to develop JMS 1.1 Producer and Consumer programs.

在阅读这篇文章之前，请阅读我以前在“ JMS API 1.1 Producer和Consumer”上的文章，以了解开发JMS 1.1 Producer和Consumer程序的一些基本步骤。

In this post, we are going to develop a Simple JMS 1.1 Producer and Consumer Example With Eclipse IDE and Embedded JBoss HornetQ Server.

在本文中，我们将使用Eclipse IDE和嵌入式JBoss HornetQ Server开发一个简单的JMS 1.1生产者和使用者示例。

发表简短目录 (Post Brief TOC)

Introduction
介绍
Steps to Develop a JMS V.1.1 Example
开发JMS V.1.1示例的步骤
Final Project Structure
最终项目结构
Execute and Observe the Output
执行并观察输出

介绍 (Introduction)

As a Novice Developer to JMS API, it is bit tough to understand about JMS Servers, ConnectionFactory Creation, Queue Creation, Topic Creation etc. We will discuss these concepts in detail in coming posts. First of all, we should understand how to write a simple JMS Producer and Consumer programs without much effort.

作为JMS API的新手开发人员，很难理解JMS服务器，ConnectionFactory创建，队列创建，主题创建等。我们将在以后的文章中详细讨论这些概念。首先，我们应该了解如何轻松编写简单的JMS Producer和Consumer程序。

To develop this example, we are going to use Eclipse IDE, JMS 1.1 API, Maven and JBoss Embedded HornetQ JMS Server. It is very easy to configure ConnectionFactory, Queue, Topic etc. with this embedded server. We just need to configure some XML files.

为了开发该示例，我们将使用Eclipse IDE，JMS 1.1 API，Maven和JBoss Embedded HornetQ JMS Server。使用此嵌入式服务器配置ConnectionFactory，Queue，Topic等非常容易。我们只需要配置一些XML文件。

To use Embedded JMS Server, we don’t need to download and install any software. We just need to configure some Jars in our Maven Project. Let’s start developing application now.

要使用Embedded JMS Server，我们不需要下载和安装任何软件。我们只需要在我们的Maven项目中配置一些Jars。现在开始开发应用程序。

开发JMS V.1.1示例的步骤： (Steps to Develop a JMS V.1.1 Example:)

Create a Mavenized Java project in Eclipse IDE
在Eclipse IDE中创建Mavenized Java项目
Project Name: EmbeddedJMS1.1Example

项目名称： EmbeddedJMS1.1Example
Use the following pom.xml file.
使用以下pom.xml文件。

<project xmlns="https://maven.apache.org/POM/4.0.0"
xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="https://maven.apache.org/POM/4.0.0
https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.journaldev.jms</groupId><artifactId>EmbeddedJMS1.1Example</artifactId><version>1.0.0</version><dependencies><dependency><groupId>org.hornetq</groupId><artifactId>hornetq-core</artifactId><version>2.3.0.BETA1</version></dependency>    <dependency><groupId>org.hornetq</groupId><artifactId>hornetq-jms-client</artifactId><version>2.3.0.BETA1</version></dependency>   <dependency><groupId>org.hornetq</groupId><artifactId>hornetq-jms-server</artifactId><version>2.3.0.BETA1</version></dependency>     <dependency><groupId>javax.jms</groupId><artifactId>javax.jms-api</artifactId><version>1.1</version></dependency>   </dependencies>
</project>

NOTE:-This pom.xml contains 3 dependencies

注意：-此pom.xml包含3个依赖项

hornetq-core-x.x.jar:- It contains to provide base API for both JMS server and client programs.
hornetq-core-xxjar：它包含为JMS服务器和客户端程序提供基本API。
hornetq-jms-server-x.x.jar:- It contains API to provide Embedded JBoss HornetQ Server.
hornetq-jms-server-xxjar：-包含用于提供嵌入式JBoss HornetQ服务器的API。
hornetq-core-x.x.jar:- It contains JMS API implementation for JMS Session,Queue,Topic etc.
hornetq-core-xxjar：-包含用于JMS会话，队列，主题等的JMS API实现。

Configure one user in “hornetq-users.xml”t o run this program.
在“ hornetq-users.xml”中配置一个用户以运行该程序。

hornetq-users.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration xmlns="urn:hornetq"
xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd"><defaultuser name="jduser" password="jduser"><role name="jduser"/></defaultuser>
</configuration>

Here we have defined one user “jduser” to use them in HornetQ Configuration XML file to configure Security.

在这里，我们定义了一个用户“ jduser”以在HornetQ Configuration XML文件中使用它们来配置安全性。

Configure in-memory server configuration “hornetq-configuration.xml” to run this program. It is used to configure In-Memory JMS Server.
配置内存服务器配置“ hornetq-configuration.xml”以运行该程序。它用于配置内存JMS服务器。

hornetq-configuration.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration xmlns="urn:hornetq" xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"><persistence-enabled>false</persistence-enabled><connectors><connector name="in-vm"><factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class></connector></connectors><acceptors><acceptor name="in-vm"><factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class></acceptor></acceptors><security-settings><security-setting match="#"><permission type="consume" roles="jduser"/><permission type="send" roles="jduser"/></security-setting></security-settings></config

Here We have configured JBoss HornetQ In-Memory Server and Security details.

在这里，我们已经配置了JBoss HornetQ内存服务器和安全性详细信息。

Configure in-memory server ConnectionFactory and Queue “hornetq-jms.xml” to run this program. It is used to configure JMS Settings.
配置内存服务器ConnectionFactory和队列“ hornetq-jms.xml”以运行该程序。它用于配置JMS设置。
hornetq-jms.xml

hornetq-jms.xml
```
<?xml version="1.0" encoding="UTF-8"?>
<configuration xmlns="urn:hornetq"
xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd"><connection-factory name="JDConnectionFactory"><connectors><connector-ref connector-name="in-vm"/></connectors><entries><entry name="JDConnectionFactory"/></entries></connection-factory><queue name="JDQueue"><entry name="/queue/JDQueue"/></queue>
</configuration>
```
Here we have configured ConnectionFactory with “JDConnectionFactory” name and Queue destination with “/queue/JDQueue” JNDI name. We have linked these two things to previous configured JBoss HornetQ In-Memory Server.

在这里，我们为ConnectionFactory配置了“ JDConnectionFactory”名称，并为队列目标配置了“ / queue / JDQueue” JNDI名称。我们已经将这两件事链接到先前配置的JBoss HornetQ内存服务器。
Create a Simple Java class “EmbeddedHornetQJMSExample” and copy below sample code.
创建一个简单的Java类“ EmbeddedHornetQJMSExample”，然后复制以下示例代码。
```
package com.jd.embedded.jms.hornetq;import javax.jms.*;
import org.hornetq.jms.server.embedded.EmbeddedJMS;public class EmbeddedHornetQJMSExample
{public static void main(final String[] args){try{// This EmbeddedJMS class acts as a JMSServer for example: JBoss HornetQ ServerEmbeddedJMS jmsServer = new EmbeddedJMS();jmsServer.start();System.out.println("JD: Embedded JMS Server started.");ConnectionFactory connectionFactory = (ConnectionFactory)jmsServer.lookup("JDConnectionFactory");Queue queue = (Queue)jmsServer.lookup("/queue/JDQueue");Connection connection = null;try{connection = connectionFactory.createConnection();Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//1. Producer Code StartMessageProducer producer = session.createProducer(queue);TextMessage message = session.createTextMessage("Hello, I'm from JournalDev(JD).");System.out.println("Sending message: " + message.getText());producer.send(message);//2. Consumer Code StartMessageConsumer messageConsumer = session.createConsumer(queue);connection.start();TextMessage messageReceived = (TextMessage)messageConsumer.receive(1000);System.out.println("Received message: " + messageReceived.getText());}finally{if (connection != null){connection.close();}jmsServer.stop();System.out.println("JD: Embedded JMS Server stopped.");}}catch (Exception e){e.printStackTrace();}}
}
```
Just for simplicity, I’ve created both Message Producer and Consumer in a single Java file. Please go through those two sub-sections(separated by comments) for understanding purpose.

为了简单起见，我在单个Java文件中创建了消息生产者和使用者。请仔细阅读这两个小节（以注释分隔）以了解目的。

最终项目结构：- (Final Project Structure:-)

If we observe the project in Eclipse IDE, it’s final structure looks like as below:

如果我们在Eclipse IDE中观察该项目，则其最终结构如下所示：

执行并观察输出： (Execute and Observe the Output:-)

In this section, we will run our JMS Program and observe the results in Eclipse IDE Console.

在本节中，我们将运行JMS程序并在Eclipse IDE控制台中观察结果。
- Right click on “EmbeddedHornetQJMSExample.java” Program
  右键单击“ EmbeddedHornetQJMSExample.java”程序
- Run it as “Java Application”
  作为“ Java应用程序”运行
- Observe the output in Eclipse IDE Console
  在Eclipse IDE控制台中观察输出
- Here we can see both Producer Sent message and Consumer Received message.
  
  在这里，我们可以看到生产者已发送消息和消费者已接收消息。
That’s it all about developing Simple JMS API 1.1 Producer and Consumer application with Embedded JBoss HornetQ Server. We will discuss JMS API 2.0 Producer and Consumer Example in my coming posts.

这就是使用嵌入式JBoss HornetQ Server开发Simple JMS API 1.1 Producer和Consumer应用程序的全部内容。我们将在我的后续文章中讨论JMS API 2.0生产者和使用者示例。

Please drop me a comment if you like my post or have any issues/suggestions.

如果您喜欢我的帖子或有任何问题/建议，请给我评论。

翻译自: https://www.journaldev.com/9858/jms1-1-producer-consumer-embedded-jboss-hornetq-example