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项目能够参考官网阐明装备

<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版别关系

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…

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/Pool或NoClassDefFoundError: 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

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

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

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

3.2 办法二测验

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

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

而当咱们把缓存办法更改为LOCAL后，再拜访localhost:8088/user2/get?id=5

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

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

3.3 办法三测验

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

redis中缓存设置成功！

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…

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

0. 引言

1. jetcache简介

2. jetcache运用

3. 测验

3.1 办法一测验

3.2 办法二测验

3.3 办法三测验

4. 常见报错

演示源码

作者信息

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

0. 引言

1. jetcache简介

2. jetcache运用

3. 测验

3.1 办法一测验

3.2 办法二测验

3.3 办法三测验

4. 常见报错

演示源码

相关文章

结合DDD讲清楚：后端系统分析七大维度（长文多图）

SwiftUI onAppear 的调用时机

小目标检测的一些问题，思路和方案

从1024开始，我们漫谈编程的本质

作者信息