测试工具下载soapui测试
http://ws.webxml.com.cn/WebServices/WeatherWS.asmx?wsdl
package com.extra.credit.util;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.io.IOUtils;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import java.nio.charset.Charset;
import java.util.List;
/**
* <pre>
* 工具类：HttpClient方式调用webService服务
* </pre>
*
* <pre>
* @author nicky ma
* 修改记录
* 修改后版本: 修改人： 修改日期: 2021/03/11 10:05 修改内容:
* </pre>
*/
@Component
public class WSHttpClientUils {
static Logger log = LoggerFactory.getLogger(WSHttpClientUils.class);
/**
* HttpClient方式调用webservice api <br>
* @Author mazq
* @Date 2021/03/11 10:14
* @Param [point, params, methodName]
* @return java.lang.String
*/
public static String doPostWebServiceURL(String point, String params, String soapAction)throws Exception {
String result = "";
// 创建HttpClientBuilder
HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
// HttpClient
CloseableHttpClient closeableHttpClient = httpClientBuilder.build();
HttpPost httpPost = new HttpPost(point);
try {
httpPost.setHeader("Content-Type", "text/xml;charset=UTF-8");
httpPost.setHeader("SOAPAction", soapAction);
StringEntity data = new StringEntity(params,
Charset.forName("UTF-8"));
httpPost.setEntity(data);
CloseableHttpResponse response = closeableHttpClient
.execute(httpPost);
HttpEntity httpEntity = response.getEntity();
if (httpEntity != null) {
result = EntityUtils.toString(httpEntity, "UTF-8");
}
} catch (Exception e) {
log.error("调用远程WebService接口异常:{}" , e);
throw e;
}finally {
IOUtils.closeQuietly(closeableHttpClient);
}
return result;
}
/**
* xml转换为JSONObject <br>
* @Author nicky ma
* @Date 2021/03/11 10:01
* @Param [xmlStr]
* @return com.alibaba.fastjson.JSONObject
*/
public static JSONObject xml2Json(String xmlStr) throws DocumentException {
Document doc = DocumentHelper.parseText(xmlStr);
JSONObject json = new JSONObject();
doParseXmlElements(doc.getRootElement() , json);
return json;
}
/**
* xml Document Elements解析 <br>
* @Author nicky ma
* @Date 2021/03/11 10:01
* @Param [element, json]
* @return void
*/
public static void doParseXmlElements(Element element, JSONObject json) {
List<Element> chdEl = element.elements();
for(Element e : chdEl){
if (!e.elements().isEmpty()) {
JSONObject chdjson = new JSONObject();
doParseXmlElements(e, chdjson);
Object o = json.get(e.getName());
if (o != null) {
JSONArray jsona = null;
if (o instanceof JSONObject) {
JSONObject jsono = (JSONObject) o;
json.remove(e.getName());
jsona = new JSONArray();
jsona.add(jsono);
jsona.add(chdjson);
}
if (o instanceof JSONArray) {
jsona = (JSONArray) o;
jsona.add(chdjson);
}
json.put(e.getName(), jsona);
} else {
if (!chdjson.isEmpty()) {
json.put(e.getName(), chdjson);
}
}
} else {
if (!e.getText().isEmpty()) {
json.put(e.getName(), e.getText());
}
}
}
}
}protected Map<String , String> obtainTokenByHttp(String paramJson , String url) throws Exception {
StringBuffer soapRequestParams = new StringBuffer();
soapRequestParams.append("<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ser="http://service.webservice.catalog.infotrust.com">");
soapRequestParams.append("<soapenv:Header/>");
soapRequestParams.append("<soapenv:Body>");
soapRequestParams.append("<ser:getToken>");
soapRequestParams.append("<ser:in0>" paramJson "</ser:in0>");
soapRequestParams.append("</ser:getToken>");
soapRequestParams.append("</soapenv:Body>");
soapRequestParams.append("</soapenv:Envelope>");
logger.warn(String.format("request params:%s", soapRequestParams.toString()));
String returnDatabase = WSHttpClientUils.doPostWebServiceURL(url , soapRequestParams.toString(),"");
logger.warn(String.format("xml string:%s" , returnDatabase));
com.alibaba.fastjson.JSONObject jsonObject = WSHttpClientUils.xml2Json(returnDatabase);
com.alibaba.fastjson.JSONObject body = jsonObject.getJSONObject("Body");
com.alibaba.fastjson.JSONObject getSafeTokenResponse = body.getJSONObject("getSafeTokenResponse");
String out = getSafeTokenResponse.getString("out");
com.alibaba.fastjson.JSONObject outJson = JSON.parseObject(out);
String code = outJson.getString("code");
String message = outJson.getString("message");
String token = "";
logger.warn(String.format("webservice api返回数据，code:%s，message:%s",code,
message));
if ("200".equals(code)) {
token = outJson.getString("token");
}
if (logger.isInfoEnabled()) {
logger.info(String.format("api token：%s", token));
}
Map<String,String> result = new HashMap<String, String>(2);
result.put("token",token);
return result;
}
