Caffeine--缓存组件

Caffeine

  • 概念
  • 缓存
    • 手动加载
    • 自动加载
    • 手动异步加载
    • 自动异步加载
  • 驱逐策略
    • 基于容量
    • 基于时间
    • 基于引用
  • 移除
    • 显式移除

概念

Caffeine是一个基于Java8开发的提供了近乎最佳命中率的高性能的缓存库。与ConcurrentMap有点相似。最根本的区别是ConcurrentMap将会持有所有加入到缓存当中的元素,直到它们被从缓存当中手动移除。Caffeine的缓存Cache 通常会被配置成自动驱逐缓存中元素,以限制其内存占用。在某些场景下,LoadingCacheAsyncLoadingCache尤为重要。

Caffeine提供了灵活的构造器去创建一个拥有下列特性的缓存:
(1)自动加载元素到缓存当中,异步加载的方式也可供选择
(2)当达到最大容量的时候可以使用基于就近度和频率的算法进行基于容量的驱逐
(3)将根据缓存中的元素上一次访问或者被修改的时间进行基于过期时间的驱逐
(4)当向缓存中一个已经过时的元素进行访问的时候将会进行异步刷新
(5)key将自动被弱引用所封装
(6)value将自动被弱引用或者软引用所封装
(7)驱逐(或移除)缓存中的元素时将会进行通知
(8)写入传播到一个外部数据源当中
(9)持续计算缓存的访问统计指标

缓存

Caffeine提供了四种缓存添加策略:手动加载自动加载手动异步加载自动异步加载

手动加载

		Cache<String, String> cache = Caffeine.newBuilder().expireAfterWrite(10, TimeUnit.MINUTES).maximumSize(10000).build();// 查找一个缓存元素, 没有查找到的时候返回nullString s=cache.getIfPresent("xiaohei");// 查找缓存,如果缓存不存在则生成缓存元素,  如果无法生成则返回nulls= cache.get("xiaohei", k -> new String("啥也没有"));// 添加或者更新一个缓存元素cache.put("xiaohei1", new String());// 移除一个缓存元素cache.invalidate("xiaohei");

Cache 接口提供了显式搜索查找、更新和移除缓存元素的能力。
推荐使用cache.get(key, k -> value)操作来在缓存中不存在该key对应的缓存元素的时候进行计算生成并直接写入至缓存内,而当该key对应的缓存元素存在的时候将会直接返回存在的缓存值。一次 cache.put(key, value) 操作将会直接写入或者更新缓存里的缓存元素,在缓存中已经存在的该key对应缓存值都会直接被覆盖。也可以使用Cache.asMap()所暴露出来的ConcurrentMap的方法对缓存进行操作。

自动加载

LoadingCache<String, String> cache = Caffeine.newBuilder().maximumSize(10000).expireAfterWrite(10, TimeUnit.MINUTES).build(key -> new String("啥也没有"));
// 查找缓存,如果缓存不存在则生成缓存元素,  如果无法生成则返回nullString s = cache.get("xiaohei");
// 批量查找缓存,如果缓存不存在则生成缓存元素Map<String, String> map = cache.getAll(Arrays.asList(new String[]{"xiaohei1", "xiaohei2"}));

一个LoadingCache是一个Cache 附加上CacheLoader能力之后的缓存实现。默认情况下,在getAll 方法中,将会对每个不存在对应缓存的key调用一次CacheLoader.load来生成缓存元素。

手动异步加载

		AsyncCache<String, String> cache = Caffeine.newBuilder().expireAfterWrite(10, TimeUnit.MINUTES).maximumSize(10000).buildAsync();// 查找一个缓存元素, 没有查找到的时候返回nullCompletableFuture<String> graph = cache.getIfPresent("xiaohei");// 查找缓存元素,如果不存在,则异步生成graph = cache.get("xiaohei", k -> new String("xiaoheissss"));// 添加或者更新一个缓存元素cache.put("xiaobai", graph);// 移除一个缓存元素cache.synchronous().invalidate("xiaohei");

一个AsyncCache是Cache的一个变体,AsyncCache提供了在Executor上生成缓存元素并返回 CompletableFuture的能力。这给出了在当前流行的响应式编程模型中利用缓存的能力。
synchronous()方法给Cache提供了阻塞直到异步缓存生成完毕的能力。也可以使用 AsyncCache.asMap()所暴露出来的ConcurrentMap的方法对缓存进行操作。默认的线程池实现是 ForkJoinPool.commonPool() ,也可以通过覆盖并实现 Caffeine.executor(Executor)方法来自定义线程池选择。

