简介

guava是google的一个开源java框架，其github地址是 https://github.com/google/guava。guava工程包含了若干被Google的Java项目广泛依赖的核心库，例如：

• 集合 [collections]
• 缓存 [caching]
• 原生类型支持 [primitives support]
• 并发库 [concurrency libraries]
• 通用注解 [common annotations]
• 字符串处理 [string processing]
• I/O

所有这些工具每天都在被Google的工程师应用在产品服务中。 其中caching是常用的模块的之一

引入依赖

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

使用示例

基本用法

@Component
public final class WsRoleCache {
    private static Logger logger = LoggerFactory.getLogger(WsRoleCache.class);
    private static AtomicBoolean isInited = new AtomicBoolean(false);
    private static LoadingCache<String, List<WsRole>> cache;

    private WsRoleCache() {
        if (!isInited.get()) {
            init();
        }
    }

    private static void init() {
        logger.info("---初始化WsRole");
        cache = CacheBuilder.newBuilder().refreshAfterWrite(10, TimeUnit.MINUTES)
                .build(new CacheLoader<String, List<WsRole>>() {
                    @Override
                    public List<WsRole> load(String key) throws Exception {
                        // 如果是第一次，调用load方法；如果是两次get时间在10分钟之间，就不会调用load
                        RoleManager service = SpringContextHolder.getBean("RoleManager");
                        logger.info("查询WsRole");
                        List<WsRole> list = service.getWsAll(key);
                        return list;
                    }
                });
        isInited.set(true);
    }


    public static List<WsRole> getWsAll(String key) {
        try {
            return cache.get(key);
        } catch (Exception e) {
        }
        return null;
    }
}

利用@Component让工程启动的时候初始化cache对象，重写构造函数并且设置为private是为了保证是单例的

核心方法

• refreshAfterWrite : 写入数据后多久过期,只阻塞当前数据加载线程,其他线程返回旧值
• expireAfterWrite : 写缓存后多久过期
• expireAfterAccess : 读写缓存后多久过期
• maximumSize : 设置缓存最大容量，超过之后就会按照LRU最近虽少使用算法来移除缓存项

异步刷新

抽象类CacheLoader是同步刷新的。

如果缓存到期了，有多个线程调用缓存，那么第一个调用的会阻塞住，其他的线程会直接返回已过期的缓存

如果想要让所有的线程都不阻塞，就要创建异步加载类

public abstract class RefreshAsyncCacheLoader<K, V> extends CacheLoader<K, V> {
    private ExecutorService threadPool = Executors.newSingleThreadExecutor();
    @Override
    public ListenableFuture<V> reload(final K key, final V oldValue) throws Exception {
        checkNotNull(key);
        checkNotNull(oldValue);
        //增加配置参数，控制是否异步加载；1-异步加载，0-同步加载
        String async = PropertyConfigurer.getProperty("cache.refres.async");
        if (StringUtils.equals(async,"1")){
            ListenableFutureTask<V> task = ListenableFutureTask.create(new Callable<V>() {
                public V call() {
                    try {
                        return load((K) key);
                    } catch (Exception e) {
                    }
                    return oldValue;
                }
            });
            threadPool.execute(task);
            return task;
        }else{
            return Futures.immediateFuture(load(key));
        }

    }

}

将CacheLoader替换成异步实现类RefreshAsyncCacheLoader

public static void init() {
    logger.info("---初始化WsUserCache");
    cache = CacheBuilder.newBuilder().refreshAfterWrite(10, TimeUnit.MINUTES)
            .build(new RefreshAsyncCacheLoader<String, List<WsUser>>() {
                @Override
                public List<WsUser> load(String key) throws Exception {
                    UserManager service = SpringContextHolder.getBean("userManager");
                    logger.info("查询WsUser");
                    List<WsUser> list = service.getWsAll();
                    return list;
                }
            });
}

显示清除

缓存会自动过期，也可以手动让其过期，主要有以下方法：

• 个别清除：Cache.invalidate(key)
• 批量清除：Cache.invalidateAll(keys)
• 清除所有缓存项：Cache.invalidateAll()

总结

• guava cache是本地缓存，和redis、memcached等集中缓存不同，如果是集群环境，本地缓存有不同步的问题，如果对缓存同步时间要求不是太高，这完全不是问题
• 相比于redis等集中缓存，本地缓存性能更高；因为没有网络交互，直接内存读取
• guava cache使用简单、控制灵活