获取token和token的缓存

src/main/java/com/jhinno/sdk/openapi/client/JHApiClient.java

@@ -0,0 +1,402 @@
+package com.jhinno.sdk.openapi.client;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.alibaba.fastjson2.TypeReference;
+import com.jhinno.sdk.openapi.ClientErrorCode;
+import com.jhinno.sdk.openapi.ClientException;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.HttpStatus;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.*;
+import org.apache.http.config.Registry;
+import org.apache.http.config.RegistryBuilder;
+import org.apache.http.conn.socket.ConnectionSocketFactory;
+import org.apache.http.conn.socket.PlainConnectionSocketFactory;
+import org.apache.http.conn.ssl.NoopHostnameVerifier;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.ssl.SSLContextBuilder;
+import org.apache.http.util.EntityUtils;
+
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.security.KeyManagementException;
+import java.security.KeyStoreException;
+import java.security.NoSuchAlgorithmException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 提供请求的工具
+ *
+ * @author yanlongqi
+ * @date 2024/1/29 10:31
+ */
+public class JHApiClient {
+
+    /**
+     * 基础的请求URL地址
+     * 如：https://192.168.3.12/appform
+     */
+    private String baseUrl;
+
+    /**
+     * 初始化一个JHApiClient的实例，值得注意的是该实例只能内部创建
+     *
+     * @param baseUrl             景行接口服务的基础地址
+     * @param closeableHttpClient 可关闭的HTTP客户端
+     */
+    private JHApiClient(CloseableHttpClient closeableHttpClient, String baseUrl) {
+        this.baseUrl = baseUrl.endsWith("/") ? baseUrl.substring(0, baseUrl.length() - 1) : baseUrl;
+        this.closeableHttpClient = closeableHttpClient;
+        this.requestConfig = RequestConfig.custom().setSocketTimeout(DefaultHttpClientConfig.SOCKET_TIMEOUT).setConnectTimeout(DefaultHttpClientConfig.CONNECT_TIMEOUT).setConnectionRequestTimeout(DefaultHttpClientConfig.CONNECTION_REQUEST_TIMEOUT).build();
+    }
+
+
+    /**
+     * HTTP的连接客户端
+     */
+    private final CloseableHttpClient closeableHttpClient;
+
+
+    /**
+     * 每次发送请求的配置，如果该配置未进行设置则走{@link DefaultHttpClientConfig｝中的默认配置
+     */
+    private RequestConfig requestConfig;
+
+
+    /**
+     * 通过最大连接数和服务每次能并行接收的请求数量构建一个JHApiClient实例
+     *
+     * @param maxTotal   最大连接数
+     * @param maxPerRout 服务每次能并行接收的请求数量
+     * @param baseUrl    景行接口服务的基础地址
+     * @return JHApiClient的实例
+     */
+    public static JHApiClient build(int maxTotal, int maxPerRout, String baseUrl) {
+        return build(createHttpClients(maxTotal, maxPerRout), baseUrl);
+    }
+
+    /**
+     * <p>
+     * 通过{@link DefaultHttpClientConfig｝默认配置的最大连接数和服务每次能并行接收的请求数量构建一个JHApiClient实例
+     * </p>
+     *
+     * @param baseUrl 景行接口服务的基础地址
+     * @return JHApiClient的实例
+     */
+    public static JHApiClient build(String baseUrl) {
+        return build(createHttpClients(DefaultHttpClientConfig.MAX_TOTAL, DefaultHttpClientConfig.MAX_PER_ROUT), baseUrl);
+    }
+
+    /**
+     * 通过外部传入的{@link CloseableHttpClient｝构建一个请求客户端
+     * <p>
+     *
+     * @param httpClient 请求连接池
+     * @param baseUrl    景行接口服务的基础地址
+     * @return JHApiClient的实例
+     */
+    public static JHApiClient build(CloseableHttpClient httpClient, String baseUrl) {
+        return new JHApiClient(httpClient, baseUrl);
+    }
+
+
+    /**
+     * 初始化一个HTTP客户端实例
+     *
+     * @param maxTotal    设置最大连接数
+     * @param maxPerRoute 服务每次能并行接收的请求数量
+     * @return 返回一个可关闭的HTTP客户端示例
+     */
+    public static CloseableHttpClient createHttpClients(int maxTotal, int maxPerRoute) {
+        SSLContextBuilder builder = new SSLContextBuilder();
+        try {
+            builder.loadTrustMaterial(null, (x509Certificates, s) -> true);
+            SSLConnectionSocketFactory sslref = new SSLConnectionSocketFactory(builder.build(), NoopHostnameVerifier.INSTANCE);
+            Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create().register("http", new PlainConnectionSocketFactory()).register("https", sslref).build();
+            PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(registry);
+            cm.setMaxTotal(maxTotal);
+            cm.setDefaultMaxPerRoute(maxPerRoute);
+            return HttpClients.custom().setSSLSocketFactory(sslref).setConnectionManager(cm).setConnectionManagerShared(true).build();
+        } catch (NoSuchAlgorithmException | KeyManagementException | KeyStoreException e) {
+            throw new ClientException(e.getMessage(), ClientErrorCode.SSL_EXCEPTION, e);
+        }
+    }
+
+    /**
+     * 关闭JHApiClient实例 (释放所有资源)
+     * 调用JHApiClient实例的shutdown() 后，JHApiClient实例不可用。
+     * 如果客户端不存在则不进行任何操作
+     */
+    public void shutdown() {
+        try {
+            if (closeableHttpClient != null) {
+                closeableHttpClient.close();
+            }
+        } catch (IOException e) {
+            throw new ClientException("关闭JHApiClient失败", e);
+        }
+    }
+
+    /**
+     * <p>
+     * 设置一个HTTP请求的配置
+     * </p>
+     *
+     * <p>
+     * {@link JHApiClient ｝ 默认只配置了 socket连接超时的时间(socketTimeout) 、连接超时的时间(connectTimeout)、
+     * 请求超时的时间(connectionRequestTimeout)这三项，其默认配置在{@link DefaultHttpClientConfig｝中。
+     * 如果你要自定义你自己的配置，则可以通过{@link HttpClients｝构建自己的RequestConfig来请求接口
+     * </p>
+     *
+     * @param requestConfig HTTP请求的配置
+     */
+    public void setRequestConfig(RequestConfig requestConfig) {
+        this.requestConfig = requestConfig;
+    }
+
+    /**
+     * 原始发送请求
+     *
+     * @param httpRequest 请求体
+     * @param headers     请求头
+     * @return 响应体
+     */
+    public HttpEntity request(HttpRequestBase httpRequest, Map<String, String> headers) {
+        if (requestConfig == null) {
+            throw new ClientException("请配置requestConfig");
+        }
+
+        if (httpRequest == null) {
+            throw new ClientException("httpRequest不能为空");
+        }
+        httpRequest.setConfig(requestConfig);
+        if (headers == null) {
+            headers = new HashMap<>();
+        }
+        // 默认请求json数据
+        if (StringUtils.isBlank(headers.get("Content-type"))) {
+            headers.put("Content-type", "application/json");
+        }
+
+        // 添加请求头
+        for (Map.Entry<String, String> entry : headers.entrySet()) {
+            httpRequest.setHeader(entry.getKey(), entry.getValue());
+        }
+        try {
+            HttpResponse response = closeableHttpClient.execute(httpRequest);
+            if (response.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
+                httpRequest.releaseConnection();
+                throw new ClientException("发送HTTP请求失败");
+            }
+            return response.getEntity();
+        } catch (Exception e) {
+            throw new ClientException(e.getMessage());
+        }
+
+    }
+
+    /**
+     * 发送请求
+     *
+     * @param httpRequest HttpRequestBase
+     * @param headers     请求头
+     * @param type        返回数据类型
+     * @param <T>         返回的数据类型
+     * @return 返回的接口数据
+     */
+    public <T> T request(HttpRequestBase httpRequest, Map<String, String> headers, TypeReference<T> type) {
+        try {
+            String result = EntityUtils.toString(request(httpRequest, headers));
+            return type.parseObject(result);
+        } catch (Exception e) {
+            throw new ClientException(e.getMessage());
+        }
+
+    }
+
+
+    /**
+     * 发送一个get请求
+     *
+     * @param path    接口地址
+     * @param headers 请求头
+     * @param type    请求返回值类型
+     * @param <T>     t
+     * @return t
+     */
+    public <T> T get(String path, Map<String, String> headers, TypeReference<T> type) {
+        if (StringUtils.isBlank(path)) {
+            throw new RuntimeException("url不能为空");
+        }
+        HttpGet httpGet = new HttpGet(baseUrl + path);
+        return request(httpGet, headers, type);
+    }
+
+    /**
+     * 发起一个get请求
+     *
+     * @param path 接口地址
+     * @param type 返回数据的类型
+     * @param <T>  返回数据的类型
+     * @return 请求的数据
+     */
+    public <T> T get(String path, TypeReference<T> type) {
+        return get(path, null, type);
+    }
+
+    /**
+     * 获的一个url
+     *
+     * @param path   请求地址
+     * @param params 请求参数
+     * @return 添加路径参数后的URL
+     */
+    public static String getUrl(String path, Map<String, Object> params) {
+        if (StringUtils.isBlank(path)) {
+            throw new ClientException("path不能为空");
+        }
+        if (params == null || params.isEmpty()) {
+            return path;
+        }
+        StringBuilder urlBuilder = new StringBuilder(path + "?");
+        for (Map.Entry<String, Object> entry : params.entrySet()) {
+            try {
+                Object value = entry.getValue();
+                // 如果值为空，则不添加该字段
+                if (value == null) {
+                    continue;
+                }
+                urlBuilder.append(entry.getKey()).append("=");
+                if (value instanceof String) {
+                    urlBuilder.append(URLEncoder.encode((String) value, "utf-8"));
+                } else {
+                    urlBuilder.append(value);
+                }
+                urlBuilder.append("&");
+            } catch (UnsupportedEncodingException e) {
+                throw new ClientException("url参数编码失败", ClientErrorCode.UNKNOWN_HOST, e);
+            }
+        }
+        urlBuilder.setLength(urlBuilder.length() - 1);
+        return urlBuilder.toString();
+    }
+
+    /**
+     * 发送post请求
+     *
+     * @param path    请求地址
+     * @param body    请求体
+     * @param headers 请求头
+     * @param type    请求数据类型
+     * @param <T>     t 返回的数据的类型
+     * @param <K>     k body的类型
+     * @return t
+     */
+    public <T, K> T post(String path, K body, Map<String, String> headers, TypeReference<T> type) {
+        if (StringUtils.isBlank(path)) {
+            throw new RuntimeException("path不能为空");
+        }
+        HttpPost httpPost = new HttpPost(baseUrl + path);
+        try {
+            if (body != null) {
+                httpPost.setEntity(new StringEntity(JSONObject.toJSONString(body), "utf-8"));
+            }
+            return request(httpPost, headers, type);
+        } catch (Exception e) {
+            throw new RuntimeException(e.getMessage());
+        }
+    }
+
+
+    /**
+     * 发起put请求
+     *
+     * @param path    请求地址
+     * @param body    请求体
+     * @param headers 请求头
+     * @param type    请求数据类型
+     * @param <T>     t 返回的数据的类型
+     * @param <K>     k body的类型
+     * @return 请求返回的数据
+     */
+    public <T, K> T put(String path, K body, Map<String, String> headers, TypeReference<T> type) {
+        if (StringUtils.isBlank(path)) {
+            throw new RuntimeException("url不能为空");
+        }
+        HttpPut httpPost = new HttpPut(baseUrl + path);
+        try {
+            if (body != null) {
+                httpPost.setEntity(new StringEntity(JSONObject.toJSONString(body), "utf-8"));
+            }
+            return request(httpPost, headers, type);
+        } catch (Exception e) {
+            throw new RuntimeException(e.getMessage());
+        }
+    }
+
+
+    /**
+     * 发起put请求
+     *
+     * @param path 请求地址
+     * @param body 请求体
+     * @param type 请求数据类型
+     * @param <T>  t 返回的数据的类型
+     * @param <K>  k body的类型
+     * @return 请求返回的数据
+     */
+    public <T, K> T put(String path, K body, TypeReference<T> type) {
+        return put(path, body, null, type);
+    }
+
+    /**
+     * @param path 请求地址
+     * @param body 请求体
+     * @param type 响应类型
+     * @param <T>  相应返回数据类型
+     * @param <K>  请求体数据类型
+     * @return 响应数据
+     */
+    public <T, K> T post(String path, K body, TypeReference<T> type) {
+        return post(path, body, null, type);
+    }
+
+
+    /**
+     * 发起delete请求
+     *
+     * @param path    请求地址
+     * @param headers 请求头
+     * @param type    响应类型
+     * @param <T>     响应数据类型
+     * @return 响应数据
+     */
+    public <T> T delete(String path, Map<String, String> headers, TypeReference<T> type) {
+        if (StringUtils.isBlank(path)) {
+            throw new RuntimeException("url不能为空");
+        }
+        HttpDelete httpDelete = new HttpDelete(baseUrl + path);
+        return request(httpDelete, headers, type);
+    }
+
+
+    /**
+     * 发起delete请求
+     *
+     * @param path 请求地址
+     * @param type 响应类型
+     * @param <T>  响应数据类型
+     * @return 响应数据
+     */
+    public <T> T delete(String path, TypeReference<T> type) {
+        return delete(path, null, type);
+    }
+}