httpclient调用接口

使用httpclient调用接口相比webservice轻量，和c#的webapi还有些区别，下面温习一下项目中使用httpclient调用接口。

1、建立HttpClientUtil类定义基本的属性和方法

import com.alibaba.fastjson.JSON;
import org.apache.commons.lang.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.net.URI;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@SuppressWarnings("all")
public class HttpClientUtil {

    /** logger */
    private static final Logger LOGGER = LoggerFactory.getLogger(HttpClientUtil.class);

    private static final CloseableHttpClient httpClient;
    public static final String CHARSET = "UTF-8";

    static {
        RequestConfig config = RequestConfig.custom().setConnectTimeout(5000).setSocketTimeout(15000).build();
        httpClient = HttpClientBuilder.create().setDefaultRequestConfig(config).build();
    }

    public static String doGet(String url, Map<String, String> params) {
        return doGet(url, params, CHARSET);
    }

    public static String doPost(String url, Map<String, String> params) {
        return doPost(url, params, CHARSET);
    }

    public static String doPostWithJSON(String url, Object params) throws Exception {
        return doPostWithJSON(url, params, CHARSET);
    }

    public static String doPutWithJSON(String url, Object params) throws Exception {
        return doPutWithJSON(url, params, CHARSET);
    }

    public static String doDeleteWithJSON(String url, Object params) throws Exception {
        return doDeleteWithJSON(url, params, CHARSET);
    }


