Java中Caffeine本地緩存項目實例

更新時間：2023年10月09日 10:13:21 作者：閃耀的瞬間

這篇文章主要介紹了Java中Caffeine本地緩存項目實例,Caffeine是一個高性能Java 緩存庫,使用Java8對Guava緩存重寫版本,在Spring Boot 2.0中將取代Guava,使用spring.cache.cache-names屬性可以在啟動時創(chuàng)建緩存,需要的朋友可以參考下

前言

為什么需要本地緩存？在系統(tǒng)中，有些數(shù)據(jù)，訪問十分頻繁（例如數(shù)據(jù)字典數(shù)據(jù)、國家標準行政區(qū)域數(shù)據(jù)），往往把這些數(shù)據(jù)放入分布式緩存中，但為了減少網(wǎng)絡傳輸，加快響應速度，緩存分布式緩存讀壓力，會把這些數(shù)據(jù)緩存到本地JVM中，大多是先取本地緩存中，再取分布式緩存中的數(shù)據(jù)

而Caffeine是一個高性能Java 緩存庫，使用Java8對Guava緩存重寫版本，在Spring Boot 2.0中將取代Guava。使用spring.cache.cache-names屬性可以在啟動時創(chuàng)建緩存

例如，以下application配置創(chuàng)建一個foo和bar緩存，最大數(shù)量為500，存活時間為10分鐘

spring.cache.cache-names=foo,bar
spring.cache.caffeine.spec=initialCapacity=10,maximumSize=500,expireAfterAccess=600s

還有一種代碼實現(xiàn)方式，我在項目中就是使用代碼方式，如何使用，請往下看

代碼實現(xiàn)

1.引入依賴

<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.2</version>
</dependency>

2.添加一個CaffeineConfig配置類，開啟緩存@EnableCaching

@Configuration
@EnableCaching //開啟緩存
public class CaffeineConfig {
    public static final int DEFAULT_MAXSIZE = 10000;
    public static final int DEFAULT_TTL = 600;
    /**
     * 定義cache名稱、超時時長（秒）、最大容量
     * 每個cache缺?。?0秒超時、最多緩存50000條數(shù)據(jù)，需要修改可以在構(gòu)造方法的參數(shù)中指定。
     */
    public enum Caches{
        getUserById(600),          //有效期600秒
        listCustomers(7200,1000),  //有效期2個小時 , 最大容量1000
        ;
        Caches() {
        }
        Caches(int ttl) {
            this.ttl = ttl;
        }
        Caches(int ttl, int maxSize) {
            this.ttl = ttl;
            this.maxSize = maxSize;
        }
        private int maxSize=DEFAULT_MAXSIZE;	//最大數(shù)量
        private int ttl=DEFAULT_TTL;		//過期時間（秒）
        public int getMaxSize() {
            return maxSize;
        }
        public int getTtl() {
            return ttl;
        }
    }
    /**
     * 創(chuàng)建基于Caffeine的Cache Manager
     * @return
     */
    @Bean
    @Primary
    public CacheManager caffeineCacheManager() {
        SimpleCacheManager cacheManager = new SimpleCacheManager();
        ArrayList<CaffeineCache> caches = new ArrayList<CaffeineCache>();
        for(Caches c : Caches.values()){
            caches.add(new CaffeineCache(c.name(),
                    Caffeine.newBuilder().recordStats()
                            .expireAfterWrite(c.getTtl(), TimeUnit.SECONDS)
                            .maximumSize(c.getMaxSize())
                            .build())
            );
        }
        cacheManager.setCaches(caches);
        return cacheManager;
    }
}

3.創(chuàng)建控制器

創(chuàng)建一個控制器，使用本地緩存，注意@Cacheable，value與上面配置的值對應，key為參數(shù)，sync=true表示同步，多個請求會被阻塞

@RestController
@RequestMapping("cache")
public class CacheController {
    @RequestMapping("listCustomers")
    @Cacheable( value = "listCustomers" , key = "#length", sync = true)
    public List<Customer> listCustomers(Long length){
        List<Customer> customers = new ArrayList<>();
        for(int i=1; i <= length ; i ++){
            Customer customer = new Customer(i, "zhuyu"+i, 20 + i, false);
            customers.add(customer);
        }
        return customers;
    }
    // 以第一個參數(shù)為key進行緩存
    @Cacheable(value="users", key="#p0")
    public Long find(Long id) {
        return id;
    }
    // 以User中的id值為key進行緩存
    @Cacheable(value="users", key="#user.id")
    public User find(User user) {
         return user;
    }
    // 以User中的id值為key，且 condition 條件滿足則緩存
    @Cacheable(value="users", key="#user.id", condition="#user.id%2==0")
    public User find(User user) {
       return user;
    }
}

@CacheEvict 是用來標注清除緩存元素的，可在方法或類上。當標記在一個類上表示其中所有的方法的執(zhí)行都會觸發(fā)緩存的清除操作。
@CacheEvict可以指定的屬性有value、key、condition、allEntries和beforeInvocation。其中value、key和condition的語義與@Cacheable對應的屬性類似。即value表示清除操作是發(fā)生在哪些Cache上的（對應Cache的名稱）；key表示需要清除的是哪個key，如未指定則會使用默認策略生成的key；condition表示清除操作發(fā)生的條件

  // allEntries表示是否需要清除緩存中的所有元素。默認為false，當allEntries為true時，清除所有的元素
  @CacheEvict(value="user", allEntries=true)
  public void delete(Integer id) {
      System.out.println(id);
  }