自动异步加载

		AsyncLoadingCache<String, String> cache = Caffeine.newBuilder().maximumSize(10000).expireAfterWrite(10, TimeUnit.MINUTES)// 你可以选择: 去异步的封装一段同步操作来生成缓存元素.buildAsync(key -> new String(key));// 你也可以选择: 构建一个异步缓存元素操作并返回一个future
//                .buildAsync((key, executor) -> createExpensiveGraphAsync(key, executor));// 查找缓存元素,如果其不存在,将会异步进行生成CompletableFuture<String> graph = cache.get("xiaohei");
// 批量查找缓存元素,如果其不存在,将会异步进行生成CompletableFuture<Map<String, String>> graphs = cache.getAll(Arrays.asList(new String[]{"xiaohei1", "xiaohei2"}));

一个 AsyncLoadingCache是一个AsyncCache加上AsyncCacheLoader能力的实现。在需要同步的方式去生成缓存元素的时候,CacheLoader是合适的选择。而在异步生成缓存的场景下,AsyncCacheLoader则是更合适的选择并且它会返回一个 CompletableFuture。默认情况下,在getAll 方法中,将会对每个不存在对应缓存的key调用一次 AsyncCacheLoader.asyncLoad 来生成缓存元素。 可以通过实现一个 AsyncCacheLoader.asyncLoadAll并在其中为没有在参数中请求的key也生成对应的缓存元素。如果对应某个key生成的缓存元素与包含这个key的一组集合剩余的key所对应的元素一致,那么在asyncLoadAll中也可以同时加载剩下的key对应的元素到缓存当中。

驱逐策略

基于容量

Caffeine提供了三种驱逐策略,分别是基于容量,基于时间和基于引用三种类型。

// 基于缓存内的元素个数进行驱逐
LoadingCache<String, String> graphs = Caffeine.newBuilder().maximumSize(10000).build(key -> new String(key));
// 基于缓存内元素权重进行驱逐
LoadingCache<String, String> graphs = Caffeine.newBuilder().maximumWeight(10000).weigher((String s, String s1) -> s1.length()).build(key -> new String(key));

基于缓存内的元素个数进行驱逐策略中,使用Caffeine.maximumSize(long)。缓存将会尝试通过基于就近度和频率的算法来驱逐掉不会再被使用到的元素。
缓存中的元素可能有不同的内存占用–需要借助Caffeine.weigher(Weigher)方法来界定每个元素的权重并通过 Caffeine.maximumWeight(long)方法来界定缓存中元素的总权重来实现上述的场景。在基于权重驱逐的策略下,一个缓存元素的权重计算是在其创建和更新时,此后其权重值都是静态存在的,在两个元素之间进行权重的比较的时候,并不会根据进行相对权重的比较。

基于时间

// 基于固定的过期时间驱逐策略LoadingCache<String, String> graphs1 = Caffeine.newBuilder().expireAfterAccess(5, TimeUnit.MINUTES).build(key -> new String());LoadingCache<String, String> graphs2 = Caffeine.newBuilder().expireAfterWrite(10, TimeUnit.MINUTES).build(key -> new String());// 基于不同的过期驱逐策略LoadingCache<String, String> graphs = Caffeine.newBuilder().expireAfter(new Expiry<String, String>() {@Overridepublic long expireAfterCreate(@NonNull String s, @NonNull String s2, long l) {return 0;}@Overridepublic long expireAfterUpdate(@NonNull String s, @NonNull String s2, long l, @NonNegative long l1) {return 0;}@Overridepublic long expireAfterRead(@NonNull String s, @NonNull String s2, long l, @NonNegative long l1) {return 0;}}).build(key -> new String());

expireAfterAccess(long, TimeUnit): 一个元素在上一次读写操作后一段时间之后,在指定的时间后没有被再次访问将会被认定为过期项。在当被缓存的元素时被绑定在一个session上时,当session因为不活跃而使元素过期的情况下,这是理想的选择。
expireAfterWrite(long, TimeUnit): 一个元素将会在其创建或者最近一次被更新之后的一段时间后被认定为过期项。在对被缓存的元素的时效性存在要求的场景下,这是理想的选择。
expireAfter(Expiry): 一个元素将会在指定的时间后被认定为过期项。当被缓存的元素过期时间收到外部资源影响的时候,这是理想的选择。

基于引用

		// 当key和缓存元素都不再存在其他强引用的时候驱逐LoadingCache<String, String> graphs1 = Caffeine.newBuilder().weakKeys().weakValues().build(key -> new String());// 当进行GC的时候进行驱逐LoadingCache<String, String> graphs2 = Caffeine.newBuilder().softValues().build(key -> new String());

