[ISSUE##3317]Change the http client implementation that nacos resttemplate depends on from apache to JDk

common/src/main/java/com/alibaba/nacos/common/http/AbstractHttpClientFactory.java

@@ -17,11 +17,10 @@
 package com.alibaba.nacos.common.http;
 
 import com.alibaba.nacos.common.http.client.DefaultAsyncHttpClientRequest;
-import com.alibaba.nacos.common.http.client.DefaultHttpClientRequest;
+import com.alibaba.nacos.common.http.client.JdkHttpClientRequest;
 import com.alibaba.nacos.common.http.client.NacosAsyncRestTemplate;
 import com.alibaba.nacos.common.http.client.NacosRestTemplate;
 import org.apache.http.client.config.RequestConfig;
-import org.apache.http.impl.client.HttpClients;
 import org.apache.http.impl.nio.client.HttpAsyncClients;
 import org.slf4j.Logger;
 
@@ -34,9 +33,8 @@ public abstract class AbstractHttpClientFactory implements HttpClientFactory {
 
     @Override
     public final NacosRestTemplate createNacosRestTemplate() {
-        RequestConfig requestConfig = getRequestConfig();
-        return new NacosRestTemplate(assignLogger(),
-                new DefaultHttpClientRequest(HttpClients.custom().setDefaultRequestConfig(requestConfig).build()));
+        HttpClientConfig httpClientConfig = buildHttpClientConfig();
+        return new NacosRestTemplate(assignLogger(), new JdkHttpClientRequest(httpClientConfig));
     }
 
     @Override

common/src/main/java/com/alibaba/nacos/common/http/HttpClientBeanHolder.java

@@ -35,7 +35,7 @@
  */
 public final class HttpClientBeanHolder {
 
-    private static final Logger LOGGER = LoggerFactory.getLogger(HttpClientManager.class);
+    private static final Logger LOGGER = LoggerFactory.getLogger(HttpClientBeanHolder.class);
 
     private static final Map<String, NacosRestTemplate> SINGLETON_REST = new HashMap<String, NacosRestTemplate>(10);
 

common/src/main/java/com/alibaba/nacos/common/http/client/HttpClientResponse.java

@@ -48,15 +48,17 @@ public interface HttpClientResponse extends Closeable {
      * Return the HTTP status code.
      *
      * @return the HTTP status as an integer
+     * @throws IOException IOException
      */
-    int getStatusCode();
+    int getStatusCode() throws IOException;
 
     /**
      * Return the HTTP status text of the response.
      *
      * @return the HTTP status text
+     * @throws IOException IOException
      */
-    String getStatusText();
+    String getStatusText() throws IOException;
 
     /**
      * close response InputStream.

common/src/main/java/com/alibaba/nacos/common/http/client/JdkHttpClientRequest.java

@@ -0,0 +1,100 @@
+/*
+ * Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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.alibaba.nacos.common.http.client;
+
+import com.alibaba.nacos.common.constant.HttpHeaderConsts;
+import com.alibaba.nacos.common.http.HttpClientConfig;
+import com.alibaba.nacos.common.http.HttpUtils;
+import com.alibaba.nacos.common.http.param.Header;
+import com.alibaba.nacos.common.http.param.MediaType;
+import com.alibaba.nacos.common.model.RequestHttpEntity;
+import com.alibaba.nacos.common.utils.JacksonUtils;
+
+import java.io.IOException;
+import java.net.HttpURLConnection;
+import java.net.URI;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * JDK http client request implement.
+ *
+ * @author mai.jh
+ */
+public class JdkHttpClientRequest implements HttpClientRequest {
+
+    private HttpClientConfig httpClientConfig;
+
+    public JdkHttpClientRequest(HttpClientConfig httpClientConfig) {
+        this.httpClientConfig = httpClientConfig;
+    }
+
+    @Override
+    public HttpClientResponse execute(URI uri, String httpMethod, RequestHttpEntity requestHttpEntity)
+            throws Exception {
+        final Object body = requestHttpEntity.getBody();
+        final Header headers = requestHttpEntity.getHeaders();
+        replaceDefaultConfig(requestHttpEntity.getHttpClientConfig());
+
+        HttpURLConnection conn = (HttpURLConnection) uri.toURL().openConnection();
+        Map<String, String> headerMap = headers.getHeader();
+        if (headerMap != null && headerMap.size() > 0) {
+            for (Map.Entry<String, String> entry : headerMap.entrySet()) {
+                conn.setRequestProperty(entry.getKey(), entry.getValue());
+            }
+        }
+
+        conn.setConnectTimeout(this.httpClientConfig.getConTimeOutMillis());
+        conn.setReadTimeout(this.httpClientConfig.getReadTimeOutMillis());
+        conn.setRequestMethod(httpMethod);
+        if (body != null) {
+            String contentType = headers.getValue(HttpHeaderConsts.CONTENT_TYPE);
+            String bodyStr = JacksonUtils.toJson(body);
+            if (MediaType.APPLICATION_FORM_URLENCODED.equals(contentType)) {
+                Map<String, String> map = JacksonUtils.toObj(bodyStr, HashMap.class);
+                bodyStr = HttpUtils.encodingParams(map, headers.getCharset());
+            }
+            if (bodyStr != null) {
+                conn.setDoOutput(true);
+                byte[] b = bodyStr.getBytes();
+                conn.setRequestProperty("Content-Length", String.valueOf(b.length));
+                conn.getOutputStream().write(b, 0, b.length);
+                conn.getOutputStream().flush();
+                conn.getOutputStream().close();
+            }
+        }
+        conn.connect();
+        return new JdkHttpClientResponse(conn);
+    }
+
+    /**
+     * Replace the HTTP config created by default with the HTTP config specified in the request.
+     *
+     * @param replaceConfig http config
+     */
+    private void replaceDefaultConfig(HttpClientConfig replaceConfig) {
+        if (replaceConfig == null) {
+            return;
+        }
+        this.httpClientConfig = replaceConfig;
+    }
+
+    @Override
+    public void close() throws IOException {
+
+    }
+}

common/src/main/java/com/alibaba/nacos/common/http/client/JdkHttpClientResponse.java

@@ -0,0 +1,78 @@
+/*
+ * Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * 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.alibaba.nacos.common.http.client;
+
+import com.alibaba.nacos.common.http.param.Header;
+import com.alibaba.nacos.common.utils.IoUtils;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.HttpURLConnection;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * JDk http client response implement.
+ *
+ * @author mai.jh
+ */
+public class JdkHttpClientResponse implements HttpClientResponse {
+
+    private final HttpURLConnection conn;
+
+    private InputStream responseStream;
+
+    private Header responseHeader;
+
+    public JdkHttpClientResponse(HttpURLConnection conn) {
+        this.conn = conn;
+    }
+
+    @Override
+    public Header getHeaders() {
+        if (this.responseHeader == null) {
+            this.responseHeader = Header.newInstance();
+        }
+
+        for (Map.Entry<String, List<String>> entry : conn.getHeaderFields().entrySet()) {
+            this.responseHeader.addParam(entry.getKey(), entry.getValue().get(0));
+        }
+        return this.responseHeader;
+    }
+
+    @Override
+    public InputStream getBody() throws IOException {
+        InputStream errorStream = this.conn.getErrorStream();
+        this.responseStream = (errorStream != null ? errorStream : this.conn.getInputStream());
+        return this.responseStream;
+    }
+
+    @Override
+    public int getStatusCode() throws IOException {
+        return this.conn.getResponseCode();
+    }
+
+    @Override
+    public String getStatusText() throws IOException {
+        return this.conn.getResponseMessage();
+    }
+
+    @Override
+    public void close() {
+        IoUtils.closeQuietly(this.responseStream);
+    }
+}