【开发篇】十二、缓存框架JetCache

文章目录

  • 0、介绍
  • 1、JetCache远程缓存
  • 2、JetCache本地缓存
  • 3、标准配置文件
  • 4、JetCache方法缓存注解--@Cached
  • 5、@Cached
  • 4、@CacheUpdate
  • 5、@CacheInvalidate
  • 6、@CacheRefresh
  • 7、缓存统计报告

上篇完成了Spring Cache底层技术的各种切换,但各个技术有各自的优缺点,因此阿里的Jetcache框架出现。 注意Jetcache是一个框架,做的是一个整合和封装,自身不是像redis一样的缓存实现技术,Jetcache框架底层还得依靠具体的缓存实现技术,它是和Spring Cache同等级的,用来替换Spring Cache的。

0、介绍

JetCache对SpringCache进行了封装,在原有功能基础上实现了多级缓存、缓存统计、自动刷新、异步调用、数据报表等功能

JetCache设定了本地缓存与远程缓存的多级缓存解决方案,其中本地缓存(local)支持:

  • LinkedHashMap
  • Caffeine

远程缓存(remote)支持:

  • Redis
  • Tair

1、JetCache远程缓存

先引入依赖

<dependency>    <groupId>com.alicp.jetcache</groupId>   <artifactId>jetcache-starter-redis</artifactId>    <version>2.6.2</version>
</dependency>

远程缓存的属性配置:

jetcache:  remote:    default:      type: redis      host: localhost      port: 6379   password: admin1234   poolConfig:        maxTotal: 50# 再定义一个缓存区域也行myArea:type: redishost: .......

@EnableCreateCacheAnnotation启动用注解来创建缓存,开启后就可以用@CreateCache来创建一个缓存对象。

@SpringBootApplication@EnableCreateCacheAnnotationpublic class CacheApplication {    public static void main(String[] args) {   SpringApplication.run(CacheApplication.class, args);    }}

使用@CreateCache注解声明一个缓存对象:

@Service
public class SMSCodeServiceImpl implements SMSCodeService {@CreateCache(area = "default", name = "smsCache::", expire = 3600, timeUnit = TimeUnit.SECONDS, cacheType = CacheType.REMOTE)  private Cache<String, String> jetSMSCache;//...}

注意@CreateCache注解的属性:

