基于springboot实现的博客系统完整源码（具备评论、留言、简历编写下载、敏感词过滤等功能）.zip

package cn.newtol.springbootblog.utils; import cn.newtol.springbootblog.entity.HttpClientResult; 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.*; import org.apache.http.client.utils.URIBuilder; import org.apache.http.entity.StringEntity; import org.apache.http.entity.mime.MultipartEntityBuilder; import org.apache.http.entity.mime.content.FileBody; 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 java.io.File; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Set; /** * @Author: 公众号：Newtol * @Description: http请求工具类 * @Date: Created in 16:45 2018/11/10 */ public class HttpClientUtil { /** * 编码格式。发送编码格式统一用UTF-8 */ private static final String ENCODING = "UTF-8"; /** * 设置连接超时时间，单位毫秒 */ private static final int CONNECT_TIMEOUT = 6000; /** * 请求获取数据的超时时间(即响应时间)，单位毫秒。 */ private static final int SOCKET_TIMEOUT = 6000; /** * 没有请求头和请求参数的Get请求 * @param url 请求地址 * @return * @throws Exception */ public static HttpClientResult doGet(String url) throws Exception { return doGet(url, null, null); } /** * 有请求参数的Get请求 * @param url 请求地址 * @param params 请求参数集合 * @return * @throws Exception */ public static HttpClientResult doGet(String url, Map<String, String> params) throws Exception { return doGet(url, null, params); } /** * 有请求参数和请求头的Get请求 * @param url 请求地址 * @param headers 请求头集合 * @param params 请求参数集合 * @return * @throws Exception */ public static HttpClientResult doGet(String url, Map<String, String> headers, Map<String, String> params) throws Exception { // 创建httpClient对象 CloseableHttpClient httpClient = HttpClients.createDefault(); // 创建访问的地址 URIBuilder uriBuilder = new URIBuilder(url); if (params != null) { Set<Entry<String, String>> entrySet = params.entrySet(); for (Entry<String, String> entry : entrySet) { uriBuilder.setParameter(entry.getKey(), entry.getValue()); } } // 创建http对象 HttpGet httpGet = new HttpGet(uriBuilder.build()); /** * setConnectTimeout：设置连接超时时间，单位毫秒。 * setConnectionRequestTimeout：设置从connect Manager(连接池)获取Connection * 超时时间，单位毫秒。这个属性是新加的属性，因为目前版本是可以共享连接池的。 * setSocketTimeout：请求获取数据的超时时间(即响应时间)，单位毫秒。 如果访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。 */ RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build(); httpGet.setConfig(requestConfig); // 设置请求头 packageHeader(headers, httpGet); // 创建httpResponse对象 CloseableHttpResponse httpResponse = null; try { // 执行请求并获得响应结果 return getHttpClientResult(httpResponse, httpClient, httpGet); } finally { // 释放资源 release(httpResponse, httpClient); } } /** * 不带请求头和请求参数post请求 * @param url 请求地址 * @return * @throws Exception */ public static HttpClientResult doPost(String url) throws Exception { return doPost(url, null, null); } /** * 带请求参数的post请求 * @param url 请求地址 * @param params 参数集合 * @return * @throws Exception */ public static HttpClientResult doPost(String url, Map<String, String> params) throws Exception { return doPost(url, null, params); } /** * url无参数，JSON数据的POST方法 * @param url 请求地址 * @param content Json数据 * @return */ public static HttpClientResult doPostWithJson(String url, String content){ return doPostWithJson(url, content); } /** * url有参数，有Json数据的POST方法 * @param url 请求地址 * @param params Url携带的参数 * @param content Json数据 * @return * @throws Exception */ public static HttpClientResult doPostWithJson(String url, Map<String, String> params, String content) throws Exception { // 创建httpClient对象 CloseableHttpClient httpClient = HttpClients.createDefault(); // 创建访问的地址 URIBuilder uriBuilder = new URIBuilder(url); if (params != null) { Set<Entry<String, String>> entrySet = params.entrySet(); for (Entry<String, String> entry : entrySet) { uriBuilder.setParameter(entry.getKey(), entry.getValue()); } } // 创建http对象 HttpPost httpPost = new HttpPost(uriBuilder.build()); RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build(); httpPost.setConfig(requestConfig); StringEntity se = new StringEntity(content.toString(),"UTF-8"); se.setContentType("application/json;charset=UTf-8"); httpPost.setEntity(se); // 创建httpResponse对象 CloseableHttpResponse httpResponse = null; try { // 执行请求并获得响应结果 return getHttpClientResult(httpResponse, httpClient, httpPost); } finally { // 释放资源 release(httpResponse, httpClient); } } /** * 模仿post提交form表单二进制文件 * @param url * @param params * @param name * @return * @throws Exception */ public static HttpClientResult doPost(String url, Map<String, String> params, String name,String pathname) throws Exception { // 创建httpClient对象 CloseableHttpClient httpClient = HttpClients.createDefault(); // 创建访问的地址 URIBuilder uriBuilder = new URIBuilder(url); if (params != null) { Set<Entry<String, String>> entrySet = params.entrySet(); for (Entry<String, String> entry : entrySet) { uriBuilder.setParameter(entry.getKey(), entry.getValue()); } } // 创建http对象 HttpPost httpPost = new HttpPost(uriBuilder.build()); RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build(); httpPost.setConfig(requestConfig); // 组装模拟表单 FileBody body = new FileBody(new File(pathname)); // 组装HTTP表单请求参数 MultipartEntityBuilder builder = MultipartEntityBuilder.create().addPart(name, body); HttpEntity httpEntity = builder.build(); httpPost.setEntity(httpEntity); // 创建httpResponse对象 CloseableHttpResponse httpResponse = null; try { // 执行请求并获得响应结果 return getHttpClientResult(httpResponse, httpClient, httpPost);