建站
咨詢
售后
建站咨詢
新聞中心
小編給大家分享一下Java內(nèi)存緩存工具Guava LoadingCache怎么用，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！
創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設(shè),普安企業(yè)網(wǎng)站建設(shè),普安品牌網(wǎng)站建設(shè),網(wǎng)站定制,普安網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷,網(wǎng)絡(luò)優(yōu)化,普安網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶成長(zhǎng)自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。
一、Guava介紹
Guava是Google guava中的一個(gè)內(nèi)存緩存模塊，用于將數(shù)據(jù)緩存到JVM內(nèi)存中。實(shí)際項(xiàng)目開發(fā)中經(jīng)常將一些公共或者常用的數(shù)據(jù)緩存起來方便快速訪問。
Guava Cache是單個(gè)應(yīng)用運(yùn)行時(shí)的本地緩存。它不把數(shù)據(jù)存放到文件或外部服務(wù)器。如果不符合需求，可以選擇Memcached、redis等工具。
二、代碼示例
1. POM引入
com.google.guava guava 28.1-jre
2. 封裝工具類
package com.soyoung.ad.engine.util;
import com.google.common.cache.*;
import lombok.extern.slf4j.Slf4j;
import java.util.Map;
import java.util.concurrent.TimeUnit;
/**
* 功能描述
*
* @author 馬振全 2020/1/13 16:18
*/
@Slf4j
public class CacheManager {
/** 緩存項(xiàng)最大數(shù)量 */
private static final long GUAVA_CACHE_SIZE = 100000;
/** 緩存時(shí)間：天 */
private static final long GUAVA_CACHE_DAY = 10;
/** 緩存操作對(duì)象 */
private static LoadingCache GLOBAL_CACHE = null;
static {
try {
GLOBAL_CACHE = loadCache(new CacheLoader() {
@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 loadCache(CacheLoader cacheLoader) throws Exception {
LoadingCache cache = CacheBuilder.newBuilder()
//緩存池大小，在緩存項(xiàng)接近該大小時(shí)， Guava開始回收舊的緩存項(xiàng)
.maximumSize(GUAVA_CACHE_SIZE)
//設(shè)置時(shí)間對(duì)象沒有被讀/寫訪問則對(duì)象從內(nèi)存中刪除(在另外的線程里面不定期維護(hù))
.expireAfterAccess(GUAVA_CACHE_DAY, TimeUnit.DAYS)
// 設(shè)置緩存在寫入之后 設(shè)定時(shí)間 后失效
.expireAfterWrite(GUAVA_CACHE_DAY, TimeUnit.DAYS)
//移除監(jiān)聽器,緩存項(xiàng)被移除時(shí)會(huì)觸發(fā)
.removalListener(new RemovalListener() {
@Override
public void onRemoval(RemovalNotification rn) {
//邏輯操作
}
})
//開啟Guava Cache的統(tǒng)計(jì)功能
.recordStats()
.build(cacheLoader);
return cache;
}
/**
* 設(shè)置緩存值
* 注: 若已有該key值，則會(huì)先移除(會(huì)觸發(fā)removalListener移除監(jiān)聽器)，再添加
*
* @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 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 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)移除分為三種：
基于大小的移除：數(shù)量達(dá)到指定大小，會(huì)把不常用的鍵值移除
基于時(shí)間的移除：expireAfterAccess(long, TimeUnit) 根據(jù)某個(gè)鍵值對(duì)最后一次訪問之后多少時(shí)間后移除
expireAfterWrite(long, TimeUnit) 根據(jù)某個(gè)鍵值對(duì)被創(chuàng)建或值被替換后多少時(shí)間移除
基于引用的移除：主要是基于java的垃圾回收機(jī)制，根據(jù)鍵或者值的引用關(guān)系決定移除
主動(dòng)移除分為三種：1).單獨(dú)移除：Cache.invalidate(key)
2).批量移除：Cache.invalidateAll(keys)
3).移除所有：Cache.invalidateAll()
如果配置了移除監(jiān)聽器RemovalListener，則在所有移除的動(dòng)作時(shí)會(huì)同步執(zhí)行該listener下的邏輯。
如需改成異步，使用：RemovalListeners.asynchronous(RemovalListener, Executor)
2. 遇到的問題
在put操作之前，如果已經(jīng)有該鍵值，會(huì)先觸發(fā)removalListener移除監(jiān)聽器，再添加
配置了expireAfterAccess和expireAfterWrite，但在指定時(shí)間后沒有被移除。
解決方案：CacheBuilder構(gòu)建的緩存不會(huì)在特定時(shí)間自動(dòng)執(zhí)行清理和回收工作，也不會(huì)在某個(gè)緩存項(xiàng)過期后馬上清理，它不會(huì)啟動(dòng)一個(gè)線程來進(jìn)行緩存維護(hù)，因?yàn)閍）線程相對(duì)較重，b）某些環(huán)境限制線程的創(chuàng)建。它會(huì)在寫操作時(shí)順帶做少量的維護(hù)工作，或者偶爾在讀操作時(shí)做。當(dāng)然，也可以創(chuàng)建自己的維護(hù)線程，以固定的時(shí)間間隔調(diào)用Cache.cleanUp()。
看完了這篇文章，相信你對(duì)“Java內(nèi)存緩存工具Guava LoadingCache怎么用”有了一定的了解，如果想了解更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！
文章標(biāo)題：Java內(nèi)存緩存工具GuavaLoadingCache怎么用
文章位置：http://fisionsoft.com.cn/article/jjdojs.html
