cxf客户端调用webservice接口，服务器端重启后调用失败，改为Restful方式调用

之前用cxf客户端调用soap协议的webservice接口，发现一个问题：

如果服务端需要重启，在重启期间（服务未成功启动之前），cxf客户端调用了服务，返回失败结果（因为服务端未启动），等服务端重启 后，cxf客户端调用服务一直失败，只有cxf客户端重启后方可继续使用。

所以调用方式改为restful方式，post方式调用，接收返回的xml文件，服务端的重启就不会影响到客户端了 。

之前cxf客户端调用方式：

public static String sendfxBackEnd(String methodName,String json, String prokey) {
		String rs = "";
		try {
			// 这个是用cxf 客户端访问cxf部署的webservice服务
			// 千万记住，访问cxf的webservice必须加上namespace ,否则通不过
			// 现在又另外一个问题，传递过去的参数服务端接收不到
			logger.info("发送WS->sendBackEnd请求:" + rs);
			JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory
					.newInstance();
			Client client = dcf
					.createClient(ConfigUtil.getProperty("config.properties", prokey));

			// url为调用webService的wsdl地址
			QName qname = new QName(ConfigUtil.getProperty("config.properties", prokey+"Ns"),
					methodName);

			String strXml = "";
			// paramvalue为参数值
			logger.info("发送WS请求:sendfxBackEnd=" + json);
			Object[] result = client.invoke(qname, json);
			// 调用web Service//输出调用结果
			rs = result[0].toString();
			logger.info("接收WS应答:" + rs);
		} catch (Exception ex) {
			ex.printStackTrace();
		}
		
             return rs;		
	}
           

restful调用方式：

package com.market.common.protocol;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;

import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;

public class RestfulClientUtils {
	
	/**
	 * 参考示例
	 * @param args
	 * @throws Exception
	 */
	public static void main(String[] args) throws Exception {
		String url = "http://127.0.0.1:8800/axis2/services/fx.adapter/crm";
		String param = "{\"op\":\"cashorder\", \"aid\":\"3000566\"}";
		String ret = call(url, param);
		System.out.println("ret: " + ret);
	}
	
	public static String call(String urlPath, String param) throws Exception {
		StringBuffer sb = new StringBuffer();
		// 建立连接
		URL url = new URL(urlPath);
		// 如有中文一定要加上，在接收方用相应字符转码即可
		param = "args0=" + URLEncoder.encode(param, "utf-8");		// 参数
		
		HttpURLConnection conn = (HttpURLConnection) url.openConnection();
		// 设置参数
		conn.setDoOutput(true); // 需要输出
		conn.setDoInput(true); // 需要输入
		conn.setUseCaches(false); // 不允许缓存
		conn.setConnectTimeout(10000);	// 
		conn.setReadTimeout(10000);
		conn.setRequestMethod("POST"); // 设置POST方式连接
		// 设置请求属性
		conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
		conn.setRequestProperty("Connection", "Keep-Alive");// 维持长连接
		conn.setRequestProperty("Charset", "UTF-8");
		// 连接,也可以不用明文connect，使用下面的httpConn.getOutputStream()会自动connect
		conn.connect();
		// 建立输入流，向指向的URL传入参数
		DataOutputStream dos = new DataOutputStream(conn.getOutputStream());
		dos.writeBytes(param);
		dos.flush();
		dos.close();
		// 获得响应状态
		int resultCode = conn.getResponseCode();
		if (HttpURLConnection.HTTP_OK == resultCode) {
			String readLine = new String();
			BufferedReader responseReader = new BufferedReader(
					new InputStreamReader(conn.getInputStream(), "UTF-8"));
			while ((readLine = responseReader.readLine()) != null) {
				sb.append(readLine).append("\n");
			}
			responseReader.close();
			return parseXmlStr(sb.toString());
		}
		return null;
	}
	
	
	/**
	 *  解析xml字符串，提取返回内容
	 * @param xmlStr
	 * @return
	 */
	public static String parseXmlStr(String xmlStr) {
		String ret = null;
		Document doc = null;
		try {
			doc = DocumentHelper.parseText(xmlStr); //将字符串转为XML
			Element root = doc.getRootElement(); // 获取根节点
			ret = root.elementTextTrim("return"); 
		} catch (Exception e) {
			e.printStackTrace();
		}
		return ret;
	}
}