0. 引言

之前咱们讲解了本地缓存ehcache组件,在实际运用中,并不是单一的运用本地缓存或许redis,更多是组合运用来满意不同的业务场景,所以如何优雅的组合本地缓存和长途缓存就成了咱们要研讨的问题,而这一点,阿里开源的jetcache组件帮咱们完成了

1. jetcache简介

jetcache是阿里开源的基于java开发的缓存结构,支持多种缓存类型:本地缓存、分布式缓存、多级缓存。能够满意不同业务场景的缓存需求。

jetcache具有上手简略、性能高效、拓展性强的特点。支持缓存预热 、缓存key前缀等功能。结合spring-cache运用,能够完成非常优雅的缓存类型切换

官网地址:github.com/alibaba/jet… 官方文档:github.com/alibaba/jet…

2. jetcache运用

1、引进依靠,这儿咱们运用sringboot项目结构,一起运用redis作为长途缓存。所以咱们引进jetcache-starter-redis依靠,这儿我的springboot版别为2.6.13

假如是非springboot项目能够参考官网阐明装备

jetcache:阿里这款多级缓存框架一定要掌握

<dependency>
            <groupId>com.alicp.jetcache</groupId>
            <artifactId>jetcache-starter-redis</artifactId>
            <version>2.7.0</version>
</dependency>
<!--        jetcache2.7.x版别需求额定增加该依靠-->
<dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>4.3.1</version>
</dependency>

对应的版别阐明如下:springboot与jetcache版别关系

jetcache:阿里这款多级缓存框架一定要掌握

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

更具体的参数装备可参考官网阐明:github.com/alibaba/jet…

jetcache:阿里这款多级缓存框架一定要掌握

3、发动类增加注解@EnableCreateCacheAnnotation,敞开缓存,增加@EnableMethodCache(basePackages = "com.example.jetcachedemo")注解,装备缓存办法扫描途径

4、运用缓存能够经过三种办法:

  • 办法一(引荐)AOP方式:经过@Cached,@CacheUpdate,@CacheInvalidate注解
@RestController
@RequestMapping("user")
public class 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 更新数据库
        return true;
    }
    @PostMapping("deleteUser")
    @CacheInvalidate(name = "userCache:", key = "#id")
    public Boolean deleteUser(Long id){
        // TODO 从数据库删去
        return true;
    }
}

这儿要注意实体类User一定要完成序列化,即声明Serializable

@Data
public class User implements Serializable {
    private Long id;
    private String name;
    private Integer age;
    private Integer sex;
}
  • 办法二 API方式:经过@CreateCache,注:在jetcache 2.7 版别CreateCache注解已抛弃,不引荐运用
@RestController
@RequestMapping("user2")
public class 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);
        return true;
    }
    @PostMapping("deleteUser")
    public Boolean deleteUser(Long id){
        // TODO 从数据库删去
        userCache.remove(id);
        return true;
    }
}
  • 办法三 高级API方式:经过CacheManager,2.7 版别才可运用

(1)增加依靠

<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>2.0.25</version>
</dependency>

(2)书写装备类

@Configuration
public class 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")
public class 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);
        return true;
    }
    @PostMapping("deleteUser")
    public Boolean deleteUser(Long id){
        // TODO 从数据库删去
        userCache.remove(id);
        return true;
    }
}

多级缓存的方式,会先从本地缓存获取数据,本地获取不到会从长途缓存获取

5、发动redis,发动演示项目

注意,假如发动出现NoClassDefFoundError: redis/clients/util/PoolNoClassDefFoundError: redis/clients/jedis/UnifiedJedis报错,阐明springboot与jetcache版别不一致,对应关系可参考上述第一步中的阐明 一起假如运用的是jetcache2.7.x版别,因为该版别中有jedis包的依靠,需求额定增加如下依靠,或许将jetcache版别将至2.6.5以下

<dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>4.3.1</version>
</dependency>

3. 测验

3.1 办法一测验

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

jetcache:阿里这款多级缓存框架一定要掌握

因为装备的是长途缓存,在redis中也能看到对应的key

jetcache:阿里这款多级缓存框架一定要掌握

2、拜访localhost:8088/user/getLocal?id=1,这个办法是从本地缓存获取的,现在只要长途缓存上有数据,咱们调用发现缓存数据仍是拿到了,这阐明当咱们在装备文件中装备了本地缓存和长途缓存后,办法一中本地缓存和长途缓存会主动彼此调用

比如本地缓存有这个key,redis中没有,经过长途缓存办法拜访时,会先从redis获取,假如没有会主动获取本地缓存,可是数据仍是存储在本地缓存,并不会同步到redis上,这样更加灵敏的完成了多级缓存架构

jetcache:阿里这款多级缓存框架一定要掌握

3.2 办法二测验

1、再测验下CreateCache的方式:localhost:8088/user2/get?id=4

jetcache:阿里这款多级缓存框架一定要掌握

正常获取了,而且redis中也有了对应的值

jetcache:阿里这款多级缓存框架一定要掌握
而当咱们把缓存办法更改为LOCAL后,再拜访localhost:8088/user2/get?id=5

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

会发现redis中就没有对应缓存了,只在本地缓存存在,阐明咱们指定本地缓存的方式成功了

jetcache:阿里这款多级缓存框架一定要掌握

3.3 办法三测验

1、调用localhost:8088/user3/get?id=11

jetcache:阿里这款多级缓存框架一定要掌握

redis中缓存设置成功!

jetcache:阿里这款多级缓存框架一定要掌握

4. 常见报错

1、 ClassNotFoundException: com.alibaba.fastjson.JSON 解决:增加依靠

<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>2.0.25</version>
</dependency>

2、NoClassDefFoundError: redis/clients/jedis/UnifiedJedis 解决: 增加依靠

<dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>4.3.1</version>
</dependency>

或许将jetcache版别降低至2.6.5以下

演示源码

gitee.com/wuhanxue/wu…