Spring Boot Cache使用方法整合代碼實(shí)例
參考:
Spring Cache擴(kuò)展功能實(shí)現(xiàn)
使用本地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); } } // 加入到緩存管理器進(jìn)行管理 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)文章
Idea servlet映射方法優(yōu)缺點(diǎn)對比
這篇文章主要介紹了Idea servlet映射方法優(yōu)缺點(diǎn)對比,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-11-11Spring-cloud 服務(wù)發(fā)現(xiàn)與消費(fèi)(以ribbon為例)
這篇文章主要介紹了Spring-cloud 服務(wù)發(fā)現(xiàn)與消費(fèi)(以ribbon為例),小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-04-04Spring rest接口中的LocalDateTime日期類型轉(zhuǎn)時(shí)間戳
這篇文章主要介紹了Spring rest接口中的LocalDateTime日期類型轉(zhuǎn)時(shí)間戳的方法,Java程序中一般將日期類型定義為LocalDateTime,數(shù)據(jù)庫中保存的時(shí)間是0時(shí)區(qū)的時(shí)間2023-03-03Spring中Service注入多個(gè)實(shí)現(xiàn)類的方法詳解
這篇文章主要介紹了Spring中Service注入多個(gè)實(shí)現(xiàn)類的方法詳解,Spring是一個(gè)開源的Java框架,用于構(gòu)建企業(yè)級應(yīng)用程序,它提供了許多功能,如依賴注入、面向切面編程、數(shù)據(jù)訪問、Web開發(fā)等,需要的朋友可以參考下2023-07-07通過Java 程序獲取Word中指定圖片的坐標(biāo)位置
本文介紹通過Java程序獲取Word文檔中指定圖片的坐標(biāo)位置,程序運(yùn)行環(huán)境是jdk1.8開發(fā)環(huán)境idea,通過java程序代碼給大家介紹的非常詳細(xì),需要的朋友參考下吧2021-05-05