[ISSUE#1815]Adding lifecycle interface and resolve the service downtime caused by thread leak

api/src/main/java/com/alibaba/nacos/api/NacosFactory.java

@@ -97,5 +97,4 @@ public static NamingMaintainService createMaintainService(String serverAddr) thr
     public static NamingMaintainService createMaintainService(Properties properties) throws NacosException {
         return NamingMaintainFactory.createMaintainService(properties);
     }
-
 }

api/src/main/java/com/alibaba/nacos/api/config/ConfigFactory.java

@@ -58,5 +58,4 @@ public static ConfigService createConfigService(String serverAddr) throws NacosE
         properties.put(PropertyKeyConst.SERVER_ADDR, serverAddr);
         return createConfigService(properties);
     }
-
 }

api/src/main/java/com/alibaba/nacos/api/config/ConfigService.java

@@ -105,4 +105,10 @@ public interface ConfigService {
      */
     String getServerStatus();
 
+    /**
+     * Shutdown the resource service
+     *
+     * @throws NacosException exception.
+     */
+    void shutDown() throws NacosException;
 }

api/src/main/java/com/alibaba/nacos/api/exception/NacosException.java

@@ -145,5 +145,4 @@ public String toString() {
 	public static final int OVER_THRESHOLD = 503;
 
 	public static final int RESOURCE_NOT_FOUND = -404;
-
 }

api/src/main/java/com/alibaba/nacos/api/naming/NamingService.java

@@ -555,4 +555,11 @@ public interface NamingService {
      * @return is server healthy
      */
     String getServerStatus();
+
+    /**
+     * Shutdown the resource service.
+     *
+     * @throws NacosException exception.
+     */
+    void shutDown() throws NacosException;
 }

client/src/main/java/com/alibaba/nacos/client/config/NacosConfigService.java

@@ -72,14 +72,15 @@ public NacosConfigService(Properties properties) throws NacosException {
         ValidatorUtils.checkInitParam(properties);
         String encodeTmp = properties.getProperty(PropertyKeyConst.ENCODE);
         if (StringUtils.isBlank(encodeTmp)) {
-            encode = Constants.ENCODE;
+            this.encode = Constants.ENCODE;
         } else {
-            encode = encodeTmp.trim();
+            this.encode = encodeTmp.trim();
         }
         initNamespace(properties);
-        agent = new MetricsHttpAgent(new ServerHttpAgent(properties));
-        agent.start();
-        worker = new ClientWorker(agent, configFilterChainManager, properties);
+
+        this.agent = new MetricsHttpAgent(new ServerHttpAgent(properties));
+        this.agent.start();
+        this.worker = new ClientWorker(this.agent, this.configFilterChainManager, properties);
     }
 
     private void initNamespace(Properties properties) {
@@ -281,4 +282,9 @@ public String getServerStatus() {
         }
     }
 
+    @Override
+    public void shutDown() throws NacosException{
+        agent.shutdown();
+        worker.shutdown();
+    }
 }

client/src/main/java/com/alibaba/nacos/client/config/http/HttpAgent.java

@@ -17,6 +17,7 @@
 
 import com.alibaba.nacos.api.exception.NacosException;
 import com.alibaba.nacos.client.config.impl.HttpSimpleClient.HttpResult;
+import com.alibaba.nacos.common.lifecycle.Closeable;
 
 import java.io.IOException;
 import java.util.List;
@@ -27,7 +28,8 @@
  *
  * @author Nacos
  */
