Spring Cache Caffeine 高性能缓存库

请在此添加图片描述

​

Caffeine 背景

Caffeine是一个高性能的Java缓存库，它基于Guava Cache进行了增强，提供了更加出色的缓存体验。Caffeine的主要特点包括：

高性能：Caffeine使用了Java 8最新的StampedLock乐观锁技术，极大地提高了缓存的并发吞吐量，使其成为一个高性能的Java缓存库。

内存友好：Caffeine支持自动驱逐缓存中的元素，以限制其内存占用。它还提供了灵活的构造器，可以创建具有不同特性的缓存，如自动加载元素、基于容量的驱逐、基于过期时间的驱逐等。

可扩展性强：Caffeine支持 JSR-107 - JCache_（Java临时缓存API (JSR-107)，也称为JCache，是定义javax.cache API的规范。 该规范是在Java社区流程下开发的，其目的是为Java应用程序提供标准化的缓存概念和机制。 API使用简单，它被设计为缓存标准，是供应商中立的。）_和Guava适配器，提高了与其他缓存库和框架的集成度。

事件监听和多种过期策略：Caffeine提供了事件监听和多种过期策略，可以更好地优化和管理数据的缓存。这些功能不仅可以提升系统的性能表现，也能够有效地降低对底层资源的压力。

本地缓存：Caffeine是一个基于Java 8开发的提供了近乎最佳命中率的高性能缓存库。可以说是目前最优秀的本地缓存。

总之，Caffeine是一个功能强大、性能卓越的Java缓存库，适用于各种需要缓存的应用场景。

Caffeine 主要特点

Caffeine 是一个高性能的 Java 缓存库，它的主要特点包括：

  1. 速度：Caffeine 的性能非常高，它的速度通常比 ConcurrentHashMap 快很多。Caffeine 使用了高效的数据结构和并发算法，以及一些优化手段，如无锁操作、缓存行填充等，来提高性能。
  2. 自动垃圾回收：Caffeine 支持基于访问时间和写入时间的自动垃圾回收。当缓存中的数据超过了设定的过期时间，Caffeine 会自动将其从缓存中移除。
  3. 基于大小的回收：Caffeine 支持基于缓存大小的回收策略。当缓存中的数据量超过了设定的最大值，Caffeine 会自动回收最近最少使用的数据。
  4. 定时回收：Caffeine 支持定时回收策略，可以设置缓存中的数据在一定时间后被强制回收。
  5. 缓存统计：Caffeine 提供了丰富的缓存统计信息，如命中率、缓存大小等，帮助开发者了解缓存的使用情况。
  6. 灵活的配置：Caffeine 提供了丰富的配置选项，允许开发者根据需要定制缓存的行为。例如，可以设置缓存的最大大小、过期时间、回收策略等。
  7. 扩展性：Caffeine 支持自定义缓存实现，开发者可以根据需要扩展 Caffeine 的功能。
  8. 与 Spring Cache 集成：Caffeine 可以很容易地与 Spring Cache 集成，使得在 Spring 项目中使用缓存变得更加简单。
  9. 无阻塞操作：Caffeine 的大部分操作都是无阻塞的，这意味着它可以在高并发环境下提供更好的性能。
  10. 轻量级：Caffeine 是一个轻量级的库，它的依赖非常少，不会给项目带来额外的负担。

这些特点使得 Caffeine 成为了一个非常受欢迎的 Java 缓存库，尤其是在需要高性能和灵活配置的场景中。如果你正在寻找一个高性能的 Java 缓存库，Caffeine 值得一试。

更多关于 Caffeine 和 Spring Cache 的信息，可以查阅官方文档：

  • Caffeine: https://github.com/ben-manes/caffeine/wiki
  • Spring Cache: https://docs.spring.io/spring-framework/docs/current/reference/html/integration.html__#cache

Caffeine 使用

