8.1 示范web程序

2013-11-29

8.1 示例web程序?jee: jndi-lookup idfooQueue? ? ? jndi-namejava:comp/env/jms/FooQueue? ? ? ca

8.1 示例web程序

<jee: jndi-lookup id="fooQueue"

? ? ? jndi-name="java:comp/env/jms/FooQueue"

? ? ? cache="true"

? ? ? resource-ref="true"

? ? ? lookup-on-startup="true"

? ? ? expected-type="org.apache.activemq.command.ActiveMQQueue"

? ? ? proxy-interface="javax.jms.Queue" />

<bean id="jmsMessageBean"

? ? ? />

? ? ??

<bean id="messageSenderService"

? ? ? />

...

The Spring application context shown in listing 8.2 is an XML configuration file for

the Spring Framework: see http://www.springframework.org. (Please also note that

Spring’s p-namespace http://mng.bz/dLT9 is being used in the configuration.) The

<jee:jndi-lookup> elements utilize Spring to perform a JNDI lookup of the noted

resources. These resources are then injected into the messageSenderService Java

bean (the values are inserted via setter methods) after it’s instantiated by Spring. The

messageSenderService is then used by the web application to send a JMS message.

代码清单8.2所示的是Spring程序上下文配置文件,该文件是用于Spring 框架的XML配置文件

参阅:http://www.springframework.org. (注意,在配置中使用了Sping的p命名空间,参阅:

http://mng.bz/dLT9).<jee:jndi-lookup>元素使用Spring 来进行JNDI查找已暴露的资源.

Spring在完成初始化之后将找到的资源注入到messageSenderService的bean中(通过

setter方法注入).然后,这个web应用程序就可以利用messageSenderService发送JMS消息.

Listing 8.3 shows the source code for the JmsMessageSenderService bean.

代码清单8.3 是 JmsMessageSenderService bean的源代码.

Listing 8.3 The JmsMessageSenderService class

代码清单8.3 ?JmsMessageSenderService 类的源代码.

public class JmsMessageSenderService?

