如何基于LoadingCache实现Java本地缓存

2023-08-04 03:01:05 83

这篇文章主要介绍了如何基于LoadingCache实现Java本地缓存,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

前言

Guava是Google开源出来的一套工具库。其中提供的cache模块非常方便，是一种与ConcurrentMap相似的缓存Map。

官方地址：https://github.com/google/guava/wiki/CachesExplained

开始构建

一.添加依赖


com.google.guava
guava
27.1-jre

二.创建CacheLoader

LoadingCachecache=CacheBuilder.newBuilder()
//缓存池大小，在缓存项接近该大小时，Guava开始回收旧的缓存项
.maximumSize(GUAVA_CACHE_SIZE)
//设置时间对象没有被读/写访问则对象从内存中删除(在另外的线程里面不定期维护)
.expireAfterAccess(10,TimeUnit.MINUTES)
//移除监听器,缓存项被移除时会触发
.removalListener(newRemovalListener(){
@Override
publicvoidonRemoval(RemovalNotificationrn){
//执行逻辑操作
}
})
//开启GuavaCache的统计功能
.recordStats()
.build(cacheLoader);

三.个人封装的工具类

packagecom.xxx;

importcom.google.common.cache.*;
importorg.slf4j.Logger;

importjava.util.ArrayList;
importjava.util.List;
importjava.util.Map;
importjava.util.concurrent.ConcurrentMap;
importjava.util.concurrent.TimeUnit;

publicclassCacheManager{

privatestaticLoggerlog=Log.get();

/**缓存项最大数量*/
privatestaticfinallongGUAVA_CACHE_SIZE=100000;

/**缓存时间：天*/
privatestaticfinallongGUAVA_CACHE_DAY=10;

/**缓存操作对象*/
privatestaticLoadingCacheGLOBAL_CACHE=null;

static{
try{
GLOBAL_CACHE=loadCache(newCacheLoader(){
@Override
publicStringload(Longkey)throwsException{
//处理缓存键不存在缓存值时的处理逻辑
return"";
}
});
}catch(Exceptione){
log.error("初始化GuavaCache出错",e);
}
}

/**
*全局缓存设置
*
*缓存项最大数量：100000
*缓存有效时间（天）：10
*
*
*@paramcacheLoader
*@return
*@throwsException
*/
privatestaticLoadingCacheloadCache(CacheLoadercacheLoader)throwsException{
LoadingCachecache=CacheBuilder.newBuilder()
//缓存池大小，在缓存项接近该大小时，Guava开始回收旧的缓存项
.maximumSize(GUAVA_CACHE_SIZE)
//设置时间对象没有被读/写访问则对象从内存中删除(在另外的线程里面不定期维护)
.expireAfterAccess(GUAVA_CACHE_DAY,TimeUnit.DAYS)
//设置缓存在写入之后设定时间后失效
.expireAfterWrite(GUAVA_CACHE_DAY,TimeUnit.DAYS)
//移除监听器,缓存项被移除时会触发
.removalListener(newRemovalListener(){
@Override
publicvoidonRemoval(RemovalNotificationrn){
//逻辑操作
}
})
//开启GuavaCache的统计功能
.recordStats()
.build(cacheLoader);
returncache;
}

/**
*设置缓存值
*注:若已有该key值，则会先移除(会触发removalListener移除监听器)，再添加
*
*@paramkey
*@paramvalue
*/
publicstaticvoidput(Longkey,Stringvalue){
try{
GLOBAL_CACHE.put(key,value);
}catch(Exceptione){
log.error("设置缓存值出错",e);
}
}

/**
*批量设置缓存值
*
*@parammap
*/
publicstaticvoidputAll(Mapmap){
try{
GLOBAL_CACHE.putAll(map);
}catch(Exceptione){
log.error("批量设置缓存值出错",e);
}
}

/**
*获取缓存值
*注：如果键不存在值，将调用CacheLoader的load方法加载新值到该键中
*
*@paramkey
*@return
*/
publicstaticStringget(Longkey){
Stringtoken="";
try{
token=GLOBAL_CACHE.get(key);
}catch(Exceptione){
log.error("获取缓存值出错",e);
}
returntoken;
}

/**
*移除缓存
*
*@paramkey
*/
publicstaticvoidremove(Longkey){
try{
GLOBAL_CACHE.invalidate(key);
}catch(Exceptione){
log.error("移除缓存出错",e);
}
}

/**
*批量移除缓存
*
*@paramkeys
*/
publicstaticvoidremoveAll(Iterablekeys){
try{
GLOBAL_CACHE.invalidateAll(keys);
}catch(Exceptione){
log.error("批量移除缓存出错",e);
}
}

/**
*清空所有缓存
*/
publicstaticvoidremoveAll(){
try{
GLOBAL_CACHE.invalidateAll();
}catch(Exceptione){
log.error("清空所有缓存出错",e);
}
}

/**
*获取缓存项数量
*
*@return
*/
publicstaticlongsize(){
longsize=0;
try{
size=GLOBAL_CACHE.size();
}catch(Exceptione){
log.error("获取缓存项数量出错",e);
}
returnsize;
}
}

总结

1.移除机制

guava做cache时候数据的移除分为被动移除和主动移除两种。

被动移除分为三种：1).基于大小的移除：数量达到指定大小，会把不常用的键值移除

2).基于时间的移除：expireAfterAccess(long,TimeUnit)根据某个键值对最后一次访问之后多少时间后移除
expireAfterWrite(long,TimeUnit)根据某个键值对被创建或值被替换后多少时间移除

3).基于引用的移除：主要是基于java的垃圾回收机制，根据键或者值的引用关系决定移除

主动移除分为三种：1).单独移除：Cache.invalidate(key)

2).批量移除：Cache.invalidateAll(keys)

3).移除所有：Cache.invalidateAll()

如果配置了移除监听器RemovalListener，则在所有移除的动作时会同步执行该listener下的逻辑。

如需改成异步，使用：RemovalListeners.asynchronous(RemovalListener,Executor)

2.遇到的问题

1).在put操作之前，如果已经有该键值，会先触发removalListener移除监听器，再添加

2).配置了expireAfterAccess和expireAfterWrite，但在指定时间后没有被移除。

解决方案：CacheBuilder在文档上有说明

IfexpireAfterWriteorexpireAfterAccessisrequestedentriesmaybeevictedoneachcachemodification,onoccasionalcacheaccesses,oroncallstoCache.cleanUp().ExpiredentriesmaybecountedinCache.size(),butwillneverbevisibletoreadorwriteoperations.

翻译过来大概的意思是：CacheBuilder构建的缓存不会在特定时间自动执行清理和回收工作，也不会在某个缓存项过期后马上清理，它不会启动一个线程来进行缓存维护，因为

a）线程相对较重

b）某些环境限制线程的创建。它会在写操作时顺带做少量的维护工作，或者偶尔在读操作时做

当然，也可以创建自己的维护线程，以固定的时间间隔调用Cache.cleanUp()。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

如何基于LoadingCache实现Java本地缓存

热门推荐

随机推荐