Spring Cache 是 Spring 框架提供的一个缓存抽象，它允许开发者通过注解的方式轻松地使用缓存。Caffeine 是一个高性能的 Java 缓存库，它提供了诸如自动垃圾回收、基于大小的回收、定时回收等功能。

要在 Spring 中使用 Caffeine 作为缓存实现，需执行以下步骤：

添加依赖

在你的项目中，添加 Caffeine 和 Spring Cache 的依赖。可以在 pom.xml 文件中添加以下依赖：

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<dependency>
   <groupId>com.github.ben-manes.caffeine</groupId>
   <artifactId>caffeine</artifactId>
</dependency>

配置 Caffeine

在你的 Spring Boot 配置类中，配置 Caffeine 缓存管理器：

创建了一个 CaffeineCacheManager Bean，并设置了 Caffeine 的一些基本属性，如过期时间和最大缓存大小。

import com.github.benmanes.caffeine.cache.Caffeine;
import org.springframework.cache.CacheManager;
import org.springframework.cache.caffeine.CaffeineCacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.TimeUnit;

@Configuration
public class CaffeineConfig {

    @Bean
    public CacheManager cacheManager() {
        CaffeineCacheManager cacheManager = new CaffeineCacheManager();
        cacheManager.setCaffeine(Caffeine.newBuilder()
                .expireAfterWrite(60, TimeUnit.SECONDS)
                .maximumSize(100));
        return cacheManager;
    }
}

可以在你的服务类中使用 Spring Cache 的注解来缓存数据。

我们使用了 @Cacheable 注解来缓存 getUserById 方法的结果。当方法被调用时，Spring 会先检查缓存中是否存在该用户，如果存在则直接返回缓存中的数据，否则才会调用方法并将结果存入缓存。例如：

import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    @Cacheable(value = "users", key = "#id")
    public User getUserById(Long id) {
        // 模拟从数据库中获取用户数据
        return new User(id, "User " + id);
    }
}

多个缓存区域

在 Caffeine 中，你可以配置多个缓存区域，每个区域都有自己的配置和缓存数据。要配置多个缓存区域，你需要为每个区域创建一个 Cache 实例，并为它们分别配置。

以下是一个使用 Spring Boot 和 Caffeine 配置多个缓存区域的例子：

配置缓存区域

在你的 Spring Boot 配置类中，配置多个缓存区域：我们创建了一个 SimpleCacheManager Bean，并为其配置了两个缓存区域。每个缓存区域都有自己的名称、过期时间和最大缓存大小。

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.caffeine.CaffeineCache;
import org.springframework.cache.support.SimpleCacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

@Configuration
@EnableCaching
public class CaffeineConfig {

    @Bean
    public CacheManager cacheManager() {
        SimpleCacheManager cacheManager = new SimpleCacheManager();
        List<CaffeineCache> caches = new ArrayList<>();

        // 配置第一个缓存区域
        Cache<Object, Object> cache1 = Caffeine.newBuilder()
                .expireAfterWrite(60, TimeUnit.SECONDS)
                .maximumSize(100)
                .build();
        caches.add(new CaffeineCache("cache1", cache1));

        // 配置第二个缓存区域
        Cache<Object, Object> cache2 = Caffeine.newBuilder()
                .expireAfterWrite(30, TimeUnit.SECONDS)
                .maximumSize(50)
                .build();
        caches.add(new CaffeineCache("cache2", cache2));

        cacheManager.setCaches(caches);
        return cacheManager;
    }
}

使用缓存区域

在你的服务类中使用 Spring Cache 的注解来缓存数据，并指定要使用的缓存区域：我们使用了 @Cacheable 注解来缓存 getUserByIdFromCache1 和 getUserByIdFromCache2 方法的结果，并分别指定了不同的缓存区域。

import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

@Service
public class UserService {

    @Cacheable(value = "cache1", key = "#id")
    public User getUserByIdFromCache1(Long id) {
        // 模拟从数据库中获取用户数据
        return new User(id, "User " + id);
    }

