Java本地緩存工具之LoadingCache的使用詳解
前言
在工作總常常需要用到緩存,而redis往往是首選,但是短期的數據緩存一般我們還是會用到本地緩存。本文提供一個我在工作中用到的緩存工具,該工具代碼為瞭演示做瞭一些調整。如果拿去使用的話,可以考慮做成註入Bean對象,看具體需求瞭。
環境依賴
先添加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的使用詳解的文章就介紹到這瞭,更多相關Java LoadingCache本地緩存內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- java WebSocket客戶端斷線重連的實現方法
- Java TimedCache 帶時間緩存工具類詳解使用
- Java輕松使用工具類實現獲取wav時間長度
- Java輕松使用工具類實現獲取MP3音頻時長
- springboot整合websocket最基礎入門使用教程詳解