Java工具篇之Guava-cache内存缓存

简介: 常在业务系统中做开发,不会点高级知识点,有点不好意思了。在业务系统中,提高系统响应速度,提供系统高并发能力,其实方向很简单,三个方向,六个字而已: **缓存降级限流。**当然这是在排除代码质量非常差的情况,如果代码质量很差,都是while循环和高内存占用,那么其实再怎么做都于事无补。除非你有一个马云爸爸,性能不够,机器来凑嘛。阿里云前来支持(1000台机器够了吗?)

本篇主要是本地缓存代码实战,提供业务中常用的本地缓存使用代码片段(直接跳过看标题五)

常在业务系统中做开发,不会点高级知识点,有点不好意思了。在业务系统中,提高系统响应速度,提供系统高并发能力,其实方向很简单,三个方向,六个字而已: 缓存降级限流。
当然这是在排除代码质量非常差的情况,如果代码质量很差,都是while循环和高内存占用,那么其实再怎么做都于事无补。除非你有一个马云爸爸,性能不够,机器来凑嘛。阿里云前来支持(1000台机器够了吗?)

一、什么是Guava Cache

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

其实就是Google提供的一个开发工具包,里面有很多好用的Java开工具,比如我们本文将的Cache缓存能力。
说到缓存,每个业务系统中现在都会用到缓存,常用的缓存数据库就是Redis和Memcache,这两款kv数据库最常用的场景就是当缓存使用,极其适合在微服务架构下做缓存使用。速度是极高的,但是跟本地缓存来比,还是算慢的,毕竟本地缓存其实就相当于一个Map集合,本地缓存获取没有网络IO。但是最大的缺点是每台服务器的本地缓存是不能共享的。所以如果要用分布式缓存就可以跳过了。因为本文将的本地缓存使用。

说到底其实缓存我们就可以理解为是一个Map集合,不过生产中我们不能用Map来做缓存,除非是缓存的数据只有一点点一点点。否则如果数据量瞬时或者数据积累量很大,很容易就直接就把Map撑爆。导致内存溢出,服务宕机下线风险。 所以我们必须要对Map做控制。

  1. 控制数据量大小
  2. 控制数据生命周期
  3. 如果能做些数据命中率统计更好了

对,以上就是Guava Cache已经为我们做好的能力了。我们只用使用就可以了

二、什么场景适合缓存

不长更新的数据都可以使用缓存,只要我们定时去刷新缓存获取最新的数据就可以了。
注意: 凡是使用GuavaCache的地方都可以使用RedisCache,但是使用RedisCache的地方不一定可以使用GuavaCache。因为前面我们也说了Guava是本地缓存,不支持多服务器数据共享,如果要共享缓存数据直接用Redis是更好的选择。

三、使用本地缓存,高并发会把机器打爆

这个担心是逻辑思考的必然,使用缓存主要是提高系统响应效率的,如果用不过把机器搞爆就不好了。所以这种担心很有必要,但是只要弄清楚没参数或者它的实现原理就不用担心了。4和5是快速入门即代码片段,直接根据代码去做不会有问题。

四、快速入门API

CacheBuilder

属性 作用 例子
removalListener 缓存移除的监听 对指定key的删除,做监听
maximumSize 设置最大缓存数量 当达到最大数量,会删除多余的缓存记录
expireAfterWrite 设置过期时间 过期的缓存自动移除
recordStats 统计信息 统计缓存命中率

1. 设置最大缓存数量

    Cache<String,String> cache = CacheBuilder.newBuilder()
                                 .maximumSize(2).build();
    cache.put("key1","value1");
    cache.put("key2","value2");
    cache.put("key3","value3");
    // 第一个key是null,因为指定缓存数量是2个,当超过就删除前面一条
    System.out.println("第一个值:" + cache.getIfPresent("key1"));
    System.out.println("第一个值:" + cache.getIfPresent("key2"));
    System.out.println("第一个值:" + cache.getIfPresent("key3"));

2. 设置过期时间

    Cache<String,String> cache = CacheBuilder.newBuilder()
                                 .maximumSize(2)
                                 .expireAfterWrite(3,TimeUnit.SECONDS)
                                     .build();
    cache.put("key1","value1");
    int time = 1;
    while(true){
        System.out.println("第" + time ++ "次取到的key1的值为:" + cache.getIfPresent("key1"));
        Thread.sleep(1000)
    }

3. 统计命中率

    Cache<String,String> cache = CacheBuilder.newBuilder()
                                 .maximumSize(3)
                                 .recordStats()
                                     .build();
    cache.put("key1","value1");
    cache.put("key2","value2");
    cache.put("key3","value3");
    
    cache.getIfPresent("key1")
    cache.getIfPresent("key1")
    cache.getIfPresent("key2")
    cache.getIfPresent("key3")
    // 获取统计信息
    System.out.println(cache.stats());

CacheStats

属性值 含义
requestCount 返回cache查找缓存的次数
hitCount 命中缓存的次数
missCount 未命中缓存的次数
missRate 返回缓存请求未命中的比率,未命中次数除以请求次数
loadCount 返回缓存调用load方法加载新值的次数
loadSuccessCount 返回缓存加载新值的成功次数
loadExceptionCount 返回缓存加载新值出现异常的次数
loadExceptionRate 返回缓存加载新值出现异常的比率
totalLoadTime 返回缓存加载新值所耗费的总时间
averageLoadPenalty 缓存加载新值的耗费的平均时间,加载的次数除以加载的总时间
evictionCount 返回缓存中条目被移除的次数

