Spring Cache缓存技术的介绍

缓存用于提升系统的性能，特别适用于一些对资源需求比较高的操作。本文介绍如何基于spring boot cache技术，使用caffeine作为具体的缓存实现，对操作的结果进行缓存。

demo场景

本demo将创建一个web应用，提供两个Rest接口。一个接口用于接受查询请求，并有条件的缓存查询结果。另一个接口用于获取所有缓存的数据，用于监控缓存的内部状态。

使用postman调用查询接口

可以看到这次查询耗时3秒左右。

使用postman调用获取缓存的接口

可以看到我们的查询结果已被缓存。这里将一次查询的结果缓存了两份，具体技术细节后面介绍。

接下来介绍具体demo的实现过程。

demo实现

本demo已经上传到github，读者可以在github上获取源码。

本demo使用Maven作为项目构建工具。按照作者的日常编程习惯，首先创建了一个root module，用于统一管理依赖。具体的功能在子module caffeine-cache中。

本demo的代码结构如下：

demo-spring-cache/
  |- pom.xml
  L caffeine-cache/
      |- pom.xml
      L src/
          L main/
              |- java/
              |   L heyikan
              |       |- Application.yml
              |       |- QueryController.java
              |       L QueryService.java
              L resources/
                  L application.yml

创建root module

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.heyikan.demo</groupId>
    <artifactId>demo-spring-cache</artifactId>
    <version>1.0-SNAPSHOT</version>
    <packaging>pom</packaging>

    <modules>
        <module>caffeine-cache</module>
    </modules>

    <properties>
        <java.version>1.8</java.version>
        <maven.compiler.source>${java.version}</maven.compiler.source>
        <maven.compiler.target>${java.version}</maven.compiler.target>

        <spring-boot.version>2.1.3.RELEASE</spring-boot.version>
    </properties>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

</project>

root module的主要作用是统一管理依赖。当项目中有多个module的时候，作者一般会构建一个root module，然后其他的moudule都继承自这个module，形成一个两级module的继承结构。

网上大部分的demo，一般是直接创建目标module，且继承自spring-boot-starter-parent。spring-boot-starter-parent管理了大部分常用的依赖，使用这些依赖我们不用再费心考虑版本的问题。

但是maven是单继承结构，继承了spring-boot-starter-parent就无法继承自己项目当中的parent module（root module）。在一个多module的项目当中，module之间的相互依赖就不是spring-boot-starter-parent能预先管理的了。

所以在实际项目当中，我们一般不会直接继承spring-boot-starter-parent。而是通过在root module中import spring-boot-dependencies，来享受spring-boot为我们管理依赖的便利，同时在root module管理额外的依赖。

具体的技术细节需要读者参考Maven的知识。作者只是阐述下这么做的原因，实际上跟demo本身的功能没有多大关系。

创建目标module

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>demo-spring-cache</artifactId>
        <groupId>com.heyikan.demo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>caffeine-cache</artifactId>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <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>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

这个module主要引入了三个依赖：

  • spring-boot-starter-web
    打包了web项目的常规依赖
  • spring-boot-starter-cache
    打包了依赖功能的常规依赖
  • caffeine
    具体的依赖实现

spring cache提供了一层抽象和使用接口，底层可以切换不同的cache实现，caffeine就是其中之一，且性能表现较优。

spring cache还可以与redis集成，提供分布式缓存的能力。

创建Application

package heyikan;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;

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

熟悉spring-boot项目的读者应该对此比较熟悉，spring-boot项目需要创建一个Application来启动整个应用。

@EnableCaching注解用于启用缓存，没有这个注解，我们后面的缓存功能将不会生效。

创建Controller

package heyikan;

import com.github.benmanes.caffeine.cache.Cache;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cache.CacheManager;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;
import java.util.concurrent.ConcurrentMap;
import java.util.function.Function;
import java.util.stream.Collectors;

@RestController
public class QueryController {
    @Autowired
    private QueryService queryService;

    @GetMapping("/query")
    public ResponseEntity<?> query(String keyWord) {
        String result = queryService.query(keyWord);
        return ResponseEntity.ok(result);
    }

    @Autowired
    @SuppressWarnings("all")
    private CacheManager cacheManager;

    @GetMapping("/caches")
    public ResponseEntity<?> getCache() {
        Map<String, ConcurrentMap> cacheMap = cacheManager.getCacheNames().stream()
                .collect(Collectors.toMap(Function.identity(), name -> {
                    Cache cache = (Cache) cacheManager.getCache(name).getNativeCache();
                    return cache.asMap();
                }));
        return ResponseEntity.ok(cacheMap);
    }
}

QueryController提供了两个Rest接口，query用于模拟耗时的查询请求，getCache用于获取当前的缓存内容。

QueryController中引入了QueryService依赖，它是提供查询和缓存功能的核心组件。

QueryController中引入了CacheManager依赖，它持有所有的缓存，并提供了遍历的API。

创建缓存组件

package heyikan;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cache.annotation.CacheConfig;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

@Service
@CacheConfig(cacheNames = {"query-result", "demo"})
public class QueryService {
    private static Logger LOG = LoggerFactory.getLogger(QueryService.class);

    @Cacheable(unless = "#result.length() > 20")
    public String query(String keyWord) {
        LOG.info("do query by keyWord: {}", keyWord);
        String queryResult = doQuery(keyWord);
        return queryResult;
    }

