讓axis1.4與spring集成

jopen 10年前發布 | 14K 次閱讀 axis WEB服務/RPC/SOA

集成Spring和Axis的一個簡單方案，使Axis Web服務引擎可以使用直接spring的service，去掉累贅層~

對于axis1.4來說，我們常用wsdd的方式來發布服務。下面先看下我們是如何使用的。

定義一個服務類

package com.sunsharing.axistest;

public class HelloWordService {
    public String sayHello(String person){
        return "hello ," + person;
    }
}

使用wsdd暴露服務以及方法

<deployment xmlns="http://xml.apache.org/axis/wsdd/"
    xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
    <handler name="URLMapper"
        type="java:org.apache.axis.handlers.http.URLMapper" />  

    <service name="helloWordService " provider="java:RPC">
        <parameter name="className"
            value="com.sunsharing.axistest.HelloWordService " />       
    </service>
    <transport name="http">
        <requestFlow>
            <handler type="URLMapper" />
        </requestFlow>
    </transport>
</deployment>

這已經把服務暴露出來了。

接下來，妹子可能會問你，能不能從我傳入的person找到它存儲在數據庫的詳細信息，多輸出點信息呢？于是乎，你又定義了一個spring的service，就簡單的jdbcTemplate來查詢想滿足妹子吧。

@Service
public class SpringHelloWordService {

    @Autowired
    JdbcTemplate jdbcTemplate;

    public String sayHello(String person){
        //這個打印為了看是不是spring托管的service，是的話，jdbcTemplate應該不為空，有注入
        System.out.println(jdbcTemplate);
        return "hello,"+person;
    }
}

繼續之前的做法，往wsdd再配置個service

<service name="springHelloWordService" provider="java:RPC">
        <parameter name="className"
            value="com.sunsharing.axistest.SpringHelloWordService" />       
    </service>

呵呵，這樣做的話，你的jdbcTemplate肯定是空指針！！！，這個className是axis自己new出來的。你還是再想想辦法吧。

這時候，你一想，那我就寫在之前定義好的HelloWordService，進行調用spring的服務不就好了。修改下HelloWordService。

public class HelloWordService {
    public String sayHello(String person){
        //ServiceLocator是我們系統初始自定義的獲取spring bean的輔助類
        SpringHelloWordService service = (SpringHelloWordService)ServiceLocator.getBean("springHelloWordService");
        return service.sayHello(person);
    }
}

好像一切都做完了，妹子的要求也滿足了。不過對于喜歡偷懶的程序猿來說，總覺得好累，為什么不直接把spring的service直接暴露出來就好了，還多這么一層，真是累啊~~~

稍微看了下源碼，wsdd的方式部署中，有個provider。再看看，就從它入手，定義一個SpringProvider（網上copy的，修改了下getServiceClass）

package com.sunsharing.axistest;

import org.apache.axis.AxisFault;
import org.apache.axis.Handler;
import org.apache.axis.MessageContext;
import org.apache.axis.components.logger.LogFactory;
import org.apache.axis.handlers.soap.SOAPService;
import org.apache.axis.providers.java.RPCProvider;
import org.apache.axis.transport.http.HTTPConstants;
import org.apache.commons.logging.Log;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.XmlWebApplicationContext;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServlet;

public class SpringProvider extends RPCProvider {
    protected static Log log =
            LogFactory.getLog(SpringProvider.class.getName());
    public static final String OPTION_BEANNAME = "beanName";

    protected Object makeNewServiceObject(MessageContext msgContext, String clsName) throws Exception {
        String beanName = getStrOption(OPTION_BEANNAME, msgContext.getService());
        return getService(beanName, msgContext);
    }

    protected String getServiceClassNameOptionName() {
        return OPTION_BEANNAME;
    }

