Spring Boot缓存实战 Caffeine示例

Caffeine和Spring Boot集成

Caffeine是使用Java8对Guava缓存的重写版本，在Spring Boot 2.0中将取代Guava。如果出现Caffeine，CaffeineCacheManager将会自动配置。使用spring.cache.cache-names属性可以在启动时创建缓存，并可以通过以下配置进行自定义（按顺序）：

• spring.cache.caffeine.spec： 定义的特殊缓存
• com.github.benmanes.caffeine.cache.CaffeineSpec： bean定义
• com.github.benmanes.caffeine.cache.Caffeine： bean定义

例如，以下配置创建一个foo和bar缓存，最大数量为500，存活时间为10分钟：

spring.cache.cache-names=foo,barspring.cache.caffeine.spec=maximumSize=500,expireAfterAccess=600s

除此之外，如果定义了com.github.benmanes.caffeine.cache.CacheLoader，它会自动关联到CaffeineCacheManager。由于该CacheLoader将关联被该缓存管理器管理的所有缓存，所以它必须定义为CacheLoader<Object, Object>，自动配置将忽略所有泛型类型。

引入依赖

<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-cache</artifactId></dependency><dependency>  <groupId>com.github.ben-manes.caffeine</groupId>  <artifactId>caffeine</artifactId>  <version>2.6.0</version></dependency>

开启缓存的支持

使用@EnableCaching注解让Spring Boot开启对缓存的支持

@SpringBootApplication@EnableCaching// 开启缓存，需要显示的指定public class SpringBootStudentCacheCaffeineApplication {  public static void main(String[] args) {    SpringApplication.run(SpringBootStudentCacheCaffeineApplication.class, args);  }}

配置文件

新增对缓存的特殊配置，如最大容量、过期时间等

spring.cache.cache-names=peoplespring.cache.caffeine.spec=initialCapacity=50,maximumSize=500,expireAfterWrite=10s,refreshAfterWrite=5s

如果使用了refreshAfterWrite配置还必须指定一个CacheLoader，如：

/** * 必须要指定这个Bean，refreshAfterWrite=5s这个配置属性才生效 * * @return */@Beanpublic CacheLoader<Object, Object> cacheLoader() {  CacheLoader<Object, Object> cacheLoader = new CacheLoader<Object, Object>() {    @Override    public Object load(Object key) throws Exception {      return null;    }    // 重写这个方法将oldValue值返回回去，进而刷新缓存    @Override    public Object reload(Object key, Object oldValue) throws Exception {      return oldValue;    }  };  return cacheLoader;}

Caffeine配置说明：

1. initialCapacity=[integer]: 初始的缓存空间大小
2. maximumSize=[long]: 缓存的最大条数
3. maximumWeight=[long]: 缓存的最大权重
4. expireAfterAccess=[duration]: 最后一次写入或访问后经过固定时间过期
5. expireAfterWrite=[duration]: 最后一次写入后经过固定时间过期
6. refreshAfterWrite=[duration]: 创建缓存或者最近一次更新缓存后经过固定的时间间隔，刷新缓存
7. weakKeys: 打开key的弱引用
8. weakValues：打开value的弱引用
9. softValues：打开value的软引用
10. recordStats：开发统计功能

注意：

1. expireAfterWrite和expireAfterAccess同事存在时，以expireAfterWrite为准。
2. maximumSize和maximumWeight不可以同时使用
3. weakValues和softValues不可以同时使用

示例代码

/** * @author yuhao.wang */@Servicepublic class PersonServiceImpl implements PersonService {  private static final Logger logger = LoggerFactory.getLogger(PersonServiceImpl.class);  @Autowired  PersonRepository personRepository;  @Override  @CachePut(value = "people", key = "#person.id")  public Person save(Person person) {    Person p = personRepository.save(person);    logger.info("为id、key为:" + p.getId() + "数据做了缓存");    return p;  }  @Override  @CacheEvict(value = "people")//2  public void remove(Long id) {    logger.info("删除了id、key为" + id + "的数据缓存");    //这里不做实际删除操作  }  /**   * Cacheable   * value：缓存key的前缀。   * key：缓存key的后缀。   * sync：设置如果缓存过期是不是只放一个请求去请求数据库，其他请求阻塞，默认是false。   */  @Override  @Cacheable(value = "people", key = "#person.id", sync = true)  public Person findOne(Person person, String a, String[] b, List<Long> c) {    Person p = personRepository.findOne(person.getId());    logger.info("为id、key为:" + p.getId() + "数据做了缓存");    return p;  }  @Override  @Cacheable(value = "people1")//3  public Person findOne1() {    Person p = personRepository.findOne(2L);    logger.info("为id、key为:" + p.getId() + "数据做了缓存");    return p;  }  @Override  @Cacheable(value = "people2")//3  public Person findOne2(Person person) {    Person p = personRepository.findOne(person.getId());    logger.info("为id、key为:" + p.getId() + "数据做了缓存");    return p;  }}

源码：https://github.com/wyh-spring-ecosystem-student/spring-boot-student/tree/releases

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持武林网。