一、说明

就是一个工具类，使用了httpclient5-fluent流式组件，其实单纯用这个组件已经很方便了。只是有一些配置要自定义，所以再封装一层。

注释懒得加了，看参数名应该就明白了。有哪里不对的欢迎指正。

二、maven引用

• 这里流式组件已经依赖了 httpclient5了，所以不需要再单独引用。
• hutool工具包太好用了，我所有项目都会引用。hutool里也有httputil，只是不支持连接池。

          <dependency>
              <groupId>org.apache.httpcomponents.client5</groupId>
              <artifactId>httpclient5-fluent</artifactId>
              <version>5.0.3</version>
          </dependency>
          <!-- 小而全的Java工具类库 -->
          <dependency>
              <groupId>cn.hutool</groupId>
              <artifactId>hutool-all</artifactId>
              <version>5.5.9</version>
          </dependency>

  三、工具类

• 去掉了https证书验证
• 禁用了请求重试

  disableAutomaticRetries()

• 简单的post、get、上传文件 等封装。有需要其他的可以自行调用call 方法。
• 可自行调整连接池大小和超时时间。

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.util.CharsetUtil;
import cn.hutool.core.util.StrUtil;
import org.apache.hc.client5.http.config.RequestConfig;
import org.apache.hc.client5.http.entity.UrlEncodedFormEntity;
import org.apache.hc.client5.http.entity.mime.MultipartEntityBuilder;
import org.apache.hc.client5.http.fluent.Form;
import org.apache.hc.client5.http.fluent.Request;
import org.apache.hc.client5.http.fluent.Response;
import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
import org.apache.hc.client5.http.impl.classic.HttpClientBuilder;
import org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManagerBuilder;
import org.apache.hc.client5.http.ssl.NoopHostnameVerifier;
import org.apache.hc.client5.http.ssl.SSLConnectionSocketFactory;
import org.apache.hc.core5.http.ContentType;
import org.apache.hc.core5.http.HttpEntity;
import org.apache.hc.core5.http.io.entity.EntityUtils;
import org.apache.hc.core5.http.io.entity.HttpEntities;
import org.apache.hc.core5.util.TimeValue;
import org.apache.hc.core5.util.Timeout;

import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLEngine;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509ExtendedTrustManager;
import java.io.File;
import java.io.IOException;
import java.net.Socket;
import java.nio.charset.Charset;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.X509Certificate;
import java.util.Map;

/**
 * @author sun
 * @date 2021-02-25
 **/
public class HttpUtil {
	private static final int maxConnTotal = 200;
	private static final Timeout connectTimeout = Timeout.ofSeconds(10);
	private static final Timeout requestTimeout = Timeout.ofSeconds(30);

	public static String uploadFile(String urlString, Map<String, Object> paramMap) throws Exception {
		return uploadFile(urlString, null, paramMap, CharsetUtil.CHARSET_UTF_8)
				.returnContent()
				.asString(CharsetUtil.CHARSET_UTF_8);
	}

	public static String uploadFile(String urlString, Map<String, Object> paramMap, Charset charSet) throws Exception {
		return uploadFile(urlString, null, paramMap, charSet)
				.returnContent()
				.asString(charSet);
	}

	public static Response uploadFile(String urlString, Map<String, Object> handlerMap, Map<String, Object> paramMap) throws Exception {
		return uploadFile(urlString, handlerMap, paramMap, CharsetUtil.CHARSET_UTF_8);
	}

	public static Response uploadFile(String urlString, Map<String, Object> handlerMap, Map<String, Object> paramMap, Charset charSet) throws Exception {
		MultipartEntityBuilder builder = MultipartEntityBuilder.create().setCharset(charSet);
		paramMap.forEach((k, v) -> {
			//判断是文件还是文本
			if (v instanceof File) {
				File file = (File) v;
				builder.addBinaryBody(k, file, ContentType.MULTIPART_FORM_DATA.withCharset(charSet), FileUtil.getName(file));
			} else {
				builder.addTextBody(k, v.toString(), ContentType.TEXT_PLAIN.withCharset(charSet));
			}
		});
		Request request = Request.post(urlString)
				.body(builder.build());
		//添加消息头
		if (CollUtil.isNotEmpty(handlerMap)) {
			handlerMap.forEach((k, v) -> request.addHeader(k, v.toString()));
		}
		return call(request);
	}

	public static String post(String urlString, Map<String, Object> paramMap) throws Exception {
		return post(urlString, paramMap, CharsetUtil.CHARSET_UTF_8);
	}

	public static String post(String urlString, Map<String, Object> paramMap, Charset charSet) throws Exception {
		return post(urlString, null, paramMap, charSet)
				.returnContent()
				.asString(charSet);
	}

	public static Response post(String urlString, Map<String, Object> handlerMap, Map<String, Object> paramMap) throws Exception {
		return post(urlString, handlerMap, paramMap, CharsetUtil.CHARSET_UTF_8);
	}

	public static Response post(String urlString, Map<String, Object> handlerMap, Map<String, Object> paramMap, Charset charSet) throws Exception {
		Form form = Form.form();
		if (CollUtil.isNotEmpty(paramMap)) {
			paramMap.forEach((k, v) -> form.add(k, v.toString()));
		}
		Request request = Request.post(urlString)
				.bodyForm(form.build(), charSet);
		//添加消息头
		if (CollUtil.isNotEmpty(handlerMap)) {
			handlerMap.forEach((k, v) -> request.addHeader(k, v.toString()));
		}
		return call(request);
	}

