Spring Boot Cache使用方法整合代碼實例
更新時間:2020年02月27日 11:31:45 作者:Kancy
這篇文章主要介紹了Spring Boot Cache使用方法整合代碼實例,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
參考:
使用本地Caffeine緩存
引入依賴包
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-cache</artifactId> </dependency> <dependency> <groupId>com.github.ben-manes.caffeine</groupId> <artifactId>caffeine</artifactId> <version>2.6.2</version> </dependency>
自定義Caffeine配置
CachingConfig.java
package com.vcredit.vmp.checkcenter.config;
import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.vcredit.vmp.checkcenter.common.properties.CaffeineCacheProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.caffeine.CaffeineCache;
import org.springframework.cache.support.SimpleCacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import java.time.Duration;
import java.util.*;
/**
* 緩存配置
* @author kancy
*/
@Configuration
@EnableCaching
public class CachingConfig {
@Autowired
CaffeineCacheProperties caffeineCacheProperties;
/**
* 創(chuàng)建基于Caffeine的Cache Manager
* @return
*/
@Bean
@Primary
@ConditionalOnProperty(prefix = "system.cache.caffeine" , name = "enabled", havingValue = "true")
public CacheManager caffeineCacheManager() {
SimpleCacheManager cacheManager = new SimpleCacheManager();
Map<String, CaffeineCache> cacheMap = new HashMap();
// 設(shè)置全局配置的本地緩存
List<String> globalCacheNames = caffeineCacheProperties.getCacheName();
if(globalCacheNames !=null && !globalCacheNames.isEmpty()){
addCacheObject(cacheMap, globalCacheNames, caffeineCacheProperties.getExpireAfterWrite(),
caffeineCacheProperties.getExpireAfterAccess(), caffeineCacheProperties.getMaximumSize());
}
// 設(shè)置自定義屬性緩存, 可以覆蓋全局緩存
List<CaffeineCacheProperties.Config> configs = caffeineCacheProperties.getConfigs();
if(configs != null && !configs.isEmpty()){
for (CaffeineCacheProperties.Config config : configs) {
List<String> cacheNames = config.getCacheName();
if (cacheNames == null || cacheNames.isEmpty()){
continue;
}
Duration expireAfterWrite = Optional.ofNullable(config.getExpireAfterWrite()).orElse(caffeineCacheProperties.getExpireAfterWrite());
Duration expireAfterAccess = Optional.ofNullable(config.getExpireAfterAccess()).orElse(caffeineCacheProperties.getExpireAfterAccess());
Long maximumSize = Optional.ofNullable(config.getMaximumSize()).orElse(caffeineCacheProperties.getMaximumSize());
addCacheObject(cacheMap, cacheNames, expireAfterWrite, expireAfterAccess, maximumSize);
}
}
// 加入到緩存管理器進行管理
cacheManager.setCaches(cacheMap.values());
return cacheManager;
}
private void addCacheObject(Map<String, CaffeineCache> cacheMap, List<String> cacheNames, Duration expireAfterWrite, Duration expireAfterAccess, Long maximumSize) {
for (String cacheName : cacheNames) {
// spring.cache.caffeine: maximumSize=500,expireAfterAccess=10s,expireAfterWrite=15s
Caffeine<Object, Object> recordStats = Caffeine.newBuilder().recordStats().maximumSize(maximumSize);
if(expireAfterAccess != null) recordStats.expireAfterAccess(expireAfterAccess);
if(expireAfterWrite != null) recordStats.expireAfterWrite(expireAfterWrite);
Cache<Object, Object> cache = recordStats.build();
CaffeineCache caffeineCache = new CaffeineCache(cacheName,cache);
// 覆蓋添加
cacheMap.put(cacheName, caffeineCache);
}
}
}
CaffeineCacheProperties.java
package com.vcredit.vmp.checkcenter.common.properties;
import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import java.time.Duration;
import java.util.List;
/**
* Caffeine本地緩存自定義配置
* @author kancy
*/
@Getter
@Setter
@Configuration
@ConfigurationProperties("system.cache.caffeine")
@ConditionalOnProperty(prefix = "system.cache.caffeine" , name = "enabled", havingValue = "true")
public class CaffeineCacheProperties {
private List<String> cacheName;
private Duration expireAfterWrite;
private Duration expireAfterAccess;
private Long maximumSize = Long.valueOf(-1);
private List<Config> configs;
@Getter
@Setter
public static class Config {
private List<String> cacheName;
Duration expireAfterWrite;
Duration expireAfterAccess;
Long maximumSize;
}
}
application.yml
system.cache.caffeine: enabled: true # 全局配置 cacheName: cache1,cache2,cache3 expireAfterWrite: 60s expireAfterAccess: 30s maximumSize: 500 # 自定義配置,cacheName相同可覆蓋全局 configs: - cacheName: checkApplyCache expireAfterAccess: 10s - cacheName: userQueryCache expireAfterAccess: 15s
使用緩存
@Cacheable(value = { "checkApplyCache" }, key="#req.md5")
public Result check(CheckReq req) {
// your code...
return Result.ok();
}
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Spring-cloud 服務(wù)發(fā)現(xiàn)與消費(以ribbon為例)
這篇文章主要介紹了Spring-cloud 服務(wù)發(fā)現(xiàn)與消費(以ribbon為例),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2018-04-04
Spring rest接口中的LocalDateTime日期類型轉(zhuǎn)時間戳
這篇文章主要介紹了Spring rest接口中的LocalDateTime日期類型轉(zhuǎn)時間戳的方法,Java程序中一般將日期類型定義為LocalDateTime,數(shù)據(jù)庫中保存的時間是0時區(qū)的時間2023-03-03
Spring中Service注入多個實現(xiàn)類的方法詳解
這篇文章主要介紹了Spring中Service注入多個實現(xiàn)類的方法詳解,Spring是一個開源的Java框架,用于構(gòu)建企業(yè)級應(yīng)用程序,它提供了許多功能,如依賴注入、面向切面編程、數(shù)據(jù)訪問、Web開發(fā)等,需要的朋友可以參考下2023-07-07
通過Java 程序獲取Word中指定圖片的坐標(biāo)位置
本文介紹通過Java程序獲取Word文檔中指定圖片的坐標(biāo)位置,程序運行環(huán)境是jdk1.8開發(fā)環(huán)境idea,通過java程序代碼給大家介紹的非常詳細,需要的朋友參考下吧2021-05-05

