♻️ 重构，添加自定义异常，方便捕获

Author: xkcoding

src/main/java/com/xkcoding/http/HttpUtil.java

@@ -16,6 +16,7 @@
 
 package com.xkcoding.http;
 
+import com.xkcoding.http.exception.SimpleHttpException;
 import com.xkcoding.http.support.Http;
 import com.xkcoding.http.support.HttpHeader;
 import com.xkcoding.http.support.httpclient.HttpClientImpl;
@@ -63,6 +64,12 @@ else if (ClassUtil.isPresent("cn.hutool.http.HttpRequest", classLoader)) {
 	public void setHttp(Http http) {
 		proxy = http;
 	}
+	
+	private void checkHttpNotNull(Http proxy) {
+		if (null == proxy) {
+			throw new SimpleHttpException("HTTP 实现类未指定！");
+		}
+	}
 
 	/**
 	 * GET 请求
@@ -71,6 +78,7 @@ public void setHttp(Http http) {
 	 * @return 结果
 	 */
 	public String get(String url) {
+		checkHttpNotNull(proxy);
 		return proxy.get(url);
 	}
 
@@ -83,6 +91,7 @@ public String get(String url) {
 	 * @return 结果
 	 */
 	public String get(String url, Map<String, String> params, boolean encode) {
+		checkHttpNotNull(proxy);
 		return proxy.get(url, params, encode);
 	}
 
@@ -96,6 +105,7 @@ public String get(String url, Map<String, String> params, boolean encode) {
 	 * @return 结果
 	 */
 	public String get(String url, Map<String, String> params, HttpHeader header, boolean encode) {
+		checkHttpNotNull(proxy);
 		return proxy.get(url, params, header, encode);
 	}
 
@@ -106,6 +116,7 @@ public String get(String url, Map<String, String> params, HttpHeader header, boo
 	 * @return 结果
 	 */
 	public String post(String url) {
+		checkHttpNotNull(proxy);
 		return proxy.post(url);
 	}
 
@@ -117,6 +128,7 @@ public String post(String url) {
 	 * @return 结果
 	 */
 	public String post(String url, String data) {
+		checkHttpNotNull(proxy);
 		return proxy.post(url, data);
 	}
 
@@ -129,6 +141,7 @@ public String post(String url, String data) {
 	 * @return 结果
 	 */
 	public String post(String url, String data, HttpHeader header) {
+		checkHttpNotNull(proxy);
 		return proxy.post(url, data, header);
 	}
 
@@ -141,6 +154,7 @@ public String post(String url, String data, HttpHeader header) {
 	 * @return 结果
 	 */
 	public String post(String url, Map<String, String> params, boolean encode) {
+		checkHttpNotNull(proxy);
 		return proxy.post(url, params, encode);
 	}
 
@@ -154,6 +168,7 @@ public String post(String url, Map<String, String> params, boolean encode) {
 	 * @return 结果
 	 */
 	public String post(String url, Map<String, String> params, HttpHeader header, boolean encode) {
+		checkHttpNotNull(proxy);
 		return proxy.post(url, params, header, encode);
 	}
 }

src/main/java/com/xkcoding/http/exception/SimpleHttpException.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright (c) 2019-2029, xkcoding & Yangkai.Shen & 沈扬凯 (237497819@qq.com & xkcoding.com).
+ * <p>
+ * Licensed under the GNU LESSER GENERAL PUBLIC LICENSE 3.0;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * <p>
+ * http://www.gnu.org/licenses/lgpl.html
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.xkcoding.http.exception;
+
+/**
+ * <p>
+ * 自定义异常
+ * </p>
+ *
+ * @author yangkai.shen
+ * @date Created in 2019/12/25 17:40
+ */
+public class SimpleHttpException extends RuntimeException {
+	public SimpleHttpException(Throwable cause) {
+		super(cause);
+	}
+
+	public SimpleHttpException(String message) {
+		super(message);
+	}
+
+	public SimpleHttpException(String message, Throwable cause) {
+		super(message, cause);
+	}
+}

src/main/java/com/xkcoding/http/support/httpclient/HttpClientImpl.java

@@ -17,6 +17,7 @@
 package com.xkcoding.http.support.httpclient;
 
 import com.xkcoding.http.constants.Constants;
+import com.xkcoding.http.exception.SimpleHttpException;
 import com.xkcoding.http.support.Http;
 import com.xkcoding.http.support.HttpHeader;
 import com.xkcoding.http.util.MapUtil;
@@ -68,7 +69,7 @@ private String exec(HttpRequestBase request) {
 
 		try (CloseableHttpResponse response = this.httpClient.execute(request)) {
 			if (!isSuccess(response)) {
-				throw new RuntimeException("Unexpected code " + response);
+				throw new SimpleHttpException("Unexpected code " + response);
 			}
 
 			StringBuffer body = new StringBuffer();
@@ -78,7 +79,7 @@ private String exec(HttpRequestBase request) {
 
 			return body.toString();
 		} catch (IOException e) {
-			throw new RuntimeException(e);
+			throw new SimpleHttpException(e);
 		}
 	}
 

src/main/java/com/xkcoding/http/support/hutool/HutoolImpl.java

@@ -19,6 +19,7 @@
 import cn.hutool.http.HttpRequest;
 import cn.hutool.http.HttpResponse;
 import com.xkcoding.http.constants.Constants;
+import com.xkcoding.http.exception.SimpleHttpException;
 import com.xkcoding.http.support.Http;
 import com.xkcoding.http.support.HttpHeader;
 import com.xkcoding.http.util.MapUtil;
@@ -40,7 +41,7 @@ private String exec(HttpRequest request) {
 		request = request.timeout(Constants.TIMEOUT);
 		try (HttpResponse response = request.execute()) {
 			if (!response.isOk()) {
-				throw new RuntimeException("Unexpected code " + response);
+				throw new SimpleHttpException("Unexpected code " + response);
 			}
 
 			return response.body();

src/main/java/com/xkcoding/http/support/java11/HttpClientImpl.java

@@ -17,6 +17,7 @@
 package com.xkcoding.http.support.java11;
 
 import com.xkcoding.http.constants.Constants;
+import com.xkcoding.http.exception.SimpleHttpException;
 import com.xkcoding.http.support.Http;
 import com.xkcoding.http.support.HttpHeader;
 import com.xkcoding.http.util.MapUtil;
@@ -50,7 +51,7 @@ private String exec(HttpRequest request) {
 		try {
 			return client.send(request, HttpResponse.BodyHandlers.ofString()).body();
 		} catch (IOException | InterruptedException e) {
-			throw new RuntimeException(e);
+			throw new SimpleHttpException(e);
 		}
 	}
 

src/main/java/com/xkcoding/http/support/okhttp3/OkHttp3Impl.java

@@ -17,6 +17,7 @@
 package com.xkcoding.http.support.okhttp3;
 
 import com.xkcoding.http.constants.Constants;
+import com.xkcoding.http.exception.SimpleHttpException;
 import com.xkcoding.http.support.Http;
 import com.xkcoding.http.support.HttpHeader;
 import com.xkcoding.http.util.MapUtil;
@@ -55,12 +56,12 @@ public OkHttp3Impl(OkHttpClient httpClient) {
 	private String exec(Request request) {
 		try (Response response = httpClient.newCall(request).execute()) {
 			if (!response.isSuccessful()) {
-				throw new RuntimeException("Unexpected code " + response);
+				throw new SimpleHttpException("Unexpected code " + response);
 			}
 
 			return response.body().string();
 		} catch (IOException e) {
-			throw new RuntimeException(e);
+			throw new SimpleHttpException(e);
 		}
 	}
 

src/main/java/com/xkcoding/http/util/StringUtil.java

@@ -29,11 +29,11 @@
 @UtilityClass
 public class StringUtil {
 
-	public static boolean isEmpty(String str) {
+	public boolean isEmpty(String str) {
 		return null == str || str.trim().isEmpty();
 	}
 
-	public static boolean isNotEmpty(String str) {
+	public boolean isNotEmpty(String str) {
 		return !isEmpty(str);
 	}
 

src/main/java/com/xkcoding/http/util/UrlUtil.java

@@ -18,6 +18,7 @@
 
 import cn.hutool.core.exceptions.UtilException;
 import com.xkcoding.http.constants.Constants;
+import com.xkcoding.http.exception.SimpleHttpException;
 import lombok.experimental.UtilityClass;
 
 import java.io.UnsupportedEncodingException;
@@ -48,7 +49,7 @@ public String urlEncode(String value) {
 			String encoded = URLEncoder.encode(value, Constants.DEFAULT_ENCODING.displayName());
 			return encoded.replace("+", "%20").replace("*", "%2A").replace("~", "%7E").replace("/", "%2F");
 		} catch (UnsupportedEncodingException e) {
-			throw new RuntimeException("Failed To Encode Uri", e);
+			throw new SimpleHttpException("Failed To Encode Uri", e);
 		}
 	}
 
@@ -67,7 +68,7 @@ public String urlDecode(String url) throws UtilException {
 		try {
 			return URLDecoder.decode(url, Constants.DEFAULT_ENCODING.displayName());
 		} catch (UnsupportedEncodingException e) {
-			throw new RuntimeException("Unsupported encoding", e);
+			throw new SimpleHttpException("Unsupported encoding", e);
 		}
 	}
 }