前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Guava缓存过期的一些坑

Guava缓存过期的一些坑

作者头像
燃192
发布2023-09-18 15:17:36
7840
发布2023-09-18 15:17:36
举报
文章被收录于专栏:Java技术圈子

1.引入依赖

代码语言:javascript
复制
<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>19.0</version>
</dependency>
代码语言:javascript
复制


2.基础使用

代码语言:javascript
复制


import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

public class GuavaLoadingCache {
    private LoadingCache<Integer, String> inventoryCacheByCondition = CacheBuilder.newBuilder().
            expireAfterWrite(2L, TimeUnit.SECONDS).
            initialCapacity(256).
            maximumSize(1024L).
            build(new CacheLoader<Integer, String>() {
                // 获取不到会执行load里的逻辑
                @Override
                public String load(Integer key) throws Exception {
                    System.out.print("缓存没查到 ");
                    reflushInventoryType(inventoryCacheByCondition, null);
                    return inventoryCacheByCondition.get(key);
                }
            });

    public static void main(String[] args) throws ExecutionException, InterruptedException {

        GuavaLoadingCache test = new GuavaLoadingCache();

        // # 基本使用
        System.out.println("====================入门部分开始=======================");
        System.out.println(test.inventoryCacheByCondition.get(1));
        TimeUnit.SECONDS.sleep( 2 );
        // 过期获取
        System.out.println(test.inventoryCacheByCondition.get(1));
        // key不存在
        // System.out.println(test.inventoryCacheByCondition.get(10));

        // System.out.println(test.inventoryCacheByCondition.toString() + " " + test.inventoryCacheByCondition.size() + "=cacheSize");
        // 过期后cacheSize
        TimeUnit.SECONDS.sleep( 2 );
        System.out.println("过期数据ing");
        // 可以看到过期了,缓存中的数量并没有减少
        System.out.println(test.inventoryCacheByCondition.size() + "=cacheSize 可以看到过期了,缓存中的数量并没有减少");

        // gc后是否回收
        System.gc();
        System.out.println("执行gc");
        System.out.println(test.inventoryCacheByCondition.size() + "=cacheSize gc后,缓存中的数量并没有减少");

        // cleanUp手动清除过期缓存
        test.inventoryCacheByCondition.cleanUp();
        System.out.println("手动cleanUp清除过期缓存");
        System.out.println(test.inventoryCacheByCondition.size() + "=cacheSize 手动cleanUp清除过期缓存才能真正清除过期数据");

        // 重新刷入数据
        test.reflushInventoryType(test.inventoryCacheByCondition,null);
        // 过期数据
        TimeUnit.SECONDS.sleep( 2 );
        test.inventoryCacheByCondition.put(7,"值7");
        // put以后cacheSize
        System.out.println("put以后cacheSize 想深入了解可以看一下源码是怎么实现的");
        System.out.println(test.inventoryCacheByCondition.size() + "=cacheSize");

        // cleanUp手动清除过期缓存开启进阶部分
        test.inventoryCacheByCondition.cleanUp();
        System.out.println("cleanUp手动清除过期缓存开启基础部分");
        

        //
        // # 进阶使用
        // 由于key不存在时候直接使用loadingCache会报com.google.common.util.concurrent.UncheckedExecutionException,
        // 面对key不存在有如下两个解决办法
        //      1.兜底值
        //          兜底逻辑有时候会破坏业务
        //      2.转换成Map
        //          这样就可以返回null,而且不用在外部处理Exp非常好用,但是有一些坑
        System.out.println("====================基础部分开始=======================");
        System.out.println(test.inventoryCacheByCondition.get(1));
        TimeUnit.SECONDS.sleep( 2 );
        // 转Map以后这里拿不到值了
        System.out.println(test.inventoryCacheByCondition.asMap().get(1) + " 转Map以后这里拿不到值了,尤其注意这里!!!,过期以后永远get null");
        // key不存在
        System.out.println(test.inventoryCacheByCondition.asMap().get(10) + " key不存在");

        // System.out.println(test.inventoryCacheByCondition.toString() + " " + test.inventoryCacheByCondition.size() + "=cacheSize");
        // 过期后cacheSize
        TimeUnit.SECONDS.sleep( 2 );
        // 可以看到过期了,cacheSize仍然大于0
        System.out.println(test.inventoryCacheByCondition.asMap().size() + "=cacheSize");
        test.inventoryCacheByCondition.asMap().put(7,"值7");
        System.out.println(test.inventoryCacheByCondition.asMap().size() + "=cacheSize map.put后cacheSize");
        TimeUnit.SECONDS.sleep( 2 );
        test.inventoryCacheByCondition.cleanUp();
        test.inventoryCacheByCondition.asMap().put(8,"值8");
        System.out.println(test.inventoryCacheByCondition.asMap().size() + "=cacheSize 清除过期缓存后 map.put后cacheSize");

        System.out.println("使用loadingCache转换后的map时,建议cleanUp()后再根据cacheSize判断是否刷新数据");
    }

    private void reflushInventoryType(LoadingCache<Integer, String> inventoryCacheByCondition
            ,Integer queryType){
        System.out.print(" reflush ");
        for(int i=1;i<=6;i++){
            inventoryCacheByCondition.put(i,"值" + i);
        }
    }
}

结果

代码语言:javascript
复制
====================入门部分开始=======================
缓存没查到  reflush 值1
缓存没查到  reflush 值1
过期数据ing
6=cacheSize 可以看到过期了,缓存中的数量并没有减少
执行gc
6=cacheSize gc后,缓存中的数量并没有减少
手动cleanUp清除过期缓存
0=cacheSize 手动cleanUp清除过期缓存才能真正清除过期数据
 reflush put以后cacheSize 想深入了解可以看一下源码是怎么实现的
7=cacheSize
cleanUp手动清除过期缓存开启进阶部分
====================基础部分开始=======================
缓存没查到  reflush 值1
null 转Map以后这里拿不到值了,尤其注意这里!!!,过期以后永远get null
null key不存在
5=cacheSize
5=cacheSize map.put后cacheSize
1=cacheSize 清除过期缓存后 map.put后cacheSize
使用loadingCache转换后的map时,建议cleanUp()后再根据cacheSize判断是否刷新数据
————————————————
版权声明:本文为CSDN博主「eck_燃」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/wdays83892469/article/details/124391171

源码拓展

清除缓存源码如下

参考

guava的loadingcache什么时候删除过期的数据https://www.jianshu.com/p/c21dd3f0eab0

guava的loadingcache什么时候删除过期的数据?

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2022/04/25 13:42:12,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 Java技术圈子 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1.引入依赖
  • 2.基础使用
  • 结果
  • 源码拓展
  • 参考
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档