Merge branch 'feature/fix_mem_0201' into 'master'

feat:[none] 增加定时清理druid统计数据任务

See merge request rays/pcloud-common-parent!178

pcloud-common-core/src/main/java/com/pcloud/common/core/datasource/DataSourceConfig.java

@@ -113,6 +113,9 @@ public class DataSourceConfig {
 			ArrayList<String> arr = new ArrayList<>();
 			arr.add("set names utf8mb4;");
 			datasource.setConnectionInitSqls(arr);
+
+			// 定时清理druid统计数据，避免占用内存过大
+			DruidStatsResetManager.resetScheduledWithFixedDelay();
 		} catch (SQLException e) {
 			logger.error("druid configuration initialization filter", e);
 		}

pcloud-common-core/src/main/java/com/pcloud/common/core/datasource/DruidStatsResetManager.java

+package com.pcloud.common.core.datasource;
+
+import com.alibaba.druid.stat.DruidStatManagerFacade;
+import org.apache.commons.lang3.concurrent.BasicThreadFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Druid统计数据重置
+ */
+class DruidStatsResetManager {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(DruidStatsResetManager.class);
+
+    private static final ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1,
+            new BasicThreadFactory.Builder().namingPattern("druid-stats-reset-%d").build());
+
+    /**
+     * 定时重置
+     */
+    static void resetScheduledWithFixedDelay() {
+        executor.scheduleWithFixedDelay(() -> {
+            DruidStatManagerFacade.getInstance().resetAll();
+
+            LOGGER.info("druid stats data reset all executed completed.");
+
+        }, 5, 5, TimeUnit.MINUTES);
+    }
+}