axis1.4客户端调用http形式

Posted 2020-11-07 lirenzhujiu

/**
 * http调用响应结果
 * @see [相关类/方法]
 * @since [云渠道2.0/module]
 */
public class HttpResp
{
    /**
     * 调用结果
     */
    private String result;

    /**
     * 接口响应报文
     */
    private String resp;

    /**
     * 开始调用时间
     */
    private long start;

    /**
     * 接口调用耗时
     */
    private long cost;

    public String getResult()
    {
        return result;
    }

    public void setResult(String result)
    {
        this.result = result;
    }

    public String getResp()
    {
        return resp;
    }

    public void setResp(String resp)
    {
        this.resp = resp;
    }

    public long getStart()
    {
        return start;
    }

    public void setStart(long start)
    {
        this.start = start;
    }

    public long getCost()
    {
        return cost;
    }

    public void setCost(long cost)
    {
        this.cost = cost;
    }

    @Override
    public String toString()
    {
        StringBuilder builder = new StringBuilder();
        builder.append(resp);
        return builder.toString();
    }
}

import java.io.IOException;
import java.util.Map;
import java.util.Map.Entry;
import org.apache.http.HttpEntity;
import org.apache.http.ParseException;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.apache.log4j.Logger;

/**
 * http工具
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public class HttpsUtil
{
    private final static Logger LOGGER = Logger.getLogger(HttpsUtil.class);

    private static CloseableHttpClient httpClient;

    private HttpsUtil()
    {
        httpClient = HttpClients.createDefault();
    }

    public static HttpsUtil getInstance()
    {
        return new HttpsUtil();
    }

    /**
     * 发送get请求
     * @param [参数1] [参数1说明]
     * @param [参数2] [参数2说明]
     * @return [返回类型说明]
     * @throws IOException
     * @throws ParseException
     * @exception/throws [违例类型] [违例说明]
     * @see [类、类#方法、类#成员]
     */

    public HttpResp sendHttpsPost(String url, Map<String, String> header,
            String body)
    {
        return sendHttpsPost(url, header, body, "UTF-8");
    }

    /**
     * 发送get请求
     * @param [参数1] [参数1说明]
     * @param [参数2] [参数2说明]
     * @return [返回类型说明]
     * @throws IOException
     * @throws ParseException
     * @exception/throws [违例类型] [违例说明]
     * @see [类、类#方法、类#成员]
     */

    public HttpResp sendHttpsPost(String url, Map<String, String> header,
            String body, String charset)
    {

            LOGGER.debug("sendHttpsGet(..); url=" + url);
            LOGGER.debug("sendHttpsGet(..); header=" + header);
            LOGGER.debug("sendHttpsGet(..); body=" + body);
        

        if (url == null || url.trim().equals(""))
        {
            LOGGER.error("send https get request failed, url is null");
            return null;
        }

        HttpResp httpResp = new HttpResp();

        long start = System.currentTimeMillis();
        httpResp.setStart(start);

        
        CloseableHttpResponse httpResponse = null;
        HttpEntity entity = null;
        try
        {
            HttpPost httpPost = new HttpPost(url);

            setTimeConfig(httpPost);

            httpPost.setEntity(new StringEntity(body, charset));

            addHttpHeader(httpPost, header);

            httpResponse = httpClient.execute(httpPost);
            int statusCode = httpResponse.getStatusLine().getStatusCode();

            if (200 == statusCode)
            {
                LOGGER.info("success:" + statusCode);

            }
            else
            {
                LOGGER.info("fail:" + statusCode);
            }
            entity = httpResponse.getEntity();
            String resp = EntityUtils.toString(entity, charset);

            httpResp.setResp(resp);

        }
        catch (ConnectTimeoutException e)
        {
            LOGGER.error(new StringBuffer(
                    "send https post request failed, ConnectTimeoutException ")
                    .toString(), e);
            e.printStackTrace();
            httpResp.setResult("9999");
        }
        catch (IOException e)
        {
            LOGGER.error(new StringBuffer(
                    "send https post request failed, IOException ").toString(),
                    e);
            e.printStackTrace();
            httpResp.setResult("9999");
        }
        finally
        {
            long cost = System.currentTimeMillis() - start;
            httpResp.setCost(cost);

            resourceClosed(httpClient, entity, httpResponse);
        }

        return httpResp;
    }

    /**
     * 
     * [关闭连接] [功能详细描述]
     * @param [参数1] [参数1说明]
     * @param [参数2] [参数2说明]
     * @return [返回类型说明]
     * @exception/throws [违例类型] [违例说明]
     * @see [类、类#方法、类#成员]
     */
    private void resourceClosed(CloseableHttpClient httpClient,
            HttpEntity httpEntity, CloseableHttpResponse closeableHttpResponse)
    {
        try
        {
            if (httpEntity != null)
            {
                EntityUtils.consume(httpEntity);
            }
            if (closeableHttpResponse != null)
            {
                closeableHttpResponse.close();
            }
        }
        catch (IOException e)
        {
            LOGGER.error("https resource closed error",e);
        }
    }

    private void setTimeConfig(HttpRequestBase base)
    {
        int soTimeout = 30000;
        int connTimeout = 30000;
        int connMgrTimeout = 30000;

        RequestConfig requestConfig = RequestConfig.custom()
                .setConnectTimeout(connTimeout)
                .setConnectionRequestTimeout(connMgrTimeout)
                .setSocketTimeout(soTimeout).build();
        base.setConfig(requestConfig);

    }

    public HttpResp sendHttpsGet(String url, Map<String, String> header,
            String body)
    {
        return sendHttpsGet(url, header, body, "UTF-8");
    }

    public HttpResp sendHttpsGet(String url, Map<String, String> header,
            String body, String charset)
    {
            LOGGER.debug("sendHttpsGet(..); body=" + body);
            LOGGER.debug("sendHttpsGet(..); header=" + header);
            LOGGER.debug("sendHttpsGet(..); url=" + url);
        

        if (url == null || url.trim().equals(""))
        {
            LOGGER.error("send https get request failed, url is null");
            return null;
        }

        HttpResp httpResp = new HttpResp();

        long start = System.currentTimeMillis();
        httpResp.setStart(start);

        HttpEntity entity = null;
        CloseableHttpResponse httpResponse = null;
        try
        {
            String buildGetUrl = buildGetUrl(url, body);

            HttpGet httpGet = new HttpGet(buildGetUrl);

            setTimeConfig(httpGet);

            addHttpHeader(httpGet, header);

            httpResponse = httpClient.execute(httpGet);

            if (httpResponse == null)
            {
                return null;
            }
            int statusCode = httpResponse.getStatusLine().getStatusCode();
            System.out.println("httpstatus:"+statusCode);
            entity = httpResponse.getEntity();
            String resp = EntityUtils.toString(entity, charset);

            httpResp.setResp(resp);


        }
        catch (ConnectTimeoutException e)
        {
            LOGGER.error(new StringBuffer(
                    "send https get request failed, ConnectTimeoutException ")
                    .toString(), e);
            httpResp.setResult("9999");
        }
        catch (IOException e)
        {
            LOGGER.error(new StringBuffer(
                    "send https get request failed, IOException ").toString(),
                    e);
            httpResp.setResult("9999");
        }
        finally
        {
            long cost = System.currentTimeMillis() - start;
            httpResp.setResult("0000");
            httpResp.setCost(cost);
            
            resourceClosed(httpClient, entity, httpResponse);
        }
        return httpResp;
    }

    private void addHttpHeader(HttpRequestBase requestBase,
            Map<String, String> header)
    {
        if (header == null || header.isEmpty())
        {
            LOGGER.warn("header is empty");
            return;
        }
        for (Entry<String, String> entrySet : header.entrySet())
        {
            requestBase.addHeader(entrySet.getKey(), entrySet.getValue());
        }
    }

    private String buildGetUrl(String url, String body)
    {
        url = url.trim();
        body = body.trim();
        StringBuffer realPath = new StringBuffer();
        realPath.append(url);
        if (!url.contains("?"))
        {
            realPath.append("?");
        }
        else
        {
            realPath.append("&");
        }

        realPath.append(body);

        return realPath.toString();
    }

}

