欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

如何基于LoadingCache實(shí)現(xiàn)Java本地緩存

 更新時(shí)間:2019年12月23日 09:29:02   作者:1024。  
這篇文章主要介紹了如何基于LoadingCache實(shí)現(xiàn)Java本地緩存,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

這篇文章主要介紹了如何基于LoadingCache實(shí)現(xiàn)Java本地緩存,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

前言

Guava是Google開(kāi)源出來(lái)的一套工具庫(kù)。其中提供的cache模塊非常方便,是一種與ConcurrentMap相似的緩存Map。

官方地址:https://github.com/google/guava/wiki/CachesExplained

開(kāi)始構(gòu)建

一. 添加依賴(lài)

<dependency>
  <groupId>com.google.guava</groupId>
  <artifactId>guava</artifactId>
  <version>27.1-jre</version>
</dependency>

二.創(chuàng)建 CacheLoader

LoadingCache<Long, String> cache = CacheBuilder.newBuilder()
        //緩存池大小,在緩存項(xiàng)接近該大小時(shí), Guava開(kāi)始回收舊的緩存項(xiàng)
        .maximumSize(GUAVA_CACHE_SIZE)
        //設(shè)置時(shí)間對(duì)象沒(méi)有被讀/寫(xiě)訪問(wèn)則對(duì)象從內(nèi)存中刪除(在另外的線程里面不定期維護(hù))
        .expireAfterAccess(10, TimeUnit.MINUTES)
        //移除監(jiān)聽(tīng)器,緩存項(xiàng)被移除時(shí)會(huì)觸發(fā)
        .removalListener(new RemovalListener <Long, String>() {
          @Override
          public void onRemoval(RemovalNotification<Long, String> rn) {
            //執(zhí)行邏輯操作
          }
        })
        //開(kāi)啟Guava Cache的統(tǒng)計(jì)功能
        .recordStats()
        .build(cacheLoader);

三.個(gè)人封裝的工具類(lèi)

package com.xxx;

import com.google.common.cache.*;
import org.slf4j.Logger;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.TimeUnit;

public class CacheManager {

  private static Logger log = Log.get();

  /** 緩存項(xiàng)最大數(shù)量 */
  private static final long GUAVA_CACHE_SIZE = 100000;

  /** 緩存時(shí)間:天 */
  private static final long GUAVA_CACHE_DAY = 10;

  /** 緩存操作對(duì)象 */
  private static LoadingCache<Long, String> GLOBAL_CACHE = null;

  static {
    try {
      GLOBAL_CACHE = loadCache(new CacheLoader <Long, String>() {
        @Override
        public String load(Long key) throws Exception {
          // 處理緩存鍵不存在緩存值時(shí)的處理邏輯
          return "";
        }
      });
    } catch (Exception e) {
      log.error("初始化Guava Cache出錯(cuò)", e);
    }
  }

  /**
   * 全局緩存設(shè)置
   *
   * 緩存項(xiàng)最大數(shù)量:100000
   * 緩存有效時(shí)間(天):10
   *
   *
   * @param cacheLoader
   * @return
   * @throws Exception
   */
  private static LoadingCache<Long, String> loadCache(CacheLoader<Long, String> cacheLoader) throws Exception {
    LoadingCache<Long, String> cache = CacheBuilder.newBuilder()
        //緩存池大小,在緩存項(xiàng)接近該大小時(shí), Guava開(kāi)始回收舊的緩存項(xiàng)
        .maximumSize(GUAVA_CACHE_SIZE)
        //設(shè)置時(shí)間對(duì)象沒(méi)有被讀/寫(xiě)訪問(wèn)則對(duì)象從內(nèi)存中刪除(在另外的線程里面不定期維護(hù))
        .expireAfterAccess(GUAVA_CACHE_DAY, TimeUnit.DAYS)
        // 設(shè)置緩存在寫(xiě)入之后 設(shè)定時(shí)間 后失效
        .expireAfterWrite(GUAVA_CACHE_DAY, TimeUnit.DAYS)
        //移除監(jiān)聽(tīng)器,緩存項(xiàng)被移除時(shí)會(huì)觸發(fā)
        .removalListener(new RemovalListener <Long, String>() {
          @Override
          public void onRemoval(RemovalNotification<Long, String> rn) {
            //邏輯操作
          }
        })
        //開(kāi)啟Guava Cache的統(tǒng)計(jì)功能
        .recordStats()
        .build(cacheLoader);
    return cache;
  }

