httpClientUtil

1.依赖jar

<!-- httpClient -->
<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.3</version>
</dependency>

2.代码

　　

package com.hshc.util;

import com.hshc.common.constant.QueryAttrConstant;
import com.hshc.web.ucp.model.vo.HttpClientVo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.config.RequestConfig;
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.HttpClients;
import org.apache.http.util.EntityUtils;

import java.io.IOException;

/**
 * @author ldg
 * @Description: HttpClient工具类
 * @date 2018/9/29 上午10:31
 */
@Slf4j
public class HttpClientUtil {

    private static  final String APPID = PropertiesUtil.getProperty("detection.query.appId");

    private static final int RES_FAIL_CODE = 500; //失败响应码
    /**
   *post35      */
    public static  HttpClientVo postHttp(String url,String sign,String para){
        //创建httpClient对象
        CloseableHttpClient httpCilent = HttpClients.createDefault();

        //创建http配置对象
        RequestConfig requestConfig = RequestConfig.custom()
                .setConnectTimeout(10000)   //连接目标超时
                .setConnectionRequestTimeout(10000) // 从连接池获取连接超时
                .setSocketTimeout(10000) //等待响应超时
                .setRedirectsEnabled(true)//默认允许自动重定向
                .build();

        //创建post请求对象
        HttpPost httpPost = new HttpPost(url);
        httpPost.setConfig(requestConfig);
        httpPost.addHeader("APPID",APPID );
        httpPost.addHeader("SIGN",sign);

        if(!StringUtils.isEmpty(para)){

        StringEntity stringEntity = new StringEntity(para, "UTF-8");//解决中文乱码问题
        stringEntity.setContentEncoding("UTF-8");
        stringEntity.setContentType("application/json");
        httpPost.setEntity(stringEntity);
        }

        httpPost.addHeader("Content-type", "application/json; charset=utf-8");

        //返回结果对象
        HttpClientVo httpClientVo = HttpClientVo.getHttpClientVo();
        //处理返回结果
        try {
            HttpResponse httpResponse = httpCilent.execute(httpPost);

            if(httpResponse.getStatusLine().getStatusCode() == QueryAttrConstant.HTTP_SUCCESS_CODE){

                httpClientVo.setCode(QueryAttrConstant.HTTP_SUCCESS_CODE);
                httpClientVo.setRusultStr(EntityUtils.toString(httpResponse.getEntity()));//获得返回的结果

            }else{

                //第三方响应失败
                httpClientVo.setCode(RES_FAIL_CODE);
                log.error("http请求第三方响应失败");

            }
        } catch (IOException e) {
            httpClientVo.setCode(RES_FAIL_CODE);
            log.error("HttpClientUtil-getRulesbyHttp连接时异常",e);
        }finally {
            try {
                //关闭链接
                httpCilent.close();
            } catch (IOException e) {
                log.error("HttpClientUtil-getRulesbyHttp关闭连接时异常",e);
            }
        }

        return httpClientVo;
    }

97
//get

private String getHttpGetData(String url){
   log.info("car300 url=[{}]",url);
   String result = StringUtils.EMPTY;
   CloseableHttpClient httpClient = HttpClients.createDefault();
   HttpGet httpGet = new HttpGet(url);
   httpGet.addHeader("kdj-token", token);
   httpGet.setConfig(RequestConfig.custom().setConnectTimeout(3000).build());

   try {
      CloseableHttpResponse response = httpClient.execute(httpGet);
      int status = response.getStatusLine().getStatusCode();
      if (status == HttpStatus.SC_OK){
         HttpEntity responseEntity = response.getEntity();
         result = EntityUtils.toString(responseEntity, "UTF-8");
      }
   } catch (Exception e) {
      log.error("car300 url=[{}], is error",url, e);
   }
   log.info("car300 url=[{}], result={}",url,result);
   return result;
}

99 }

3.调用