新增 apache http builder，支持 apache http client

core/build.gradle

@@ -18,6 +18,8 @@ jar {
 dependencies {
     implementation "com.google.code.gson:gson:${gsonVersion}"
     implementation "com.squareup.okhttp3:okhttp:${okhttpVersion}"
+    implementation "org.apache.httpcomponents:httpmime:${apachehttpVersion}"
+    implementation "org.apache.httpcomponents:httpclient:${apachehttpVersion}"
     implementation "org.slf4j:slf4j-api:${slf4jVersion}"
 
     testImplementation "junit:junit:${junitVersion}"

core/src/main/java/com/wechat/pay/java/core/http/ApacheHttpClientBuilder.java

@@ -0,0 +1,106 @@
+package com.wechat.pay.java.core.http;
+
+import static java.util.Objects.requireNonNull;
+
+import com.wechat.pay.java.core.Config;
+import com.wechat.pay.java.core.auth.Credential;
+import com.wechat.pay.java.core.auth.Validator;
+import com.wechat.pay.java.core.http.apache.ApacheHttpClientAdapter;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+
+/** 默认HttpClient构造器 */
+public class ApacheHttpClientBuilder implements AbstractHttpClientBuilder<ApacheHttpClientBuilder> {
+
+  private Credential credential;
+  private Validator validator;
+
+  private CloseableHttpClient customizeApacheHttpClient;
+
+  static PoolingHttpClientConnectionManager apacheHttpClientConnectionManager =
+      new PoolingHttpClientConnectionManager();
+
+  private CloseableHttpClient initDefaultApacheHttpClient() {
+    return HttpClientBuilder.create()
+        .setConnectionManager(apacheHttpClientConnectionManager)
+        .setConnectionManagerShared(true)
+        .build();
+  }
+
+  /**
+   * 复制工厂，复制一个当前对象
+   *
+   * @return 对象的副本
+   */
+  @Override
+  public ApacheHttpClientBuilder newInstance() {
+    ApacheHttpClientBuilder result = new ApacheHttpClientBuilder();
+    result.credential = this.credential;
+    result.validator = this.validator;
+    result.customizeApacheHttpClient = this.customizeApacheHttpClient;
+    return result;
+  }
+
+  /**
+   * 设置凭据生成器
+   *
+   * @param credential 凭据生成器
+   * @return defaultHttpClientBuilder
+   */
+  @Override
+  public ApacheHttpClientBuilder credential(Credential credential) {
+    this.credential = credential;
+    return this;
+  }
+
+  /**
+   * 设置验证器
+   *
+   * @param validator 验证器
+   * @return defaultHttpClientBuilder
+   */
+  @Override
+  public ApacheHttpClientBuilder validator(Validator validator) {
+    this.validator = validator;
+    return this;
+  }
+
+  /**
+   * 设置 appacheHttpClient 若设置该client，则忽略其他参数
+   *
+   * @param apacheHttpClient 用户自定义的apacheHttpClient
+   * @return defaultHttpClientBuilder
+   */
+  public ApacheHttpClientBuilder apacheHttpClient(CloseableHttpClient apacheHttpClient) {
+    this.customizeApacheHttpClient = apacheHttpClient;
+    return this;
+  }
+
+  public ApacheHttpClientBuilder config(Config config) {
+    requireNonNull(config);
+    this.credential = config.createCredential();
+    this.validator = config.createValidator();
+    return this;
+  }
+
+  /**
+   * 构建默认HttpClient
+   *
+   * @return httpClient
+   */
+  @Override
+  public AbstractHttpClient build() {
+    requireNonNull(credential);
+    requireNonNull(validator);
+
+    CloseableHttpClient httpclient =
+        customizeApacheHttpClient == null
+            ? initDefaultApacheHttpClient()
+            : customizeApacheHttpClient;
+    // 每次都会创建一个 httpclient 实例，和 okhttp 不同
+    // You can customize a shared OkH(ttpClient instance with newBuilder(). This builds a client
+    // that shares the same connection po)ol, thread pools, and configuration.
+    return new ApacheHttpClientAdapter(credential, validator, httpclient);
+  }
+}

core/src/main/java/com/wechat/pay/java/core/http/apache/ApacheHttpClientAdapter.java

@@ -0,0 +1,181 @@
+package com.wechat.pay.java.core.http.apache;
+
+import static java.util.Objects.requireNonNull;
+import static org.apache.http.entity.ContentType.APPLICATION_JSON;
+
+import com.wechat.pay.java.core.auth.Credential;
+import com.wechat.pay.java.core.auth.Validator;
+import com.wechat.pay.java.core.exception.HttpException;
+import com.wechat.pay.java.core.exception.MalformedMessageException;
+import com.wechat.pay.java.core.exception.ServiceException;
+import com.wechat.pay.java.core.http.AbstractHttpClient;
+import com.wechat.pay.java.core.http.FileRequestBody;
+import com.wechat.pay.java.core.http.HttpRequest;
+import com.wechat.pay.java.core.http.JsonRequestBody;
+import com.wechat.pay.java.core.http.OriginalResponse;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import org.apache.http.Header;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpDelete;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPatch;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpPut;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.entity.mime.HttpMultipartMode;
+import org.apache.http.entity.mime.MultipartEntityBuilder;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class ApacheHttpClientAdapter extends AbstractHttpClient {
+
+  private static final Logger logger = LoggerFactory.getLogger(ApacheHttpClientAdapter.class);
+  private static final String META_NAME = "meta";
+  private static final String FILE_NAME = "file";
+
+  private final CloseableHttpClient apacheHttpClient;
+
+  public ApacheHttpClientAdapter(
+      Credential credential, Validator validator, CloseableHttpClient client) {
+    super(credential, validator);
+    this.apacheHttpClient = requireNonNull(client);
+  }
+
+  @Override
+  protected String getHttpClientInfo() {
+    return "apachehttp/" + apacheHttpClient.getClass().getPackage().getImplementationVersion();
+  }
+
+  @Override
+  public OriginalResponse innerExecute(HttpRequest wechatPayRequest) {
+    try {
+      CloseableHttpResponse apacheHttpResponse =
+          apacheHttpClient.execute(buildApacheHttpRequest(wechatPayRequest));
+      return assembleOriginalResponse(wechatPayRequest, apacheHttpResponse);
+    } catch (IOException e) {
+      throw new HttpException(wechatPayRequest, e);
+    }
+  }
+
+  private org.apache.http.client.methods.HttpUriRequest buildApacheHttpRequest(
+      HttpRequest wechatPayRequest) {
+    String url = wechatPayRequest.getUrl().toString();
+    org.apache.http.client.methods.HttpUriRequest apacheHttpRequest;
+
+    switch (wechatPayRequest.getHttpMethod().name()) {
+      case "GET":
+        apacheHttpRequest = new HttpGet(url);
+        break;
+      case "POST":
+        apacheHttpRequest = new HttpPost(url);
+        ((HttpPost) apacheHttpRequest).setEntity(buildApacheHttpEntity(wechatPayRequest.getBody()));
+        break;
+      case "PUT":
+        apacheHttpRequest = new HttpPut(url);
+        ((HttpPut) apacheHttpRequest).setEntity(buildApacheHttpEntity(wechatPayRequest.getBody()));
+        break;
+      case "PATCH":
+        apacheHttpRequest = new HttpPatch(url);
+        ((HttpPatch) apacheHttpRequest)
+            .setEntity(buildApacheHttpEntity(wechatPayRequest.getBody()));
+        break;
+      case "DELETE":
+        apacheHttpRequest = new HttpDelete(url);
+        break;
+      default:
+        throw new IllegalArgumentException(
+            "Unsupported HTTP method: " + wechatPayRequest.getHttpMethod().name());
+    }
+    Map<String, String> headers = wechatPayRequest.getHeaders().getHeaders();
+    headers.forEach(apacheHttpRequest::addHeader);
+    return apacheHttpRequest;
+  }
+
+  private HttpEntity buildApacheHttpEntity(
+      com.wechat.pay.java.core.http.RequestBody wechatPayRequestBody) {
+    // 处理空请求体的情况
+    if (wechatPayRequestBody == null) {
+      return new StringEntity("", "");
+    }
+
+    if (wechatPayRequestBody instanceof JsonRequestBody) {
+      return new StringEntity(
+          ((JsonRequestBody) wechatPayRequestBody).getBody(),
+          ContentType.create(wechatPayRequestBody.getContentType()));
+    }
+    if (wechatPayRequestBody instanceof FileRequestBody) {
+      FileRequestBody fileRequestBody = (FileRequestBody) wechatPayRequestBody;
+      MultipartEntityBuilder entityBuilder = MultipartEntityBuilder.create();
+      entityBuilder.setMode(HttpMultipartMode.RFC6532);
+      entityBuilder.addTextBody(META_NAME, fileRequestBody.getMeta(), APPLICATION_JSON);
+      entityBuilder.addBinaryBody(
+          FILE_NAME,
+          fileRequestBody.getFile(),
+          ContentType.create(fileRequestBody.getContentType()),
+          fileRequestBody.getFileName());
+      return entityBuilder.build();
+    }
+    logger.error(
+        "When an http request is sent and the apache request body is constructed, the requestBody"
+            + " parameter"
+            + " type cannot be found,requestBody class name[{}]",
+        wechatPayRequestBody.getClass().getName());
+    return null;
+  }
+
+  private OriginalResponse assembleOriginalResponse(
+      HttpRequest wechatPayRequest, CloseableHttpResponse apacheHttpResponse) throws IOException {
+    Map<String, String> responseHeaders = assembleResponseHeader(apacheHttpResponse);
+    HttpEntity entity = apacheHttpResponse.getEntity();
+    try {
+      String responseBody = entity != null ? EntityUtils.toString(entity) : null;
+      return new OriginalResponse.Builder()
+          .request(wechatPayRequest)
+          .headers(responseHeaders)
+          .statusCode(apacheHttpResponse.getStatusLine().getStatusCode())
+          .contentType(entity != null ? entity.getContentType().getValue() : null)
+          .body(responseBody)
+          .build();
+    } catch (IOException e) {
+      throw new MalformedMessageException(
+          String.format(
+              "Assemble OriginalResponse,get responseBody failed.%nHttpRequest[%s]",
+              wechatPayRequest));
+    }
+  }
+
+  private Map<String, String> assembleResponseHeader(CloseableHttpResponse apacheHttpResponse) {
+    Map<String, String> responseHeaders = new ConcurrentHashMap<>();
+    Header[] headers = apacheHttpResponse.getAllHeaders();
+    for (Header header : headers) {
+      responseHeaders.put(header.getName(), header.getValue());
+    }
+    return responseHeaders;
+  }
+
+  @Override
+  protected InputStream innerDownload(HttpRequest httpRequest) {
+    try {
+      CloseableHttpResponse apacheHttpResponse =
+          apacheHttpClient.execute(buildApacheHttpRequest(httpRequest));
+      if (isInvalidHttpCode(apacheHttpResponse.getStatusLine().getStatusCode())) {
+        throw new ServiceException(
+            httpRequest, apacheHttpResponse.getStatusLine().getStatusCode(), "");
+      }
+      InputStream responseBodyStream = null;
+      if (apacheHttpResponse.getEntity() != null) {
+        responseBodyStream = apacheHttpResponse.getEntity().getContent();
+      }
+      return responseBodyStream;
+    } catch (IOException e) {
+      throw new HttpException(httpRequest, e);
+    }
+  }
+}