  /**
   * 設(shè)置緩存值
   * 注: 若已有該key值,則會(huì)先移除(會(huì)觸發(fā)removalListener移除監(jiān)聽(tīng)器),再添加
   *
   * @param key
   * @param value
   */
  public static void put(Long key, String value) {
    try {
      GLOBAL_CACHE.put(key, value);
    } catch (Exception e) {
      log.error("設(shè)置緩存值出錯(cuò)", e);
    }
  }

  /**
   * 批量設(shè)置緩存值
   *
   * @param map
   */
  public static void putAll(Map<? extends Long, ? extends String> map) {
    try {
      GLOBAL_CACHE.putAll(map);
    } catch (Exception e) {
      log.error("批量設(shè)置緩存值出錯(cuò)", e);
    }
  }

  /**
   * 獲取緩存值
   * 注:如果鍵不存在值,將調(diào)用CacheLoader的load方法加載新值到該鍵中
   *
   * @param key
   * @return
   */
  public static String get(Long key) {
    String token = "";
    try {
      token = GLOBAL_CACHE.get(key);
    } catch (Exception e) {
      log.error("獲取緩存值出錯(cuò)", e);
    }
    return token;
  }

    /**
   * 移除緩存
   *
   * @param key
   */
  public static void remove(Long key) {
    try {
      GLOBAL_CACHE.invalidate(key);
    } catch (Exception e) {
      log.error("移除緩存出錯(cuò)", e);
    }
  }

  /**
   * 批量移除緩存
   *
   * @param keys
   */
  public static void removeAll(Iterable<Long> keys) {
    try {
      GLOBAL_CACHE.invalidateAll(keys);
    } catch (Exception e) {
      log.error("批量移除緩存出錯(cuò)", e);
    }
  }

  /**
   * 清空所有緩存
   */
  public static void removeAll() {
    try {
      GLOBAL_CACHE.invalidateAll();
    } catch (Exception e) {
      log.error("清空所有緩存出錯(cuò)", e);
    }
  }

  /**
   * 獲取緩存項(xiàng)數(shù)量
   *
   * @return
   */
  public static long size() {
    long size = 0;
    try {
      size = GLOBAL_CACHE.size();
    } catch (Exception e) {
      log.error("獲取緩存項(xiàng)數(shù)量出錯(cuò)", e);
    }
    return size;
  }
}

總結(jié)

1.移除機(jī)制

guava做cache時(shí)候數(shù)據(jù)的移除分為被動(dòng)移除和主動(dòng)移除兩種。

被動(dòng)移除分為三種:1).基于大小的移除:數(shù)量達(dá)到指定大小,會(huì)把不常用的鍵值移除

         2).基于時(shí)間的移除:expireAfterAccess(long, TimeUnit) 根據(jù)某個(gè)鍵值對(duì)最后一次訪問(wèn)之后多少時(shí)間后移除
                   expireAfterWrite(long, TimeUnit) 根據(jù)某個(gè)鍵值對(duì)被創(chuàng)建或值被替換后多少時(shí)間移除

         3).基于引用的移除:主要是基于java的垃圾回收機(jī)制,根據(jù)鍵或者值的引用關(guān)系決定移除

主動(dòng)移除分為三種:1).單獨(dú)移除:Cache.invalidate(key)

         2).批量移除:Cache.invalidateAll(keys)

         3).移除所有:Cache.invalidateAll()

如果配置了移除監(jiān)聽(tīng)器RemovalListener,則在所有移除的動(dòng)作時(shí)會(huì)同步執(zhí)行該listener下的邏輯。

如需改成異步,使用:RemovalListeners.asynchronous(RemovalListener, Executor)

2.遇到的問(wèn)題

1). 在put操作之前,如果已經(jīng)有該鍵值,會(huì)先觸發(fā)removalListener移除監(jiān)聽(tīng)器,再添加

2). 配置了expireAfterAccess和expireAfterWrite,但在指定時(shí)間后沒(méi)有被移除。

解決方案:CacheBuilder在文檔上有說(shuō)明

If expireAfterWrite or expireAfterAccess is requested entries may be evicted on each cache modification, on occasional cache accesses, or on calls to Cache.cleanUp(). Expired entries may be counted in Cache.size(), but will never be visible to read or write operations.

翻譯過(guò)來(lái)大概的意思是:CacheBuilder構(gòu)建的緩存不會(huì)在特定時(shí)間自動(dòng)執(zhí)行清理和回收工作,也不會(huì)在某個(gè)緩存項(xiàng)過(guò)期后馬上清理,它不會(huì)啟動(dòng)一個(gè)線程來(lái)進(jìn)行緩存維護(hù),因?yàn)?/p>

