tomee
我记得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 message
producer.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.
@EJB
private Messages messages;
@Before
public 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 inside
EJBContainer.createEJBContainer(p).getContext().bind("inject", this);
}
@Test
public 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)进行相同的操作。
翻译自: https://www.javacodegeeks.com/2015/01/apache-tomee-jms-it-has-never-been-so-easy.html
tomee