HttpClientUtil工具类封装

package com.jd.ng.shiro.utils;

import org.apache.http.HttpEntity;

import org.apache.http.HttpStatus;

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.HttpGet;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClients;

import org.apache.http.message.BasicNameValuePair;

import org.apache.http.util.EntityUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import java.io.IOException;

import java.util.ArrayList;

import java.util.List;

/**

@Author: husToy.Wang
@Date: 2019/8/5 9:38

@Version 1.0

*/

public class HttpClientUtil {

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

/**

封装 doGet方法，执行
@param url
@return

*/

public static String doGet(String url) {

CloseableHttpClient httpClient = HttpClients.createDefault();

HttpGet httpGet = new HttpGet(url);

/**
- 设置请求头
  
  */
  
  //httpGet.setHeader(new BasicHeader("Content-Type", "application/x-www-form-urlencoded; charset=utf-8"));
CloseableHttpResponse response = null;

try {

response = httpClient.execute(httpGet);
```
 if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {

     HttpEntity entity = response.getEntity();

     String result = EntityUtils.toString(entity, "UTF-8");

     EntityUtils.consume(entity);

     httpClient.close();

     return result;

 }

 httpClient.close();
```
} catch (IOException e) {

logger.error("httpClient.doGet.error:{}", e.getMessage());

return null;

}

return null;

}

/**

封装 post请求

@return

*/

public static String doPost(String url) throws IOException {

String result = null;

CloseableHttpClient httpClient = HttpClients.createDefault();

CloseableHttpResponse response = null;

try {

 HttpPost httpPost = new HttpPost(url);

 // 定义请求的配置

 RequestConfig config = RequestConfig.custom().setSocketTimeout(20000).setConnectTimeout(2000).build();

 httpPost.setConfig(config);

 List<NameValuePair> parameters = new ArrayList<NameValuePair>(0);

 parameters.add(new BasicNameValuePair("scope", "project"));

 parameters.add(new BasicNameValuePair("q", "java"));

 // 提交参数发送请求

 UrlEncodedFormEntity urlEncodedFormEntity = new UrlEncodedFormEntity(parameters);

 // 请求中设置请求体

 httpPost.setEntity(urlEncodedFormEntity);

 // 如果需要，设置请求头,多个请求头

 //Header[] headers = {new BasicHeader("Content-Type","application/x-www-form-urlencoded; charset=utf-8")};

 //httpPost.setHeaders(headers);

 response = httpClient.execute(httpPost);

 HttpEntity entity = response.getEntity();

 if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {

     result = EntityUtils.toString(entity, "UTF-8");

     EntityUtils.consume(entity);

     httpClient.close();

     return result;

 }

} catch (Exception e) {

logger.error("httpClient.doPost.error:{}", e.getMessage());

return null;

}

return null;

}

}

巴特西

HttpClientUtil工具类封装

最新文章

热门文章