Guava使用

燃192

发布于 2023-02-28 13:51:14

2760

发布于 2023-02-28 13:51:14

文章被收录于专栏：Java技术圈子

Guava使用

Guava Cache 是Google Fuava中的一个内存缓存模块，用于将数据缓存到JVM内存中。提供了get、put封装操作，能够集成数据源；线程安全的缓存，与ConcurrentMap相似，但前者增加了更多的元素失效策略，后者只能显示的移除元素，相当于对已有集合框架类的一个扩充；Guava Cache提供了多种基本的缓存回收方式监控缓存加载/命中情况通常，Guava缓存适用于以下情况：

愿意花费一些内存来提高速度。使用场景有时会多次查询key。缓存将不需要存储超出RAM容量的数据

比如端面要将某一个类型Code转为类型名称这个类型数量比较多，有可能发生变动但不频繁的情景

比如端面需要根据填报志愿的专业code获取专业名称如果返回实体不带Name，每个调一次查询服务，或者一次性拿出所有名称循环对比取显然不是很优雅就可以用Guava来实现

/** 引入如下依赖
<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>18.0</version>
</dependency>
*/
public class GuavaTest {
    
    private LoadingCache<Integer, String> inventoryCacheByCondition = CacheBuilder.newBuilder().
            // 设置过期时间
                    expireAfterWrite(5L, TimeUnit.SECONDS).
            // 初始容量，扩容非常消耗资源这个一定规划好合适大小
                    initialCapacity(256).
            // 最大容量
                    maximumSize(1024L).
                    build(new CacheLoader<Integer, String>() {
                        /*
                         * 如果出现缓存没命中到场景会调用到load
                         * 实际场景这里处理不好极有可能oom要注意
                         */
                        @Override
                        public String load(Integer key) throws Exception {
                            System.out.println("调用load重新加载缓存");
                            reflushInventoryType(inventoryCacheByCondition, 0);
                            return inventoryCacheByCondition.get(key);
                        }
                    });
    public static void main(String[] args) throws ExecutionException, InterruptedException {

        GuavaTest test = new GuavaTest();
        System.out.println("=====================================第一次查缓存");
        System.out.println(test.inventoryCacheByCondition.get(6));
        System.out.println("=====================================缓存持续时间内查询");
        System.out.println(test.inventoryCacheByCondition.get(6));
        TimeUnit.SECONDS.sleep( 5 );
        System.out.println("=====================================我睡了5s，缓存过期啦");
        System.out.println(test.inventoryCacheByCondition.get(6));
        test.reflushInventoryType(test.inventoryCacheByCondition, 0);
        System.out.println("=====================================遍历map");
        test.fun(test);

    }

    public void fun(GuavaTest test){
        test.inventoryCacheByCondition.asMap().forEach((key,value)->{
            System.out.println(key + value);
        });
    }

    private void reflushInventoryType(LoadingCache<Integer, String> inventoryCacheByCondition
            ,Integer queryType){
        inventoryCacheByCondition.put(1,"value1");
        inventoryCacheByCondition.put(2,"value2");
        inventoryCacheByCondition.put(3,"value3");
        inventoryCacheByCondition.put(4,"value4");
        inventoryCacheByCondition.put(5,"value5");
        inventoryCacheByCondition.put(6,"value6");
    }
}

结果

=====================================第一次查缓存
调用load重新加载缓存
value6
=====================================缓存持续时间内查询
value6
=====================================我睡了5s，缓存过期啦
调用load重新加载缓存
value6
=====================================遍历map
5value5
6value6
2value2
1value1
4value4
3value3

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2022-03-11，如有侵权请联系 cloudcommunity@tencent.com 删除

缓存