webService工具类

张军 528 0

所有工具类

项目中调用了别的系统的webservice接口,调用成功之后发现wsdlLocation的地址是写死的,不方便修改,所以需要实现地址,包括用户名密码的可配置。项目的框架是Spring,调用webservice使用的是CXF。

package zj.cxf.util;

import java.io.Serializable;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.endpoint.dynamic.DynamicClientFactory;
import org.apache.cxf.transport.http.HTTPConduit;
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
import org.apache.log4j.Logger;

/**
 * 
 * webService工具类
 * 
 * @version 1.00 (2014.09.15)
 * @author SHNKCS 张军 {@link  <a target=_blank href="http://www.zhangjunbk.com">张军个人网站</a>&nbsp;&nbsp;&nbsp;&nbsp;<a target=_blank href="http://user.qzone.qq.com/360901061/">张军QQ空间</a>}
 * 
 */
public class CxfUtil implements Serializable {
	private static final long serialVersionUID = 1L;
	private static Map<String, Client> MAP_CLIENTS = Collections.synchronizedMap(new HashMap<String, Client>());
	private static DynamicClientFactory DYNAMIC_CLIENT_FACTORY = null;
	private static final Logger logger = Logger.getLogger(CxfUtil.class);
	static {
		initInvoke();
	}

	/**
	 * 初使化调用
	 */
	private static void initInvoke() {
		if (DYNAMIC_CLIENT_FACTORY == null) {
			// DYNAMIC_CLIENT_FACTORY = JaxWsDynamicClientFactory.newInstance();
			DYNAMIC_CLIENT_FACTORY = DynamicClientFactory.newInstance();
		}
	}

	/**
	 * 创建webservice代理并且调用webservice
	 * 
	 * @param wsdlAddress
	 *            调用webservice地址
	 * @param method
	 *            调用远程的方法名
	 * @param params
	 *            传递的参数
	 * @return
	 */
	public static Object[] invoke(String wsdlAddress, String method, Object[] params) throws Exception {
		Client client = (Client) MAP_CLIENTS.get(wsdlAddress);
		if (client == null) {
			client = DYNAMIC_CLIENT_FACTORY.createClient(wsdlAddress);
			// add 时间设置防止webservice在访问时候再次超时
			HTTPConduit conduit = (HTTPConduit) client.getConduit();
			HTTPClientPolicy policy = new HTTPClientPolicy();
			policy.setConnectionTimeout(1800000);
			policy.setReceiveTimeout(1800000);
			conduit.setClient(policy);
			MAP_CLIENTS.put(wsdlAddress, client);
		}
		Object[] results = client.invoke(method, params);
		return results;
	}

	/**
	 * 
	 * @param wsdlAddress
	 *            配置文件路径
	 * @param method
	 * @param arg0
	 * @return
	 */
	public static String invoke(String wsdlAddress, String method, String params) throws Exception {
		Object[] results = invoke(wsdlAddress, method, new Object[] { params });
		if (results != null && results.length > 0 && results[0] != null) {
			return String.valueOf(results[0]);
		} else {
			return null;
		}

	}

	/**
	 * 创建客户端地址集合
	 * 
	 * @param wsdlAddressList
	 * @return
	 */
	public static boolean addClientMap(List<String> wsdlAddressList) throws Exception {
		logger.debug("创建WebService开始");
		for (String wsdlAddress : wsdlAddressList) {
			try {
				Client client = DYNAMIC_CLIENT_FACTORY.createClient(wsdlAddress);
				// 设置超时时间
				HTTPConduit conduit = (HTTPConduit) client.getConduit();
				HTTPClientPolicy policy = new HTTPClientPolicy();
				policy.setConnectionTimeout(1800000);
				policy.setReceiveTimeout(1800000);
				conduit.setClient(policy);
				MAP_CLIENTS.put(wsdlAddress, client);
				logger.debug(wsdlAddress + "创建成功");
			} catch (Exception e) {
				logger.error(wsdlAddress + "创建失败:" + e.getMessage());
				e.printStackTrace();
			}
		}
		logger.debug("WebService创建成功MAP_CLIENTS集合:" + MAP_CLIENTS);
		return true;
	}
}



更多文章、技术交流、商务合作、联系博主

微信扫码或搜索:z360901061

微信扫一扫加我为好友

QQ号联系: 360901061

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请请扫描上面二维码支持博主1元、2元、5元等您想捐的金额吧,狠狠点击下面给点支持吧

发表我的评论
最新评论 总共0条评论