Ehcache！这才是Java本地缓存之王！
一、Caffeine介绍
1、缓存介绍
缓存(Cache)在代码世界中无处不在。从底层的CPU多级缓存，到客户端的页面缓存，处处都存在着缓存的身影。缓存从本质上来说，是一种空间换时间的手段，通过对数据进行一定的空间安排，使得下次进行数据访问时起到加速的效果。
就Java而言，其常用的缓存解决方案有很多，例如数据库缓存框架EhCache，分布式缓存Memcached等，这些缓存方案实际上都是为了提升吞吐效率，避免持久层压力过大。
对于常见缓存类型而言，可以分为本地缓存以及分布式缓存两种，Caffeine就是一种优秀的本地缓存，而Redis可以用来做分布式缓存
2、Caffeine介绍
Caffeine官方：
- https://github.com/ben-manes/caffeine
Caffeine是基于Java 1.8的高性能本地缓存库，由Guava改进而来，而且在Spring5开始的默认缓存实现就将Caffeine代替原来的Google Guava，官方说明指出，其缓存命中率已经接近最优值。实际上Caffeine这样的本地缓存和ConcurrentMap很像，即支持并发，并且支持O(1)时间复杂度的数据存取。二者的主要区别在于：
- ConcurrentMap将存储所有存入的数据，直到你显式将其移除；
- Caffeine将通过给定的配置，自动移除“不常用”的数据，以保持内存的合理占用。
因此，一种更好的理解方式是：Cache是一种带有存储和移除策略的Map。
基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能
- 项目地址：https://github.com/YunaiV/ruoyi-vue-pro
- 视频教程：https://doc.iocoder.cn/video/
二、Caffeine基础
使用Caffeine，需要在工程中引入如下依赖
com.github.ben-manes.caffeine
caffeine
3.0.5
1、缓存加载策略
1.1 Cache手动创建
最普通的一种缓存，无需指定加载方式，需要手动调用put()进行加载。需要注意的是put()方法对于已存在的key将进行覆盖，这点和Map的表现是一致的。在获取缓存值时，如果想要在缓存值不存在时，原子地将值写入缓存，则可以调用get(key, k -> value)方法，该方法将避免写入竞争。调用invalidate()方法，将手动移除缓存。
在多线程情况下，当使用get(key, k -> value)时，如果有另一个线程同时调用本方法进行竞争，则后一线程会被阻塞，直到前一线程更新缓存完成；而若另一线程调用getIfPresent()方法，则会立即返回null，不会被阻塞。
Cachecache=Caffeine.newBuilder()
//初始数量
.initialCapacity(10)
//最大条数
.maximumSize(10)
//expireAfterWrite和expireAfterAccess同时存在时，以expireAfterWrite为准
//最后一次写操作后经过指定时间过期
.expireAfterWrite(1,TimeUnit.SECONDS)
//最后一次读或写操作后经过指定时间过期
.expireAfterAccess(1,TimeUnit.SECONDS)
//监听缓存被移除
.removalListener((key,val,removalCause)->{})
//记录命中
.recordStats()
.build();
cache.put("1","张三");
//张三
System.out.println(cache.getIfPresent("1"));
//存储的是默认值
System.out.println(cache.get("2",o->"默认值"));
1.2 Loading Cache自动创建
LoadingCache是一种自动加载的缓存。其和普通缓存不同的地方在于，当缓存不存在/缓存已过期时，若调用get()方法，则会自动调用CacheLoader.load()方法加载最新值。调用getAll()方法将遍历所有的key调用get()，除非实现了CacheLoader.loadAll()方法。使用LoadingCache时，需要指定CacheLoader，并实现其中的load()方法供缓存缺失时自动加载。
在多线程情况下，当两个线程同时调用get()，则后一线程将被阻塞，直至前一线程更新缓存完成。
LoadingCacheloadingCache=Caffeine.newBuilder()
//创建缓存或者最近一次更新缓存后经过指定时间间隔，刷新缓存；refreshAfterWrite仅支持LoadingCache
.refreshAfterWrite(10,TimeUnit.SECONDS)
.expireAfterWrite(10,TimeUnit.SECONDS)
.expireAfterAccess(10,TimeUnit.SECONDS)
.maximumSize(10)
//根据key查询数据库里面的值，这里是个lamba表达式
.build(key->newDate().toString());
1.3 Async Cache异步获取
AsyncCache是Cache的一个变体，其响应结果均为CompletableFuture，通过这种方式，AsyncCache对异步编程模式进行了适配。默认情况下，缓存计算使用ForkJoinPool.commonPool()作为线程池，如果想要指定线程池，则可以覆盖并实现Caffeine.executor(Executor)方法。synchronous()提供了阻塞直到异步缓存生成完毕的能力，它将以Cache进行返回。
在多线程情况下，当两个线程同时调用get(key, k -> value)，则会返回同一个CompletableFuture对象。由于返回结果本身不进行阻塞，可以根据业务设计自行选择阻塞等待或者非阻塞。
AsyncLoadingCacheasyncLoadingCache=Caffeine.newBuilder()
//创建缓存或者最近一次更新缓存后经过指定时间间隔刷新缓存；仅支持LoadingCache
.refreshAfterWrite(1,TimeUnit.SECONDS)
.expireAfterWrite(1,TimeUnit.SECONDS)
.expireAfterAccess(1,TimeUnit.SECONDS)
.maximumSize(10)
//根据key查询数据库里面的值
.buildAsync(key->{
Thread.sleep(1000);
returnnewDate().toString();
});
//异步缓存返回的是CompletableFuture
CompletableFuturefuture=asyncLoadingCache.get("1");
future.thenAccept(System.out::println);
2、驱逐策略
驱逐策略在创建缓存的时候进行指定。常用的有基于容量的驱逐和基于时间的驱逐。
基于容量的驱逐需要指定缓存容量的最大值，当缓存容量达到最大时，Caffeine将使用LRU策略对缓存进行淘汰；基于时间的驱逐策略如字面意思，可以设置在最后访问/写入一个缓存经过指定时间后，自动进行淘汰。
驱逐策略可以组合使用，任意驱逐策略生效后，该缓存条目即被驱逐。
- LRU 最近最少使用，淘汰最长时间没有被使用的页面。
- LFU 最不经常使用，淘汰一段时间内使用次数最少的页面
- FIFO 先进先出
Caffeine有4种缓存淘汰设置
- 大小 （LFU算法进行淘汰）
- 权重 （大小与权重 只能二选一）
- 时间
- 引用 （不常用，本文不介绍）
@Slf4j
publicclassCacheTest{
/**
*缓存大小淘汰
*/
@Test
publicvoidmaximumSizeTest()throwsInterruptedException{
Cachecache=Caffeine.newBuilder()
//超过10个后会使用W-TinyLFU算法进行淘汰
.maximumSize(10)
.evictionListener((key,val,removalCause)->{
log.info("淘汰缓存：key:{}val:{}",key,val);
})
.build();
for(inti=1;i< 20;i++){
cache.put(i,i);
}
Thread.sleep(500);//缓存淘汰是异步的
//打印还没被淘汰的缓存
System.out.println(cache.asMap());
}
/**
*权重淘汰
*/
@Test
publicvoidmaximumWeightTest()throwsInterruptedException{
Cachecache=Caffeine.newBuilder()
//限制总权重，若所有缓存的权重加起来>总权重就会淘汰权重小的缓存
.maximumWeight(100)
.weigher((Weigher)(key,value)->key)
.evictionListener((key,val,removalCause)->{
log.info("淘汰缓存：key:{}val:{}",key,val);
})
.build();
//总权重其实是=所有缓存的权重加起来
intmaximumWeight=0;
for(inti=1;i< 20;i++){
cache.put(i,i);
maximumWeight+=i;
}
System.out.println("总权重="+maximumWeight);
Thread.sleep(500);//缓存淘汰是异步的
//打印还没被淘汰的缓存
System.out.println(cache.asMap());
}
/**
*访问后到期（每次访问都会重置时间，也就是说如果一直被访问就不会被淘汰）
*/
@Test
publicvoidexpireAfterAccessTest()throwsInterruptedException{
Cachecache=Caffeine.newBuilder()
.expireAfterAccess(1,TimeUnit.SECONDS)
//可以指定调度程序来及时删除过期缓存项，而不是等待Caffeine触发定期维护
//若不设置scheduler，则缓存会在下一次调用get的时候才会被动删除
.scheduler(Scheduler.systemScheduler())
.evictionListener((key,val,removalCause)->{
log.info("淘汰缓存：key:{}val:{}",key,val);
})
.build();
cache.put(1,2);
System.out.println(cache.getIfPresent(1));
Thread.sleep(3000);
System.out.println(cache.getIfPresent(1));//null
}
/**
*写入后到期
*/
@Test
publicvoidexpireAfterWriteTest()throwsInterruptedException{
Cachecache=Caffeine.newBuilder()
.expireAfterWrite(1,TimeUnit.SECONDS)
//可以指定调度程序来及时删除过期缓存项，而不是等待Caffeine触发定期维护
//若不设置scheduler，则缓存会在下一次调用get的时候才会被动删除
.scheduler(Scheduler.systemScheduler())
.evictionListener((key,val,removalCause)->{
log.info("淘汰缓存：key:{}val:{}",key,val);
})
.build();
cache.put(1,2);
Thread.sleep(3000);
System.out.println(cache.getIfPresent(1));//null
}
}
3、刷新机制
refreshAfterWrite()表示x秒后自动刷新缓存的策略可以配合淘汰策略使用，注意的是刷新机制只支持LoadingCache和AsyncLoadingCache
privatestaticintNUM=0;
@Test
publicvoidrefreshAfterWriteTest()throwsInterruptedException{
LoadingCachecache=Caffeine.newBuilder()
.refreshAfterWrite(1,TimeUnit.SECONDS)
//vwin
获取数据，每次获取就自增1
.build(integer->++NUM);
//获取ID=1的值，由于缓存里还没有，所以会自动放入缓存
System.out.println(cache.get(1));//1
//延迟2秒后，理论上自动刷新缓存后取到的值是2
//但其实不是，值还是1，因为refreshAfterWrite并不是设置了n秒后重新获取就会自动刷新
//而是x秒后&&第二次调用getIfPresent的时候才会被动刷新
Thread.sleep(2000);
System.out.println(cache.getIfPresent(1));//1
//此时才会刷新缓存，而第一次拿到的还是旧值
System.out.println(cache.getIfPresent(1));//2
}
4、统计
LoadingCachecache=Caffeine.newBuilder()
//创建缓存或者最近一次更新缓存后经过指定时间间隔，刷新缓存；refreshAfterWrite仅支持LoadingCache
.refreshAfterWrite(1,TimeUnit.SECONDS)
.expireAfterWrite(1,TimeUnit.SECONDS)
.expireAfterAccess(1,TimeUnit.SECONDS)
.maximumSize(10)
//开启记录缓存命中率等信息
.recordStats()
//根据key查询数据库里面的值
.build(key->{
Thread.sleep(1000);
returnnewDate().toString();
});
cache.put("1","shawn");
cache.get("1");
/*
*hitCount:命中的次数
*missCount:未命中次数
*requestCount:请求次数
*hitRate:命中率
*missRate:丢失率
*loadSuccessCount:成功加载新值的次数
*loadExceptionCount:失败加载新值的次数
*totalLoadCount:总条数
*loadExceptionRate:失败加载新值的比率
*totalLoadTime:全部加载时间
*evictionCount:丢失的条数
*/
System.out.println(cache.stats());
5、总结
上述一些策略在创建时都可以进行自由组合，一般情况下有两种方法
-
设置
maxSize、refreshAfterWrite，不设置expireAfterWrite/expireAfterAccess，设置expireAfterWrite当缓存过期时会同步加锁获取缓存，所以设置expireAfterWrite时性能较好，但是某些时候会取旧数据,适合允许取到旧数据的场景 -
设置
maxSize、expireAfterWrite/expireAfterAccess，不设置 refreshAfterWrite 数据一致性好，不会获取到旧数据，但是性能没那么好（对比起来），适合获取数据时不耗时的场景
基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能
三、SpringBoot整合Caffeine
1、@Cacheable相关注解
1.1 相关依赖
如果要使用@Cacheable注解，需要引入相关依赖，并在任一配置类文件上添加@EnableCaching注解
org.springframework.boot
spring-boot-starter-cache
1.2 常用注解
- @Cacheable ：表示该方法支持缓存。当调用被注解的方法时，如果对应的键已经存在缓存，则不再执行方法体，而从缓存中直接返回。当方法返回null时，将不进行缓存操作。
- @CachePut ：表示执行该方法后，其值将作为最新结果更新到缓存中，每次都会执行该方法。
- @CacheEvict ：表示执行该方法后，将触发缓存清除操作。
- @Caching ：用于组合前三个注解，例如：
@Caching(cacheable=@Cacheable("CacheConstants.GET_USER"),
evict={@CacheEvict("CacheConstants.GET_DYNAMIC",allEntries=true)}
publicUserfind(Integerid){
returnnull;
}
1.3 常用注解属性
- cacheNames/value ：缓存组件的名字，即cacheManager中缓存的名称。
- key ：缓存数据时使用的key。默认使用方法参数值，也可以使用SpEL表达式进行编写。
- keyGenerator ：和key二选一使用。
- cacheManager ：指定使用的缓存管理器。
- condition ：在方法执行开始前检查，在符合condition的情况下，进行缓存
- unless ：在方法执行完成后检查，在符合unless的情况下，不进行缓存
- sync ：是否使用同步模式。若使用同步模式，在多个线程同时对一个key进行load时，其他线程将被阻塞。
1.4 缓存同步模式
sync开启或关闭，在Cache和LoadingCache中的表现是不一致的：
- Cache中，sync表示是否需要所有线程同步等待
- LoadingCache中，sync表示在读取不存在/已驱逐的key时，是否执行被注解方法
2、实战
2.1 引入依赖
org.springframework.boot
spring-boot-starter-cache
com.github.ben-manes.caffeine
caffeine
2.2 缓存常量CacheConstants
创建缓存常量类，把公共的常量提取一层，复用，这里也可以通过配置文件加载这些数据，例如@ConfigurationProperties和@Value
publicclassCacheConstants{
/**
*默认过期时间（配置类中我使用的时间单位是秒，所以这里如3*60为3分钟）
*/
publicstaticfinalintDEFAULT_EXPIRES=3*60;
publicstaticfinalintEXPIRES_5_MIN=5*60;
publicstaticfinalintEXPIRES_10_MIN=10*60;
publicstaticfinalStringGET_USER="GET:USER";
publicstaticfinalStringGET_DYNAMIC="GET:DYNAMIC";
}
2.3 缓存配置类CacheConfig
@Configuration
@EnableCaching
publicclassCacheConfig{
/**
*Caffeine配置说明：
*initialCapacity=[integer]:初始的缓存空间大小
*maximumSize=[long]:缓存的最大条数
*maximumWeight=[long]:缓存的最大权重
*expireAfterAccess=[duration]:最后一次写入或访问后经过固定时间过期
*expireAfterWrite=[duration]:最后一次写入后经过固定时间过期
*refreshAfterWrite=[duration]:创建缓存或者最近一次更新缓存后经过固定的时间间隔，刷新缓存
*weakKeys:打开key的弱引用
*weakValues：打开value的弱引用
*softValues：打开value的软引用
*recordStats：开发统计功能
*注意：
*expireAfterWrite和expireAfterAccess同事存在时，以expireAfterWrite为准。
*maximumSize和maximumWeight不可以同时使用
*weakValues和softValues不可以同时使用
*/
@Bean
publicCacheManagercacheManager(){
SimpleCacheManagercacheManager=newSimpleCacheManager();
Listlist=newArrayList<>();
//循环添加枚举类中自定义的缓存，可以自定义
for(CacheEnumcacheEnum:CacheEnum.values()){
list.add(newCaffeineCache(cacheEnum.getName(),
Caffeine.newBuilder()
.initialCapacity(50)
.maximumSize(1000)
.expireAfterAccess(cacheEnum.getExpires(),TimeUnit.SECONDS)
.build()));
}
cacheManager.setCaches(list);
returncacheManager;
}
}
2.4 调用缓存
这里要注意的是Cache和@Transactional一样也使用了代理，类内调用将失效
/**
*value：缓存key的前缀。
*key：缓存key的后缀。
*sync：设置如果缓存过期是不是只放一个请求去请求数据库，其他请求阻塞，默认是false（根据个人需求）。
*unless：不缓存空值,这里不使用，会报错
*查询用户信息类
*如果需要加自定义字符串，需要用单引号
*如果查询为null，也会被缓存
*/
@Cacheable(value=CacheConstants.GET_USER,key="'user'+#userId",sync=true)
@CacheEvict
publicUserEntitygetUserByUserId(IntegeruserId){
UserEntityuserEntity=userMapper.findById(userId);
System.out.println("查询了数据库");
returnuserEntity;
}
声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表德赢Vwin官网
网立场。文章及其配图仅供工程师学习之用，如有内容侵权或者其他违规问题，请联系本站处理。
举报投诉
-
JAVA
+关注
关注
19文章
2966浏览量
104702 -
缓存
+关注
关注
1文章
239浏览量
26669 -
数据库
+关注
关注
7文章
3794浏览量
64360
原文标题：再见，Guava！再见，Ehcache！这才是 Java 本地缓存之王！
文章出处：【微信号：芋道源码，微信公众号：芋道源码】欢迎添加关注！文章转载请注明出处。
发布评论请先 登录
相关推荐
HTTP缓存头的使用 本地缓存与远程缓存的区别
HTTP缓存头是一组HTTP响应头，它们控制浏览器和中间代理服务器如何缓存网页内容。合理使用HTTP缓存头可以显著提高网站的加载速度和性能，减少服务器的负载。 1. HTTP缓存头概述
Web缓存的类型及功能分析
随着互联网的迅速发展，用户对网络内容的访问需求日益增长。为了提高用户体验和降低服务器负担，Web缓存技术应运而生。Web缓存通过存储重复请求的数据，减少了对原始服务器的访问次数，从而加快了数据传输
缓存技术在软件开发中的应用
在现代软件开发中，随着数据量的爆炸性增长和用户对响应速度的高要求，缓存技术成为了提升系统性能的重要手段。缓存技术通过将数据存储在离用户更近的位置，减少数据访问延迟，提高数据处理速度，从而优化
什么是缓存(Cache)及其作用
缓存（Cache）是一种高速存储器，用于临时存储数据，以便快速访问。在计算机系统中，缓存的作用是减少处理器访问主存储器（如随机存取存储器RAM）所需的时间。 缓存（Cache）概述 缓存
Java 23功能介绍
Java 23 包含全新和更新的 Java 语言功能、核心 API 以及 JVM，同时适合新的 Java 开发者和高级开发者。从 IntelliJ IDEA 2024.2 开始已支持 Java
缓存之美——如何选择合适的本地缓存？
Guava cache是Google开发的Guava工具包中一套完善的JVM本地缓存框架，底层实现的数据结构类似于ConcurrentHashMap，但是进行了更多的能力拓展，包括缓存过期时间设置、
什么是CPU缓存？它有哪些作用？
CPU缓存（Cache Memory）是计算机系统中一个至关重要的组成部分，它位于CPU与内存之间，作为两者之间的临时存储器。CPU缓存的主要作用是减少CPU访问内存所需的时间，从而提高系统的整体性能。以下将详细阐述CPU缓存的
使用Nexus在本地搭建npm、yum和maven私有仓库
，实现集成环境部署。 (1) 使用Nexus在本地搭建npm、yum和maven私有仓库，Nexus是一个很强大的私服软件，不仅仅是作为Java的Maven打包使用，同样的也支持pypi、yum源
华纳云：java web和java有什么区别java web和java有什么区别
Java Web和Java是两个不同的概念，它们在功能、用途和实现方式上存在一些区别，下面将详细介绍它们之间的区别。 1. 功能和用途： – Java是一种编程语言，它提供了一种用于开发各种应用程序
鸿蒙原生应用元服务开发WEB-缓存与存储管理
在访问网站时，网络资源请求是相对比较耗时的。开发者可以通过Cache、Dom Storage等手段将资源保持至本地，以提升访问同一网站的速度。
Cache
使用cacheMode()配置页面资源
发表于 05-17 11:23
做STM32f103 USB双缓存的时候，发送4K数据里面前64字节是0，为什么？
做STM32f103 USB 双缓存的时候, 采取ENP3的TXaddr1和TXaddr0的双缓存ping-pong发送机制,每次上位机接收完4K数据, 4K数据前64个字节全部是0,后面才是上位
发表于 04-28 07:07
云服务器的maven怎么配置本地仓库？
在云服务器上使用Maven时，你可以配置本地仓库以缓存和管理依赖项，以减少对中央仓库的依赖和加快构建过程。以下是配置Maven本地仓库的步骤： 1、选择本地仓库路径： 在云服务器上选择
如何选择合适的本地缓存？
的 Guava 缓存、在 Guava 上进一步传承的 Caffine 以及自称在 Java 中使用最广泛的 EhCache，那么我们该怎么选择适合自己应用的缓存呢，小编下面会简单介绍，
labview怎么清除串口缓存的数据
LabVIEW 是一款功能强大的图形化编程软件，常用于控制、监测和数据采集等应用。当我们使用串口进行数据通信时，有时会遇到串口缓存的数据无法及时清除或清除不彻底的情况。解决这个问题的方法有多种，下面
工商网监
评论