webservice调度函数 - JAVA

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource;

/**
*

* Title: WebServiceClientHelper.java
*

* Description:
*

* Company:
*

*
* @author erdp
* @date 2011-8-7
* @version 1.0
*/
public class WebServiceClientHelper {

/**
* webservice 公共接口类
*
* @param url webservice远程地址
*
* @param cls 接口参数
*
* @return
*/
public static T getService(String url, Class cls) {
JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
factory.setServiceClass(cls);
factory.setAddress(url);
@SuppressWarnings("unchecked")
T service = (T) factory.create();
return service;
}

public static String callService(String wsMethod , Object[] objArr) throws Exception {
Resource resource = new ClassPathResource(Constants.NC_WEBSERVICE_URL);
org.codehaus.xfire.client.Client client = new org.codehaus.xfire.client.Client(resource.getInputStream(), null);
Object[] results = client.invoke(wsMethod, objArr);
System.out.println((String)results[0]);
return (String)results[0];
}

/**
*
* @param wsUrl
* @param method
* @param arg
* @return
*/
public static String callService(String wsUrl, String method, Object arg) {
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
Client client = dcf.createClient(wsUrl);
Object[] res = null;
try {
res = client.invoke(method, arg);
client.destroy();
System.out.println((String) res[0]);
} catch (Exception e) {
e.printStackTrace();
}
return (String) res[0];
}
}
作者“ERDP技术架构”