a)線程相對(duì)較重

b)某些環(huán)境限制線程的創(chuàng)建。它會(huì)在寫(xiě)操作時(shí)順帶做少量的維護(hù)工作,或者偶爾在讀操作時(shí)做

當(dāng)然,也可以創(chuàng)建自己的維護(hù)線程,以固定的時(shí)間間隔調(diào)用Cache.cleanUp()。

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • SpringBoot使用Druid數(shù)據(jù)源的配置方法

    SpringBoot使用Druid數(shù)據(jù)源的配置方法

    這篇文章主要介紹了SpringBoot使用Druid數(shù)據(jù)源的配置方法,文中代碼實(shí)例相結(jié)合的形式給大家介紹的非常詳細(xì),需要的朋友參考下吧
    2018-04-04
  • Idea啟動(dòng)多個(gè)SpringBoot項(xiàng)目的3種最新方案

    Idea啟動(dòng)多個(gè)SpringBoot項(xiàng)目的3種最新方案

    SpringBoot自帶Tomcat,直接運(yùn)行main方法里面的SpringApplication.run即可,并且訪問(wèn)時(shí)不需要帶項(xiàng)目名,這篇文章主要介紹了Idea啟動(dòng)多個(gè)SpringBoot項(xiàng)目的3種方案,需要的朋友可以參考下
    2023-02-02
  • 淺析java程序入口main()方法

    淺析java程序入口main()方法

    這篇文章主要介紹了淺析java程序入口main()方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2019-07-07
  • Intellij IDEA安裝lombok插件及使用詳解

    Intellij IDEA安裝lombok插件及使用詳解

    今天小編就為大家分享一篇關(guān)于Intellij IDEA安裝lombok插件及使用詳解,小編覺(jué)得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來(lái)看看吧
    2018-12-12
  • 一文教你學(xué)會(huì)搭建SpringBoot分布式項(xiàng)目

    一文教你學(xué)會(huì)搭建SpringBoot分布式項(xiàng)目

    這篇文章主要為大家詳細(xì)介紹了搭建SpringBoot分布式項(xiàng)目的相關(guān)知識(shí),文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下
    2024-01-01
  • Eclipse/MyEclipse轉(zhuǎn)IntelliJ IDEA完全攻略(圖文)

    Eclipse/MyEclipse轉(zhuǎn)IntelliJ IDEA完全攻略(圖文)

    這篇文章主要介紹了Eclipse/MyEclipse轉(zhuǎn)IntelliJ IDEA完全攻略(圖文),小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2019-01-01
  • SpringBoot全局異常處理之多個(gè)處理器匹配順序(最新推薦)

    SpringBoot全局異常處理之多個(gè)處理器匹配順序(最新推薦)

    這篇文章主要介紹了SpringBoot全局異常處理之多個(gè)處理器匹配順序(最新推薦),調(diào)試源碼可見(jiàn)匹配順序?yàn)椋寒惓蛹?jí)高者優(yōu)先,再清楚點(diǎn),子類(lèi)異常處理器優(yōu)先,本文給大家介紹的非常詳細(xì),感興趣的朋友一起看看吧
    2024-03-03
  • fastjson轉(zhuǎn)換對(duì)象實(shí)體@JsonProperty不生效問(wèn)題及解決

    fastjson轉(zhuǎn)換對(duì)象實(shí)體@JsonProperty不生效問(wèn)題及解決

    這篇文章主要介紹了fastjson轉(zhuǎn)換對(duì)象實(shí)體@JsonProperty不生效問(wèn)題及解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-08-08
  • SpringBoot 使用Mongo的GridFs實(shí)現(xiàn)分布式文件存儲(chǔ)操作

    SpringBoot 使用Mongo的GridFs實(shí)現(xiàn)分布式文件存儲(chǔ)操作

    這篇文章主要介紹了Spring Boot 使用Mongo的GridFs實(shí)現(xiàn)分布式文件存儲(chǔ)操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-10-10
  • try catch finally的執(zhí)行順序深入分析

    try catch finally的執(zhí)行順序深入分析

    首先執(zhí)行try,如果有異常執(zhí)行catch,無(wú)論如何都會(huì)執(zhí)行finally,當(dāng)有return以后,函數(shù)就會(huì)把這個(gè)數(shù)據(jù)存儲(chǔ)在某個(gè)位置,然后告訴主函數(shù),我不執(zhí)行了,接下來(lái)你執(zhí)行吧,所以函數(shù)就會(huì)推出
    2013-09-09

最新評(píng)論