{

private JmsTemplate jmsTemplate;

public void sendMessage(final JmsMessage bean) throws JMSException?

{

if (bean.isPersistent())

{

jmsTemplate.setDeliveryPersistent(bean.isPersistent());

}

if (0 != bean.getTimeToLive())?

{

jmsTemplate.setTimeToLive(bean.getTimeToLive());

}

jmsTemplate.send

(new MessageCreator()?

{

public Message createMessage(Session session) throws JMSException?

{

TextMessage message = session.createTextMessage(bean.getMessagePayload());

if (bean.getReplyTo() != null && !bean.getReplyTo().equals(""))?

{

ActiveMQQueue replyToQueue = new ActiveMQQueue(bean.getReplyTo());

message.setJMSReplyTo(replyToQueue);

}

return message;

}

});

}

public void setJmsTemplate(JmsTemplate jmsTemplate)?

{

this.jmsTemplate = jmsTemplate;

}

The JmsMessageSenderService bean is kept simple so that it only focuses on the task

of sending the JMS message. This class uses the Spring JmsTemplate and an anonymous

MessageCreator to easily send the JMS message.

JmsMessageSenderService bean被设计成尽量保持简单,以便能将精力集中在发送JMS消息上.

这个类(JmsMessageSenderService)使用Spring的JmsTemplate模版和一个匿名的

MessageCreator实现类轻松实现JMS消息的发送.

There’s only one web page in this web application and it’s deliberately uncomplicated.

This is because the web application is only necessary to test the integration and

nothing more. To add further detail to it would only complicate matters and detract

from the real purpose of the chapter.

这个示例web程序只有一恶搞页面,并且特意的把这个页面做的简单一些.这是因为使用这个web程序

仅仅是用来测试集成ActiveMQ的.要添加进一步的细节，只会使问题复杂化，这也不是本章的主旨.

To better understand the flow of a JMS message through these classes, take a look

at figure 8.2.

为了更好的理解使用这些类发送JMS消息的流程,请看图8.2.

Here’s a brief explanation of the illustrated steps:

下面简要解释一下使用Spring发送和接受JMS消息的步骤:

Step 1 The JmsMessageSenderService implements

an anonymous Spring Message-

Creator to create the message.

第一步,JmsMessageSenderService使用一个匿名类实现了一个MessageCreator,用来创建消息.

Step 2 The JmsMessageSenderService uses the

Spring JmsTemplate to send the message

to ActiveMQ.

第二步,JmsMessageSenderService类使用JmsTemplate给ActiveMQ发送消息.

Step 3 The Spring DefaultMessageListener-

Container consumes the message and

hands it off to the JmsMessageDelegate.

第三步,Spring的DefaultMessageListenerContainer接收并处理消息,并把消息传递给

JmsMessageDelegate.

Step 4 The JmsMessageDelegate bean processes

the message (it outputs the message payload).

第4步,JmsMessageDelegate bean处理消息(它输出payload消息).

The ?JmsMessageSenderService is ?completely isolated ?from the ?Spring

DefaultMessageListener- Container and the JmsMessageDelegate bean. Any ?messages

sent to ActiveMQ by the JmsMessage- SenderService have no bearing on whether the

DefaultMessageListenerContainer ?is actually ?online and ?ready to ?consume.?

JmsMessageSenderService与Spring中的DefaultMessageListenerContainer and和

JmsMessageDelegate 是完全隔离的.任何通过 JmsMessageSenderService发送给

ActiveMQ的消息都无需了解DefaultMessageListenerContainer是否在线并已做好

处理消息的准备.

In fact, ? ?the ? ?Jms-MessageSenderService ? ?and ? ?the ? ?Spring ? ? Default

MessageListenerContainer could easily be split out of this application so as ?to

reside ?in ? completely ?different ? processes ?and ? it ?wouldn’t ? change ?the

functionality of this application. This is a perfect albeit small example of the

asynchronous messaging provided ?by ActiveMQ. figure ?8.2 are all ?hidden behind

the scenes of the single page in ?the sample web application shown in 8.3.?

事实上,在这个程序之外,Jms MessageSenderService 和 Spring默认的MessageListenerContainer

可以很容易的被分隔开,从而驻留到不同的处理过程中,并且分割后并不会影响这个程序的功能.

这个示例程序是一个非常小的使用ActiveMQ发送异步消息的程序.图8.2中展示的是所有web

程序中由图8.3所示的单个页面的后台处理过程.

?When sending a message using ?the page shown in ?figure 8.3, a small ?message appears

briefly on the page and then fades away quickly to indicate that the message was

sent. This is just a sanity check to show some activity in the web ?application.

These are ?the only ?visible features ?in the ?web application. ?Everything else

happens behind the scenes.

当使用如图8.3所示的页面发送消息时,页面会生成一个短小的消息然后迅速的消失,表示

该消息已经被发送出去了.这仅仅是为了显示web程序做了一些操作而做的检查.

这些是web程序中仅有的可见部分,其他工作都是在幕后完成的.

These are only the portions of the web application that are apropos to the integration

of ActiveMQ with application servers. To get a better look at the details of this

sample web application, and to actually deploy it yourself to test your own integrations

as you work through the examples, download the example source code for the book.

这里介绍的仅仅是在应用程序服务器中集成示例web程序和ActiveMQ的部分内容.如果想要更好

的了解示例web程序的细节,并且自己动手部署这些程序以便测试web程序和ActiveMQ集成的话,

请下载本书示例程序源码.

The four versions of the sample web application for this chapter are

四个版本示例web应用程序分别是:

? jms-webapp-geronimo —Used to demonstrate ActiveMQ integration with Geronimo

jms-webapp-geronimo -- 用于说明Geronimo和ActiveMQ集成

? jms-webapp-global—Used to demonstrate ActiveMQ integration with Tomcat and Jetty using global JNDI

jms-webapp-global -- 用于说明ActiveMQ与Tomcat和Jetty的集成并使用了全局JNDI

? jms-webapp-jboss—Used to demonstrate ActiveMQ configuration and deployment with JBoss

jms-webapp-jboss -- 用于说明ActiveMQ和JBoss的集成配置和部署

? jms-webapp-local—Used to demonstrate ActiveMQ integration with Tomcat and Jetty using local JNDI

?jms-webapp-local -- 用于说明ActiveMQ和Jetty的集成并使用了本地JNDI

NOTE The local JNDI configuration example and the global JNDI configuration

example can’t be deployed at the same time. This will cause classloader

issues and will prevent ActiveMQ from being deployed correctly. Make sure to

only deploy one style of configuration at a time.

注意,使用了本地JNDI配置和全局JNDI配置的例子不能同时部署,否则会导致类加载问题,使得

ActiveMQ不能正常部署.切记一次只能部署一种风格的JNDI.

Before proceeding with this chapter, you need to build all four of these examples.

This can be achieved using the Maven command shown next.

在继续阅读本章的内容之前,你需要构建所有的4个示例程序.

可以使用下面的Maven命令构建:

Listing 8.4 Build the examples

代码清单8.4 构建示例程序

[amq-in-action-example-src] $ cd chapter8/

[chapter8] $ mvn clean install

[INFO] Scanning for projects...

[INFO] Reactor build order:

[INFO] jms-webapp-geronimo

[INFO] jms-webapp-global

[INFO] jms-webapp-jboss

[INFO] jms-webapp-local

[INFO] ActiveMQ In Action Examples Chapter 8

...

[INFO]