应用Spring DM和CXF在TOMCAT上发布WebService

美奇科技

1       目标
项目应用Spring DM实现模块化开发。系统和其他进程之间的控制信息希望能通过Webservice实现。要求如下：
Ø  动态发布
有多个Bundle需要发布WebService，所以希望创建一个Webservice Util（下面简称ws-util）的Bundle并提供易用的接口发布为OSGI的服务，其它Bundle可以通过调用该服务即可实现Webservice的发布。
Ø  依赖最小化
需要发布的Bundle依赖ws-util，但不需要依赖CXF，如果把CXF替换为其他的Webservice引擎，不会引起其他Bundle的变更。
Ø  编码方便
尽可能减少对业务代码的侵入。
2       思路
1，  如何实现动态发布？
需要发布的Bundle依赖ws-util，调用接口即可完成发布，所以不能在ws-util中静态配置webservice。
解决的办法是利用jax-ws 中定义EndPoint接口，对该接口包装成一个类并发布为OSGI Service，其他bundle调用该service完成webservice的发布。
2，  ws-util的上下文环境是什么样的？
Project中存在WEB-INF目录，并且存在web.xml描述文件，osgi的tomcat bundle启动时会自动监视该目录并且加载该文件，并把ws-util作为war包部署到web容器中。
OSGI CORE启动时会监视METAINF.MF中的MANIFEST.MF文件，并初始化OSGI上下文，发布OSGI Service。所以ws-util处于双重的容器管理之下，一重是OSGI容器管理，一重是WEB容器管理。
Tomcat bundle也是由OSGI CORE启动，所以ws-util的OSGI上下文初始化要早于Web上下文的初始化，如果用META-INF/spring下的spring配置方式发布EndPoint包装接口，此时的CXF Bus还没有开始初始化，EndPoint找不到web server的provider，发布就不会成功。
3，  如何把tomcat和cxf整合起来？
       1）注册Activator, 在activator初始化方法中获取osgi上下文。
    2）web上下文加载CxfNoSpringServlet时，初始化cxf bus后，获取缓存中的osgi上下文，并且把EndPoint包装类注册为osgi 服务。
 
3       环境配置
JDK：1.6
Eclipse：3.5.2
Spring：3.0.6
CXF：2.3.1
3.1   OSGI PlatForm的依赖Bundle

Spring 相关Bundle	org.springframework.beans-3.0.6.RELEASE.jar org.springframework.context.support-3.0.6.RELEASE.jar  org.springframework.web-3.0.6.RELEASE.jar  org.springframework.context-3.0.6.RELEASE.jar  org.springframework.asm-3.0.6.RELEASE.jar  org.springframework.expression-3.0.6.RELEASE.jar  org.springframework.web.servlet-3.0.6.RELEASE.jar  org.springframework.core-3.0.6.RELEASE.jar  org.springframework.aspects-3.0.6.RELEASE.jar  org.springframework.aop-3.0.6.RELEASE.jar  org.springframework.oxm-3.0.6.RELEASE.jar
Spring DM 相关Bundle	org.eclipse.osgi.services_3.2.0.v20090520-1800.jar  spring-osgi-core-2.0.0.M1.jar  spring-osgi-extender-2.0.0.M1.jar  spring-osgi-annotation-2.0.0.M1.jar  spring-osgi-web-extender-2.0.0.M1.jar  spring-osgi-io-2.0.0.M1.jar  spring-osgi-web-2.0.0.M1.jar
XML 相关Bundle	com.springsource.org.apache.xml.serializer-2.7.1.jar  com.springsource.javax.xml.ws-2.1.1.jar  com.springsource.javax.xml.stream-1.0.1.jar  com.springsource.javax.xml.bind-2.2.0.jar  com.springsource.org.apache.xmlcommons-1.3.4.jar  com.springsource.javax.xml.soap-1.3.0.jar  com.springsource.org.apache.xml.resolver-1.2.0.jar  com.springsource.org.dom4j-1.6.1.jar  com.springsource.org.apache.xerces-2.9.1.jar
其他依赖包	com.springsource.net.sf.cglib-2.2.0.jar  com.springsource.javax.activation-1.1.1.jar  javax.el-2.2.0.v201105051105.jar  com.springsource.org.apache.commons.el-1.0.0.jar  com.springsource.org.aopalliance-1.0.0.jar com.springsource.org.apache.commons.logging-1.1.1.jar
Tomcat启动包	catalina.start.osgi-1.0.0.jar  catalina.osgi-5.5.23-SNAPSHOT.jar

      
所有这些Bundle可以在http://ebr.springsource.com/repository/app/ 网站下载。
4       创建Webservice Bundle
4.1   创建Plug-in project

4.2   Project 目录结构

 
目录说明如下：
 

SRC	插件代码
Lib	CXF 依赖包
META-INF	OSGI工程的配置项
WEB-INF	当前项目要发布到Web容器中，OSGI根据该目录的Web.xml确定部署方式

