1. 引入依赖
2. 常用API
   2.1 创建缓存
   -2.1.1 创建LoadingCache缓存
   -2.1.2 创建Cache缓存
   2.2 创建缓存时的API
   -2.2.1 基于大小的数据移除
   -2.2.2 基于时间的数据移除
   -2.2.3 基于引用的回收
   -2.2.4 removalListener移除缓存时的监听
   -2.2.5 recordStats开启统计功能
   2.3 操作缓存的API
   -2.3.1 显式移除缓存
   -2.3.2 维护缓存的API
   官方文档

1. 引入依赖

<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>27.0.1-jre</version>
</dependency>

2. 常用API

2.1 创建缓存

2.1.1 创建LoadingCache缓存

public class CacheTest {

    /**
     * 当进行查询时，若缓存中无数据，那么使用load方法进行动态加载。
     * 若load(key)方法返回""，那么缓存的value=""。
     */
    private static LoadingCache<String, String> cache1 = CacheBuilder.
            newBuilder().
            maximumSize(2).   //LRU缓存的最大个数
            removalListener((notification) -> System.out.println("移除掉的缓存值" +   //移除缓存的回调方法
            notification.getCause().name() + ":" +
            notification.getKey() + ":" +
            notification.getValue())).
            build(new CacheLoader<String, String>() {
                @Override
                public String load(String key) throws Exception {  //动态加载缓存
                    //从SQL或者NoSql 获取对象
                    if ("a".equals(key)) {
                        return "a-v";
                    }
                    return "";
                }
            });
    public static void main(String[] args) throws Exception {
        cache1();
    }


    private static void cache1() throws ExecutionException {

        System.out.println("a的缓存：" + cache1.get("a"));
        System.out.println("b的缓存：" + cache1.get("b"));

        cache1.put("c", "c");
        System.out.println("c的缓存：" + cache1.get("c"));
    }
}

执行结果：

a的缓存：a-v
b的缓存：
移除掉的缓存值SIZE:a:a-v
c的缓存：c

当get("b")，因为cache1中并没有缓存，所以会调用CacheLoader的load方法加载缓存，注意CacheLoader的load方法不能返回null。但是返回""后，缓存存储的值如下图2.1-1所示，也是"'。

图2.1-1.png

2.1.2 创建Cache缓存

@Slf4j
public class CacheTest {
   
    private static Cache<String, String> cache2 = CacheBuilder.newBuilder().
            maximumSize(10).build();



    private static void cache2() throws Exception {


        System.out.println("cache2.getIfPresent(a)：" + cache2.getIfPresent("a"));

        System.out.println("cache2.get(a) one：" + cache2.get("a", () -> {
            log.info("开始维护缓存,key:{}", "a");
            return "a-v";
        }));
        System.out.println("cache2.get(a) two：" + cache2.get("a", () -> {
            log.info("开始维护缓存,key:{}", "a");
            return "a-v";
        }));
        cache2.invalidate("a");
        System.out.println("invalidate后cache2.getIfPresent(a)：" + cache2.getIfPresent("a"));
        //填充值
        cache2.put("b", "b");
        //删除值

        System.out.println("put后cache2.getIfPresent(b)：" + cache2.getIfPresent("b"));
    }
}

执行结果：

cache2.getIfPresent(a)：null
10:45:22.869 [main] INFO com.tellme.Test.jdk.CacheTest - 开始维护缓存,key:a
cache2.get(a) one：a-v
cache2.get(a) two：a-v
invalidate后cache2.getIfPresent(a)：null
put后cache2.getIfPresent(b)：b

Cache缓存，可以看做功能更加强大ConcurrentHashMap缓存。

2.2 创建缓存时的API

2.2.1 基于大小的数据移除

maximumWeight也不是基于对象真正占用内存，而是通过weigher为每一个缓存定义重量实现的。

    private static Cache<String, String> cache = CacheBuilder.newBuilder().
            maximumWeight(6).
            weigher((k, v) -> {
                if ("a".equals(k)) {
                    return 5;
                } else {
                    return 1;
                }
            }).
            build();

例如上述代码：key=“a”时，可能缓存的value占用内存比较大，故可以设置权重为5。其余缓存占用的内存比较小，可以设置权重为1。

注意：maximumWeight和weigher需要搭配使用。

2.2.2 基于时间的数据移除

详细请见——guavaCache本地缓存失效方案expireAfterWrites和refreshAfterWrites

    private static Cache<String, String> cache = CacheBuilder.newBuilder().
            expireAfterAccess(2, TimeUnit.SECONDS).
            build();

2.2.3 基于引用的回收

JVM那点事-对象的自救计划（对象被设为null会被回收吗？）

guava也可以设置value的引用类型，来实现基于引用的回收。

@Slf4j
public class CacheTest {
    /**
     * 缓存大小
     */
    private static Cache<String, String> cache = CacheBuilder.newBuilder().
            weakValues().
            build();

    private static void cache() throws InterruptedException {
        cache.put("a",  new String("a"));
        //显式GC
        System.gc();
        System.out.println(cache.getIfPresent("a"));
    }
}

执行后果

null

2.2.4 removalListener移除缓存时的监听

@Slf4j
public class CacheTest {
    /**
     * 缓存大小
     */
    private static Cache<String, String> cache = CacheBuilder.newBuilder().
            maximumSize(2).
            removalListener((notification) -> System.out.println("移除掉的缓存值" +   //移除缓存的回调方法
                    notification.getCause().name() + ":" +
                    notification.getKey() + ":" +
                    notification.getValue())).
            build();

    private static void cache() throws InterruptedException {
        cache.put("a", "a");
        cache.put("b", "b");
        cache.put("c", "c");
        System.out.println(cache.getIfPresent("a"));
    }
}

执行结果：

移除掉的缓存值SIZE:a:a
null

但是有点需要注意的是默认Removal Listener中的行为是和移除动作同步执行的，如果需要改成异步形式，可以考虑使用RemovalListeners.asynchronous(RemovalListener, Executor)

2.2.5 recordStats开启统计功能

@Slf4j
public class CacheTest {
    private static Cache<String, String> cache = CacheBuilder.newBuilder().
            maximumSize(2).
            recordStats().
            build();
    private static void cache() throws InterruptedException {
        cache.put("a", "a");
        cache.put("b", "b");
        cache.put("c", "c");
        System.out.println(cache.getIfPresent("b"));
        System.out.println(cache.getIfPresent("b"));
        System.out.println(cache.getIfPresent("c"));
        System.out.println(cache.getIfPresent("a"));

        CacheStats stats = cache.stats();
        System.out.println(JSON.toJSONString(stats));
    }
}

效果图：

image.png

2.3 操作缓存的API

2.3.1 显式移除缓存

2.3.2 维护缓存的API

官方文档

guava Cache官方文档