Caffeine 允许去让GC去帮助清理缓存当中的元素,其中key支持弱引用,而value则支持弱引用和软引用。AsyncCache不支持软引用和弱引用。
Caffeine.weakKeys():在保存key的时候将会进行弱引用。这允许在GC的过程中,当key没有被任何强引用指向的时候去将缓存元素回收。由于GC只依赖于引用相等性。这导致在这个情况下,缓存将会通过引用相等(==)而不是对象相等 equals()去进行key之间的比较。

Caffeine.weakValues():在保存value的时候将会使用弱引用。这允许在GC的过程中,当value没有被任何强引用指向的时候去将缓存元素回收。由于GC只依赖于引用相等性。这导致在这个情况下,缓存将会通过引用相等(==)而不是对象相等 equals()去进行value之间的比较。

Caffeine.softValues():在保存value的时候将会使用软引用。为了相应内存的需要,在GC过程中被软引用的对象将会被通过LRU算法回收。由于使用软引用可能会影响整体性能,我们还是建议通过使用基于缓存容量的驱逐策略代替软引用的使用。同样的,使用 softValues() 将会通过引用相等(==)而不是对象相等equals()去进行value之间的比较。

移除

驱逐:缓存元素因为策略被移除
失效:缓存元素被手动移除
移除:由于驱逐或者失效而最终导致的结果

显式移除

可以手动去让某个缓存元素失效而不是只能等待其因为策略而被驱逐。

// 失效key
cache.invalidate("小黑");
// 批量失效key
cache.invalidateAll(Arrays.asList(new String[]{"xiaohei1", "xiaohei2"}));
// 失效所有的key
cache.invalidateAll();

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

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

相关文章

Three.js基础入门介绍——Three.js学习三【借助控制器操作相机】

在Three.js基础入门介绍——Three.js学习二【极简入门】中介绍了如何搭建Three.js开发环境并实现一个包含旋转立方体的场景示例&#xff0c;以此为前提&#xff0c;本篇将引进一个控制器的概念并使用”轨道控制器”&#xff08;OrbitControls&#xff09;来达到从不同方向展示场…

【Java基础系列】equals方法使用与总结

&#x1f49d;&#x1f49d;&#x1f49d;欢迎来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里可以感受到一份轻松愉快的氛围&#xff0c;不仅可以获得有趣的内容和知识&#xff0c;也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…

网络IP地址如何更改?怎么使用动态代理IP提高网速?

网络IP地址更改以及使用动态代理IP提高网速的步骤如下&#xff1a; 一、更改IP地址 1. 打开浏览器&#xff0c;输入路由器登陆地址并登陆路由器后台管理界面。 2. 找到“高级设置”或“无线设置”或“VPN设置”一栏&#xff0c;点击“断开”&#xff0c;即可断开网络&#xff0…

RDD键值对的应用——一个简单的例子对比用与不用键值对的差别

有关RDD编程&#xff08;Python版&#xff09;的基础操作可参考&#xff1a;spark&#xff1a;RDD编程&#xff08;Python版&#xff09; 初看题目 先来看一道比较简单的用 pyspark交互式环境的编程题目&#xff1a; 该数据集包含了某大学计算机系的成绩&#xff0c;数据格…

CamSim相机模拟器:极大加速图像处理开发与验证过程

随着图像处理技术的不断发展&#xff0c;相机模拟在图像处理开发和验证中扮演着越来越重要的角色。相机模拟能够模拟真实相机的成像过程&#xff0c;提供高质量的图像输入&#xff0c;使开发人员能够更好地评估和调整图像处理算法。本文将探讨如何通过相机模拟来加速图像处理的…

Docker的基础使用

Docker的基础使用 Docker 是一个开放平台&#xff0c;用于开发、运输和运行应用程序。Docker 允许你将应用程序与基础架构分离&#xff0c;从而可以像管理应用程序一样快速交付软件。以下是 Docker 的详细使用指南&#xff1a; 安装 Docker 下载 Docker : 根据你的操作系统…

vue实现H5拖拽可视化编辑器

一款专注可视化平台工具&#xff0c;功能强大&#xff0c;高可扩展的HTML5可视化编辑器&#xff0c;致力于提供一套简单易用、高效创新、无限可能的解决方案。技术栈采用vue和typescript开发, 专注研发创新工具。 <template><div:style"style":class"…

MYSQL数据库的安全管理-数据库实验六

Mysql数据库实验及练习题相关 MySQL 数据库和表的管理-数据库实验一 MySQL连接查询、索引、视图-数据库实验二、实验三 MySQL约束、触发器-数据库实验四 MYSQL存储过程和存储函数-数据库实验五 MySQL批量随机生成name、TEL、idNumber MYSQL数据库的安全管理-数据库实验六 MYSQ…

msvcr120.dll丢失的解决方法