import java.util.HashMap;
import java.util.Map;


public class Main2
{

    public static void main(String[] args)
    {
        
        String url = "http://ip:port/xxx";
        
        Map<String, String> header = new HashMap<String, String>();
        header.put("SOAPAction", "");
        String body = getXmlData2();
        
        System.out.println(body);
        String chartset = "UTF-8";
        
        HttpResp resp = HttpsUtil.getInstance().sendHttpsPost(
                url, header,
                body,
                chartset);
        System.out.println(resp.toString());

    }
    
    public static String getXmlData() {
        StringBuffer sb = new StringBuffer();
        sb.append("<soapenv:Envelope xmlns:soapenv=\\"http://xxxxxx/\\" xmlns:aaa=\\"http://xxxxx/\\">");
        sb.append("<soapenv:Header/>");
        sb.append("<soapenv:Body>");
        sb.append("<aaa>");
        sb.append("<bbb>");
        sb.append("<id>201805192212345678</sequenceNo>");
        sb.append("<type>aaa</srcDeviceType>");
        sb.append("<srcDeviceId>1</srcDeviceId>");
        sb.append("<loginName>wp</loginName>");
        sb.append("</bbb>");
        sb.append("</aaa>");
        sb.append("</soapenv:Body>");
        sb.append("</soapenv:Envelope>");
        return sb.toString();
}

    public static String getXmlData2() {
        StringBuffer sb = new StringBuffer();
        sb.append("<soapenv:Envelope xmlns:soapenv=\\"http://xxxxx/\\" xmlns:ser=\\"http://xxx\\">");
        sb.append("<soapenv:Header />");
        sb.append("<soapenv:Body>");
        sb.append("<ser:remind>");
        sb.append("<ser:opDetail>");
        sb.append("<![CDATA[");
        sb.append("<recordInfo>");
        sb.append("<fieldInfo>");
        sb.append("<fieldChName>流水号</fieldChName>");
        sb.append("<fieldEnName>so_serial_code</fieldEnName>");
        sb.append("<fieldContent>20150629154117</fieldContent>");
        sb.append("</fieldInfo>");
        sb.append("<fieldInfo>");
        sb.append("<fieldChName>意见</fieldChName>");
        sb.append("<fieldEnName>remind_advice</fieldEnName>");
        sb.append("<fieldContent>121</fieldContent>");
        sb.append("</fieldInfo>");
        sb.append("</recordInfo>");
        sb.append("]]>");
        sb.append("</ser:opDetail>");
        sb.append("</ser:remind>");
        sb.append("</soapenv:Body>");
        sb.append("</soapenv:Envelope>");
        return sb.toString();
}
    
}

任何webservice调用都可以用以上模板。

在写的过程中遇到如下问题：no SOAPAction header!

<?xml version="1.0" encoding="UTF-8"?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
 <soapenv:Body>
  <soapenv:Fault>
   <faultcode xmlns:ns1="http://xml.apache.org/axis/">ns1:Client.NoSOAPAction</faultcode>
   <faultstring>no SOAPAction header!</faultstring>
   <detail>
    <ns2:hostname xmlns:ns2="http://xml.apache.org/axis/">bportal</ns2:hostname>
   </detail>
  </soapenv:Fault>
 </soapenv:Body>
</soapenv:Envelope>

 

1.关于SOAPAction描述：SOAPAction指的就是wsdl调用的方法。具体描述看：https://blog.csdn.net/kthq/article/details/1823686/

2.出现no SOAPAction header问题分析：

我有以下两个wsdl:

 

和

当我调用remind就出现no SOAPAction header问题，调用userTemplateQuery方法时便没有。原来axis1.4代码中指定，当服务端没有指定soapAction时，客户端调用必须指定，如果服务端指定了soapAction，则客户端调用不用指定。

3.服务端的sopAction=“”的原因是wsdl文件中存在多个方法，所以没有进行指定，等客户端调用指定

4.soapAction指的就是目的地即需要调用的方法，组成部分：soapAction=targetNamespace+方法名。如：我的targetNamespace为" targetNamespace="http://service.interfaces.com"，方法名为remind，则soapAction就是：soapAction=http://service.interfaces.com/remind

5.解决办法：在head中设定SOAPAction的值，可为空，也可为URI。所以我在main方法中传入head.put("soapAction","");。再将head传入到httpUtil中去。