  • area:用哪块存储空间,默认值为default,即配置文件里的jetcache.remote.default及其下面的配置,可以再自己定义区域
  • name:key的分组前缀,常用str::或者str_
  • expire:过期时间,单位默认秒
  • timeUnit:时间单位,默认值秒
  • cacheType:缓存类型,local即本地缓存,remote即远程缓存,all即两个都写,默认远程缓存

操作缓存:使用缓存对象.put和get

@Service
public class SMSCodeServiceImpl implements SMSCodeService {    @Override   public String sendCodeToSMS(String tele) {     String code = this.codeUtils.generator(tele);  jetSMSCache.put(tele,code);    //putreturn code;    }   @Override    public boolean checkCode(String tele,String code) {  String value = jetSMSCache.get(tele);     //getreturn code.equals(value);}
}

重启服务,调用之前的缓存接口查看效果。出现了一个莫名奇妙的循环依赖,先临时解决下,跳过了:

spring:main:allow-circular-references: true

发现接口调用正常,启动日志也输出了相关信息:

在这里插入图片描述

2、JetCache本地缓存

和远程一样,引入依赖后,配置文件不同:

jetcache:  local:    default:     type: linkedhashmap      keyConvertor: fastjson # 即key不是String时,用哪个转换器转为String

再后面一样的操作,开启缓存注解支持、声明缓存对象、put和get都一样,需要注意的是上面的CacheType属性改为Local

@CreateCache(name = "smsCache::", expire = 3600, cacheType = CacheType.LOCAL)  
private Cache<String, String> jetSMSCache;

3、标准配置文件

JetCache能同时支持本地和远程缓存,所以标准的配置文件写一起就行:

jetcache:  statIntervalMinutes: 15  areaInCacheName: false    # 即key里加不加area的名字,true时key形如default_myname::keylocal:    default:      type: linkedhashmap      keyConvertor: fastjson      limit: 100  remote:default:      host: localhost      port: 6379      type: redis      keyConvertor: fastjson      valueEncoder: java      valueDecoder: java      poolConfig:        minIdle: 5        maxIdle: 20       maxTotal: 50

关于配置的含义:

在这里插入图片描述

4、JetCache方法缓存注解–@Cached

上面写缓存得创建JetCache缓存对象后put和get,如何像@Cacheable注解一样,对整个方法的结果通过加注解来自动写查缓存?

请添加图片描述

答案是在@EnableCreateCacheAnnotation的基础上,再加注解@EnableMethodCache(basePackages = "com.mydemo"),开启对方法缓存注解的支持,basePackeages属性写需要用到方法缓存注解的包路径。

@SpringBootApplication
@EnableCreateCacheAnnotation  ####!
@EnableMethodCache(basePackages = "com.mydemo") ####!
public class JetCacheApplication {  public static void main(String[] args) { SpringApplication.run(JetCacheApplication.class, args);    }
}

@Cached注解加需要缓存的方法上,如此查到的Book对象就被缓存到default的Area,且是远程缓存

@Service
public class BookServiceImpl implements BookService {    @Autowired    private BookDao bookDao;   @Cached(name = "smsCache_", key = "#id", expire = 3600) @Override      public Book getById(Integer id) {return bookDao.selectById(id);    }}

上面@Cache注解的cacheType属性没写,那就是默认的远程缓存。此时,调用接口返回正常,但接口日志有异常:

在这里插入图片描述

需要加一个配置,指定key的转换器给本地和远程缓存:

在这里插入图片描述

再重启,接口正常,但日志仍有报错NotSerializableException,这个就很明确了,Java对象存进缓存时,要转为json,而要存的对象的实体类没去实现序列化接口,实现下Serializable接口就行。

在这里插入图片描述
实现序列化接口后,别忘了要在配置中加:

valueEncoder: java      
valueDecoder: java    

即,编码时的是java对象,解码时,也要转汇Java对象。

5、@Cached

重新整理下@Cached注解,它的属性和@CreateCache的一样,但多了几个,放一起整理了:

属性默认值描述
areadefault如果在配置中配置了多个缓存area,在这里指定使用哪个area
name未定义($$undefined$$)指定缓存的唯一名称,不是必须的,如果没有指定,会使用类名+方法名。name会被用于远程缓存的key前缀。另外在统计中,一个简短有意义的名字会提高可读性。
key未定义使用SpEL来指定缓存的key值,如#id 、#p0
expire-2147483648过期时间
timeUnitTimeUnit.SECONDS过期时间的单位
cacheTypeCacheType.REMOTE缓存的类型,可选CacheType.REMOTE、CacheType.LOCAL、CacheType.BOTH。如果定义为BOTH,会使用LOCAL和REMOTE组合成两级缓存
localLimit-2147483648如果cacheType为LOCAL或BOTH,这个参数指定本地缓存的最大元素数量,以控制内存占用。如果注解上没有定义,会使用全局配置,如果此时全局配置也没有定义,则为100
localExpire-2147483648仅当cacheType为BOTH时适用,为内存中的Cache指定一个不一样的超时时间,通常应该小于expire
serialPolicy未定义指定远程缓存的序列化方式。可选值为SerialPolicy.JAVA和SerialPolicy.KRYO。如果注解上没有定义,会使用全局配置,如果此时全局配置也没有定义,则为SerialPolicy.JAVA
keyConvertor未定义指定KEY的转换方式,用于将复杂的KEY类型转换为缓存实现可以接受的类型,当前支持KeyConvertor.FASTJSON和KeyConvertor.NONE。NONE表示不转换,FASTJSON可以将复杂对象KEY转换成String。如果注解上没有定义,会使用全局配置
enabledtrue是否激活缓存。例如某个dao方法上加缓存注解,由于某些调用场景下不能有缓存,所以可以设置enabled为false,正常调用不会使用缓存,在需要的地方可使用CacheContext.enableCache在回调中激活缓存,缓存激活的标记在ThreadLocal上,该标记被设置后,所有enable=false的缓存都被激活
cacheNullValuefalse当方法返回值为null的时候是否要缓存
condition未定义使用SpEL指定条件,如果表达式返回true的时候才去缓存中查询
postCondition未定义使用SpEL指定条件,如果表达式返回true的时候才更新缓存,该评估在方法执行后进行,因此可以访问到#result

整体有点像@Cacheable注解。重点注意下area,一块一块的缓存区域。

4、@CacheUpdate

方法上加了@Cached后,方法返回值被写进缓存,但如果持久层被update,再查数据时。从缓存中拿到的数据就不对了,可通过在更新持久层的方法上加@CacheUpdate注解解决。先看这个注解属性:

属性默认值描述
areadefault缓存区域,注意和上面@Cached时所在的区域保持一致
namekey前缀,注意和上面@Cached时的name一致
key未定义SpEL表达式,根据当前方法的形参拼出@Cached时的key,如@Cached的方法形参为id,key为#id。而@CacheUpdate所在方法形参为Book对象book,则key为#book.id
value要更新的值
condition未定义使用SpEL指定条件,如果表达式返回true才执行更新,可访问方法结果#result
@Service
public class BookServiceImpl implements BookService {@CacheUpdate(name = "smsCache_", key = "#book.id", value = "#book")    public boolean update(Book book) {            return bookDao.updateById(book) > 0;       }}

对照上面的@Cached注解的key来看这个@CacheUpdate的key。此时,调用查询接口,返回更新后的数据,且不会查持久层,因为缓存已被更新,到不了持久层。

5、@CacheInvalidate

和更新一样,如果持久层数据被删除,如何通知到缓存呢,答案是@CacheInvalidate注解。

@Service
public class BookServiceImpl implements BookService {@CacheInvalidate(name = "smsCache_", key = "#id")    public boolean delete(Integer id) {        return bookDao.deleteById(id) > 0;    }
}

这样,当delete方法执行,持久层数据被删除时,缓存也就被删掉了。此时,调用查询接口,会去查持久层!!查持久层才合理,缓存里都没数据了,不去持久层看看停在缓存层干嘛 。这个注解属性和更新缓存注解一样,少了value,参照上文。

6、@CacheRefresh

以上,不管是更新还是删除,总在我的服务中,我自己掌握,我自己加了注解去通知缓存跟着变。但如果持久层更新的操作是在别的部门管理的服务里呢?即在缓存层无感知,如何保证数据最新,答案是@CacheRefresh,每隔一定间隔去查数据库,刷新缓存值。 先看注解属性:

属性默认值描述
refresh刷新间隔,谨慎设置,过小会导致查持久层频率太高,给数据库带来压力
timeUnitTimeUnit.SECONDS时间单位
stopRefreshAfterLastAccess-2147483648指定该key多长时间没有访问就停止刷新,如果不指定会一直刷新
refreshLockTimeout-2147483648类型为BOTH/REMOTE的缓存刷新时,同时只会有一台服务器在刷新,这台服务器会在远程缓存放置一个分布式锁,此配置指定该锁的超时时间

在这里插入图片描述
以上即,查到的Book对象缓存起来,且没10秒去数据库查一下,然后刷新缓存里的Book值

7、缓存统计报告

在服务配置文件application.yaml中加以下配置:

jetcache:statIntervalMinutes: 15# statInterval即统计间隔,也就是15分钟一统计

重启服务,控制台每隔15分钟输出一次统计数据,值为0时即不统计,(直接不写就行,不用写了又给个0值),效果如下:
在这里插入图片描述

查询26次,命中缓存21次。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/144170.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

STM32G070RBT6-MCU温度测量(ADC)

1、借助STM32CubeMX生成系统及外设相关初始化代码。 在以上配置后就可以生成相关初始化代码了。 /* ADC1 init function */ void MX_ADC1_Init(void) {/* USER CODE BEGIN ADC1_Init 0 *//* USER CODE END ADC1_Init 0 */ADC_ChannelConfTypeDef sConfig {0};/* USER COD…

【Linux】—— 详解软硬链接

前言&#xff1a; 本期&#xff0c;我将要给大家讲解的是有关 Linux下软硬链接的相关知识&#xff01;&#xff01;&#xff01; 目录 前言 &#xff08;一&#xff09;理解硬链接 1.什么是硬链接 2.创建硬链接 3.硬链接的使用场景 &#xff08;二&#xff09;理解软链接…

区块链(6):p2p去中心化介绍

1 互联网中中心化的服务和去中心化服务的概念介绍 目前的互联网公司大都是中心化的 区块链网络大多是去中心化的 去中心化 2 p2p的简单介绍 java 网络编程:socket编程,netty编程,websoket简单介绍 2.1 节点是如何提供服务的(web编程实现)

目标检测:FROD: Robust Object Detection for Free

论文作者&#xff1a;Muhammad,Awais,Weiming,Zhuang,Lingjuan,Lyu,Sung-Ho,Bae 作者单位&#xff1a;Sony AI; Kyung-Hee University 论文链接&#xff1a;http://arxiv.org/abs/2308.01888v1 内容简介&#xff1a; 1&#xff09;方向&#xff1a;目标检测 2&#xff09;…

jmeterbeanshell调用jsonpath获取对应值

1.jmeter 新建线程组、Java Request、BeanShell Assertion、View Results Tree 2、在BeanShell Assertion中贴入代码&#xff1a; import org.apache.jmeter.extractor.json.jsonpath.JSONManager; import java.util.List; JSONManager js new JSONManager(); String jsonStr…

Easysearch 压缩功能的显著提升:从 8.7GB 到 1.4GB

引言 在海量数据的存储和处理中&#xff0c;索引膨胀率是一个不可忽视的关键指标。它直接影响了存储成本和查询性能。近期&#xff0c;Easysearch 在这方面取得了显著的进展&#xff0c;其压缩功能的效果远超过了之前的版本。本文将详细介绍这一进展。 Easysearch 各版本压缩性…

广告牌安全监测系统,用科技护航大型广告牌安全

城市的街头巷尾&#xff0c;处处可见高耸的广告牌&#xff0c;它们以各种形式和颜色吸引着行人的目光。然而&#xff0c;作为城市景观的一部分&#xff0c;广告牌的安全性常常被我们所忽视。广告牌量大面大&#xff0c;由于设计、材料、施工方法的缺陷&#xff0c;加上后期的检…

No145.精选前端面试题,享受每天的挑战和学习

🤍 前端开发工程师(主业)、技术博主(副业)、已过CET6 🍨 阿珊和她的猫_CSDN个人主页 🕠 牛客高级专题作者、在牛客打造高质量专栏《前端面试必备》 🍚 蓝桥云课签约作者、已在蓝桥云课上架的前后端实战课程《Vue.js 和 Egg.js 开发企业级健康管理项目》、《带你从入…

多线程学习

并发&#xff1a;交替运行 并行&#xff1a;一起运行 多线程实现方式 继承Thread类 ①自己定义一个类继承Thread public class MyThread extends Thread{public void run(){}} ②重写run方法 public class MyThread extends Thread{public void run(){"重写的内容&…

基于Java的学生选课管理系统设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作…

umi4中的配置问题,我想用umirc.ts中alias配置没起作用。是我的用法不对吗?

在文件中直接配置是不生效的 alias: {: /src,components: /src/components,components: /src/components, },解决&#xff1a; 具体查看官方文档&#xff1a;https://umijs.org/docs/api/config#chainwebpack 配置之后&#xff0c;在页面中引用会有ts警告&#xff0c;原因在于…

云部署家里的服务器

1.固定静态ip 查看ip地址&#xff0c;en开头的 ifconfig查看路由器ip&#xff0c;via开头的 ip route修改配置文件 cd /etc/netplan/ #来到这个文件夹 sudo cp 01-network-manager-all.yaml 01-network-manager-all.yaml.bak #先备…

No142.精选前端面试题,享受每天的挑战和学习

🤍 前端开发工程师(主业)、技术博主(副业)、已过CET6 🍨 阿珊和她的猫_CSDN个人主页 🕠 牛客高级专题作者、在牛客打造高质量专栏《前端面试必备》 🍚 蓝桥云课签约作者、已在蓝桥云课上架的前后端实战课程《Vue.js 和 Egg.js 开发企业级健康管理项目》、《带你从入…

基于微信小程序的新闻发布平台小程序设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言系统主要功能&#xff1a;具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计…

SpringMVC 学习(八)整合SSM

10. 整合 SSM (1) 新建数据库 CREATE DATABASE SSM;USE SSM;DROP TABLE IF EXISTS BOOKS;CREATE TABLE BOOKS (BOOK_ID INT(10) NOT NULL AUTO_INCREMENT COMMENT 书ID,BOOK_NAME VARCHAR(100) NOT NULL COMMENT 书名,BOOK_COUNTS INT(11) NOT NULL COMMENT 数量,DETAIL VARCH…

科技云报道:大模型的阴面:无法忽视的安全隐忧

科技云报道原创。 在AI大模型的身上&#xff0c;竟也出现了“to be or not to be”问题。 争议是伴随着大模型的能力惊艳四座而来的&#xff0c;争议的核心问题在于安全。安全有两个方面&#xff0c;一个是大模型带来的对人类伦理的思考&#xff0c;一个是大模型本身带来的隐…

私有继承和虚函数私有化能用么?

源起 以前就知道private私有化声明关键字&#xff0c;和virtual虚函数关键字两者并不冲突&#xff0c;可以同时使用。 但是&#xff0c;它所表示的场景没有那么明晰&#xff0c;也觉得难以理解&#xff0c;直到近段时间遇到一个具体场景。 场景 借助ACE遇到的问题进行展示 …

(SAR)Sentinel-1影像自动下载

基于ASF网站提供的python代码&#xff0c;实现Sentinel-1影像的自动下载&#xff1b; 1、登录ASF网站 登录Sentinel-1影像ASF网站&#xff1a;https://search.asf.alaska.edu/&#xff1b; 点击网站最右侧Sign in图标&#xff0c;进行用户注册&#xff1b; 注册完用户之后&…

怒刷LeetCode的第19天(Java版)

目录 第一题 题目来源 题目内容 解决方法 方法一&#xff1a;遍历一次数组 方法二&#xff1a;贪心算法 方法三&#xff1a;双指针 第二题 题目来源 题目内容 解决方法 方法一&#xff1a;动态规划 方法二&#xff1a;贪婪算法 方法三&#xff1a;正则表达式 第…

使用不同尺寸的传感器拍照时,怎么保证拍出同样视场范围的照片?

1、问题背景 使用竞品机做图像效果对比时&#xff0c;我们通常都会要求拍摄的照片要视场范围一致&#xff0c;这样才具有可比性。之前我会考虑用同样焦距、同样分辨率的设备去拍照对比就可以了&#xff0c;觉得相机的视场范围只由镜头焦距来决定。 但如果对于不同尺寸的传感器…