msvcr120.dll丢失的解决方法 大家好&#xff0c;我是免费搭建查券返利机器人赚佣金就用微赚淘客系统3.0的小编&#xff0c;也是冬天不穿秋裤&#xff0c;天冷也要风度的程序猿&#xff01;今天&#xff0c;我将为大家分享一个常见但可能令人头痛的问题的解决方法——“msvcr12…

<JavaEE> TCP 的通信机制(二) -- 连接管理(三次握手和四次挥手)

目录 TCP的通信机制的核心特性 三、连接管理 1&#xff09;什么是连接管理&#xff1f; 2&#xff09;“三次握手”建立连接 1> 什么是“三次握手”&#xff1f; 2> “三次握手”的核心作用是什么&#xff1f; 3&#xff09;“四次挥手”断开连接 1> 什么是“…

【JavaWeb】函数式接口(学习笔记)

一、函数式接口概述 定义&#xff1a;有且只有一个抽象方法 注解&#xff1a;FunctionalInterface 函数式接口作为参数&#xff1a;Lambda表达式作为参数传递 函数式接口作为返回值&#xff1a;Lambda表达式作为结果返回 二、Supplier接口 Supplier<T>&#xff1a;…

Ubuntu安装WordPress并使用Nginx作为Web服务器

在Ubuntu上安装和配置WordPress并使用Nginx作为Web服务器&#xff0c;以下是一个简单的操作流程&#xff1a; 步骤 1: 安装Nginx bashCopy code sudo apt update sudo apt install nginx 启动Nginx并设置开机自启&#xff1a; sudo systemctl start nginx sudo systemctl e…

第2课 用FFmpeg读取rtmp流并显示视频

这节课我们开始利用ffmpeg和opencv来实现一个rtmp播放器。播放器的最基本功能其实就两个:显示画面和播放声音。在实现这两个功能前&#xff0c;我们需要先用ffmpeg连接到rtmp服务器&#xff0c;当然也可以打开一个文件。 1.压缩备份上节课工程文件夹为demo.rar&#xff0c;并修…

版权登记是怎么个流程?都需要准备些什么材料?

版权登记是指按照规定的程序和条件&#xff0c;向版权局或相关机构提交申请&#xff0c;对作品进行登记和记录的过程。版权登记是一种法律手段&#xff0c;旨在保护创作者的权益和作品的完整性&#xff0c;防止盗版和侵权行为。 版权登记的申请范围包括但不限于文字作品、口述…

ZETA落地合肥、宜城南方水泥,纵行科技携手中才邦业助力水泥企业数智化管理

近日&#xff0c;合肥南方水泥、宜城南方水泥落地ZETA预测性维护方案&#xff0c;通过在水泥厂内搭建ZETA网络&#xff0c;并在B类及C类主辅机设备上安装ZETA系列端智能传感器&#xff0c;进行数据采集和监测设备运行状态、以及早期故障警报和诊断&#xff0c;实现水泥生产设备…

web期末大作业--网页设计 HTML+CSS+JS(附源码)

目录 一&#xff0c;作品介绍 二.运用知识 三.作品详情 四.部分作品效果图 我的&#xff1a;​编辑 五.部分源代码 六.文件目录 七.源码 一&#xff0c;作品介绍 作品介绍&#xff1a;该作品是一个是一个关于影视作品的网页&#xff0c;一共有五个页面&#xff0c;主页&a…

文件IO

文章目录 文章目录 前言 一 . 文件 文件路径 文件类型 Java中操作文件 File 概述 属性 构造方法 方法 createNewFile mkdir 二 . 文件内容的读写 - IO InputStream 概述 FileInputStream 概述 利用 Scanner 进行字符读取 OutputStream 概述 PrintWriter封装O…

gin框架使用系列之五——表单校验

系列目录 《gin框架使用系列之一——快速启动和url分组》《gin框架使用系列之二——uri占位符和占位符变量的获取》《gin框架使用系列之三——获取表单数据》《gin框架使用系列之四——json和protobuf的渲染》 一 、表单验证的基本理论 在第三篇中&#xff0c;我们介绍了如何…

SpringIOC-注解式

IOC操作Bean管理(基于注解方式) 1.什么是注解(1)注解是代码的特殊标记, 格式 注解名(属性名值,属性2值2)(2)使用注解,注解作用在 类上面,方法上,属性上(3)使用注解目的: 简化xml配置2.spring针对bean 管理中创建对象提供注解(1) Component (2) Service(3) Controller(4) Repo…

Flink1.17实战教程(第四篇:处理函数)

系列文章目录 Flink1.17实战教程&#xff08;第一篇&#xff1a;概念、部署、架构&#xff09; Flink1.17实战教程&#xff08;第二篇&#xff1a;DataStream API&#xff09; Flink1.17实战教程&#xff08;第三篇&#xff1a;时间和窗口&#xff09; Flink1.17实战教程&…