Caffeine實現(xiàn)類似redis的動態(tài)過期時間設置示例

更新時間：2023年08月29日 10:37:33 作者：TinyThing

這篇文章主要為大家介紹了Caffeine實現(xiàn)類似redis的動態(tài)過期時間示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

使用Caffeine實現(xiàn)緩存功能

為了替換原有的redis接口，發(fā)現(xiàn)存在一個問題：

原本的redis支持set(key, value, expire)這樣的功能，而原始的caffeine只能全局設置過期策略，不支持類似的功能，因此需要對Caffeine包裝一下，做了一個工具類實現(xiàn)類似redis的動態(tài)過期時間設置。

工具類實現(xiàn)類似redis

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.Expiry;
import org.checkerframework.checker.index.qual.NonNegative;
import org.checkerframework.checker.nullness.qual.NonNull;
import org.springframework.stereotype.Component;
import java.util.Collection;
import java.util.concurrent.TimeUnit;
import static java.util.Objects.isNull;
/**
 * 工具類
 *
 * @author guo
 */
public class CacheUtils {
    /**
     * 不設置過期時長
     */
    public static final long NOT_EXPIRE = Long.MAX_VALUE;
    public static final Cache<String, CacheObject<?>> CAFFEINE = Caffeine.newBuilder()
            .expireAfter(new Expiry<String, CacheObject<?>>() {
                @Override
                public long expireAfterCreate(@NonNull String key, @NonNull CacheObject<?> value, long currentTime) {
                    return value.expire;
                }
                @Override
                public long expireAfterUpdate(@NonNull String key, @NonNull CacheObject<?> value, long currentTime, @NonNegative long currentDuration) {
                    return value.expire;
                }
                @Override
                public long expireAfterRead(@NonNull String key, @NonNull CacheObject<?> value, long currentTime, @NonNegative long currentDuration) {
                    return value.expire;
                }
            })
            .initialCapacity(100)
            .maximumSize(1024)
            .build();
    private static class CacheObject<T> {
        T data;
        long expire;
        public CacheObject(T data, long second) {
            this.data = data;
            this.expire = TimeUnit.SECONDS.toNanos(second);
        }
    }
    public static <T> void set(String key, T value, long expire) {
        CacheObject<T> cacheObject = new CacheObject<>(value, expire);
        CAFFEINE.put(key, cacheObject);
    }
    public static void set(String key, Object value) {
        set(key, value, NOT_EXPIRE);
    }
    @SuppressWarnings("unchecked")
    public static <T> T get(String key) {
        CacheObject<?> cacheObject = CAFFEINE.getIfPresent(key);
        if (isNull(cacheObject)) {
            return null;
        }
        return (T) cacheObject.data;
    }
    public static void delete(String key) {
        CAFFEINE.invalidate(key);
    }
    public static void delete(Collection<String> keys) {
        CAFFEINE.invalidateAll(keys);
    }
    public static void main(String[] args) throws InterruptedException {
        CacheUtils.set("A", 1, 2);
        CacheUtils.set("B", 2, 5);
        CacheUtils.set("C", 3, 8);
        System.out.println(CAFFEINE.asMap());
        Object a = CacheUtils.get("A");
        Object b = CacheUtils.get("B");
        Object c = CacheUtils.get("C");
        System.out.println(a);
        System.out.println(b);
        System.out.println(c);
        System.out.println("-----------------");
        Thread.sleep(2000);
        a = CacheUtils.get("A");
        b = CacheUtils.get("B");
        c = CacheUtils.get("C");
        System.out.println(a);
        System.out.println(b);
        System.out.println(c);
        System.out.println("-----------------");
        Thread.sleep(5000);
        a = CacheUtils.get("A");
        b = CacheUtils.get("B");
        c = CacheUtils.get("C");
        System.out.println(a);
        System.out.println(b);
        System.out.println(c);
        System.out.println("-----------------");
        Thread.sleep(8000);
        a = CacheUtils.get("A");
        b = CacheUtils.get("B");
        c = CacheUtils.get("C");
        System.out.println(a);
        System.out.println(b);
        System.out.println(c);
        System.out.println("-----------------");
    }
}

以上就是Caffeine實現(xiàn)類似redis的動態(tài)過期時間設置示例的詳細內(nèi)容，更多關(guān)于Caffeine動態(tài)過期時間設置的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: