1. 程式人生 > 程式設計 >Springboot Caffeine本地快取使用示例

Springboot Caffeine本地快取使用示例

Caffeine是使用Java8對Guava快取的重寫版本效能有很大提升

一 依賴

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

二 配置快取,單獨使用

只需要配置Bean就可以了,然後進行資料讀寫,注意這裡提供了很多強大的自定義配置,可以檢視文件詳細配置

//定義快取,可直接使用
  @Bean
  public LoadingCache expiryCache(){
    LoadingCache<String,Object> loadingCache = Caffeine.newBuilder()
        .initialCapacity(100)
        .maximumSize(1000)
        //快取寫入/刪除監控
        .writer(new CacheWriter<Object,Object>() {
          @Override
          public void write(Object key,Object value) { //此方法是同步阻塞的
            System.out.println("--快取寫入--:key=" + key + ",value=" + value);
          }
          @Override
          public void delete(Object key,Object value,RemovalCause cause) { System.out.println("--快取刪除--:key=" + key); }
        })
        .expireAfterAccess(1,TimeUnit.MINUTES) //過期時間
        .build((String key)->"重新整理的資料"); //cacheload實現類,重新整理時候呼叫
    loadingCache.put("name","侯徵");
    return loadingCache;
  }

測試使用:

@Autowired
  private LoadingCache loadingCache;
  @GetMapping("/get")
  public Object getValue(String key){
    return loadingCache.get(key);
  }
  @GetMapping("/add")
  public void addValue(String value){
    loadingCache.put(value,value);
  }
  @GetMapping("/delete")
  public void deleteValue(String key){
    loadingCache.invalidate(key);
    loadingCache.invalidateAll();//清楚所有
  }
  @GetMapping("/refresh")
  public void refreshValue(String key){
    //重新整理時會根據build方法中中指定的cacheload重新載入
    loadingCache.refresh(key);
  }

三 配置CacheManager,和spring快取註解一起使用

//配置CacheManager
  @Bean(name = "caffeine")
  public CacheManager cacheManagerWithCaffeine() {
    CaffeineCacheManager cacheManager = new CaffeineCacheManager();
    Caffeine caffeine = Caffeine.newBuilder()
        //cache的初始容量值
        .initialCapacity(100)
        //maximumSize用來控制cache的最大快取數量,maximumSize和maximumWeight(最大權重)不可以同時使用,
        .maximumSize(1000)
        //最後一次寫入或者訪問後過久過期
        .expireAfterAccess(500,TimeUnit.SECONDS)
        //建立或更新之後多久重新整理,需要設定cacheLoader
        .refreshAfterWrite(10,TimeUnit.SECONDS);
    cacheManager.setCaffeine(caffeine);
    cacheManager.setCacheLoader(cacheLoader);
    cacheManager.setCacheNames(names);//根據名字可以建立多個cache,但是多個cache使用相同的策略
    cacheManager.setAllowNullValues(false);//是否允許值為空
    return cacheManager;
  }

配置 cacheload

/**
   * 必須要指定這個Bean,refreshAfterWrite配置屬性才生效
   */
  @Bean
  public CacheLoader<Object,Object> cacheLoader() {
    return 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 {
        System.out.println("--refresh--:"+key);
        return oldValue;
      }
    };
  }

其他就是在service中配置spring的幾個快取註解使用就行了,這裡放一張截圖,這些註解用法,網上很多:[/code]

Springboot Caffeine本地快取使用示例

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。