!639 发布 5.3.0-BETA 公测版本 Merge pull request !639 from 疯狂的狮子Li/dev

疯狂的狮子Li

2025-01-20 3c8d864b5f68af5167199e0d5c9ff6c0c5852638

 ruoyi-common/ruoyi-common-satoken/src/main/java/org/dromara/common/satoken/core/dao/PlusSaTokenDao.java

@@ -2,7 +2,6 @@

import cn.dev33.satoken.dao.SaTokenDao;
import cn.dev33.satoken.util.SaFoxUtil;
import cn.hutool.core.lang.Console;
import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import org.dromara.common.redis.utils.RedisUtils;
@@ -15,6 +14,8 @@

/**
 * Sa-Token持久层接口(使用框架自带RedisUtils实现 协议统一)
 * <p>
 * 采用 caffeine + redis 多级缓存 优化并发查询效率
 *
 * @author Lion Li
 */
@@ -22,7 +23,7 @@

    private static final Cache<String, Object> CAFFEINE = Caffeine.newBuilder()
        // 设置最后一次写入或访问后经过固定时间过期
        .expireAfterWrite(10, TimeUnit.SECONDS)
        .expireAfterWrite(5, TimeUnit.SECONDS)
        // 初始的缓存空间大小
        .initialCapacity(100)
        // 缓存的最大条数
@@ -35,7 +36,6 @@
    @Override
    public String get(String key) {
        Object o = CAFFEINE.get(key, k -> RedisUtils.getCacheObject(key));
        Console.log("caffeine -> key:" + key + ",value:" + o);
        return (String) o;
    }

@@ -51,9 +51,13 @@
        if (timeout == NEVER_EXPIRE) {
            RedisUtils.setCacheObject(key, value);
        } else {
            RedisUtils.setCacheObject(key, value, Duration.ofSeconds(timeout));
            if (RedisUtils.hasKey(key)) {
                RedisUtils.setCacheObject(key, value, true);
            } else {
                RedisUtils.setCacheObject(key, value, Duration.ofSeconds(timeout));
            }
        }
        CAFFEINE.put(key, value);
        CAFFEINE.invalidate(key);
    }

    /**
@@ -63,7 +67,7 @@
    public void update(String key, String value) {
        if (RedisUtils.hasKey(key)) {
            RedisUtils.setCacheObject(key, value, true);
            CAFFEINE.put(key, value);
            CAFFEINE.invalidate(key);
        }
    }

@@ -99,7 +103,6 @@
    @Override
    public Object getObject(String key) {
        Object o = CAFFEINE.get(key, k -> RedisUtils.getCacheObject(key));
        Console.log("caffeine -> key:" + key + ",value:" + o);
        return o;
    }

@@ -115,9 +118,13 @@
        if (timeout == NEVER_EXPIRE) {
            RedisUtils.setCacheObject(key, object);
        } else {
            RedisUtils.setCacheObject(key, object, Duration.ofSeconds(timeout));
            if (RedisUtils.hasKey(key)) {
                RedisUtils.setCacheObject(key, object, true);
            } else {
                RedisUtils.setCacheObject(key, object, Duration.ofSeconds(timeout));
            }
        }
        CAFFEINE.put(key, object);
        CAFFEINE.invalidate(key);
    }

    /**
@@ -127,7 +134,7 @@
    public void updateObject(String key, Object object) {
        if (RedisUtils.hasKey(key)) {
            RedisUtils.setCacheObject(key, object, true);
            CAFFEINE.put(key, object);
            CAFFEINE.invalidate(key);
        }
    }