快捷導(dǎo)航

Java高性能緩存框架之Caffeine詳解

更新時間：2023年12月29日 08:32:23 作者：_Romeo

這篇文章主要介紹了Java高性能緩存框架之Caffeine詳解,Caffeine是一個基于Java8的高性能緩存框架,號稱趨于完美,Caffeine受啟發(fā)于Guava?Cache的API,使用API和Guava是一致的,需要的朋友可以參考下

Caffeine緩存框架

Caffeine是一個基于Java8的高性能緩存框架，號稱趨于完美。

Caffeine受啟發(fā)于Guava Cache的API，使用API和Guava是一致的。

它借鑒了Guava Cache和ConcurrentLinkedHashMap的設(shè)計經(jīng)驗。

在Springboot中使用Caffeine

在工程的pom文件引入caffeine的依賴，如下：

<dependency>
            <groupId>com.github.ben-manes.caffeine</groupId>
            <artifactId>caffeine</artifactId>
            <version>2.6.2</version>
        </dependency>

創(chuàng)建一個抽象類AbstractCaffineCache，該類使用范型來約束緩存的數(shù)據(jù)類型，并實現(xiàn)了三個方法，put、get、clear。

/**
 * @Author ZhuZiKai
 * @Description
 * @date 2022/3/7 10:44
 */
public abstract class AbstractCaffeineCache<T> {
    protected LoadingCache<String, T> loadingCache;
    abstract LoadingCache<String, T> createLoadingCache();
    public boolean put(String key, T value) {
        if (loadingCache == null) {
            loadingCache = createLoadingCache();
        }
        loadingCache.put(key, value);
        return Boolean.TRUE;
    }
    public T get(String key) {
        if (loadingCache == null) {
            loadingCache = createLoadingCache();
        }
        try {
            return loadingCache.get(key);
        } catch (Exception e) {
            return null;
        }
    }
    public boolean clear(String key) {
        if (loadingCache == null) {
            loadingCache = createLoadingCache();
        }
        loadingCache.invalidate(key);
        return Boolean.TRUE;
    }
}

創(chuàng)建MyCaffeineCache的緩存類，該類緩存類。創(chuàng)建LoadingCache類，該類設(shè)置了緩存過期的時間，最大的緩存?zhèn)€數(shù)。

/**
 * @Author ZhuZiKai
 * @Description
 * @date 2022/3/7 10:44
 */
public class MyCaffeineCache extends AbstractCaffeineCache {
    /**
     * Caffeine配置說明：
     * initialCapacity=[integer]: 初始的緩存空間大小
     * maximumSize=[long]: 緩存的最大條數(shù)
     * maximumWeight=[long]: 緩存的最大權(quán)重
     * expireAfterAccess=[duration]: 最后一次寫入或訪問后經(jīng)過固定時間過期
     * expireAfterWrite=[duration]: 最后一次寫入后經(jīng)過固定時間過期
     * refreshAfterWrite=[duration]: 創(chuàng)建緩存或者最近一次更新緩存后經(jīng)過固定的時間間隔，刷新緩存
     * recordStats：開發(fā)統(tǒng)計功能
     *
     * @return
     */
    @Override
    LoadingCache createLoadingCache() {
        loadingCache = Caffeine.newBuilder()
                .expireAfterWrite(1000L, TimeUnit.MILLISECONDS)
                .initialCapacity(10)
                .maximumSize(100)
                .recordStats()
                .build((CacheLoader<String, String>) key -> null);
        return loadingCache;
    }
}

將MyCaffeineCache注入到spring ioc中，代碼如下：

/**
 * @Author ZhuZiKai
 * @Description
 * @date 2022/3/7 10:45
 */
@Configuration
public class CaffeineCacheConfig {
    @Bean
    public MyCaffeineCache MyCaffeineCache(){
        return new MyCaffeineCache();
    }
}

如何使用。

/**
 * @Author ZhuZiKai
 * @Description
 * @date 2022/1/6 9:45
 */
@Aspect
@Component
@Slf4j
public class IdempotentAspect extends BaseController {
    @Resource
    private MyCaffeineCache cache;
    private static final ThreadLocalUtil threadLocalUtil = new ThreadLocalUtil();
    @Around(value = "@annotation(idempotent)")
    public Object around(ProceedingJoinPoint joinPoint, Idempotent idempotent) throws Throwable {
        UserBO user = getUserBO(request);
        Integer userId = user.getUserId();
        String userRequest = userId + request.getRequestURI();
        threadLocalUtil.setLocalUserRequest(userRequest);
        Object uuid = cache.get(userRequest);
        VerifyUtils.throwWhen(uuid != null, idempotent.value());
        return joinPoint.proceed();
    }
    @AfterReturning(value = "@annotation(idempotent)")
    public void afterReturning(JoinPoint point, Idempotent idempotent) {
        try {
            cache.put(threadLocalUtil.getLocalUserRequest(), UUIDUtil.simpleUUID());
        } finally {
            threadLocalUtil.clearLocalUserRequest();
        }
    }
}

使用本地緩存可以加快頁面響應(yīng)速度，緩存分布式緩存讀壓力，大量、高并發(fā)請求的網(wǎng)站比較適用

Caffeine配置說明：