Java Google Guava Cache @上源码

骑猪看日落 2023-10-04 13:49 30阅读 0赞

[缓存 https://blog.csdn.net/qq\_34253002/article/details/117026206][https_blog.csdn.net_qq_34253002_article_details_117026206]

Google的Guava Cache是本地缓存的一种，将数据存储在JVM内存中，适合数据量少、访问频繁、存在热键、几乎零修改、时效性不高数据缓存。如果有分布式、数据量大、时效性强的情况可以考虑使用Redis或者Memcached。

**pom依赖**

<dependency>
        <groupId>com.google.guava</groupId>
        <artifactId>guava</artifactId>
    </dependency>

**CacheLoader（自动加载）**

private LoadingCache<Integer, User> cache = CacheBuilder.newBuilder()
            .weakKeys()                     // 弱引用 垃圾回收触发后清空
            .weakValues()
            .concurrencyLevel(8) // 缓存写入并发级别
            .initialCapacity(5)  // 初始化容量设置
            .maximumSize(100)    // 缓存容器容量设置 超出后默认按照LRU策略淘汰
            .expireAfterAccess(5, TimeUnit.MINUTES)  // 5分钟内无写入和查询缓存失效
            .expireAfterWrite(5, TimeUnit.MINUTES)   // 缓存写入后过期时间 5分钟
            .refreshAfterWrite(1, TimeUnit.MINUTES)  // 缓存写入后刷新时间 1分钟
            .removalListener(new RemovalListener<Object, Object>() { // 数据移除通知
                @Override
                public void onRemoval(RemovalNotification<Object, Object> removalNotification) {
                    RemovalCause cause = removalNotification.getCause(); // EXPLICIT REPLACED COLLECTED EXPIRED SIZE
                    // TODO
                }
            })
            .build(new CacheLoader<Integer, User>() { // 指定CacheLoader，当查询key在缓存中不存在时通过指定CacheLoader加载数据
                @Override
                public User load(Integer id) throws Exception {
                    return userMapper.getById(id); //数据加载操作
                }
            });
        }
        
    public User get(Integer id){
       // cache.put(id, new User()); // 直接插入到缓存 
       // cache.asMap();             // 获取缓存容器所有缓存信息
       // cache.invalidate(id);      // 清除缓存信息
       // cache.invalidateAll(Lists.newArrayList(id)); // 批量清除缓存信息
       // cache.invalidateAll();     // 清除所有缓存信息
       // cache.refresh(id);         // 重新加载缓存信息
       return cache.get(id);
    }

**Callable的（手动加载）**

private Cache<Integer, User> cache = CacheBuilder.newBuilder().build(); // 属性信息同上
    
       public User get(Integer id)
           User user = cache.get(id, new Callable<User>() {
               @Override
               public User call() throws Exception {
                   return userMapper.getById(id); //数据加载操作
               }
           });
       }

@浅见 @如有疏漏请帮忙补充完善 @开发一家人 0000012 待完善 感兴趣可以 点赞 收藏 评论 大家一起交流呀

[https_blog.csdn.net_qq_34253002_article_details_117026206]: https://blog.csdn.net/qq_34253002/article/details/117026206