使用guava cache在本地緩存熱點數據

某些熱點數據在短時間內可能會被成千上萬次訪問，所以除了放在redis之外，還可以放在本地內存，也就是JVM的內存中。

我們可以使用google的guava cache組件實現本地緩存，之所以選擇guava是因為它可以控制key和value的大小和超時時間，可以配置LRU策略且guava是線程安全的。

首先引入guava cache

<dependency>
      <groupId>com.google.guava</groupId>
      <artifactId>guava</artifactId>
      <version>18.0</version>
</dependency>

編寫CacheService接口

public interface CacheService {
    //存方法
    void setCommonCache(String key,Object value);
    //取方法
    Object getFromCommonCache(String key);
}

實現CacheService（@PostConstruct注解的方法將會在依賴注入完成后被自動調用。）

@Service
public class CacheServiceImpl implements CacheService {

    private Cache<String,Object> commonCache=null;


    @PostConstruct
    public void init(){
        commonCache= CacheBuilder.newBuilder()
                //緩存初始容量10
                .initialCapacity(10)
                //最多100個key，超過按LRU策略移除
                .maximumSize(100)
                //寫入后多少秒過期
                .expireAfterWrite(60, TimeUnit.SECONDS).build();
    }
    @Override
    public void setCommonCache(String key, Object value) {
        commonCache.put(key,value);
    }

    @Override
    public Object getFromCommonCache(String key) {
        return commonCache.getIfPresent(key);
    }
}

使用CacheService

@RequestMapping(value = "/get",method = {RequestMethod.GET})
    @ResponseBody
    public CommonReturnType getItem(@RequestParam(name = "id")Integer id){
        //在本地緩存中查找
        ItemModel itemModel= (ItemModel) cacheService.getFromCommonCache("item_"+id);

        if(itemModel==null){
            //本地緩存沒有則到redis緩存中查找
            itemModel= (ItemModel) redisTemplate.opsForValue().get("item_"+id);
            if(itemModel==null){
                //都沒有則到數據庫查找，找到后放入redis中
                itemModel = itemService.getItemById(id);
                redisTemplate.opsForValue().set("item_"+id,itemModel);
                redisTemplate.expire("item_"+id,10, TimeUnit.MINUTES);
            }
            //本地緩存沒有時，在redis或數據庫找到后再放入本地緩存
            cacheService.setCommonCache("item_"+id,itemModel);
        }


        ItemVO itemVO = convertVOFromModel(itemModel);

        return CommonReturnType.create(itemVO);

    }