Java中的Caffeine加载与驱逐策略详解

Cache<String, Integer> cache = Caffeine.newBuilder()
                // 写入缓存后30分钟后过期
                .expireAfterWrite(30, TimeUnit.MINUTES)
                // 最大缓存数量1000
                .maximumSize(1000)
                .build();
        String key = "1";
        // 新增缓存
        cache.put(key, 1);
        cache.put("2", 2);
        cache.put("3", 3);
        // 从缓存中获取数据: 如果存在在返回"1"的值，如果不存在返回null
        System.out.println(cache.getIfPresent(key));
        // 缓存key不存在cache中, 则新增一条数据到cache中
        String key1 = "4";
        cache.get(key1, k -> 3);
        System.out.println(cache.getIfPresent(key1));
        // 从cache中移除缓存
        cache.invalidate("1");

public void loadingCache() {
    LoadingCache<String, Integer> loadingCache = Caffeine.newBuilder()
            // 写入缓存后30分钟后过期
            .expireAfterWrite(30, TimeUnit.MINUTES)
            // 最大缓存数量1000
            .maximumSize(1000)
            // build中的CacheLoader可以在初始化LoaddingCache时，加载一部分数据到内存中,
            // 此处就把key的hash值作为value
            .build(this::getIntByKey);
    Integer val = loadingCache.get("1", this::getIntByKey);
    System.out.println(val);
	 // 批量获取键值
    Map<String, Integer> all = loadingCache.getAll(Arrays.asList("1", "2"));
    System.out.println(JSON.toJSONString(all.values()));
}
public Integer getIntByKey(String key) {
    return key.hashCode();
}

public void sync() {
        AsyncCache<String, Integer> asyncCache = Caffeine.newBuilder()
        // 写入缓存后30分钟后过期
                .expireAfterWrite(30, TimeUnit.MINUTES)
                // 最大缓存数量1000
                .maximumSize(1000)
            .buildAsync();
        // 如果Key不存在, 则把key和value 加入到cache中, CompletableFuture提供了一个阻塞Cache, 直到异步完成
        CompletableFuture<Integer> future = asyncCache.get("1", this::getIntByKey);
    }
    public Integer getIntByKey(String key) {
        return key.hashCode();
    }

 public void syncLoadingCache() {
        AsyncLoadingCache<String, Integer> async = Caffeine.newBuilder().buildAsync(new AsyncCacheLoader<>() {
            @Override
            public @NonNull CompletableFuture<Integer> asyncLoad(@NonNull String key, @NonNull Executor executor) {
                return new CompletableFuture<>();
            }
        });
        CompletableFuture<Integer> future = async.get("1");
        CompletableFuture<Map<String, Integer>> all = async.getAll(Arrays.asList("1", "2"));
    }

Cache<String, Integer> graphs = Caffeine.newBuilder()
                // 设置一个定时器任务
                .scheduler(Scheduler.systemScheduler())
                // 添加一个移除元素监听事件
                .removalListener((k , v, cause) -> {
                    System.out.println(k);
                    System.out.println(v);
                    System.out.println(cause.wasEvicted());
                })
                .expireAfterWrite(3, TimeUnit.SECONDS)
                .weakValues()
                .build();
        // 创建一个清理线程
        Cleaner cleaner = Cleaner.create();
        // 注册一个对象，并在对象运行时执行一个cleanUp操作
        cleaner.register("1", graphs::cleanUp);
        graphs.put("1", 1);
        graphs.put("2", 2);
        graphs.put("3", 3);
        Thread.sleep(5000);
        graphs.put("3", 3);
        System.out.println(graphs.getIfPresent("1"));
        System.out.println(graphs.getIfPresent("2"));
        System.out.println(graphs.getIfPresent("3"));