    @Cacheable(value = "cache2", key = "#id")
    public User getUserByIdFromCache2(Long id) {
        // 模拟从数据库中获取用户数据
        return new User(id, "User " + id);
    }
}

Caffeine 常见机制

Notification on Eviction

Caffeine 提供了一种机制，允许你在缓存项被回收时接收通知，这被称为 “Notification on Eviction”。使用 removalListener 方法注册一个回调函数。当缓存项被回收时，这个回调函数会被调用。

以下是一个使用 Caffeine 的 “Notification on Eviction” 的例子：我们创建了一个 Caffeine 缓存，并使用 removalListener 方法注册了一个回调函数。当缓存项被回收时，这个回调函数会被调用，并打印出被回收的缓存项的键、值和回收原因。

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.RemovalCause;
import com.github.benmanes.caffeine.cache.RemovalListener;

import java.util.concurrent.TimeUnit;

public class CaffeineNotificationOnEvictionExample {

    public static void main(String[] args) throws InterruptedException {
        RemovalListener<String, String> removalListener = (key, value, cause) -> {
            System.out.println("Key: " + key + ", Value: " + value + ", Cause: " + cause);
        };

        Cache<String, String> cache = Caffeine.newBuilder()
                .expireAfterWrite(1, TimeUnit.MINUTES)
                .maximumSize(100)
                .removalListener(removalListener)
                .build();

        cache.put("key1", "value1");
        cache.put("key2", "value2");

        // 等待一段时间，让缓存项过期
        Thread.sleep(60 * 1000);

        // 清理缓存
        cache.cleanUp();
    }
}

需要注意，“Notification on Eviction” 只在缓存项被主动回收时触发，而不是在缓存项被读取或写入时触发。

此外，“Notification on Eviction” 并不保证在所有情况下都能接收到通知，例如在缓存关闭或应用程序退出时，可能无法接收到通知。因此，在使用 “Notification on Eviction” 时，需要考虑到这些因素。

Cleanup

Caffeine 提供了一种机制，允许你手动触发缓存的清理操作，这被称为 “Cleanup”。使用 cleanUp 方法注册一个回调函数。当需要清理缓存时，可以调用 cleanUp 方法来触发回调函数。

以下是一个使用 Caffeine 的 “Cleanup” 的例子：我们创建了一个 Caffeine 缓存，并使用 removalListener 方法注册了一个回调函数。当缓存项被回收时，这个回调函数会被调用，并打印出被回收的缓存项的键、值和回收原因。

在这个例子中，我们使用 cleanUp 方法手动触发了缓存的清理操作。这会导致所有过期的缓存项被回收，并触发回调函数。

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.RemovalCause;
import com.github.benmanes.caffeine.cache.RemovalListener;

import java.util.concurrent.TimeUnit;

public class CaffeineCleanupExample {

    public static void main(String[] args) throws InterruptedException {
        RemovalListener<String, String> removalListener = (key, value, cause) -> {
            System.out.println("Key: " + key + ", Value: " + value + ", Cause: " + cause);
        };

        Cache<String, String> cache = Caffeine.newBuilder()
                .expireAfterWrite(1, TimeUnit.MINUTES)
                .maximumSize(100)
                .removalListener(removalListener)
                .build();

        cache.put("key1", "value1");
        cache.put("key2", "value2");

        // 等待一段时间，让缓存项过期
        Thread.sleep(60 * 1000);

        // 手动触发缓存清理
        cache.cleanUp();
    }
}

需要注意，“Cleanup” 并不保证在所有情况下都能清理缓存。例如，在缓存关闭或应用程序退出时，可能无法清理缓存。因此，在使用 “Cleanup” 时，需要考虑到这些因素。

Enable Statistics

