Merge pull request #11 from admin4j/feate-dev

feat(http): HttpUtil 支持 send HttpRequest

Author: andanyoung

admin4j-common-http/src/main/java/io/github/admin4j/http/HttpRequest.java

@@ -7,6 +7,7 @@
 import io.github.admin4j.http.core.Pair;
 import io.github.admin4j.http.util.HttpUtil;
 import lombok.Cleanup;
+import lombok.Getter;
 import lombok.Setter;
 import lombok.experimental.Accessors;
 import okhttp3.Call;
@@ -22,6 +23,7 @@
  * @author andanyang
  * @since 2022/10/14 15:43
  */
+@Getter
 public class HttpRequest {
 
     private Method method;

admin4j-common-http/src/main/java/io/github/admin4j/http/util/HttpUtil.java

@@ -1,10 +1,13 @@
 package io.github.admin4j.http.util;
 
 import io.github.admin4j.http.ApiClient;
+import io.github.admin4j.http.HttpRequest;
 import io.github.admin4j.http.core.HttpDefaultConfig;
 import io.github.admin4j.http.core.MediaTypeEnum;
 import io.github.admin4j.http.core.Pair;
 import lombok.Cleanup;
+import okhttp3.Call;
+import okhttp3.Callback;
 import okhttp3.Response;
 import org.apache.commons.lang3.StringUtils;
 
@@ -45,6 +48,7 @@ public static void setClient(ApiClient apiJsonClient) {
 
     /**
      * get 请求
+     *
      * @param url
      * @param queryParams 查询参数
      * @return
@@ -57,6 +61,7 @@ public static Response get(String url, Pair<?>... queryParams) {
 
     /**
      * get 请求
+     *
      * @param url
      * @param queryParams 查询参数
      * @return
@@ -69,6 +74,7 @@ public static Response get(String url, Map<String, Object> queryParams) {
 
     /**
      * post 请求
+     *
      * @param url
      * @param body post body 体
      * @return
@@ -79,8 +85,9 @@ public static Response post(String url, Object body) {
 
     /**
      * post（application/json;） 请求
+     *
      * @param url
-     * @param body  post body 体
+     * @param body   post body 体
      * @param header header 头
      * @return
      */
@@ -89,7 +96,8 @@ public static Response post(String url, Object body, Map<String, Object> header)
     }
 
     /**
-     *  form（x-www-form-urlencoded） 格式的 post 请求
+     * form（x-www-form-urlencoded） 格式的 post 请求
+     *
      * @param url
      * @param formParams
      * @return
@@ -100,6 +108,7 @@ public static Response postForm(String url, Map<String, Object> formParams) {
 
     /**
      * form（x-www-form-urlencoded） 格式的 post 请求
+     *
      * @param url
      * @param formParams
      * @param header
@@ -111,6 +120,7 @@ public static Response postForm(String url, Map<String, Object> formParams, Map<
 
     /**
      * put 请求
+     *
      * @param url
      * @param body
      * @return
@@ -121,6 +131,7 @@ public static Response put(String url, Object body) {
 
     /**
      * put 请求
+     *
      * @param url
      * @param body
      * @param header
@@ -132,6 +143,7 @@ public static Response put(String url, Object body, Map<String, Object> header)
 
     /**
      * form（x-www-form-urlencoded） 格式的 put 请求
+     *
      * @param url
      * @param formParams
      * @return
@@ -142,6 +154,7 @@ public static Response putForm(String url, Map<String, Object> formParams) {
 
     /**
      * form（x-www-form-urlencoded） 格式的 put 请求
+     *
      * @param url
      * @param formParams
      * @return
@@ -152,6 +165,7 @@ public static Response putForm(String url, Map<String, Object> formParams, Map<S
 
     /**
      * delete 请求
+     *
      * @param url
      * @param body
      * @return
@@ -162,6 +176,7 @@ public static Response delete(String url, Object body) {
 
     /**
      * delete 请求
+     *
      * @param url
      * @param body
      * @return
@@ -172,6 +187,7 @@ public static Response delete(String url, Object body, Map<String, Object> heade
 
     /**
      * form（x-www-form-urlencoded） 格式的 delete 请求
+     *
      * @param url
      * @param formParams
      * @return
@@ -182,6 +198,7 @@ public static Response deleteForm(String url, Map<String, Object> formParams) {
 
     /**
      * form（x-www-form-urlencoded） 格式的 delete 请求
+     *
      * @param url
      * @param formParams
      * @return
@@ -192,6 +209,7 @@ public static Response deleteForm(String url, Map<String, Object> formParams, Ma
 
     /**
      * form-data（multipart/form-data） 格式的 post 请求
+     *
      * @param url
      * @param formParams
      * @return
@@ -204,9 +222,10 @@ public static Response postFormData(String url, Map<String, Object> formParams,
         return getClient().post(url, MediaTypeEnum.FORM_DATA, null, formParams, header);
     }
 
-    
+
     /**
      * form-data（multipart/form-data） 格式的 post 请求
+     *
      * @param url
      * @param formParams
      * @return
@@ -250,4 +269,29 @@ public static void down(String url, String savePath) throws IOException {
             fileOutputStream.write(b);
         }
     }
+
+    //============= 发送http 请求 =================
+    public static Response send(HttpRequest httpRequest) {
+        ApiClient apiClient = HttpUtil.getClient();
+        Call call = apiClient.buildCall(httpRequest.getUrl(), httpRequest.getMethod(), httpRequest.getMediaType(),
+                httpRequest.getQueryParams(), httpRequest.getQueryMap(), httpRequest.getBody(), httpRequest.getForm(),
+                httpRequest.getHeaders());
+        return apiClient.execute(call);
+    }
+
+
+    /**
+     * 异步执行
+     *
+     * @param httpRequest
+     * @param callback
+     */
+    public static void asyncExecute(HttpRequest httpRequest, Callback callback) {
+
+        ApiClient apiClient = HttpUtil.getClient();
+        Call call = apiClient.buildCall(httpRequest.getUrl(), httpRequest.getMethod(), httpRequest.getMediaType(),
+                httpRequest.getQueryParams(), httpRequest.getQueryMap(), httpRequest.getBody(), httpRequest.getForm(),
+                httpRequest.getHeaders());
+        apiClient.executeAsync(call, callback);
+    }
 }