中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Java本地緩存工具LoadingCache怎么使用

發布時間:2022-01-05 16:04:47 來源:億速云 閱讀:293 作者:iii 欄目:開發技術

這篇文章主要介紹“Java本地緩存工具LoadingCache怎么使用”,在日常操作中,相信很多人在Java本地緩存工具LoadingCache怎么使用問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”Java本地緩存工具LoadingCache怎么使用”的疑惑有所幫助!接下來,請跟著小編一起來學習吧!

環境依賴

先添加maven依賴

        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>30.1.1-jre</version>
        </dependency>
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.5.2</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

代碼

不廢話,上代碼了。

package ai.guiji.csdn.tools;
 
import cn.hutool.core.thread.ThreadUtil;
import com.google.common.cache.*;
import lombok.extern.slf4j.Slf4j;
 
import java.text.MessageFormat;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
import java.util.function.Function;
import java.util.stream.LongStream;
 
/** @Author 劍客阿良_ALiang @Date 2021/12/30 17:57 @Description: 緩存工具 */
@Slf4j
public class CacheUtils {
 
  private static LoadingCache<Long, String> cache;
 
  /**
   * 初始化緩存方法
   *
   * @param totleCount 緩存池上限
   * @param overtime 超時時間
   * @param unit 時間單位
   * @param handleNotExist 處理不存在key方法
   * @param handleRemove 移除主鍵消費
   */
  private static void initCache(
      Integer totleCount,
      Integer overtime,
      TimeUnit unit,
      Function<Long, String> handleNotExist,
      Consumer<Long> handleRemove) {
    cache =
        CacheBuilder.newBuilder()
            // 緩存池大小
            .maximumSize(totleCount)
            // 設置時間對象沒有被讀/寫訪問則對象從內存中刪除
            .expireAfterWrite(overtime, unit)
            // 移除監聽器
            .removalListener(
                new RemovalListener<Long, String>() {
                  @Override
                  public void onRemoval(RemovalNotification<Long, String> rn) {
                    handleRemove.accept(rn.getKey());
                  }
                })
            .recordStats()
            .build(
                new CacheLoader<Long, String>() {
                  @Override
                  public String load(Long aLong) throws Exception {
                    return handleNotExist.apply(aLong);
                  }
                });
    log.info("初始化緩存");
  }
 
  /**
   * 存入緩存
   *
   * @param key 鍵
   * @param value 值
   */
  public static void put(Long key, String value) {
    try {
      log.info("緩存存入:[{}]-[{}]", key, value);
      cache.put(key, value);
    } catch (Exception exception) {
      log.error("存入緩存異常", exception);
    }
  }
 
  /**
   * 批量存入緩存
   *
   * @param map 映射
   */
  public static void putMap(Map<Long, String> map) {
    try {
      log.info("批量緩存存入:[{}]", map);
      cache.putAll(map);
    } catch (Exception exception) {
      log.error("批量存入緩存異常", exception);
    }
  }
 
  /**
   * 獲取緩存
   *
   * @param key 鍵
   */
  public static String get(Long key) {
    try {
      return cache.get(key);
    } catch (Exception exception) {
      log.error("獲取緩存異常", exception);
      return null;
    }
  }
 
  /**
   * 刪除緩存
   *
   * @param key 鍵
   */
  public static void removeKey(Long key) {
    try {
      cache.invalidate(key);
    } catch (Exception exception) {
      log.error("刪除緩存異常", exception);
    }
  }
 
  /**
   * 批量刪除緩存
   *
   * @param keys 鍵
   */
  public static void removeAll(Iterable<Long> keys) {
    try {
      cache.invalidateAll(keys);
    } catch (Exception exception) {
      log.error("批量刪除緩存異常", exception);
    }
  }
 
  /** 清理緩存 */
  public static void clear() {
    try {
      cache.invalidateAll();
    } catch (Exception exception) {
      log.error("清理緩存異常", exception);
    }
  }
 
  /**
   * 獲取緩存大小
   *
   * @return 長度
   */
  public static long size() {
    return cache.size();
  }
 
  public static void main(String[] args) {
    initCache(
        Integer.MAX_VALUE,
        10,
        TimeUnit.SECONDS,
        k -> {
          log.info("緩存:[{}],不存在", k);
          return "";
        },
        x -> log.info("緩存:[{}],已經移除", x));
    System.out.println(size());
    LongStream.range(0, 10).forEach(a -> put(a, MessageFormat.format("tt-{0}", a)));
    System.out.println(cache.asMap());
    ThreadUtil.sleep(5000);
    LongStream.range(0, 10)
        .forEach(
            a -> {
              System.out.println(get(a));
              ThreadUtil.sleep(1000);
            });
    System.out.println(cache.asMap());
    ThreadUtil.sleep(10000);
    System.out.println(cache.asMap());
  }
}

代碼說明

1、在初始化loadingCache的時候,可以添加緩存的最大數量、消逝時間、消逝或者移除監聽事件、不存在鍵處理等等。在上面的代碼中,我初始化緩存大小為Integer的最大值,寫入10秒后消逝,如不存在key返回空字符串等等。

2、該類也提供了put、putAll、get、remove、removeAll、clear、size方法,可以對緩存進行存、取、刪、清理、大小等操作。

3、main演示方法中,先往緩存存入10個數據,然后過5秒后每秒取一個數據,并且打印一下緩存中的全部內容。

4、補充一句LoadingCache是線程安全的哦。

演示一下

15:31:53.495 [main] INFO ai.guiji.csdn.tools.CacheUtils - 初始化緩存
0
15:31:53.502 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[0]-[tt-0]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[1]-[tt-1]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[2]-[tt-2]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[3]-[tt-3]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[4]-[tt-4]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[5]-[tt-5]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[6]-[tt-6]
15:31:53.508 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[7]-[tt-7]
15:31:53.509 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[8]-[tt-8]
15:31:53.509 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存存入:[9]-[tt-9]
{6=tt-6, 5=tt-5, 0=tt-0, 8=tt-8, 7=tt-7, 2=tt-2, 1=tt-1, 9=tt-9, 3=tt-3, 4=tt-4}
tt-0
tt-1
tt-2
tt-3
tt-4
15:32:03.572 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[5],已經移除
15:32:03.573 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[6],已經移除
15:32:03.573 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[5],不存在
15:32:04.581 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[6],不存在
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[0],已經移除
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[7],已經移除
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[8],已經移除
15:32:05.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[7],不存在
15:32:06.589 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[8],不存在
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[1],已經移除
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[2],已經移除
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[9],已經移除
15:32:07.591 [main] INFO ai.guiji.csdn.tools.CacheUtils - 緩存:[9],不存在
{6=, 5=, 8=, 7=, 9=}
{}
Process finished with exit code 0

可以看到,后面的5-9在內存中已經不存在對應的值了。

到此,關于“Java本地緩存工具LoadingCache怎么使用”的學習就結束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續學習更多相關知識,請繼續關注億速云網站,小編會繼續努力為大家帶來更多實用的文章!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

开鲁县| 景泰县| 临洮县| 文水县| 玛曲县| 达孜县| 仁寿县| 万盛区| 兴城市| 新乐市| 张家界市| 浦江县| 西藏| 延津县| 西和县| 云霄县| 旬邑县| 青阳县| 陵水| 突泉县| 信丰县| 新宾| 大同市| 南乐县| 沂南县| 万年县| 辽阳县| 河间市| 昌宁县| 资兴市| 青冈县| 大厂| 修武县| 敦化市| 沿河| 林芝县| 武穴市| 藁城市| 龙海市| 壤塘县| 新竹县|