Caffeine 提供了一种机制，允许你启用缓存的统计信息收集功能，这被称为 “Enable Statistics”。在创建 Caffeine 缓存时，使用 recordStats 方法启用统计信息收集功能。启用统计信息收集功能后，使用 stats 方法获取缓存的统计信息。

以下是一个使用 Caffeine 的 “Enable Statistics” 的例子：我们创建了一个 Caffeine 缓存，并使用 recordStats 方法启用了统计信息收集功能。在缓存中添加了两个缓存项后，我们等待了一段时间，让缓存项过期。然后，我们使用 stats 方法获取了缓存的统计信息，并将其打印出来。

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.stats.CacheStats;

import java.util.concurrent.TimeUnit;

public class CaffeineEnableStatisticsExample {

    public static void main(String[] args) throws InterruptedException {
        Cache<String, String> cache = Caffeine.newBuilder()
                .expireAfterWrite(1, TimeUnit.MINUTES)
                .maximumSize(100)
                .recordStats()
                .build();

        cache.put("key1", "value1");
        cache.put("key2", "value2");

        // 等待一段时间，让缓存项过期
        Thread.sleep(60 * 1000);

        // 获取缓存的统计信息
        CacheStats stats = cache.stats();
        System.out.println("Cache Stats: " + stats);
    }
}

需要注意，启用统计信息收集功能会增加缓存的开销，因此在生产环境中使用时需要谨慎。在开发和测试环境中，启用统计信息收集功能可以帮助你更好地了解缓存的使用情况，从而优化缓存的配置和使用。

​

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

多模态大语言模型（MLLM）-Deepseek Janus

多模态大语言模型（MLLM）-Deepseek Janus

论文链接&#xff1a;https://arxiv.org/abs/2410.13848 代码链接&#xff1a;https://github.com/deepseek-ai/Janus 本次解读Janus: Decoupling Visual Encoding for Unified Multimodal Understanding and Generation 前言 Deepseek出品&#xff0c;必属精品。 创新点 传…
阅读更多...
Redis学习笔记（二）--Redis的安装与配置

Redis学习笔记（二）--Redis的安装与配置

文章目录 一、Redis的安装1、克隆并配置主机2、安装前的准备工作1.安装gcc2.下载Redis3.上传到Linux 3、安装Redis1.解压Redis2.编译3.安装3.查看bin目录 4、Redis启动与停止1.前台启动2.命令式后台启动3.Redis的停止4.配置式后台启动 二、连接前的配置1、绑定客户端IP2、关闭保…
阅读更多...
使用 Elasticsearch 作为向量数据库询问有关你的 GitHub 存储库的问题

使用 Elasticsearch 作为向量数据库询问有关你的 GitHub 存储库的问题

作者&#xff1a;来自 Elastic Fram Souza 本博客介绍了使用 RAG 和 Elasticsearch 实现语义代码查询的 GitHub Assistant&#xff0c;提供对 GitHub 存储库的洞察&#xff0c;并可扩展到 PR 反馈、问题处理和生产准备情况审查。 该项目允许你直接与 GitHub 存储库交互并利用语…
阅读更多...
xlsx xlsx-style-vite 实现前端根据element 表格导出excel且定制化样式 背景 列宽等

xlsx xlsx-style-vite 实现前端根据element 表格导出excel且定制化样式 背景 列宽等

前言 先看下最终效果图吧&#xff0c;需要的可以参考我的实现方式 这是最终导出的表格文件 类似这种的&#xff0c;特定单元格需要额外标注&#xff0c;表头也有月份然后细分的&#xff0c;表格组件是这样的 注意 别使用xlsx-style 这个库&#xff0c;太多问题了&#xff0c;…
阅读更多...
如何选择云主机或者VPS挂EA？

如何选择云主机或者VPS挂EA？

