快捷導(dǎo)航

Springboot使用cache緩存過程代碼實(shí)例

更新時(shí)間：2020年06月30日 08:32:48 投稿：yaominghui

這篇文章主要介紹了Springboot使用cache緩存過程代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

1.pom.xml

<!-- Ehcache 坐標(biāo) -->
<dependency>
  <groupId>net.sf.ehcache</groupId>
  <artifactId>ehcache</artifactId>
</dependency>

2.ehcache.xml

<?xml version="1.0" encoding="UTF-8"?>
<ehcache>
 
  <diskStore path="java.io.tmpdir"/>
 
  <!--defaultCache:echcache的默認(rèn)緩存策略 -->
  <defaultCache
      maxElementsInMemory="10000"
      eternal="false"
      timeToIdleSeconds="120"
      timeToLiveSeconds="120"
      maxElementsOnDisk="10000000"
      diskExpiryThreadIntervalSeconds="120"
      memoryStoreEvictionPolicy="LRU">
    <persistence strategy="localTempSwap"/>
  </defaultCache>
  <!--
    maxElementsInMemory設(shè)置成1，overflowToDisk設(shè)置成true，只要有一個(gè)緩存元素，就直接存到硬盤上去
    eternal設(shè)置成true，代表對(duì)象永久有效
    maxElementsOnDisk設(shè)置成0 表示硬盤中最大緩存對(duì)象數(shù)無限大
    diskPersistent設(shè)置成true表示緩存虛擬機(jī)重啟期數(shù)據(jù)
  -->
  <cache name="usercache"
      maxElementsInMemory="1"
      eternal="true"
      overflowToDisk="true"
      maxElementsOnDisk="0"
      diskPersistent="true">
<!--    <persistence strategy="localTempSwap"/>--> <!--不能和diskPersistent 同時(shí)存在-->
  </cache>

diskStore是物理文件的存儲(chǔ)路徑，

cache標(biāo)簽中的name是多cache時(shí)區(qū)分的唯一標(biāo)識(shí)，和程序中初始化方法getCache("***")參數(shù)一致。<br>緩存參數(shù)和本地?cái)?shù)據(jù)持久化存儲(chǔ)需自行配置

3.application.yml

spring:
 cache:
  ehcache:
   config: classpath:/ehcache.xml

4.啟動(dòng)類添加

@EnableCaching

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
 
@EnableCaching
@SpringBootApplication
public class DemoApplication {
 
  public static void main(String[] args) {
    SpringApplication.run(DemoApplication.class, args);
  }
 
}

5.springcloud 中使用cache

import net.sf.ehcache.Cache;
import net.sf.ehcache.CacheManager;
import net.sf.ehcache.Element;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.ClassPathResource;
import org.springframework.stereotype.Component;
 
import java.io.IOException;
 
 
/**
 * @Author: Peacock__
 * @Date: 2019/6/14 17:30
 */
@Component
public class CacheService {
 
  @Autowired
  private CacheManager cacheManager;
  /**
   * 從緩存中獲取數(shù)據(jù)
   * @return
   * @throws IOException
   */
  public String getCache() throws IOException {
   String res = "";
 
    Cache cache = cacheManager.getCache("usercache");
    if(cache != null){
      Element element = cache.get("name");
      if(element != null){
        Object objectValue = element.getObjectValue();
        res = (String) objectValue;
      }
    }
    return res;
  }
 
  /**
   * 數(shù)據(jù)存入緩存
   * @param data
   * @throws IOException
   */
  public void putCache(String data) throws IOException {
    //若cacheManager被關(guān)閉，則重新創(chuàng)建
    if(cacheManager == null || cacheManager.getStatus().intValue() != 1){
      cacheManager = new CacheManager(new ClassPathResource("ehcache.xml").getInputStream());
    }
    Cache cache = cacheManager.getCache("usercache");
    //處理成要緩存的數(shù)據(jù)
 
    //存入緩存（注意：需要保證存入緩存的數(shù)據(jù)都是可序列化的）
    cache.put(new Element("name", data));
    /**
     * ehcache和其它緩存類似，需要flush或shutdown后才會(huì)持久化到磁盤。
     * 會(huì)生成.data 的數(shù)據(jù)文件和 .index 的索引文件，方便重啟恢復(fù)。
     * ehcache恢復(fù)數(shù)據(jù)是根據(jù).index索引文件來進(jìn)行數(shù)據(jù)恢復(fù)的。
     * 當(dāng)程序再次啟動(dòng)的時(shí)候，ehcache的一個(gè)方法會(huì)將.data文件和.index文件的修改時(shí)間進(jìn)行比較，如果不符合直接將.index文件刪除。
     */
    //將所有緩存項(xiàng)從內(nèi)存刷新到磁盤存儲(chǔ)，并從DiskStore刷新到磁盤。
//    cache.flush();
    //更新.index文件
//    cacheManager.shutdown();
  }
}

6.controller層

import java.io.IOException;
 
@RestController
public class AppController{
 
 
  @Autowired
  private CacheService cacheService;
 
  @RequestMapping("/setName")
  public String setName() {
 
    try {
      cacheService.putCache( "heshan");
    } catch (IOException e) {
      e.printStackTrace();
    }
    return "yes";
  }
  @RequestMapping("/getName")
  public String getName() {
 
    String res = null;
    try {
      res = cacheService.getCache( );
    } catch (IOException e) {
      e.printStackTrace();
    }
    return res;
  }
}

結(jié)果：