Caffeine本地缓存技术

news2024/9/27 15:35:53

说明：Caffeine是本地缓存方案，在所有本地缓存中命中率最佳，参考下图（引自http://t.csdn.cn/oiQlH），本文介绍Caffeine在SpringBoot项目中的应用。

在这里插入图片描述

使用

例如现在有两个接口，一个查询所有用户，一个根据ID查询用户，数据访问层使用的是Mybatis-plus；

controller层代码如下：

import com.hzy.pojo.User;
import com.hzy.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("list")
    public List<User> getUsers() {
        return userService.list();
    }

    @GetMapping("{id}")
    public User getUserById(@PathVariable Long id) {
        return userService.getById(id);
    }
}

第一步：引入依赖

使用Caffeine前先引入相关依赖：

	<dependency>
	    <groupId>com.github.ben-manes.caffeine</groupId>
	    <artifactId>caffeine</artifactId>
	</dependency>

第二步：创建Bean对象

针对需要用本地缓存的接口，创建对应的缓存对象，注意导包是"com.github……"里面的；

（创建一个配置类）

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.hzy.pojo.User;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class CaffeineConfig {

    /**
     * 创建User相关接口的Cache对象，缓存数量上限为100，初始容量为10
     * @return
     */
    @Bean
    public Cache<Long, User> userCache(){
        return Caffeine.newBuilder()
                .initialCapacity(10)
                .maximumSize(100)
                .build();

    }
}

顺便一提，Caffeine提供了三种缓存驱逐策略，分别如下：

基于容量，设置缓存数量的上限；

Cache<String, String> cache = Caffeine.newBuilder()
    .maximumSize(100)	// 设置缓存数量上限
    .build();

基于时间，设置缓存的有效时间；

Cache<String, String> cache = Caffeine.newBuilder()
    .expireAfterWrite(Duration.ofSeconds(10)) 	  // 设置缓存有效期为最后一次写入后的10秒
    .build();

基于引用，设置缓存为软件引用或者弱引用，利用JVM虚拟机的GC来回收缓存，性能差，不推荐；

第三步：修改代码

可以针对这两个接口，在Service层输入信息，来判断缓存是否生效，有没有每次都访问数据库；

（controller层，方法改为访问Service的方法，查询所有的接口不使用缓存）

@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private UserService userService;

    @Autowired
    private Cache<Long, User> userCache;

    /**
     * 不使用缓存
     * @return
     */
    @GetMapping("list")
    public List<User> getUsers() {
        return userService.list();
    }

    /**
     * 使用缓存
     * @param id
     * @return
     */
    @GetMapping("{id}")
    public User getUserById(@PathVariable Long id) {
        return userCache.get(id, new Function<Long, User>() {
            @Override
            public User apply(Long key) {
                return userService.getUserById(key);
            }
        });
    }
}

（Service层代码，每次访问数据库前打印信息）

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {

    @Override
    public User getUserById(Long id) {

        System.out.println("根据ID查询用户接口====访问了数据库");

        return getById(id);
    }
}