    protected Object getService(String beanName, MessageContext context) throws AxisFault {
        ApplicationContext appContext = getAppContext(context);
        if (appContext == null) {
            log.fatal("Spring ApplicationContext is NULL.");
            throw new AxisFault("get Spring ApplicationContext error.");
        }

        Object bean = appContext.getBean(beanName);
        if (bean == null) {
            log.error("bean named:" + beanName + " is NULL");
            throw new AxisFault("bean named:" + beanName + " is NULL");
        }
        return bean;
    }

    protected String getStrOption(String optionName, Handler service) {
        String value = null;
        if (service != null)
            value = (String) service.getOption(optionName);
        if (value == null)
            value = (String) getOption(optionName);
        return value;
    }

    protected Class getServiceClass(String beanName, SOAPService service, MessageContext msgContext) throws AxisFault {
//        ConfigurableListableBeanFactory beanFactory = getBeanFactory(msgContext);
//        if (beanFactory == null) {
//            log.error("BeanFactory is NULL");
//            throw new AxisFault("BeanFactory is NULL");
//        }
//        Object bean = beanFactory.getBeanDefinition(beanName);
//        return bean.getClass();
        Object bean = getService(beanName,msgContext);
        return bean.getClass();
    }

    protected XmlWebApplicationContext getAppContext(MessageContext msgContext) {
        HttpServlet servlet = (HttpServlet) msgContext.getProperty(HTTPConstants.MC_HTTP_SERVLET);
        ServletContext servletContext = servlet.getServletContext();
        XmlWebApplicationContext appContext = (XmlWebApplicationContext) servletContext
                .getAttribute(WebApplicationContext.ROOT_WEB_APPLICATION_CONTEXT_ATTRIBUTE);
        return appContext;
    }

    private final ConfigurableListableBeanFactory getBeanFactory(MessageContext msgContext) {
        XmlWebApplicationContext appContext = getAppContext(msgContext);
        return appContext.getBeanFactory();
    }
}

再定義一個wsdd的provider,WSDDJavaSpringProvider

public class WSDDJavaSpringProvider extends WSDDProvider {

    public static final String PROVIDER_RPC = "SPRING";
    public static final QName QNAME = new QName(WSDDConstants.URI_WSDD_JAVA, PROVIDER_RPC);
    /**
     * @param service
     * @param registry XXX
     * @return XXX
     * @throws Exception XXX
     */
    @Override
    public Handler newProviderInstance(WSDDService service, EngineConfiguration registry) throws Exception {
        return new SpringProvider();
    }

    @Override
    public String getName() {
        return PROVIDER_RPC;
    }
}

wsdd再配置個service，請注意allowedMethods，可能你不想把spring service的所有方法暴露，那么可以在此配置聲明要暴露出來的方法，用英文逗號隔開即可。

<service name="springHelloWordService" provider="java:SPRING">
        <parameter name="beanName"
            value="springHelloWordService" />
        <parameter name="allowedMethods" value="sayHello" />
    </service>

還缺少一個重要的事情，就是注冊provider，好的，就這么干，在系統啟動時候加上注冊（注意注冊的方法一定要在AxisServlet初始化之前執行，load-on-startup調大點，下面是web.xml對axisServlet的配置和注冊的語句）

<servlet>
        <servlet-name>AxisServlet</servlet-name>
        <servlet-class>org.apache.axis.transport.http.AxisServlet</servlet-class>
        <load-on-startup>6</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>AxisServlet</servlet-name>
        <url-pattern>/services/*</url-pattern>
    </servlet-mapping>

WSDDProvider.registerProvider(WSDDJavaSpringProvider.QNAME,new WSDDJavaSpringProvider());

啟動~~~訪問看看吧~

來自：http://my.oschina.net/ulyn/blog/294580

本文由用戶 jopen 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。

轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。

本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！

本文地址：http://www.baiduhome.net/lib/view/open1406257961820.html

axis WEB服務/RPC/SOA

讓axis1.4與spring集成

相關經驗

相關資訊

相關文檔

目錄