feature:close and shutdown (#1103)

3 years ago · 51457f64ab
parent caf7b99328
commit 51457f64ab
1 changed files with 5 additions and 0 deletions
--- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DiscoveryClient.java
+++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DiscoveryClient.java
@ -92,6 +92,8 @@ public class DiscoveryClient implements DisposableBean {
        String clientCloseUrlPath = Constants.BASE_PATH + "/client/close";
        Result clientCloseResult;
        try {
+            // close scheduledExecutor
+            this.scheduler.shutdown();
            String groupKeyIp = new StringBuilder()
                    .append(instanceInfo.getGroupKey())
                    .append(Constants.GROUP_KEY_DELIMITER)
@ -126,6 +128,9 @@ public class DiscoveryClient implements DisposableBean {
    private boolean renew() {
        Result renewResult;
        try {
+            if (this.scheduler.isShutdown()) {
+                return false;
+            }
            InstanceInfo.InstanceRenew instanceRenew = new InstanceInfo.InstanceRenew()
                    .setAppName(instanceInfo.getAppName())
                    .setInstanceId(instanceInfo.getInstanceId())