java icache_java手写多级缓存

深碍√TFBOYSˉ_ 2022-11-07 13:08 184阅读 0赞

多级缓存完成类，时间有限，该类未抽取接口，目前只支持两级缓存：JVM缓存(完成请查看上一篇：java手写JVM高性能缓存)、redis缓存(在spring的redisTemplate根底完成)

复制代码

packagecom.ws.commons.cache;

importjava.util.function.Supplier;

importcom.ws.commons.tool.ThreadTool;

/\*\*

\*多级缓存完成

\*@author尘无尘

\*/

publicclassMultilevelCache\{

privateMultilevelCache()\{

privatestaticfinalICacheFIRST\_LEVE\_LCACHE=LocalCache.instance();

privatestaticICachesecondCache;

privatestaticfinalStringLOCK\_PREFIX=”MUILCACHE\_LOCK:”;

publicstaticsynchronizedvoidinit(ICachesecondCache)\{

if(MultilevelCache.secondCache==null)\{

MultilevelCache.secondCache=secondCache;

publicstaticvoidput(Stringkey,Objectvalue,inttimeOutSecond)\{

FIRST\_LEVE\_LCACHE.put(key,value,timeOutSecond);

if(secondCache!=null)\{

secondCache.put(key,value,timeOutSecond);

/\*\*![53735d760d3d7cbfa805608b95bb1702.png][]

\*提供数据，并缓存

\*@paramkey

\*@paramsupplier

\*@return

\*/

@SuppressWarnings(“unchecked”)

publicstaticTgetForload(Stringkey,Suppliersupplier)\{

Tdata=FIRST\_LEVE\_LCACHE.get(key);

if(data==null&&secondCache!=null)\{

data=(T)secondCache.get(key);

if(data!=null)\{

returndata;

synchronized(ThreadTool.buildLock(LOCK\_PREFIX,key))\{

data=FIRST\_LEVE\_LCACHE.get(key);

if(data==null&&secondCache!=null)\{

data=(T)secondCache.get(key);

if(data!=null)\{

returndata;

data=supplier.get();

if(secondCache!=null)\{

secondCache.put(key,data);

FIRST\_LEVE\_LCACHE.put(key,data);

returndata;

/\*\*

\*提供数据，并缓存一定的时间

\*@paramkey

\*@paramtimeOutSecond

\*@paramsupplier

\*@return

\*/

@SuppressWarnings(“unchecked”)

publicstaticTgetForload(Stringkey,inttimeOutSecond,Suppliersupplier)\{

Tdata=FIRST\_LEVE\_LCACHE.get(key);

if(data==null&&secondCache!=null)\{

data=(T)secondCache.get(key);

if(data!=null)\{

returndata;

synchronized(ThreadTool.buildLock(LOCK\_PREFIX,key))\{

data=FIRST\_LEVE\_LCACHE.get(key);

if(data==null&&secondCache!=null)\{

data=(T)secondCache.get(key);

if(data!=null)\{

returndata;

data=supplier.get();

if(secondCache!=null)\{

secondCache.put(key,data,timeOutSecond);

FIRST\_LEVE\_LCACHE.put(key,data,timeOutSecond);

returndata;

@SuppressWarnings(“unchecked”)

publicstaticTremoveAndGet(Stringkey)\{

Tdata=null;

if(secondCache!=null)\{

data=(T)secondCache.removeAndGet(key);

Tdata2=FIRST\_LEVE\_LCACHE.removeAndGet(key);

if(data==null)\{

data=data2;

returndata;

publicstaticvoidremove(Stringkey)\{

if(secondCache!=null)\{

secondCache.remove(key);

FIRST\_LEVE\_LCACHE.remove(key);

@SuppressWarnings(“unchecked”)

publicstaticTget(Stringkey)\{

Tdata=FIRST\_LEVE\_LCACHE.get(key);

if(data==null&&secondCache!=null)\{

data=(T)secondCache.get(key);

returndata;

publicstaticvoidexpire(Stringkey,inttimeOutSecond)\{

FIRST\_LEVE\_LCACHE.expire(key,timeOutSecond);

if(secondCache!=null)\{

secondCache.expire(key,timeOutSecond);

复制代码

redis缓存完成类

复制代码

packagecom.walmart.cirular.interfaces.application;

importjava.util.concurrent.TimeUnit;

importorg.springframework.beans.factory.annotation.Autowired;

importorg.springframework.data.redis.core.RedisTemplate;

importorg.springframework.stereotype.Component;

importcom.ws.commons.cache.ICache;

/\*\*

\*redis缓存完成类

\*@author尘无尘

\*/

@Component

publicclassRedisICacheImplimplementsICache\{

@Autowired(required=false)

privateRedisTemplateredisTemplate;

@Override

publicvoidput(Stringkey,Objectvalue)\{

redisTemplate.opsForValue().set(key,value);

@Override

publicvoidput(Stringkey,Objectvalue,inttimeOutSecond)\{

redisTemplate.opsForValue().set(key,value,(long)timeOutSecond,TimeUnit.SECONDS);

@SuppressWarnings(“unchecked”)

@Override

publicTget(Stringkey)\{

Tt=(T)redisTemplate.opsForValue().get(key);

redisTemplate.delete(key);

returnt;

@Override

publicvoidremove(Stringkey)\{

redisTemplate.delete(key);

@SuppressWarnings(“unchecked”)

@Override

publicTremoveAndGet(Stringkey)\{

Objectobj=get(key);

redisTemplate.delete(key);

return(T)obj;

@Override

publicvoidrightPush(Stringkey,Objectvalue,inttimeOutSecond)\{

redisTemplate.opsForList().rightPush(key,value);

redisTemplate.expire(key,timeOutSecond,TimeUnit.SECONDS);

@SuppressWarnings(“unchecked”)

@Override

publicTrightPop(Stringkey)\{

return(T)redisTemplate.opsForList().rightPop(key);

@SuppressWarnings(“unchecked”)

@Override

publicTleftPop(Stringkey)\{

return(T)redisTemplate.opsForList().leftPop(key);

@Override

publicvoidleftPush(Stringkey,Objectvalue)\{

redisTemplate.opsForList().leftPush(key,value);

@Override

publicvoidrightPush(Stringkey,Objectvalue)\{

redisTemplate.opsForList().rightPush(key,value);

@Override

publicvoidexpire(Stringkey,inttimeOutSecond)\{

redisTemplate.expire(key,timeOutSecond,TimeUnit.SECONDS);

@Override

publicbooleanhasKey(Stringkey)\{

returnredisTemplate.hasKey(key);

@Override

publicbooleanputIfAbsent(Stringkey,Objectvalue)\{

returnredisTemplate.opsForValue().setIfAbsent(key,value);

@Override

publicbooleanputIfAbsent(Stringkey,Objectvalue,inttimeOutSecond)\{

booleanflag=putIfAbsent(key,value);

if(flag)\{

expire(key,timeOutSecond);

returnflag;

[53735d760d3d7cbfa805608b95bb1702.png]: /images/20221023/a42f4097ce90490dab495c3bef238c9a.png

java icache_java手写多级缓存

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关多级缓存快速上手

相关 Reids多级缓存

相关多级缓存之实现多级缓存

相关【Redis】多级缓存

相关 c语言-手撕多级时间轮定时器(纯手写)

相关 CPU 多级缓存

相关 JetCache多级缓存

相关手写高性能缓存

相关 java icache_java手写多级缓存

相关多级缓存