阿里这款多级缓存框架一定要掌握，非常不错！

大家好，我是凯哥Java

本文标签：多级缓存架构、阿里开源组件、SpringBoot缓存集成

在实际应用中，并不是单一的使用本地缓存或者redis，更多是组合使用来满足不同的业务场景，于是如何优雅的组合本地缓存和远程缓存就成了我们要研究的问题，而这一点，阿里开源的jetcache组件帮我们实现了

JetCache作为阿里开源的多级缓存框架，完美解决了本地缓存与Redis的协同问题，通过自动化的缓存加载和失效机制，显著提升系统性能‌。其注解驱动开发模式与Spring生态无缝集成，支持TTL、缓存预热等高级特性，是构建高并发系统的利器‌。

1. jetcache简介

jetcache是阿里开源的基于java开发的缓存框架，支持多种缓存类型：本地缓存、分布式缓存、多级缓存。能够满足不同业务场景的缓存需求。

jetcache具有上手简单、性能高效、拓展性强的特点。支持缓存预热、缓存key前缀等功能。结合spring-cache使用，可以实现十分优雅的缓存类型切换

官网地址：https://github.com/alibaba/jetcache

官方文档：https://github.com/alibaba/jetcache/tree/master/docs/CN

2. jetcache使用

1、引入依赖，这里我们使用sringboot项目框架，同时使用redis作为远程缓存。于是我们引入jetcache-starter-redis依赖，这里我的springboot版本为2.6.13

如果是非springboot项目可以参考官网说明配置：

<groupId>com.alicp.jetcache</groupId>

<artifactId>jetcache-starter-redis</artifactId>

</dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

</dependency>

对应的版本说明如下：https://github.com/alibaba/jetcache/blob/master/docs/CN/Compatibility.md

2、修改配置文件，配置redis地址和线程数

jetcache:

# 统计间隔，0表示不统计，开启后定期在控制台输出缓存信息

statIntervalMinutes:15

# 是否把cacheName作为远程缓存key前缀

areaInCacheName:false

# 本地缓存配置

local:

default:# default表示全部生效，也可以指定某个cacheName

# 本地缓存类型，其他可选：caffeine/linkedhashmap

type:linkedhashmap

keyConvertor:fastjson

# 远程缓存配置

remote:

default:# default表示全部生效，也可以指定某个cacheName

type:redis

# key转换器方式n

keyConvertor:fastjson

broadcastChannel:projectA

# redis序列化方式

valueEncoder:java

valueDecoder:java

# redis线程池

poolConfig:

minIdle:5

maxIdle:20

maxTotal:50

# redis地址与端口

host:127.0.0.1

port:6379

更详细的参数配置可参考官网说明：

3、启动类添加注解@EnableCreateCacheAnnotation，开启缓存，添加@EnableMethodCache(basePackages = "com.example.jetcachedemo")注解，配置缓存方法扫描路径

4、使用缓存可以通过三种方式：

方式一（推荐）AOP模式：通过@Cached,@CacheUpdate,@CacheInvalidate注解

@RestController

@RequestMapping("user")