近年来&#xff0c;随着EA交易在零售外汇圈的逐渐流行&#xff0c;越来越多的交易者开始使用外汇VPS&#xff08;虚拟专用服务器&#xff09;来挂载EA&#xff08;智能交易系统&#xff09;进行交易。通过外汇VPS&#xff0c;可以最大程度地减少MT4客户终端与MT4服务器之间的延…
阅读更多...
多特征变量序列预测(四) Transformer-BiLSTM风速预测模型

多特征变量序列预测(四) Transformer-BiLSTM风速预测模型

往期精彩内容&#xff1a; 时序预测&#xff1a;LSTM、ARIMA、Holt-Winters、SARIMA模型的分析与比较 全是干货 | 数据集、学习资料、建模资源分享&#xff01; EMD、EEMD、FEEMD、CEEMD、CEEMDAN的区别、原理和Python实现&#xff08;一&#xff09;EMD-CSDN博客 EMD、EEM…
阅读更多...
【模型部署】python中socket编程入门知识-系列1

【模型部署】python中socket编程入门知识-系列1

写在前面&#xff1a; 首先感谢兄弟们的订阅&#xff0c;让我有创作的动力&#xff0c;在创作过程我会尽最大能力&#xff0c;保证作品的质量&#xff0c;如果有问题&#xff0c;可以私信我&#xff0c;让我们携手共进&#xff0c;共创辉煌。 路虽远&#xff0c;行则将至&#…
阅读更多...
[实时计算flink]基于Paimon的数据库实时入湖快速入门

[实时计算flink]基于Paimon的数据库实时入湖快速入门

Apache Paimon是一种流批统一的湖存储格式&#xff0c;支持高吞吐的写入和低延迟的查询。本文通过Paimon Catalog和MySQL连接器&#xff0c;将云数据库RDS中的订单数据和表结构变更导入Paimon表中&#xff0c;并使用Flink对Paimon表进行简单分析。 背景信息 Apache Paimon是一…
阅读更多...
深度学习之梯度下降法 | Chapter 2 | Deep Learning | 3Blue1Brown

深度学习之梯度下降法 | Chapter 2 | Deep Learning | 3Blue1Brown

目录 前言1. 总览2. 回顾3. 训练数据的使用4. 代价函数5. 梯度下降法6. 梯度向量7. 梯度下降小结8. 分析网络9. 网络如何学习的研究相关资料结语 前言 3Blue1Brown 视频笔记&#xff0c;仅供自己参考 这个章节主要介绍梯度下降的思想&#xff0c;之后进一步探索网络的能力以及隐…
阅读更多...
助农贷款、保险精准定价，背后的“星绽”机密计算全球开源

助农贷款、保险精准定价，背后的“星绽”机密计算全球开源

文&#xff5c;白 鸽 编&#xff5c;王一粟 河南平顶山种植日本引进白草莓的李朝阳&#xff0c;和山东临沂种植山楂和桃子的李东旭&#xff0c;都是网商银行“农户秒贷”项目的受益者。 “发果农工资&#xff0c;收购水果&#xff0c;遇上天气灾害时周转应急时&#xff0c;“…
阅读更多...
E/MicroMsg.SDK.WXMediaMessage:checkArgs fail,thumbData is invalid 图片资源太大导致分享失败

E/MicroMsg.SDK.WXMediaMessage:checkArgs fail,thumbData is invalid 图片资源太大导致分享失败

1、微信分享报&#xff1a; 2、这个问题是因为图片太大导致&#xff1a; WXWebpageObject webpage new WXWebpageObject();webpage.webpageUrl qrCodeUrl;//用 WXWebpageObject 对象初始化一个 WXMediaMessage 对象WXMediaMessage msg new WXMediaMessage(webpage);msg.tit…
阅读更多...
MySQL-12.DQL-条件查询

MySQL-12.DQL-条件查询

一.DQL-条件查询 -- DQL:条件查询 -- 1.查询 姓名 为 杨逍 的员工 select id, username, password, name, gender, image, job, entrydate, create_time, update_timefrom tb_emp where name 杨逍;-- 2.查询 id小于等于5 的员工信息 select * from tb_emp where id < 5;-…
阅读更多...
Flutter 小技巧之 equatable 包解析以及宏编程解析

