add GlobalInterceptor

CHANGELOG.md

@@ -47,6 +47,7 @@
 * 【db     】     DruidDataSource构建时支持自定义参数（issue#I4ZKCW@Gitee）
 * 【poi    】     ExcelWriter增加addImg重载（issue#2218@Github）
 * 【bloomFilter】 增加FuncFilter
+* 【http   】     增加GlobalInterceptor（issue#2217）
 
 ### 🐞Bug修复
 * 【core   】     修复ObjectUtil.hasNull传入null返回true的问题（pr#555@Gitee）

hutool-http/src/main/java/cn/hutool/http/GlobalHeaders.java

@@ -113,7 +113,7 @@ public enum GlobalHeaders {
 	 * @param isOverride 是否覆盖已有值
 	 * @return this
 	 */
-	public GlobalHeaders header(String name, String value, boolean isOverride) {
+	synchronized public GlobalHeaders header(String name, String value, boolean isOverride) {
 		if (null != name && null != value) {
 			final List<String> values = headers.get(name.trim());
 			if (isOverride || CollectionUtil.isEmpty(values)) {
@@ -192,7 +192,7 @@ public enum GlobalHeaders {
 	 * @param name Header名
 	 * @return this
 	 */
-	public GlobalHeaders removeHeader(String name) {
+	synchronized public GlobalHeaders removeHeader(String name) {
 		if (name != null) {
 			headers.remove(name.trim());
 		}
@@ -224,7 +224,7 @@ public enum GlobalHeaders {
 	 * @return this
 	 * @since 5.7.13
 	 */
-	public GlobalHeaders clearHeaders() {
+	synchronized public GlobalHeaders clearHeaders() {
 		this.headers.clear();
 		return this;
 	}

hutool-http/src/main/java/cn/hutool/http/GlobalInterceptor.java

@@ -0,0 +1,44 @@
+package cn.hutool.http;
+
+/**
+ * 全局的拦截器
+ *
+ * @author looly
+ * @since 5.8.0
+ */
+public enum GlobalInterceptor {
+	INSTANCE;
+
+	private final HttpInterceptor.Chain interceptors = new HttpInterceptor.Chain();
+
+	/**
+	 * 设置拦截器，用于在请求前重新编辑请求
+	 *
+	 * @param interceptor 拦截器实现
+	 */
+	synchronized public GlobalInterceptor addInterceptor(HttpInterceptor interceptor) {
+		this.interceptors.addChain(interceptor);
+		return this;
+	}
+
+	/**
+	 * 清空
+	 * @return this
+	 */
+	synchronized public GlobalInterceptor clear(){
+		interceptors.clear();
+		return this;
+	}
+
+	/**
+	 * 复制过滤器列表
+	 * @return {@link cn.hutool.http.HttpInterceptor.Chain}
+	 */
+	HttpInterceptor.Chain getCopied(){
+		final HttpInterceptor.Chain copied = new HttpInterceptor.Chain();
+		for (HttpInterceptor interceptor : this.interceptors) {
+			copied.addChain(interceptor);
+		}
+		return copied;
+	}
+}

hutool-http/src/main/java/cn/hutool/http/HttpInterceptor.java

@@ -29,7 +29,6 @@ public interface HttpInterceptor {
 	class Chain implements cn.hutool.core.lang.Chain<HttpInterceptor, Chain> {
 		private final List<HttpInterceptor> interceptors = new LinkedList<>();
 
-
 		@Override
 		public Chain addChain(HttpInterceptor element) {
 			interceptors.add(element);
@@ -40,5 +39,16 @@ public interface HttpInterceptor {
 		public Iterator<HttpInterceptor> iterator() {
 			return interceptors.iterator();
 		}
+
+		/**
+		 * 清空
+		 *
+		 * @return this
+		 * @since 5.8.0
+		 */
+		public Chain clear() {
+			interceptors.clear();
+			return this;
+		}
 	}
 }

hutool-http/src/main/java/cn/hutool/http/HttpRequest.java

@@ -206,7 +206,7 @@ public class HttpRequest extends HttpBase<HttpRequest> {
 	/**
 	 * 请求前的拦截器，用于在请求前重新编辑请求
 	 */
-	private final HttpInterceptor.Chain interceptors = new HttpInterceptor.Chain();
+	private final HttpInterceptor.Chain interceptors = GlobalInterceptor.INSTANCE.getCopied();
 
 	/**
 	 * 默认连接超时
@@ -967,8 +967,9 @@ public class HttpRequest extends HttpBase<HttpRequest> {
 	 * @param interceptor 拦截器实现
 	 * @since 5.7.16
 	 */
-	public void addInterceptor(HttpInterceptor interceptor) {
+	public HttpRequest addInterceptor(HttpInterceptor interceptor) {
 		this.interceptors.addChain(interceptor);
+		return this;
 	}
 
 	/**

hutool-http/src/test/java/cn/hutool/http/HttpRequestTest.java

@@ -167,4 +167,17 @@ public class HttpRequestTest {
 		execute = HttpRequest.get(url).setMaxRedirectCount(1).execute();
 		Console.log(execute.getStatus(), execute.header(Header.LOCATION));
 	}
+
+	@Test
+	@Ignore
+	public void addInterceptorTest() {
+		HttpUtil.createGet("https://hutool.cn").addInterceptor(Console::log).execute();
+	}
+
+	@Test
+	@Ignore
+	public void addGlobalInterceptorTest() {
+		GlobalInterceptor.INSTANCE.addInterceptor(Console::log);
+		HttpUtil.createGet("https://hutool.cn").execute();
+	}
 }