五、代码片段

    private LoadingCache<Long,UserInfoDTO> userCache;
    
    {
        userCache =  CacheBuilder.newBuilder().maximumSize(30)//缓存30条数据
                .expireAfterWrite(10,TimeUnit.SECONDS) // 缓存时间10s
                    .build(// 缓存加载器,如果没有找到key,就去加载这个key到缓存中
                new CacheLoader<Long,UserInfoDTO>(){
                    @Override
                    public UserInfoDTO load(Long key) throws Exception{
                        return userService.queryById(key);
                    }
                }
            )
    }
    
    public UserInfoDTO queryUserInfoByIdFromCache(Long userId){
        return userCache.get(userId);
    }
相关文章
|
8月前
|
安全 Java 应用服务中间件
Spring Boot + Java 21:内存减少 60%,启动速度提高 30% — 零代码
通过调整三个JVM和Spring Boot配置开关,无需重写代码即可显著优化Java应用性能:内存减少60%,启动速度提升30%。适用于所有在JVM上运行API的生产团队,低成本实现高效能。
978 3
|
8月前
|
人工智能 缓存 监控
使用LangChain4j构建Java AI智能体:让大模型学会使用工具
AI智能体是大模型技术的重要演进方向,它使模型能够主动使用工具、与环境交互,以完成复杂任务。本文详细介绍如何在Java应用中,借助LangChain4j框架构建一个具备工具使用能力的AI智能体。我们将创建一个能够进行数学计算和实时信息查询的智能体,涵盖工具定义、智能体组装、记忆管理以及Spring Boot集成等关键步骤,并展示如何通过简单的对话界面与智能体交互。
3174 1
|
9月前
|
存储 缓存 Java
Java数组全解析:一维、多维与内存模型
本文深入解析Java数组的内存布局与操作技巧,涵盖一维及多维数组的声明、初始化、内存模型,以及数组常见陷阱和性能优化。通过图文结合的方式帮助开发者彻底理解数组本质,并提供Arrays工具类的实用方法与面试高频问题解析,助你掌握数组核心知识,避免常见错误。
|
7月前
|
Java 大数据 Go
从混沌到秩序:Java共享内存模型如何通过显式约束驯服并发?
并发编程旨在混乱中建立秩序。本文对比Java共享内存模型与Golang消息传递模型,剖析显式同步与隐式因果的哲学差异,揭示happens-before等机制如何保障内存可见性与数据一致性,展现两大范式的深层分野。(238字)
207 4
|
7月前
|
存储 缓存 Java
【深入浅出】揭秘Java内存模型(JMM):并发编程的基石
本文深入解析Java内存模型(JMM),揭示synchronized与volatile的底层原理,剖析主内存与工作内存、可见性、有序性等核心概念,助你理解并发编程三大难题及Happens-Before、内存屏障等解决方案,掌握多线程编程基石。
|
7月前
|
人工智能 监控 Java
Java与AI智能体:构建自主决策与工具调用的智能系统
随着AI智能体技术的快速发展,构建能够自主理解任务、制定计划并执行复杂操作的智能系统已成为新的技术前沿。本文深入探讨如何在Java生态中构建具备工具调用、记忆管理和自主决策能力的AI智能体系统。我们将完整展示从智能体架构设计、工具生态系统、记忆机制到多智能体协作的全流程,为Java开发者提供构建下一代自主智能系统的完整技术方案。
938 4
|
8月前
|
人工智能 Java API
Java AI智能体实战:使用LangChain4j构建能使用工具的AI助手
随着AI技术的发展,AI智能体(Agent)能够通过使用工具来执行复杂任务,从而大幅扩展其能力边界。本文介绍如何在Java中使用LangChain4j框架构建一个能够使用外部工具的AI智能体。我们将通过一个具体示例——一个能获取天气信息和执行数学计算的AI助手,详细讲解如何定义工具、创建智能体并处理执行流程。本文包含完整的代码示例和架构说明,帮助Java开发者快速上手AI智能体的开发。
3109 8
|
8月前
|
缓存 监控 Kubernetes
Java虚拟机内存溢出(Java Heap Space)问题处理方案
综上所述, 解决Java Heap Space溢出需从多角度综合施策; 包括但不限于配置调整、代码审查与优化以及系统设计层面改进; 同样也不能忽视运行期监控与预警设置之重要性; 及早发现潜在风险点并采取相应补救手段至关重要.
953 17
|
9月前
|
监控 Kubernetes Java
最新技术栈驱动的 Java 绿色计算与性能优化实操指南涵盖内存优化与能效提升实战技巧
本文介绍了基于Java 24+技术栈的绿色计算与性能优化实操指南。主要内容包括:1)JVM调优,如分代ZGC配置和结构化并发优化;2)代码级优化,包括向量API加速数据处理和零拷贝I/O;3)容器化环境优化,如K8s资源匹配和节能模式配置;4)监控分析工具使用。通过实践表明,这些优化能显著提升性能(响应时间降低40-60%)同时降低资源消耗(内存减少30-50%,CPU降低20-40%)和能耗(服务器功耗减少15-35%)。建议采用渐进式优化策略。
484 2
|
10月前
|
SQL 缓存 安全
深度理解 Java 内存模型:从并发基石到实践应用
本文深入解析 Java 内存模型(JMM),涵盖其在并发编程中的核心作用与实践应用。内容包括 JMM 解决的可见性、原子性和有序性问题,线程与内存的交互机制,volatile、synchronized 和 happens-before 等关键机制的使用,以及在单例模式、线程通信等场景中的实战案例。同时,还介绍了常见并发 Bug 的排查与解决方案,帮助开发者写出高效、线程安全的 Java 程序。
521 0