8.3和Jetty集成

gfdxy3322

Jetty web container已经存在了很长时间并使可靠的。它是小的，快的并且有一个活跃的开发者社区。Jetty提供了许多和Tomcat相同的特性因为它们都是基于Java Servlet spec，但是每个实现都是特殊的。
Jetty本质上是一个构建一个web容器的工具包,它可以在许多方面定制。Out of box，Jetty是bare-bones的，但是它有一些配置文件这样徐东不同的组合服务能在Jetty中启动。这种程度的定制是有意的和允许极端的灵活性。Jetty Hightide是分布式的Jetty，有一组默认启用的服务。Jetty Hightide最好的描述是它的文档：
Hightide 是一个optimized,versioned的分布式Jetty 开源web容器。它预先集成了一定数量的仅在J2EE应用服务器中找到的服务，或者是你不得不craft together yourself：JNDI，一个XA transaction service，一个JMS消息fabric，和一个JDBC可访问数据库。感谢Jetty的lightweight，pluggable architecture，Hightide 允许你简单地选择你想要使用的服务，或者甚至使用其他的替换它们。
在本章节中，ActiveMQ将使用一个local JNDI配置和一个global JNDI配置集成到Jetty Hightide。为该章节从Codehaus下载Jetty Hightide 7.0.2.v20100331（http://mng.bz/Sk6u）并解压到你的电脑上。
Jetty为JNDI资源配置提供了三种风格：local，影响在Jetty上布置的所有应用的global和影响在JVM上布置的所有应用的global。在这些JNDI配置风格中有些不同，有些能通过Jetty的特性控制，该特性提供了scopt JNDI资源到一个特定的context的能力。Jetty的JNDI的scopting是强大的并能在该章节中被利用，但是仅是minimally。为了更深地了解Jetty的scopeJNDI资源的能力，看一下Jetty的global JNDI信息(http://mng.bz/x67C)。我们将演示的这两种风格的JNDI配置是local JNDI和global JNDI.这两种风格的配置类似于在Tomcat中它们的配置，但是配置格式是独特的。
注意  local JNDI配置示例和global JNDI配置示例无法同时部署。因为这会导致classloader issues并使ActiveMQ无法正确部署。确保某刻只部署某一个风格的配置。
8.3.1使用local JNDI来在Jetty中集成ActiveMQ
Jetty的local JNDI配置也在资源定义的地方限制了资源对于应用的可用性。JNDI资源在一个文件中定义，该文件存在于web应用中名为WEB-INF/jetty-env.xml，显示如下。
Listing 8.8 The Jetty jetty-env.xml file

<Configure id='jms-webapp-wac' class="org.foo.mortbay.jetty.webapp.WebAppContext">
<New id="connectionFactory" class="org.mortbay.jetty.plus.naming.Resource">
<Arg>
<Ref id='jms-webapp-wac' />
</Arg>
<Arg>jms/ConnectionFactory</Arg>
<Arg>
<New class="org.apache.activemq.ActiveMQConnectionFactory">
<Arg>vm://localhost?brokerConfig=xbean:activemq.xml</Arg>
</New>
</Arg>
</New>
<New id="fooQueue" class="org.mortbay.jetty.plus.naming.Resource">
<Arg>jms/FooQueue</Arg>
<Arg>
<New class="org.apache.activemq.command.ActiveMQQueue">
<Arg>FOO.QUEUE</Arg>
</New>
</Arg>
</New>
</Configure>

在表8.8的配置特定于Jetty，并且它通过一个对示例web应用的基本的JNDI查找告诉Jetty来使三个资源有效。注意表8.8包含了ActiveMQ连接工厂定义和一个ActiveMQ queue定义。关于jms-webapp-wac context identifier限制了这些资源对于该web app context（local context）的可用性。
注意  $JETTY_HOME变量一般被用来指向Jetty Hightide的安装目录，它并不是必须在你的环境中设置的。
测试在jetty中的local JNDI配置可使用下面的步骤：
第一步 复制jms-webapp-local/target/jms-webapp.war文件到$JETTY_HOME/webapps目录。
第二步 使用下面的命令启动Jetty Hightide：

$ cd $JETTY_HOME
$ java -jar ./start.jar
2010-04-08 21:06:51.994:INFO::Logging to StdErrLog::DEBUG=false via
org.eclipse.jetty.util.log.StdErrLog
...
INFO - BrokerService - ActiveMQ 5.4.1 JMS Message
Broker (FooBroker) is starting
...
2010-04-08 21:07:01.995:INFO::Started SelectChannelConnector@0.0.0.0:8080

该输出说明ActiveMQ使用activemq.xml配置文件因为在那个文件中brokerName FooBroker被指定了。再一次，如在本章开头所说的，该配置利用了ActiveMQ的独特特性。该特性允许ActiveMQ代理通过建立一个连接工厂并传递给它一个代理URI来启动。这个连接工厂尝试连接该URI上的代理并如果没有，它将启动一个这样的代理。
第三步 访问http://localhost:8080/jms-webapp并使用显示在图8.4上的图来发送一个消息。
第四步 通过检查控制台显示的输出来确认消息已经被成功发送了：

...
2010-04-08 21:07:01.995:INFO::Started SelectChannelConnector@0.0.0.0:8080
INFO - SingleConnectionFactory - Established shared JMS Connection:
ActiveMQConnection {id=ID:mongoose.local-61512-1270782421187-2:1,
clientId=null,started=false}
INFO - JmsMessageDelegate - Consumed message with payload:
This is a test message

注意从Jetty上的输出。从JmsMessageDelegateListener bean的日志消息显示了消息被consumed并消息正文被logged。
这展示了为ActiveMQ资源配置local JNDI context是被Jetty支持的。在Jetty application server中说明都不需要改变。因为配置已在示例web应用中。local JNDI context相对的就是global JNDI context。
8.3.2使用global JNDI在Jetty中集成ActiveMQ
Jetty的global JNDI配置文件需要不同的配置，但是XML配置几乎和local JNDI XML配置完全相同。不同点事它必须将它放在不同的地方。为了该演示，global JNDI配置已经在etc/jetty.xml文件内配置，如下显示：
Listing 8.9 The Jetty jetty.xml file

...
<New id="connectionFactory" class="org.eclipse.jetty.plus.jndi.Resource">
<Arg>
<Ref id="Server"/>
</Arg>
<Arg>jms/ConnectionFactory</Arg>
<Arg>
<New class="org.apache.activemq.ActiveMQConnectionFactory">
<Arg>vm://localhost?brokerConfig=xbean:etc/activemq.xml</Arg>
</New>
</Arg>
</New>
<New id="fooQueue" class="org.eclipse.jetty.plus.jndi.Resource">
<Arg>jms/FooQueue</Arg>
<Arg>
<New class="org.apache.activemq.command.ActiveMQQueue">
<Arg>FOO.QUEUE</Arg>
</New>
</Arg>
</New>
<New id="fooTopic" class="org.eclipse.jetty.plus.jndi.Resource">
<Arg>jms/FooTopic</Arg>
<Arg>
<New class="org.apache.activemq.command.ActiveMQTopic">
<Arg>FOO.TOPIC</Arg>
</New>
</Arg>
</New>
...

注意在表8.9和Jetty中local JNDI XML配置相比仅稍有不同。不同的是第一个<Arg>元素涉及Server--整个Jetty server。这个Jetty的scoping特性示例，它告诉Jetty expose该资源到Server对象--整个server（它将在同一个文件中被定义）。
验证在Jetty中的global JNDI资源的定义，使用下面的步骤：
第一步 建立如下新目录：$JETTY_HOME/lib/ext/activemq。
第二步 复制如下列表的JARs到在第一步中创建的文件夹中：
■ activemq-all-5.4.1.jar
■ spring-context-2.5.6.jar
■ aopalliance-1.0.jar
■ spring-context-support-2.5.6.jar
■ commons-logging-1.1.1.jar
■ spring-core-2.5.6.jar
■ geronimo-j2ee-management_1.0_spec-1.0.jar
■ spring-jms-2.5.6.jar
■ geronimo-jms_1.1_spec-1.1.1.jar
■ spring-tx-2.5.6.jar
■ log4j-1.2.14.jar
■ spring-web-2.5.6.jar
■ org.osgi.core-4.1.0.jar
■ spring-webmvc-2.5.6.jar
■ spring-aop-2.5.6.jar
■ xbean-spring-3.4.3.jar
■ spring-beans-2.5.6.jar
再一次，获取这些JARs的最快捷的地方是在在编译以后的jms-webapp-local项目里。在使用Maven编译这个项目之后，你将能够在jms-webapp-local/target/jms-webapp/WEB-INF/lib/目录下找到JARs。仅需复制它们到$JETTY_HOME/lib/ext/activemq目录。
第三步 编译jms-webapp-global目录并建立WAR文件，在命令行运行如下的命令：

$ mvn clean install
...
[INFO] Scanning for projects...
[INFO] ----------------------------------------------------------------
-----
[INFO] Building jms-webapp-global
[INFO] task-segment: [clean, install]
[INFO] ----------------------------------------------------------------
-----
...
[INFO] ----------------------------------------------------------------
-----
[INFO] BUILD SUCCESSFUL
[INFO] ----------------------------------------------------------------
-----
...

运行这个命令之后，一个WAR文件将出现在target文件夹下。
第四步 复制jms-webapp-global/activemq.xml文件到$JETTY_HOME/etc/activemq.xml中。这使ActiveMQ配置文件在classpath上可用。
第五步 复制jms-webapp-global/target/jms-webapp.war到$TOMCAT_HOME/webapps目录。这将部署示例web应用。
第六步 使用如下命令启动Jetty：

$ java -jar start.jar
2010-04-11 21:41:23.253:INFO::Logging to StdErrLog::DEBUG=false
via org.eclipse.jetty.util.log.StdErrLog
...
INFO - BrokerService - ActiveMQ 5.4.1 JMS Message
Broker (FooBroker) is starting
...
2010-04-11 21:41:33.116:INFO::Started SelectChannelConnector@0.0.0.0:8080

你能从上面代理启动的输出中看到ActiveMQ在使用activemq.xml配置文件因为brokerName FooBroker在那个文件中被指定了。
第七步 访问http://localhost:8080/jms-webapp并使用在图8.4中显示的页面来发送一个消息。
第八步 通过检查控制台查看下面的输出verify消息已成功发送和消费：

...
2010-04-11 21:41:33.116:INFO::Started SelectChannelConnector@0.0.0.0:8080
INFO - SingleConnectionFactory - Established shared JMS Connection:
ActiveMQConnection {id=ID:mongoose.local-61512-1270782421187-2:1,
clientId=null,started=false}
INFO - JmsMessageDelegate - Consumed message with payload:
This is a test message

再一次，注意Jetty运行的输出。从JmsMessageDelegateListener bean的输出展示了消息已经被consumed。
Jetty的global JNDI配置提供了与Tomcat相同的优点。如果在单个Jetty实例上部署的多一个应用需要对JNDI资源的访问权，这是个很好的选择。
Tomcat和Jetty是两个能很好和集成ActiveMQ的web 容器示例。web容器之外是非常完善的Java EE应用服务器如Apache Geronimo和JBoss。