加载图片缓存统计

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/context/combined/ImageCombined.java

@@ -10,8 +10,10 @@ import com.gic.haoban.manage.api.qdto.combined.CombinedQDTO;
 import com.gic.haoban.manage.service.util.ApolloUtils;
 import com.github.benmanes.caffeine.cache.Cache;
 import com.github.benmanes.caffeine.cache.Caffeine;
+import com.github.benmanes.caffeine.cache.stats.CacheStats;
 import net.coobird.thumbnailator.Thumbnails;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.poi.ss.formula.functions.T;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -28,9 +30,7 @@ import java.io.InputStream;
 import java.net.URL;
 import java.util.Arrays;
 import java.util.Iterator;
-import java.util.concurrent.ArrayBlockingQueue;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
+import java.util.concurrent.*;
 
 /**
  * Created by wangzubo on 2024/10/27.
@@ -42,14 +42,15 @@ public class ImageCombined {
     private static final Logger logger = LoggerFactory.getLogger(ImageCombined.class);
 
     private static final Cache<String, BufferedImage> imageCache = Caffeine.newBuilder()
-            .maximumWeight(200 * 1024 * 1024) // 100MB
-            .weigher((String key, BufferedImage image) -> image.getWidth() * image.getHeight() * 3)
+            .maximumWeight(300 * 1024 * 1024) // 100MB
+            .weigher((String key, BufferedImage image) -> image.getWidth() * image.getHeight() * 4)
             .removalListener((key, value, cause) -> {
                 logger.info("移除缓存:{}",key);
                 if (value != null) {
                     value.flush();
                 }
             })
+            .recordStats()
             .expireAfterAccess(10, TimeUnit.MINUTES) // 可设置失效时间
             .build();
 
@@ -62,6 +63,8 @@ public class ImageCombined {
             new ThreadPoolExecutor.AbortPolicy()
     );
 
+    private static final ScheduledExecutorService CACHE_STAT_SCHEDULER = Executors.newScheduledThreadPool(1);
+
     private static void refreshThreadPool(ConfigChangeEvent changeEvent) {
         if (!StringUtils.equals(changeEvent.getNamespace(), APPLICATION)) {
             return;
@@ -99,6 +102,15 @@ public class ImageCombined {
         ImageIO.scanForPlugins();  // 初始化图像插件
         Config config = ConfigService.getAppConfig();
         config.addChangeListener(ImageCombined::refreshThreadPool);
+
+        CACHE_STAT_SCHEDULER.scheduleAtFixedRate(() -> {
+            CacheStats stats = imageCache.stats();
+            logger.info("【加载图片缓存统计】请求数: {}, 命中: {}, 未命中: {}, 命中率: {}%",
+                    stats.requestCount(),
+                    stats.hitCount(),
+                    stats.missCount(),
+                    String.format("%.2f", stats.hitRate() * 100));
+        }, 10, 10, TimeUnit.MINUTES);
     }
 
     public static void main(String[] args) throws Exception{