	public static String post(String urlString, String body) throws IOException {
		return post(urlString, body, CharsetUtil.CHARSET_UTF_8);
	}

	public static String post(String urlString, String body, Charset charSet) throws IOException {
		return post(urlString, null, body, charSet)
				.returnContent()
				.asString(charSet);
	}

	public static Response post(String urlString, Map<String, Object> handlerMap, String body) throws IOException {
		return post(urlString, handlerMap, body, CharsetUtil.CHARSET_UTF_8);
	}

	public static Response post(String urlString, Map<String, Object> handlerMap, String body, Charset charSet) throws IOException {
		HttpEntity httpEntity = HttpEntities.create(body, getContentType(body, charSet));
		Request request = Request.post(urlString)
				.body(httpEntity);
		//添加消息头
		if (CollUtil.isNotEmpty(handlerMap)) {
			handlerMap.forEach((k, v) -> request.addHeader(k, v.toString()));
		}
		return call(request);
	}

	public static String get(String urlString) throws Exception {
		return get(urlString, null, CharsetUtil.CHARSET_UTF_8);
	}

	public static String get(String urlString, Map<String, Object> paramMap) throws Exception {
		return get(urlString, paramMap, CharsetUtil.CHARSET_UTF_8);
	}

	public static String get(String urlString, Map<String, Object> paramMap, Charset charSet) throws Exception {
		return get(urlString, null, paramMap, charSet)
				.returnContent()
				.asString(charSet);
	}

	public static String get(String urlString, Map<String, Object> handlerMap, Map<String, Object> paramMap) throws Exception {
		return get(urlString, handlerMap, paramMap, CharsetUtil.CHARSET_UTF_8)
				.returnContent()
				.asString(CharsetUtil.CHARSET_UTF_8);
	}

	public static Response get(String urlString, Map<String, Object> handlerMap, Map<String, Object> paramMap, Charset charSet) throws Exception {
		Form form = Form.form();
		if (CollUtil.isNotEmpty(paramMap)) {
			paramMap.forEach((k, v) -> form.add(k, v.toString()));
		}
		String paramStr = EntityUtils.toString(new UrlEncodedFormEntity(form.build(), charSet));
		Request request = Request.get(urlString + '?' + paramStr);
		//添加消息头
		if (CollUtil.isNotEmpty(handlerMap)) {
			handlerMap.forEach((k, v) -> request.addHeader(k, v.toString()));
		}
		return call(request);
	}

	public static Response call(Request request) throws IOException {
		return request.execute(Client.c);
	}

	public static ContentType getContentType(String body, Charset charSet) {
		ContentType contentType = ContentType.TEXT_PLAIN;
		if (StrUtil.isNotBlank(body)) {
			char firstChar = body.charAt(0);
			switch (firstChar) {
				case '{':
				case '[':
					// JSON请求体
					contentType = ContentType.APPLICATION_JSON;
					break;
				case '<':
					// XML请求体
					contentType = ContentType.APPLICATION_XML;
					break;
				default:
					break;
			}
		}
		if (charSet != null) {
			contentType.withCharset(charSet);
		}
		return contentType;
	}

	private static class Client {
		private static final CloseableHttpClient c = HttpClientBuilder.create()
				.setConnectionManager(PoolingHttpClientConnectionManagerBuilder.create()
						.setSSLSocketFactory(getSSLFactory())
						.setValidateAfterInactivity(TimeValue.ofSeconds(10))
						.setMaxConnPerRoute(maxConnTotal - 1)
						.setMaxConnTotal(maxConnTotal)
						.build())
				.evictIdleConnections(TimeValue.ofMinutes(1))
				.disableAutomaticRetries()
				.setDefaultRequestConfig(RequestConfig.custom()
						.setConnectTimeout(connectTimeout)
						.setConnectionRequestTimeout(requestTimeout)
						.build())
				.build();

		private static SSLConnectionSocketFactory getSSLFactory() {
			X509ExtendedTrustManager trustManager = new X509ExtendedTrustManager() {
				@Override
				public void checkClientTrusted(X509Certificate[] x509Certificates, String s, Socket socket) {
				}
				@Override
				public void checkServerTrusted(X509Certificate[] x509Certificates, String s, Socket socket) {
				}
				@Override
				public void checkClientTrusted(X509Certificate[] x509Certificates, String s, SSLEngine sslEngine) {
				}
				@Override
				public void checkServerTrusted(X509Certificate[] x509Certificates, String s, SSLEngine sslEngine) {
				}
				@Override
				public void checkClientTrusted(X509Certificate[] arg0, String arg1) {
				}
				@Override
				public void checkServerTrusted(X509Certificate[] arg0, String arg1) {
				}
				@Override
				public X509Certificate[] getAcceptedIssuers() {
					return new X509Certificate[0];
				}
			};
			SSLContext ctx = null;
			try {
				ctx = SSLContext.getInstance("TLS");
				ctx.init(null, new TrustManager[]{trustManager}, null);
			} catch (NoSuchAlgorithmException | KeyManagementException e) {
				e.printStackTrace();
			}
			assert ctx != null;
			return new SSLConnectionSocketFactory(ctx, NoopHostnameVerifier.INSTANCE);
		}
	}
}

标签：Httpclient5,String,charSet,static,paramMap,import,工具,urlString
来源： https://blog.csdn.net/shenbururen/article/details/115483590