    private String doQuery(String keyWord) {
        try {
            Thread.sleep(3000L);
            String result = "result of " + keyWord;
            return result;
        } catch (InterruptedException e) {
            throw new IllegalStateException(e);
        }
    }
}

我们使用@CacheConfig配置缓存，如代码所示，数据将会同时缓存到"query-result"和"demo"中。

query方法是查询的入口，@Cacheable注解用于表示query方法的返回结果将被放到缓存中，默认以方法的参数作为key。

@Cacheable注解的unless属性补充了缓存的条件，按照代码所示，当query的返回结果其长度大于20的时候，就不会进行缓存。

doQuery方法代表实际的查询操作，模拟耗时的查询过程。

创建配置

application.yml文件内容如下：

spring:
  cache:
    caffeine:
      spec: maximumSize=500, expireAfterAccess=30s
logging:
  pattern:
    console: "%-5level - %msg%n"
  level:
    - error
    - heyikan=ALL

spring.cache.caffeine.spec配置了两个缓存指标：

  • maximumSize
    配置缓存的最大容量，当快要达到容量上限的时候，缓存管理器会根据一定的策略将部分缓存项移除。
  • expireAfterAccess
    配置缓存项的过期机制，如代码所示当缓存项被访问后30秒将会过期，从而被移除。

技术要点

缓存的结构

在上文获取缓存的接口中，我们得到的结果是：

{
    "query-result": {
        "spring": "result of spring"
    },
    "demo": {
        "spring": "result of spring"
    }
}

缓存的结构大概像Map<cacheName, Map<key, value>>，其中每一对key-value又称为一个缓存项。

上文中，我们缓存组件的query方法的返回结果，就是以参数为key，以结果为value，构建缓存项进行缓存的。

另外，我们配置的超时时间，也是以缓存项为粒度进行控制的。

包含缓存项的Map我们称为缓存实例，每一个实例有一个实例名（cacheName）。

cache结构相关的类图如下：

spring-cache-class.jpg

上图简单绘制了Spring中定义的Cache接口和caffeine中定义的Cache接口。

Spring的Cache定义了极其通用的方法，包括获取实例名、根据缓存项的key获取、更新和移除缓存项。

Spring并没有限定缓存所使用的具体存储结构，不管使用哪一种存储结构，在Spring的Cache中都以nativeCache进行表示，注意它是Object类型的。

caffeine的Cache接口，就是caffeine对nativeCache的又一层抽象，它提供了asMap方法可以对缓存项进行遍历。

使用缓存

在上文中，我们已经简单演示了如何使用缓存。除了获取缓存之外，我们几乎没有任何额外的代码，只是在合适的地方，添加了注解，就添加了缓存的功能。

所以在日常开发中，如果我们意识到某个操作可能会有很大开销，不妨把它移到一个独立的组件，实现之后根据具体情况考虑是否为它添加缓存。

注意：如果缓存的方法是组件内部调用的，可能没有缓存的效果。

比如，上文中的QueryService的query方法，是由QueryController调用的，缓存生效了。如果该方法由QueryService自身的其他方法调用，缓存无效。

在上文的demo中，我们已经使用了一些基本的功能，还有一些常用的功能如下：

指定key构建规则

在上文中，我们使用默认的规则来构建缓存项的key，即以参数keyWord作为key。

在必要的情况下，我们可以指定key构建的规则，使用spring el表达式：

@Cacheable(cacheNames="books", key="#isbn")
public Book findBook(ISBN isbn, boolean checkWarehouse, boolean includeUsed)

@Cacheable(cacheNames="books", key="#isbn.rawNumber")
public Book findBook(ISBN isbn, boolean checkWarehouse, boolean includeUsed)

@Cacheable(cacheNames="books", key="T(someType).hash(#isbn)")
public Book findBook(ISBN isbn, boolean checkWarehouse, boolean includeUsed)

第一个实例，我们使用三个参数中的其中一个来构建key。
第二个实例，我们使用参数内部的field来构建key。
第三个实例，我们使用静态方法来生成key。

更多内容可以参考Custom Key Generation Declaration。

有选择的cache

上文demo中我们使用unless属性对方法返回的结果进行判断，当返回结果满足一定条件时才进行缓存。

另外，我们还可以使用condition属性对方法的参数进行判断：

@Cacheable(cacheNames="book", condition="#name.length() < 32") 
public Book findBook(String name)

上述代码表示，只有当参数的长度小于32时，我们才会缓存。

更多内容可以参考Conditional Caching。

扩展阅读

  • Spring官方demo
    这里提供了使用默认缓存的demo，内容更加简单，适合对spring-boot不熟悉的读者。
  • Spring官方文档
    这里有对如何使用cache的详细介绍，比如如何主动更新缓存、移除缓存，都是本demo中没有的内容。
  • Spring Boot Caffeine Caching Example Configuration
    这里介绍了如何使用Caffeine缓存，本文的内容相当一部分参考了这篇文章。
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 213,254评论 6赞 492
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,875评论 3赞 387
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 158,682评论 0赞 348
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,896评论 1赞 285
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,015评论 6赞 385
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,152评论 1赞 291
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,208评论 3赞 412
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,962评论 0赞 268
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,388评论 1赞 304
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,700评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,867评论 1赞 341
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,551评论 4赞 335
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,186评论 3赞 317
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,901评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,142评论 1赞 267
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,689评论 2赞 362
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,757评论 2赞 351