From eafecc3ac0227960f2b8fa377be27f066e10e50f Mon Sep 17 00:00:00 2001 From: baoshiwei <baoshiwei@shlanbao.cn> Date: 星期二, 20 五月 2025 10:47:58 +0800 Subject: [PATCH] perf(lb-qms): 优化查询功能和时间范围筛选 --- ruoyi-common/ruoyi-common-redis/src/main/java/org/dromara/common/redis/manager/CaffeineCacheDecorator.java | 18 +++++++++++------- 1 files changed, 11 insertions(+), 7 deletions(-) diff --git a/ruoyi-common/ruoyi-common-redis/src/main/java/org/dromara/common/redis/manager/CaffeineCacheDecorator.java b/ruoyi-common/ruoyi-common-redis/src/main/java/org/dromara/common/redis/manager/CaffeineCacheDecorator.java index 8d1f518..6e83df1 100644 --- a/ruoyi-common/ruoyi-common-redis/src/main/java/org/dromara/common/redis/manager/CaffeineCacheDecorator.java +++ b/ruoyi-common/ruoyi-common-redis/src/main/java/org/dromara/common/redis/manager/CaffeineCacheDecorator.java @@ -1,6 +1,5 @@ package org.dromara.common.redis.manager; -import cn.hutool.core.lang.Console; import org.dromara.common.core.utils.SpringUtils; import org.springframework.cache.Cache; @@ -16,15 +15,17 @@ private static final com.github.benmanes.caffeine.cache.Cache<Object, Object> CAFFEINE = SpringUtils.getBean("caffeine"); + private final String name; private final Cache cache; - public CaffeineCacheDecorator(Cache cache) { + public CaffeineCacheDecorator(String name, Cache cache) { + this.name = name; this.cache = cache; } @Override public String getName() { - return cache.getName(); + return name; } @Override @@ -33,29 +34,31 @@ } public String getUniqueKey(Object key) { - return cache.getName() + ":" + key; + return name + ":" + key; } @Override public ValueWrapper get(Object key) { Object o = CAFFEINE.get(getUniqueKey(key), k -> cache.get(key)); - Console.log("redisson caffeine -> key: " + getUniqueKey(key) + ",value:" + o); return (ValueWrapper) o; } @SuppressWarnings("unchecked") + @Override public <T> T get(Object key, Class<T> type) { Object o = CAFFEINE.get(getUniqueKey(key), k -> cache.get(key, type)); - Console.log("redisson caffeine -> key: " + getUniqueKey(key) + ",value:" + o); return (T) o; } @Override public void put(Object key, Object value) { + CAFFEINE.invalidate(getUniqueKey(key)); cache.put(key, value); } + @Override public ValueWrapper putIfAbsent(Object key, Object value) { + CAFFEINE.invalidate(getUniqueKey(key)); return cache.putIfAbsent(key, value); } @@ -64,6 +67,7 @@ evictIfPresent(key); } + @Override public boolean evictIfPresent(Object key) { boolean b = cache.evictIfPresent(key); if (b) { @@ -77,6 +81,7 @@ cache.clear(); } + @Override public boolean invalidate() { return cache.invalidate(); } @@ -85,7 +90,6 @@ @Override public <T> T get(Object key, Callable<T> valueLoader) { Object o = CAFFEINE.get(getUniqueKey(key), k -> cache.get(key, valueLoader)); - Console.log("redisson caffeine -> key: " + getUniqueKey(key) + ",value:" + o); return (T) o; } -- Gitblit v1.9.3