WebService系列之HttpClient调用WebService接口

你的名字 2021-09-07 06:17 916阅读 0赞

测试工具下载soapui测试

[http://ws.webxml.com.cn/WebServices/WeatherWS.asmx?wsdl][http_ws.webxml.com.cn_WebServices_WeatherWS.asmx_wsdl]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0MjczOTE_size_16_color_FFFFFF_t_70]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0MjczOTE_size_16_color_FFFFFF_t_70 1]

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;
     }

[http_ws.webxml.com.cn_WebServices_WeatherWS.asmx_wsdl]: http://ws.webxml.com.cn/WebServices/WeatherWS.asmx?wsdl
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0MjczOTE_size_16_color_FFFFFF_t_70]: /images/20210813/f0f5e5fa0cb243a18b17466f30577f74.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQ0MjczOTE_size_16_color_FFFFFF_t_70 1]: /images/20210813/4cd40db4d52f491c9f03a56516ddd7fa.png