Apache TomEE + JMS。这从未如此简单。

我记得J2EE （1.3和1.4）的过去，使用JMS启动项目非常困难。您需要安装JMS 代理，创建主题或队列，最后使用服务器配置文件和JNDI开始自己的战斗。

感谢JavaEE 6及其它，使用JMS确实非常简单。但是使用Apache TomEE则更容易上手。在本文中，我们将了解如何创建和测试一个简单的应用程序，该应用程序使用Apache TomEE向JMS队列发送消息或从JMS队列接收消息。

Apache TomEE使用Apache Active MQ作为JMS提供程序。在此示例中，您不需要下载或安装任何东西，因为所有元素都将作为Maven依赖项提供，但是如果您计划（并且应该）使用Apache TomEE服务器，则需要下载Apache TomEE plus或Apache TomEE plume。您可以在http://tomee.apache.org/comparison.html中了解有关Apache TomEE风味的更多信息。

依存关系

首先要做的是将javaee-api添加为提供的依赖项，并将junit和openejb-core添加为测试依赖项。请注意，添加了openejb-core依赖项以使其具有运行时来执行测试，我们将在测试部分中对其进行深入了解。

<dependencies><dependency><groupId>org.apache.openejb</groupId><artifactId>javaee-api</artifactId><version>6.0-6</version><scope>provided</scope></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version><scope>test</scope></dependency><dependency><groupId>org.apache.openejb</groupId><artifactId>openejb-core</artifactId><version>4.7.1</version><scope>test</scope></dependency>
</dependencies>

商业代码

下一步是创建负责发送消息和从JMS 队列接收消息的业务代码。它还包含一种从队列接收消息的方法。对于此示例，我们将使用无状态 EJB 。

import javax.annotation.Resource;
import javax.ejb.Stateless;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;@Stateless
public class Messages {//Standard @Resource annotation is used to inject the ConnectionFactory. //If no name is provided using lookup or name attribute, //the fully qualified name of the class with an slash (/) and the name of the attribute is used. //In this example: java:comp/env/org.superbiz.jms.Messages/connectionFactory.@Resource private ConnectionFactory connectionFactory;//Standard @Resource annotation is used to inject the Queue. //If no name is provided using lookup or name attribute, //the fully qualified name of the class with an slash (/) and the name of the attribute is used. //In this example: java:comp/env/org.superbiz.injection.jms.Messages/chatQueue.@Resource private Queue chatQueue;public void sendMessage(String text) throws JMSException {Connection connection = null;Session session = null;try {connection = connectionFactory.createConnection();//Connection is get from ConnectionFactory instance and it is started.connection.start(); //Creates a session to created connection.session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); //Creates a MessageProducer from Session to the Queue.MessageProducer producer = session.createProducer(chatQueue);producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); TextMessage message = session.createTextMessage(text);//Tells the producer to send the messageproducer.send(message); } finally {if (session != null) session.close(); if (connection != null) connection.close();}}public String receiveMessage() throws JMSException {Connection connection = null;Session session = null;MessageConsumer consumer = null;try {connection = connectionFactory.createConnection();connection.start();session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);consumer = session.createConsumer(chatQueue); //Waits for a message with timeout. Note that because a TextMessage is sent, the receive method expects a TextMessage too.TextMessage message = (TextMessage) consumer.receive(1000); return message.getText(); } finally {if (consumer != null) consumer.close();if (session != null) session.close();if (connection != null) connection.close();}}
}

Messages类的最重要部分是注意注入ConnectionFactory和
在代码内将实例排队。您只需要使用@Resource批注，容器将为您完成其余工作。最后请注意，由于我们尚未使用name或lookup属性来设置名称，因此将字段名称用作资源名称。

测试

最后，我们可以编写一个测试来断言使用JMS队列发送和接收消息。例如，我们可以使用Arquilian编写测试，但是由于这种情况，由于简单起见，我们将使用嵌入式OpenEJB实例来部署JMS示例并运行测试。

public class MessagesTest {//Messages EJB is injected.@EJBprivate Messages messages;@Beforepublic void setUp() throws Exception {Properties p = new Properties();//Embedded OpenEJB container is started.//And current test added inside created container//So we can use javaee annotations insideEJBContainer.createEJBContainer(p).getContext().bind("inject", this); }@Testpublic void shouldSendAndReceiveMessages() throws Exception {//Three messages are sent.messages.sendMessage("Hello World!"); messages.sendMessage("How are you?");messages.sendMessage("Still spinning?");//Three messages are received.assertThat(messages.receiveMessage(), is("Hello World!")); assertThat(messages.receiveMessage(), is("How are you?"));assertThat(messages.receiveMessage(), is("Still spinning?"));}}

请注意，该测试非常简单明了，您只需要以编程方式启动EJB容器并在其中绑定当前测试，这样我们就可以在测试中使用JavaEE批注。其余的是一个简单的JUnit测试。

而且，如果您运行测试，您将收到绿色的子弹。但是，等等，您可能想知道JMS 代理及其配置在哪里？ ConnectionFactory和JMS 队列的定义在哪里？这就是OpenEJB （和Apache TomEE ）发挥作用的地方。

在这种情况下， OpenEJB （和Apache TomEE ）将以嵌入式模式使用Apache Active MQ ，因此您无需在计算机上安装Apache Active MQ即可运行测试。此外， Apache TomEE将为您创建所有必需的资源。例如，它会创建一个连接工厂和一个队列为你使用默认参数和预期的名称（org.superbiz.Messages / connectionFactory的用于连接工厂和org.superbiz.Messages / chatQueue的队列），所以你不必担心到在测试阶段配置JMS 。 Apache TomEE足够聪明，可以为您创建和配置它们。

您可以通过阅读下一条日志消息来检查控制台输出，以了解资源是自动创建的： INFO：自动创建资源 。

Jan 10, 2015 10:32:48 AM org.apache.openejb.config.AutoConfig processResourceRef
INFO: Auto-linking resource-ref 'java:comp/env/org.superbiz.Messages/connectionFactory' in bean Messages to Resource(id=Default JMS Connection Factory)
Jan 10, 2015 10:32:48 AM org.apache.openejb.config.ConfigurationFactory configureService
INFO: Configuring Service(id=org.superbiz.Messages/chatQueue, type=Resource, provider-id=Default Queue)
Jan 10, 2015 10:32:48 AM org.apache.openejb.config.AutoConfig logAutoCreateResource
INFO: Auto-creating a Resource with id 'org.superbiz.Messages/chatQueue' of type 'javax.jms.Queue for 'Messages'.
Jan 10, 2015 10:32:48 AM org.apache.openejb.assembler.classic.Assembler createRecipe
INFO: Creating Resource(id=org.superbiz.Messages/chatQueue)
Jan 10, 2015 10:32:48 AM org.apache.openejb.config.AutoConfig processResourceEnvRef
INFO: Auto-linking resource-env-ref 'java:comp/env/org.superbiz.Messages/chatQueue' in bean Messages to Resource(id=org.superbiz.Messages/chatQueue)
Jan 10, 2015 10:32:48 AM org.apache.openejb.config.ConfigurationFactory configureService
INFO: Configuring Service(id=Default Managed Container, type=Container, provider-id=Default Managed Container)
Jan 10, 2015 10:32:48 AM org.apache.openejb.config.AutoConfig createContainer
INFO: Auto-creating a container for bean javaee.MessagesTest: Container(type=MANAGED, id=Default Managed Container)

如此，借助Java EE和TomEE ， JMS真的非常容易上手。在下一篇文章中，我们将看到如何使用消息驱动Bean （MDB）进行相同的操作。