    /**
     * HTTP Get 获取内容
     *
     * @param url     请求的url地址 ?之前的地址
     * @param params  请求的参数
     * @param charset 编码格式
     * @return 页面内容
     */
    public static String doGet(String url, Map<String, String> params, String charset) {
        if (StringUtils.isBlank(url)) {
            return null;
        }
        try {
            if (params != null && !params.isEmpty()) {
                List<NameValuePair> pairs = new ArrayList<NameValuePair>(params.size());
                for (Map.Entry<String, String> entry : params.entrySet()) {
                    String value = entry.getValue();
                    if (value != null) {
                        pairs.add(new BasicNameValuePair(entry.getKey(), value));
                    }
                }
                url += "?" + EntityUtils.toString(new UrlEncodedFormEntity(pairs, charset));
            }
            HttpGet httpGet = new HttpGet(url);
            CloseableHttpResponse response = httpClient.execute(httpGet);
            int statusCode = response.getStatusLine().getStatusCode();
            if (statusCode != 200) {
                httpGet.abort();
                throw new RuntimeException("HttpClient,error status code :" + statusCode);
            }
            HttpEntity entity = response.getEntity();
            String result = null;
            if (entity != null) {
                result = EntityUtils.toString(entity, "utf-8");
            }
            EntityUtils.consume(entity);
            response.close();
            return result;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * HTTP Post 获取内容
     *
     * @param url     请求的url地址 ?之前的地址
     * @param params  请求的参数
     * @param charset 编码格式
     * @return 页面内容
     */
    public static String doPost(String url, Map<String, String> params, String charset) {
        if (StringUtils.isBlank(url)) {
            return null;
        }
        try {
            List<NameValuePair> pairs = null;
            if (params != null && !params.isEmpty()) {
                pairs = new ArrayList<>(params.size());
                for (Map.Entry<String, String> entry : params.entrySet()) {
                    String value = entry.getValue();
                    if (value != null) {
                        pairs.add(new BasicNameValuePair(entry.getKey(), value));
                    }
                }
            }
            HttpPost httpPost = new HttpPost(url);
            if (pairs != null && pairs.size() > 0) {
                httpPost.setEntity(new UrlEncodedFormEntity(pairs, CHARSET));
            }
            CloseableHttpResponse response = httpClient.execute(httpPost);
            int statusCode = response.getStatusLine().getStatusCode();
            if (statusCode != 200) {
                httpPost.abort();
                throw new RuntimeException("HttpClient,error status code :" + statusCode);
            }
            HttpEntity entity = response.getEntity();
            String result = null;
            if (entity != null) {
                result = EntityUtils.toString(entity, "utf-8");
            }
            EntityUtils.consume(entity);
            response.close();
            return result;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * json post
     *
     *
     * @date: 2017-10-27 16:14:47
     */
    public static String doPostWithJSON(String url, Object params, String charset) throws Exception {
        LOGGER.debug("httpClient doPostWithJSON url:	" + url);

        HttpPost httpPost = new HttpPost(url);

        StringEntity entity = new StringEntity(JSON.toJSONString(params), charset);
        entity.setContentEncoding(charset);
        entity.setContentType("application/json");
        httpPost.setEntity(entity);
        LOGGER.debug("httpClient doPostWithJSON params:	" + JSON.toJSONString(params));

        HttpResponse response = httpClient.execute(httpPost);
        int statusCode = response.getStatusLine().getStatusCode();
        if (statusCode != 200) {
            httpPost.abort();
            throw new RuntimeException("HttpClient,error status code :" + statusCode);
        }
        HttpEntity responseEntity = response.getEntity();
        String respContent = EntityUtils.toString(responseEntity, charset);
        LOGGER.debug("httpClient doPostWithJSON respContent:	" + respContent);
        return respContent;
    }

    /**
     * @Title: doPutWithJSON
     * @Description:
     * @param: url
     * @param: params
     * @param: charset
     * @return: java.lang.String
     * @throws:
     * 
     */
    public static String doPutWithJSON(String url, Object params, String charset) throws Exception {
        LOGGER.debug("httpClient doPutWithJSON url:	" + url);
        HttpPut httpPut = new HttpPut(url);

        StringEntity entity = new StringEntity(JSON.toJSONString(params), charset);
        entity.setContentEncoding(charset);
        entity.setContentType("application/json");
        httpPut.setEntity(entity);
        LOGGER.debug("httpClient doPutWithJSON params:	" + JSON.toJSONString(params));

        HttpResponse response = httpClient.execute(httpPut);
        int statusCode = response.getStatusLine().getStatusCode();
        if (statusCode != 200) {
            httpPut.abort();
            throw new RuntimeException("HttpClient,error status code :" + statusCode);
        }
        HttpEntity responseEntity = response.getEntity();
        String respContent = EntityUtils.toString(responseEntity, charset);
        LOGGER.debug("httpClient doPutWithJSON respContent:	" + respContent);
        return respContent;
    }

    /**
     * @Title: doDeleteWithJSON
     * @Description:
     * @param: url
     * @param: params
     * @param: charset
     * @return: java.lang.String
     * @throws:
     * 
     */
    public static String doDeleteWithJSON(String url, Object params, String charset) throws Exception {
        /**
         * 没有现成的delete可以带json的，自己实现一个，参考HttpPost的实现
         */
        class HttpDeleteWithBody extends HttpEntityEnclosingRequestBase {
            public static final String METHOD_NAME = "DELETE";

            @SuppressWarnings("unused")
            public HttpDeleteWithBody() {
            }

            @SuppressWarnings("unused")
            public HttpDeleteWithBody(URI uri) {
                setURI(uri);
            }

            public HttpDeleteWithBody(String uri) {
                setURI(URI.create(uri));
            }

            public String getMethod() {
                return METHOD_NAME;
            }
        }
        LOGGER.debug("httpClient doDeleteWithJSON url:	" + url);
        HttpDeleteWithBody httpDelete = new HttpDeleteWithBody(url);

        StringEntity entity = new StringEntity(JSON.toJSONString(params), charset);
        entity.setContentEncoding(charset);
        entity.setContentType("application/json");
        httpDelete.setEntity(entity);
        LOGGER.debug("httpClient doDeleteWithJSON params:	" + JSON.toJSONString(params));

        HttpResponse response = httpClient.execute(httpDelete);
        int statusCode = response.getStatusLine().getStatusCode();
        if (statusCode != 200) {
            httpDelete.abort();
            throw new RuntimeException("HttpClient,error status code :" + statusCode);
        }
        HttpEntity responseEntity = response.getEntity();
        String respContent = EntityUtils.toString(responseEntity, charset);
        LOGGER.debug("httpClient doDeleteWithJSON respContent:	" + respContent);
        return respContent;
    }

    /**
     * 获取新建柜员参数
     *
     * @param tlrIdt
     * @return
     */
    public static Map<String, String> getCiftlrAddParam(String tlrIdt) {
        Map<String, String> params = new HashMap<String, String>();
        params.put("tlrIdt", tlrIdt);//柜员号
        params.put("tlrNum", tlrIdt.substring(2, tlrIdt.length()));//柜员编号
        params.put("bdtTdtTyp", "0000100 - 国泰安银行总行营业部");
        params.put("bdtTdt", "0000100");
        params.put("bdtTyp", "05");
        params.put("tlrNam", "信贷员" + Integer.parseInt(tlrIdt));//用户名
        params.put("tlrTyp", "1");
        params.put("sgnPwd", "666666");
        params.put("sgnPdc", "666666");
        params.put("tlrRak", "5");
        params.put("aut1", "000005@6");
        params.put("autMa1", "000005");
        params.put("mngCl1", "6");
        params.put("aut2", "000006@7");
        params.put("autMa2", "000006");
        params.put("mngCl2", "7");
        params.put("ftxFlg", "Y");
        params.put("cbxFlg", "1");
        params.put("eftDat", "2015-01-19");
        params.put("expDat", "2099-01-01");
        params.put("uptTlr", "000001");
        params.put("recSts", "P");
        params.put("uptDat", "2015-01-19 00:00:00");
        params.put("citCde", "00");
        return params;

    }

    /**
     * 获取柜员匹配参数
     *
     * @param tlrIdt
     * @return
     */
    public static Map<String, String> getUserroleAddParam(String tlrIdt) {
        Map<String, String> params = new HashMap<String, String>();
        params.put("usr_rol", "0007,00070002;0008,00080002;");
        params.put("tlr_idt", tlrIdt);
        params.put("radio_0007", "11");
        params.put("radio_0008", "11");
        return params;
    }


}

2、在项目中调用

ScoreApi scoreApi = traintestService.getExeScoreListApi(trainTest.getId(), 0);
                     
                    String s = HttpClientUtil.doPostWithJSON(sPath+score, scoreApi);
                    ResultMsg resultMsg = JSON.parseObject(s, ResultMsg.class);
                    if(resultMsg.getResult() == 1){
                        throw new RuntimeException(resultMsg.getExplain());
                    }

String url = hostAddr+"/common/projectInfo/getBasicItemsApi";
        Map params = new HashMap<>();
        params.put("teacherId", "2");
        String str = HttpClientUtil.doPost(url, params);