监控适配netty

hippo4j-config/src/main/java/cn/hippo4j/config/netty/MonitorNettyServer.java

@@ -22,6 +22,7 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
 import java.util.concurrent.ThreadPoolExecutor;
 
 /**
@@ -66,10 +67,13 @@ public class MonitorNettyServer {
                 channelFuture.channel().closeFuture().sync();
             } catch (Exception e) {
                 log.error("nettyServerInit error",e);
-            } finally {
-                bossGroup.shutdownGracefully();
-                workGroup.shutdownGracefully();
             }
         },"nettyServerInit thread").start();
     }
+
+    @PreDestroy
+    public void destroy(){
+        bossGroup.shutdownGracefully();
+        workGroup.shutdownGracefully();
+    }
 }

hippo4j-example/hippo4j-spring-boot-starter-example/src/main/resources/application.properties

@@ -7,7 +7,7 @@ spring.application.name=dynamic-threadpool-example
 
 spring.dynamic.thread-pool.server-addr=http://localhost:6691
 spring.dynamic.thread-pool.netty-server-port=8899
-#spring.dynamic.thread-pool.report-type=netty
+spring.dynamic.thread-pool.report-type=netty
 spring.dynamic.thread-pool.namespace=prescription
 spring.dynamic.thread-pool.item-id=dynamic-threadpool-example
 spring.dynamic.thread-pool.username=admin