springboot封装HTTPClient请求方法（get/post）_Java

1、springboot整合HTTPClient

2、封装请求方法get/post

package pers.yezi.utils; 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.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.util.ArrayList; import java.util.List; import java.util.Map; /**
 * @ClassName : HttpClientService
 * @Description :
 * @Author : Yezi
 * @Date: 2020-08-08 15:05
 */ @Service public class HttpClientService { @Autowired private CloseableHttpClient httpClient; @Autowired private RequestConfig requestConfig; /**
	 * get请求
	 */ public String doGet(String url, Map<String, String> params, String charset) { StringBuilder stringBuilder = new StringBuilder(url); String result = null; //判断字符编码 if (StringUtils.isEmpty(charset)) { charset = "utf-8"; } //判断请求参数 if (params != null) { stringBuilder.append("?"); //请求参数拼接 for (String s : params.keySet()) { stringBuilder.append(s).append("=").append(params.get(s)).append("&"); } stringBuilder.deleteCharAt(stringBuilder.lastIndexOf("&")); } //定义请求对象 HttpGet httpGet = new HttpGet(stringBuilder.toString()); httpGet.setConfig(requestConfig); try { //发送请求 CloseableHttpResponse httpResponse = httpClient.execute(httpGet); //判断请求状态 if (httpResponse.getStatusLine().getStatusCode() == 200) { //获取响应数据 result = EntityUtils.toString(httpResponse.getEntity(), charset); } } catch (IOException e) { e.printStackTrace(); throw new RuntimeException(); } return result; } public String doGet(String url) { return doGet(url, null, null); } public String doGet(String url, Map<String, String> params) { return doGet(url, params, null); } public String doGet(String url, String charset) { return doGet(url, null, charset); } //实现httpClient POST提交 public String doPost(String url, Map<String, String> params, String charset) { String result = null; //1.定义请求类型 HttpPost post = new HttpPost(url); post.setConfig(requestConfig); //定义超时时间 //2.判断字符集是否为null if (StringUtils.isEmpty(charset)) { charset = "UTF-8"; } //3.判断用户是否传递参数 if (params != null) { //3.1准备List集合信息 List<NameValuePair> parameters = new ArrayList<>(); //3.2将数据封装到List集合中 for (Map.Entry<String, String> entry : params.entrySet()) { parameters.add(new BasicNameValuePair(entry.getKey(), entry.getValue())); } //3.3模拟表单提交 try { UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(parameters, charset); //采用u8编码 //3.4将实体对象封装到请求对象中 post.setEntity(formEntity); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } } //4.发送请求 try { CloseableHttpResponse response = httpClient.execute(post); //4.1判断返回值状态 if (response.getStatusLine().getStatusCode() == 200) { //4.2表示请求成功 result = EntityUtils.toString(response.getEntity(), charset); } else { //				System.out.println("获取状态码信息:" + response.getStatusLine().getStatusCode()); throw new RuntimeException(); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return result; } public String doPost(String url) { return doPost(url, null, null); } public String doPost(String url, Map<String, String> params) { return doPost(url, params, null); } public String doPost(String url, String charset) { return doPost(url, null, charset); } }

测试方法

 @Autowired private CloseableHttpClient httpClient; @Test public void testHttpClientService() { System.out.println(httpClientService.doGet("https://www.baidu.com")); }