-public interface HttpAgent {
+public interface HttpAgent extends Closeable {
+
     /**
      * start to get nacos ip list
      * @return Nothing.

client/src/main/java/com/alibaba/nacos/client/config/http/MetricsHttpAgent.java

@@ -13,6 +13,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+/**
+ * MetricsHttpAgent
+ *
+ * @author Nacos
+ */
 package com.alibaba.nacos.client.config.http;
 
 import com.alibaba.nacos.api.exception.NacosException;
@@ -29,6 +34,7 @@
  * @author Nacos
  */
 public class MetricsHttpAgent implements HttpAgent {
+
     private HttpAgent httpAgent;
 
     public MetricsHttpAgent(HttpAgent httpAgent) {
@@ -108,5 +114,10 @@ public String getTenant() {
     public String getEncode() {
         return httpAgent.getEncode();
     }
+
+    @Override
+    public void shutdown() throws NacosException{
+        httpAgent.shutdown();
+    }
 }
 

client/src/main/java/com/alibaba/nacos/client/config/http/ServerHttpAgent.java

@@ -29,6 +29,7 @@
 import com.alibaba.nacos.client.utils.TemplateUtils;
 import com.alibaba.nacos.common.utils.IoUtils;
 import com.alibaba.nacos.common.utils.JacksonUtils;
+import com.alibaba.nacos.common.utils.ThreadUtils;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.core.type.TypeReference;
 import org.apache.commons.lang3.StringUtils;
@@ -44,7 +45,11 @@
 import java.util.Date;
 import java.util.List;
 import java.util.Properties;
-import java.util.concurrent.*;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.Callable;
 
 /**
  * Server Agent
@@ -61,6 +66,8 @@ public class ServerHttpAgent implements HttpAgent {
 
     private long securityInfoRefreshIntervalMills = TimeUnit.SECONDS.toMillis(5);
 
+    private ScheduledExecutorService executorService;
+
     /**
      * @param path          相对于web应用根，以/开头
      * @param headers
@@ -235,7 +242,7 @@ public HttpResult httpDelete(String path, List<String> headers, List<String> par
 
     private String getUrl(String serverAddr, String relativePath) {
         String contextPath = serverListMgr.getContentPath().startsWith("/") ?
-                serverListMgr.getContentPath() : "/" + serverListMgr.getContentPath();
+            serverListMgr.getContentPath() : "/" + serverListMgr.getContentPath();
         return serverAddr + contextPath + relativePath;
     }
 
@@ -244,22 +251,24 @@ public static String getAppname() {
     }
 
     public ServerHttpAgent(ServerListManager mgr) {
-        serverListMgr = mgr;
+        this.serverListMgr = mgr;
     }
 
     public ServerHttpAgent(ServerListManager mgr, Properties properties) {
-        serverListMgr = mgr;
+        this.serverListMgr = mgr;
         init(properties);
     }
 
     public ServerHttpAgent(Properties properties) throws NacosException {
-        serverListMgr = new ServerListManager(properties);
-        securityProxy = new SecurityProxy(properties);
-        namespaceId = properties.getProperty(PropertyKeyConst.NAMESPACE);
+        this.serverListMgr = new ServerListManager(properties);
+        this.securityProxy = new SecurityProxy(properties);
+        this.namespaceId = properties.getProperty(PropertyKeyConst.NAMESPACE);
         init(properties);
-        securityProxy.login(serverListMgr.getServerUrls());
+        this.securityProxy.login(this.serverListMgr.getServerUrls());
+
 
-        ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(1, new ThreadFactory() {
+        // init executorService
+        this.executorService = new ScheduledThreadPoolExecutor(1, new ThreadFactory() {
             @Override
             public Thread newThread(Runnable r) {
                 Thread t = new Thread(r);
@@ -269,12 +278,13 @@ public Thread newThread(Runnable r) {
             }
         });
 
-        executorService.scheduleWithFixedDelay(new Runnable() {
+        this.executorService.scheduleWithFixedDelay(new Runnable() {
             @Override
             public void run() {
                 securityProxy.login(serverListMgr.getServerUrls());
             }
-        }, 0, securityInfoRefreshIntervalMills, TimeUnit.MILLISECONDS);
+        }, 0, this.securityInfoRefreshIntervalMills, TimeUnit.MILLISECONDS);
+
     }
 
     private void injectSecurityInfo(List<String> params) {
@@ -329,7 +339,7 @@ private void initMaxRetry(Properties properties) {
     }
 
     @Override
-    public synchronized void start() throws NacosException {
+    public void start() throws NacosException {
         serverListMgr.start();
     }
 
@@ -430,6 +440,14 @@ public String getEncode() {
         return encode;
     }
 
+    @Override
+    public void shutdown() throws NacosException{
+        String className = this.getClass().getName();
+        LOGGER.info("{} do shutdown begin", className);
+        ThreadUtils.shutdownThreadPool(executorService, LOGGER);
+        LOGGER.info("{} do shutdown stop", className);
+    }
+
     @SuppressWarnings("PMD.ClassNamingShouldBeCamelRule")
     private static class STSCredential {
         @JsonProperty(value = "AccessKeyId")