4.3   CXF依赖包
Webservice lib下面的jar都是来自于cxf，但是我们用不了所有的jar包，需要根据我们的需要剔除一部分。
我们需要把webservice发布到Tomcat中，并且以jax-ws的方式，可以从cxf的lib中剔除jetty和restful实现相关的jar包。
另外我们的OSGI platform中已经有web相关的bundle，所以servlet相关的jar也要剔除。
剩下的jar列表如下：

lib/cxf-2.3.1.jar,  lib/cxf-wstx-msv-validation-2.3.1.jar,  lib/cxf-xjc-boolean-2.3.0.jar,  lib/cxf-xjc-bug671-2.3.0.jar,  lib/cxf-xjc-dv-2.3.0.jar,  lib/cxf-xjc-ts-2.3.0.jar,  lib/msv-20050913.jar,  lib/neethi-2.0.4.jar,  lib/oro-2.0.8.jar,  lib/stax2-api-3.0.2.jar,  lib/velocity-1.6.4.jar,  lib/woodstox-core-asl-4.0.8.jar,  lib/wsdl4j-1.6.2.jar,  lib/xmlbeans-2.4.0.jar,  lib/XmlSchema-1.4.7.jar,  lib/xmlsec-1.4.4.jar

4.4   MANIFEST.MF添加需要import的package

javax.servlet,  javax.servlet.http;version="2.5.0",  javax.xml.ws,  org.osgi.framework,  org.osgi.util.tracker,  org.springframework.beans;version="3.0.6.RELEASE",  org.springframework.beans.factory;version="3.0.6.RELEASE",  org.springframework.beans.factory.config;version="3.0.6.RELEASE",  org.springframework.beans.factory.support;version="3.0.6.RELEASE",  org.springframework.beans.factory.wiring;version="3.0.6.RELEASE",  org.springframework.beans.factory.xml;version="3.0.6.RELEASE",  org.springframework.context;version="3.0.6.RELEASE",  org.springframework.context.event;version="3.0.6.RELEASE",  org.springframework.context.support;version="3.0.6.RELEASE",  org.springframework.core;version="3.0.6.RELEASE",  org.springframework.core.io;version="3.0.6.RELEASE",  org.springframework.core.io.support;version="3.0.6.RELEASE",  org.springframework.osgi.context;version="2.0.0.M1",  org.springframework.osgi.web.context.support;version="2.0.0.M1",  org.springframework.web.context;version="3.0.6.RELEASE"

 
导入结束后，会在project的plug-in Dependencies下出现下列bundle：
 
4.5   JAVA 源码说明
4.5.1   类结构

说明：

WSRegister	EndPoint包装类接口
WSRegisterImpl	包装接口实现类
CXFWrapperServlet	CXFNoSpringServlet
WsActivator	OSGI启动类
ContextStore	OSGI 上下文缓存

 
4.5.2   WSRegister

package com.boco.gutil.webservice.exports;   public interface WSRegister {     public void regiser(Object impl,String address); }

 
4.5.3   WSRegisterImpl

public class WSRegisterImpl implements WSRegister {     private static final Logger logger = Logger.getLogger(WSRegisterImpl.class            .getName());       public void regiser(final Object impl, final String address) {        ClassLoader clsCl = this.getClass().getClassLoader();        Thread.currentThread().setContextClassLoader(clsCl);               logger.info(" Regiser Service @" + address);               Endpoint.publish(address, impl);     } }

4.5.4   ContextStore

public class ContextStore {     private static BundleContext context = null;       public static BundleContext getContext() {        return context;     }       public static void setContext(BundleContext context) {        ContextStore.context = context;     } }

 
4.5.5   WsActivator

public class WsActivator implements BundleActivator {         public void start(BundleContext context) throws Exception {        ContextStore.setContext(context);            }           public void stop(BundleContext bc) throws Exception {        ContextStore.setContext(null);     }   }

4.5.6   CXFWrapperServlet

public class CXFWrapperServlet extends CXFNonSpringServlet {     private static final long serialVersionUID = -6994879522066465447L;     private static final Logger logger = Logger.getLogger(CXFWrapperServlet.class            .getName());         public void loadBus(ServletConfig servletConfig) throws ServletException {         super.loadBus(servletConfig);                        Bus bus = this.getBus();                 BusFactory.setDefaultBus(bus);                 BundleContext context = ContextStore.getContext();                 Dictionary<String, String> props = new  Hashtable<String, String>();         props.put("context-class-loader", "service-provider");                 context.registerService(WSRegister.class.getName(), new WSRegisterImpl(), props);         logger.info("Start Deploy com.boco.gutil.webservice");     } }

4.5.7   Web.xml

