From 3bcb066862186b88b1625a9bc074cc2789f8ae71 Mon Sep 17 00:00:00 2001
From: liyongde <1419499670@qq.com>
Date: Mon, 8 Apr 2024 13:39:31 +0800
Subject: [PATCH] fix: dynamic

---
 .../src/main/java/org/nl/AppRun.java          |  2 ++
 .../config/thread/ThreadMonitorCollector.java | 30 +++++++++++++++++++
 ...tp.core.monitor.collector.MetricsCollector |  1 +
 3 files changed, 33 insertions(+)
 create mode 100644 lms/nladmin-system/nlsso-server/src/main/java/org/nl/config/thread/ThreadMonitorCollector.java
 create mode 100644 lms/nladmin-system/nlsso-server/src/main/resources/META-INF/services/org.dromara.dynamictp.core.monitor.collector.MetricsCollector

diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/AppRun.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/AppRun.java
index 485db79..d2580d5 100644
--- a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/AppRun.java
+++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/AppRun.java
@@ -4,6 +4,7 @@ import cn.dev33.satoken.annotation.SaIgnore;
 import com.alicp.jetcache.anno.config.EnableCreateCacheAnnotation;
 import com.alicp.jetcache.anno.config.EnableMethodCache;
 
+import org.dromara.dynamictp.core.spring.EnableDynamicTp;
 import org.mybatis.spring.annotation.MapperScan;
 import org.nl.common.annotation.Limit;
 import org.nl.config.SpringContextHolder;
@@ -33,6 +34,7 @@ import org.springframework.web.bind.annotation.RestController;
         QuartzAutoConfiguration.class,
         org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class
 })
+@EnableDynamicTp
 @ServletComponentScan
 @EnableTransactionManagement
 @EnableMethodCache(basePackages = "org.nl")
diff --git a/lms/nladmin-system/nlsso-server/src/main/java/org/nl/config/thread/ThreadMonitorCollector.java b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/config/thread/ThreadMonitorCollector.java
new file mode 100644
index 0000000..53889fc
--- /dev/null
+++ b/lms/nladmin-system/nlsso-server/src/main/java/org/nl/config/thread/ThreadMonitorCollector.java
@@ -0,0 +1,30 @@
+package org.nl.config.thread;
+
+import lombok.extern.slf4j.Slf4j;
+import org.dromara.dynamictp.common.entity.ThreadPoolStats;
+import org.dromara.dynamictp.core.monitor.collector.AbstractCollector;
+
+/**
+ * @Author: lyd
+ * @Description: 线程监控
+ * @Date: 2023/12/25
+ */
+@Slf4j
+public class ThreadMonitorCollector extends AbstractCollector {
+    public static ThreadPoolStats TOMCAT_THREAD;
+    public static ThreadPoolStats EL_THREAD;
+    @Override
+    public void collect(ThreadPoolStats threadPoolStats) {
+        if ("tomcatTp".equals(threadPoolStats.getPoolName())) {
+            ThreadMonitorCollector.TOMCAT_THREAD = threadPoolStats;
+        } else {
+            ThreadMonitorCollector.EL_THREAD = threadPoolStats;
+        }
+        log.info("线程池数据:{}", threadPoolStats);
+    }
+
+    @Override
+    public String type() {
+        return "test_collect";
+    }
+}
diff --git a/lms/nladmin-system/nlsso-server/src/main/resources/META-INF/services/org.dromara.dynamictp.core.monitor.collector.MetricsCollector b/lms/nladmin-system/nlsso-server/src/main/resources/META-INF/services/org.dromara.dynamictp.core.monitor.collector.MetricsCollector
new file mode 100644
index 0000000..ca36075
--- /dev/null
+++ b/lms/nladmin-system/nlsso-server/src/main/resources/META-INF/services/org.dromara.dynamictp.core.monitor.collector.MetricsCollector
@@ -0,0 +1 @@
+# org.nl.config.thread.ThreadMonitorCollector