Flutter 小技巧之 equatable 包解析以及宏编程解析

今天我们聊聊 equatable 包的实现&#xff0c;并通过 equatable 去理解 Dart 宏编程的作用和实现&#xff0c;对于 Flutter 开发者来说&#xff0c;Dart 宏编程可以说是「望眼欲穿」。 equatable 正如 equatable 这个包名所示&#xff0c;它的功能很简单&#xff0c;主要是用…
阅读更多...
LeetCode 热题100之双指针

LeetCode 热题100之双指针

1.移动零 思路分析1&#xff08;纯模拟&#xff09; 定义指针j&#xff0c;用来收集不是0的数&#xff1b;收集完毕之后&#xff0c;再把剩下位置处置为0即可。 具体实现代码&#xff08;详解版&#xff09;&#xff1a; class Solution { public:void moveZeroes(vector<…
阅读更多...
前端vue框架配置基础信息详解分析

前端vue框架配置基础信息详解分析

前端vue2、vue3框架是我们最近常用的框架&#xff0c;今天我们分析一下配置基础信息、详解其中的功能含义。 1、vue.config.js 文件分析 这个 vue.config.js 文件是 Vue CLI 项目中用于配置项目构建行为和开发环境设置的文件。它能够让开发者定制打包、代理、路径、样式等方面…
阅读更多...
国产单片机及其特点

国产单片机及其特点

国产单片机在近年来取得了显著的发展&#xff0c;不仅在技术上不断突破&#xff0c;还在市场上占据了越来越重要的位置。 主要国产单片机品牌及特点 兆易创新&#xff08;GD&#xff09; 主要系列&#xff1a;GD32系列&#xff0c;基于ARM Cortex-M内核。特点&#xff1a;高性能…
阅读更多...
Android 中的串口开发

Android 中的串口开发

一&#xff1a;背景 本文着重讲安卓下的串口。 由于开源的Android在各种智能设备上的使用越来越多&#xff0c;如车载系统等。在我们的认识中&#xff0c;Android OS的物理接口一般只有usb host接口和耳机接口&#xff0c;但其实安卓支持各种各样的工业接口&#xff0c;如HDM…
阅读更多...
ResNet18果蔬图像识别分类

ResNet18果蔬图像识别分类

1. 项目简介 本项目的目标是开发一个基于ResNet18深度学习模型的果蔬图像分类系统。随着现代农业与人工智能的结合&#xff0c;智能果蔬分类技术在供应链、生产和销售管理中扮演了越来越重要的角色。本项目的背景源于提升果蔬分类效率的需求&#xff0c;通过使用计算机视觉技术…
阅读更多...
基于SSM+微信小程序的酒店管理系统1

基于SSM+微信小程序的酒店管理系统1

&#x1f449;文末查看项目功能视频演示获取源码sql脚本视频导入教程视频 1、项目介绍 基于微信小程序开发的酒店管理系统管理员&#xff0c;酒店管理员以及用户。 1、管理员功能可以管理个人中心&#xff0c;用户信息管理&#xff0c;酒店管理员管理&#xff0c;房间类型管…
阅读更多...
YOLO11改进 | 注意力机制 | 添加SE注意力机制

YOLO11改进 | 注意力机制 | 添加SE注意力机制

秋招面试专栏推荐 &#xff1a;深度学习算法工程师面试问题总结【百面算法工程师】——点击即可跳转 &#x1f4a1;&#x1f4a1;&#x1f4a1;本专栏所有程序均经过测试&#xff0c;可成功执行&#x1f4a1;&#x1f4a1;&#x1f4a1; 本文介绍了YOLOv11添加SE注意力机制&…
阅读更多...
最新文章

Copyright @ 2022~2023