<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"     xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee     http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd"     version="2.4">     <context-param>        <param-name>contextConfigLocation</param-name>        <param-value>            /WEB-INF/spring/*.xml        </param-value>     </context-param>     <context-param>        <param-name>contextClass</param-name>         <param-value>org.springframework.osgi.web.context.support.OsgiBundleXmlWebApplicationContext        </param-value>     </context-param>     <listener>        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>     </listener>     <servlet>        <servlet-name>CXFServlet</servlet-name>        <servlet-class>com.boco.gutil.webservice.context.CXFWrapperServlet</servlet-class>        <load-on-startup>0</load-on-startup>     </servlet>       <servlet-mapping>        <servlet-name>CXFServlet</servlet-name>        <url-pattern>/*</url-pattern>     </servlet-mapping> </web-app>

4.5.8   MANIFEST.MF

Manifest-Version: 1.0 Bundle-ManifestVersion: 2 Bundle-Name: Webservice Bundle-SymbolicName: com.boco.gutil.webservice Bundle-Version: 1.0.0.qualifier Bundle-Vendor: BOCO Web-ContextPath: GDPP_WS Bundle-RequiredExecutionEnvironment: JavaSE-1.6 Export-Package: com.boco.gutil.webservice.exports,  org.apache.cxf.frontend,  org.apache.cxf.jaxws Bundle-ClassPath: .,  lib/cxf-2.3.1.jar,  lib/cxf-wstx-msv-validation-2.3.1.jar,  lib/cxf-xjc-boolean-2.3.0.jar,  lib/cxf-xjc-bug671-2.3.0.jar,  lib/cxf-xjc-dv-2.3.0.jar,  lib/cxf-xjc-ts-2.3.0.jar,  lib/msv-20050913.jar,  lib/neethi-2.0.4.jar,  lib/oro-2.0.8.jar,  lib/stax2-api-3.0.2.jar,  lib/velocity-1.6.4.jar,  lib/woodstox-core-asl-4.0.8.jar,  lib/wsdl4j-1.6.2.jar,  lib/xmlbeans-2.4.0.jar,  lib/XmlSchema-1.4.7.jar,  lib/xmlsec-1.4.4.jar Import-Package: javax.servlet,  javax.servlet.http;version="2.5.0",  javax.xml.ws,  org.osgi.framework,  org.osgi.util.tracker,  org.springframework.beans;version="3.0.6.RELEASE",  org.springframework.beans.factory;version="3.0.6.RELEASE",  org.springframework.beans.factory.config;version="3.0.6.RELEASE",  org.springframework.beans.factory.support;version="3.0.6.RELEASE",  org.springframework.beans.factory.wiring;version="3.0.6.RELEASE",  org.springframework.beans.factory.xml;version="3.0.6.RELEASE",  org.springframework.context;version="3.0.6.RELEASE",  org.springframework.context.event;version="3.0.6.RELEASE",  org.springframework.context.support;version="3.0.6.RELEASE",  org.springframework.core;version="3.0.6.RELEASE",  org.springframework.core.io;version="3.0.6.RELEASE",  org.springframework.core.io.support;version="3.0.6.RELEASE",  org.springframework.osgi.context;version="2.0.0.M1",  org.springframework.osgi.web.context.support;version="2.0.0.M1",  org.springframework.web.context;version="3.0.6.RELEASE" Bundle-ActivationPolicy: lazy Bundle-Activator: com.boco.gutil.webservice.context.WsActivator

其中：

Web-ContextPath: GDPP_WS

设置webservice的web 上下文路径。
Bundle-Activator: com.boco.gutil.webservice.context.WsActivator
设置ws-util osgi启动时触发器。
5       发布WebService（依赖ws-util的bundle）
5.1   创建ServiceTracker

public class WSRegisterTracker extends ServiceTracker {     public WSRegisterTracker(BundleContext context) {        super(context,WSRegister.class.getName(),null);     }         public Object addingService(ServiceReference reference) {        Object serviceObj = context.getService(reference);        //注册webservice        WSRegister wsRegister = (WSRegister)serviceObj;        wsRegister.regiser(new HelloWorldImpl(), "/Hello");               return super.addingService(reference);     } }

 
5.2   创建Activator

public class WSClientActivator implements BundleActivator {     private WSRegisterTracker tracker = null;     public void start(BundleContext context) throws Exception {        tracker = new WSRegisterTracker(context);        tracker.open();     }       public void stop(BundleContext bundleContext) throws Exception {        tracker.close();     } }

5.3   接口，实现类和引用类

@WebService public interface IHelloWorld {       String sayHi(String text);       String sayHiToUser(User user);   }   @WebService public class HelloWorldImpl implements IHelloWorld {     public String sayHi(String text) {         System.out.println("sayHi called");         return "Hello " + text;     }       public String sayHiToUser(User user) {         System.out.println("sayHiToUser called");         return "Hello "  + user.getName();     } }   public class User implements Serializable{     String name;       public User() {     }     public User(String s) {         name = s;     }       public String getName() {         return name;     }       public void setName(String s) {         name = s;     } }