阿里开源的缓存框架JetCache

jujusharp  •  Apr 11, 2019 10:45:23 PM

原文地址


阿里开源的缓存框架JetCache

之前一直在用Spring Cache进行接口数据的缓存,主要是Spring Cache在对具体key缓存失效时间的设置不是很方法,还要自己去扩展,无意中发现了阿里的JetCache。大部分的需求都能满足,并且有一些很实用的功能,今天给大家介绍下。

JetCache是一个基于Java的缓存系统封装,提供统一的API和注解来简化缓存的使用。 JetCache提供了比SpringCache更加强大的注解,可以原生的支持TTL、两级缓存、分布式自动刷新,还提供了Cache接口用于手工缓存操作。 当前有四个实现,RedisCache、TairCache(此部分未在github开源)、CaffeineCache(in memory)和一个简易的LinkedHashMapCache(in memory),要添加新的实现也是非常简单的。

GitHub:https://github.com/alibaba/jetcache

全部特性:

  • 通过统一的API访问Cache系统

  • 通过注解实现声明式的方法缓存,支持TTL和两级缓存

  • 通过注解创建并配置Cache实例

  • 针对所有Cache实例和方法缓存的自动统计

  • Key的生成策略和Value的序列化策略是可以配置的

  • 分布式缓存自动刷新,分布式锁 (2.2+)

  • 异步Cache API (2.2+,使用Redis的lettuce客户端时)

  • Spring Boot支持

增加Maven配置:

  1. <dependency>

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

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

  4. <version>2.5.11</version>

  5. </dependency>

配置内容:

  1. # 采用Java序列化存储

  2. jetcache.remote.default.valueDecoder = java

  3. # Key的转换器

  4. jetcache.remote.default.keyConvertor = fastjson

  5. # 是否加入缓存key前缀

  6. jetcache.areaInCacheName = false

  7. jetcache.remote.default.valueEncoder = java

  8. # 缓存类型。tair、redis为当前支持的远程缓存;linkedhashmap、caffeine为当前支持的本地缓存类型

  9. jetcache.local.default.type = linkedhashmap

  10. # 控制台输出统计数据,统计间隔,0表示不统计

  11. jetcache.statIntervalMinutes = 15

  12. jetcache.local.default.keyConvertor = fastjson

  13. jetcache.remote.default.uri = redis://192.168.0.210:6379/

  • remote 表示远程缓存

  • local表示本地缓存

启动类开启缓存:

  1. @SpringBootApplication

  2. @EnableMethodCache(basePackages = "com.cxytiandi.jetcache")

  3. @EnableCreateCacheAnnotation

  4. public class App {

  5. public static void main(String[] args) {

  6. SpringApplication.run(App.class);

  7. }

  8. }

  • @EnableMethodCache 用于激活@Cached注解的使用

  • @EnableCreateCacheAnnotation 用于激活@CreateCache注解的使用

定义一个简单的实体类来作为数据的缓存,必须实现Serializable接口。

  1. @Data

  2. public class User implements Serializable {

  3. private Long id;

  4. private String name;

  5. }

@CreateCache使用

  1. // 定义

  2. @CreateCache(expire = 100)

  3. private Cache<Long, User> userCache;

  4. ------------------------------------

  5. // 使用

  6. User user = new User();

  7. user.setId(1L);

  8. user.setName("yinjihuan");

  9. // 新增缓存

  10. userCache.put(1L, user);

  11. // 删除缓存

  12. userCache.remove(1L);

用起来很简单,就像操作本地Map一样,@CreateCache中有很多配置需要我们自己去指定,不指定则使用默认的,关于配置请查看文档:https://github.com/alibaba/jetcache/wiki/CreateCache_CN

@Cached使用

  1. @Cached(name="getUser.", key="#id", expire = 8, cacheType=CacheType.BOTH)

  2. @Override

  3. public User getUser(Long id) {

  4. User user = new User();

  5. user.setId(1L);

  6. user.setName("yinjihuan");

  7. return user;

  8. }

  • name 缓存名称

  • key 缓存key,追加到name后面构成唯一的缓存key, 使用SpEL指定key,如果没有指定会根据所有参数自动生成。

  • expire 缓存失效时间

  • cacheType 缓存的类型,包括CacheType.REMOTE、CacheType.LOCAL、CacheType.BOTH。如果定义为BOTH,会使用LOCAL和REMOTE组合成两级缓存

更多配置的介绍请查看文档:https://github.com/alibaba/jetcache/wiki/MethodCache_CN

今天的介绍就到这里,使用起来还是很方便的,关于更多的功能大家自行去尝试吧,比如缓存定时刷新,缓存命中率统计,自定义序列化方式等等。


整合Apollo的坑 

在这边提一个容易被坑到的点,如果你们的配置都是在Apollo中进行管理的话,那么在集成的时候会有个问题,需要在项目中加上下面的配置才行,其余的配置可以放Apollo中。

  1. spring.application.name=district-service

  2. app.id=${spring.application.name}

  3. apollo.bootstrap.enabled=true

  4. // 这是你要加的,指定缓存类型,我这边用的是lettuce

  5. jetcache.remote.default.type=redis.lettuce

@Cached定义在接口上的坑 

还有一个呢就是@Cached如果定义在接口上就不能指定key属性,框架中会自动根据参数生成key, 如果非得自己用SPEL表达式指定key的话,项目编译设置target必须为1.8格式,并且指定javac的-parameters参数,否则就要使用key="args[0]"这样按下标访问的形式。我建议还是把@Cached的定义放在实现类上,也方便修改。

我这边也录制了一套视频,感兴趣的可以去了解下:http://cxytiandi.com/course/24

加入星球特权

1、实战分库分表中间件Sharding-JDBC

2、实战分布式任务调度框架Elastic Job

3、配置中心Apollo实战

4、高并发解决方案之缓存

5、更多课程等你来解锁,20+课程

点个“好看”你懂得!

0 回复
暂时没有回复,你也许会成为第一个哦