publicclass UserController {

@GetMapping("getRemote")

@Cached(name="userCache:", key = "#id", expire = 3600, timeUnit = TimeUnit.SECONDS, cacheType = CacheType.REMOTE)

public User getRemote(Long id){

// 直接新建用户，模拟从数据库获取数据

User user = new User();

user.setId(id);

user.setName("用户remote"+id);

user.setAge(23);

user.setSex(1);

System.out.println("第一次获取数据，未走缓存："+id);

return user;

}

@GetMapping("getLocal")

@Cached(name="userCache:", key = "#id", expire = 3600, timeUnit = TimeUnit.SECONDS, cacheType = CacheType.LOCAL)

public User getLocal(Long id){

// 直接新建用户，模拟从数据库获取数据

User user = new User();

user.setId(id);

user.setName("用户local"+id);

user.setAge(23);

user.setSex(1);

System.out.println("第一次获取数据，未走缓存："+id);

return user;

}

@GetMapping("getBoth")

@Cached(name="userCache:", key = "#id", expire = 3600, timeUnit = TimeUnit.SECONDS, cacheType = CacheType.BOTH)

public User getBoth(Long id){

// 直接新建用户，模拟从数据库获取数据

User user = new User();

user.setId(id);

user.setName("用户both"+id);

user.setAge(23);

user.setSex(1);

System.out.println("第一次获取数据，未走缓存："+id);

return user;

}

@PostMapping("updateUser")

@CacheUpdate(name = "userCache:", key = "#user.id", value = "#user")

public Boolean updateUser(@RequestBody User user){

// TODO 更新数据库

returntrue;

}

@PostMapping("deleteUser")

@CacheInvalidate(name = "userCache:", key = "#id")

public Boolean deleteUser(Long id){

// TODO 从数据库删除

returntrue;

}

这里要注意实体类User一定要实现序列化，即声明Serializable

@Data

public User implements Serializable {

private Long id;

private String name;

private Integer age;

private Integer sex;

}

方式二 API模式：通过@CreateCache，注：在jetcache 2.7 版本CreateCache注解已废弃，不推荐使用

@RestController

@RequestMapping("user2")

publicclass User2Controller {

@CreateCache(name= "userCache:", expire = 3600, timeUnit = TimeUnit.SECONDS, cacheType = CacheType.BOTH)

private Cache<Long, Object> userCache;

@GetMapping("get")

public User get(Long id){

if(userCache.get(id) != null){

return (User) userCache.get(id);

}

User user = new User();

user.setId(id);

user.setName("用户both"+id);

user.setAge(23);

user.setSex(1);

userCache.put(id, user);

System.out.println("第一次获取数据，未走缓存："+id);

return user;

}

@PostMapping("updateUser")

public Boolean updateUser(@RequestBody User user){

// TODO 更新数据库

userCache.put(user.getId(), user);

returntrue;

}

@PostMapping("deleteUser")

public Boolean deleteUser(Long id){

// TODO 从数据库删除

userCache.remove(id);

returntrue;

}

方式三高级API模式：通过CacheManager，2.7 版本才可使用

（1）添加依赖

<groupId>com.alibaba</groupId>

<artifactId>fastjson</artifactId>

</dependency>

（2）书写配置类

@Configuration

publicclass JetcacheConfig {

@Autowired

private CacheManager cacheManager;

private Cache<Long, Object> userCache;

@PostConstruct

public void init(){

QuickConfig qc = QuickConfig.newBuilder("userCache:")

.expire(Duration.ofSeconds(3600))

.cacheType(CacheType.BOTH)

// 本地缓存更新后，将在所有的节点中删除缓存，以保持强一致性

.syncLocal(false)

.build();

userCache = cacheManager.getOrCreateCache(qc);

}

@Bean

public Cache<Long, Object> getUserCache(){

return userCache;

}

（3）调用代码

@RestController

@RequestMapping("user3")

publicclass User3Controller {

@Autowired

JetcacheConfig jetcacheConfig;

@Autowired

private Cache<Long, Object> userCache;

@GetMapping("get")

public User get(Long id){

if(userCache.get(id) != null){

return (User) userCache.get(id);

}

User user = new User();

user.setId(id);

user.setName("用户both"+id);

user.setAge(23);

user.setSex(1);

userCache.put(id, user);

System.out.println("第一次获取数据，未走缓存："+id);

return user;

}

@PostMapping("updateUser")

public Boolean updateUser(@RequestBody User user){

// TODO 更新数据库

userCache.put(user.getId(), user);

returntrue;

}

@PostMapping("deleteUser")

public Boolean deleteUser(Long id){

// TODO 从数据库删除

userCache.remove(id);

returntrue;

}

多级缓存的形式，会先从本地缓存获取数据，本地获取不到会从远程缓存获取；关注工众号：码猿技术专栏，回复关键词：1111 获取阿里内部Java性能调优手册！

5、启动redis，启动演示项目

注意，如果启动出现NoClassDefFoundError: redis/clients/util/Pool或NoClassDefFoundError: redis/clients/jedis/UnifiedJedis报错，说明springboot与jetcache版本不一致，对应关系可参考上述第一步中的说明同时如果使用的是jetcache2.7.x版本，因为该版本中有jedis包的依赖，需要额外添加如下依赖，或者将jetcache版本将至2.6.5以下.

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

</dependency>

3. 测试3.1 方式一测试

1、访问localhost:8088/user/getRemote?id=1