Spring項(xiàng)目中使用Cache?Redis實(shí)現(xiàn)數(shù)據(jù)緩存
Spring項(xiàng)目中實(shí)現(xiàn)數(shù)據(jù)緩存
有時(shí)候我們?yōu)榱颂岣卟樵?xún)速度,會(huì)使用緩存,但是并不是所有數(shù)據(jù)都適合放到緩存中來(lái)。
像一些不經(jīng)常修改的數(shù)據(jù)、固定的數(shù)據(jù)、經(jīng)常查詢(xún)的數(shù)據(jù)等,是適合放到緩存的。
那么現(xiàn)在就把之前實(shí)現(xiàn)的字典功能里的數(shù)據(jù),放到緩存里去。
一、Spring Cache + Redis 介紹
Spring Cache是一個(gè)非常優(yōu)秀的緩存組件。
自 Spring 3.1起,提供了類(lèi)似于@Transactional注解事務(wù)的注解Cache支持,且提供了Cache抽象,方便切換各種底層Cache(如:redis)。
使用Spring Cache的優(yōu)點(diǎn):
- 提供基本的Cache抽象,方便切換各種底層Cache
- 通過(guò)注解Cache可以實(shí)現(xiàn)類(lèi)似于事務(wù)一樣,緩存邏輯透明的應(yīng)用到我們的業(yè)務(wù)代碼上,且只需要更少的代碼就可以完成
- 提供事務(wù)回滾時(shí)也自動(dòng)回滾緩存
- 支持比較復(fù)雜的緩存邏輯
二、項(xiàng)目中集成
1. 引入依賴(lài)
<dependencies>
<!-- redis -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- spring2.X集成redis所需common-pool2-->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
<version>2.6.0</version>
</dependency>
</dependencies>2. 添加 redis 配置類(lèi)
配置類(lèi)是一個(gè)比較固定的寫(xiě)法,需要了解下結(jié)構(gòu)。
// 配置類(lèi)
@Configuration
// 開(kāi)啟緩存處理
@EnableCaching
public class RedisConfig {
/**
* 自定義key規(guī)則
*
* @return
*/
@Bean
public KeyGenerator keyGenerator() {
return new KeyGenerator() {
@Override
public Object generate(Object target, Method method, Object... params) {
StringBuilder sb = new StringBuilder();
sb.append(target.getClass().getName());
sb.append(method.getName());
for (Object obj : params) {
sb.append(obj.toString());
}
return sb.toString();
}
};
}
/**
* 設(shè)置RedisTemplate規(guī)則
* @param redisConnectionFactory
* @return
*/
@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(redisConnectionFactory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
//解決查詢(xún)緩存轉(zhuǎn)換異常的問(wèn)題
ObjectMapper om = new ObjectMapper();
// 指定要序列化的域,field,get和set,以及修飾符范圍,ANY是都有包括private和public
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
// 指定序列化輸入的類(lèi)型,類(lèi)必須是非final修飾的,final修飾的類(lèi),比如String,Integer等會(huì)跑出異常
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
//序列號(hào)key value
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
/**
* 設(shè)置CacheManager緩存規(guī)則
* @param factory
* @return
*/
@Bean
public CacheManager cacheManager(RedisConnectionFactory factory) {
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
//解決查詢(xún)緩存轉(zhuǎn)換異常的問(wèn)題
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
// 配置序列化(解決亂碼的問(wèn)題),過(guò)期時(shí)間600秒
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
.entryTtl(Duration.ofSeconds(600))
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
.disableCachingNullValues();
RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
.cacheDefaults(config)
.build();
return cacheManager;
}
}主要是 3 個(gè)方法:
- 自定義key規(guī)則:可以更具我們自定義規(guī)則生成 key。
- 設(shè)置RedisTemplate規(guī)則:后續(xù)操作redis,往里存取內(nèi)容,需要用到 RedisTemplate,這里進(jìn)行相關(guān)設(shè)置。
- 設(shè)置CacheManager緩存規(guī)則:處理緩存相關(guān)的一些規(guī)則,比如緩存時(shí)間、亂碼處理等。
3. 配置文件增加 redis 配置
spring.redis.host=XXX.XXX.XXX.XX spring.redis.port=6379 spring.redis.database= 0 spring.redis.timeout=1800000 spring.redis.lettuce.pool.max-active=20 spring.redis.lettuce.pool.max-wait=-1 #最大阻塞等待時(shí)間(負(fù)數(shù)表示沒(méi)限制) spring.redis.lettuce.pool.max-idle=5 spring.redis.lettuce.pool.min-idle=0
4. 啟動(dòng)安裝好的 redis
安裝相關(guān)可以參考我之前的分享:
http://www.dhdzp.com/do/plus/view.php?aid=830685
我換了臺(tái)云服務(wù)器,也重新安裝了下,測(cè)試正常。

這是單機(jī)操作,如果需要其他主機(jī)也可以鏈接到redis,還要改個(gè)配置:

三、Spring Cache 常用注解介紹
Spring Cache 提供了相關(guān)注解,可以讓我們很方便實(shí)現(xiàn)緩存操作,先看下最常用的幾個(gè)。
1. @Cacheable
用的最多的注解,功能也很強(qiáng)大,一般用在查詢(xún)方法上。
可以根據(jù)方法對(duì)其返回結(jié)果進(jìn)行緩存,下次請(qǐng)求時(shí),如果緩存存在,則直接讀取緩存數(shù)據(jù)返回;如果緩存不存在,則執(zhí)行方法,并把返回的結(jié)果存入緩存中。
說(shuō)白了,比如我第一次查詢(xún)緩存操作,如果不存在就去查詢(xún)數(shù)據(jù)庫(kù),查到數(shù)據(jù)后返回,并且放到緩存里去,當(dāng)?shù)诙尾樵?xún)的時(shí)候就可以查詢(xún)緩存里的數(shù)據(jù)。
查看源碼,屬性值如下:
value:緩存名,必填,它指定了你的緩存存放在哪塊命名空間
cacheNames:與 value 差不多,二選一即可
key:可選屬性,可以使用 SpEL 標(biāo)簽自定義緩存的key
2. @CachePut
一般用在新增方法上。
使用該注解標(biāo)志的方法,每次都會(huì)執(zhí)行,并將結(jié)果存入指定的緩存中。其他方法可以直接從響應(yīng)的緩存中讀取緩存數(shù)據(jù),而不需要再去查詢(xún)數(shù)據(jù)庫(kù)。
查看源碼,屬性值如下:
value:緩存名,必填,它指定了你的緩存存放在哪塊命名空間
cacheNames:與 value 差不多,二選一即可
key:可選屬性,可以使用 SpEL 標(biāo)簽自定義緩存的key
3. @CacheEvict
一般用在更新或者刪除方法上,使用該注解標(biāo)志的方法,會(huì)清空指定的緩存。
查看源碼,屬性值如下:
value:緩存名,必填,它指定了你的緩存存放在哪塊命名空間
cacheNames:與 value 差不多,二選一即可
key:可選屬性,可以使用 SpEL 標(biāo)簽自定義緩存的key
allEntries:是否清空所有緩存,默認(rèn)為 false。如果指定為 true,則方法調(diào)用后將立即清空所有的緩存
beforeInvocation:是否在方法執(zhí)行前就清空,默認(rèn)為 false。如果指定為 true,則在方法執(zhí)行前就會(huì)清空緩存
四、功能里實(shí)現(xiàn)緩存操作
改造之前的字典功能,加入緩存相關(guān)操作,在查詢(xún)和導(dǎo)入(新增)的操作上增加對(duì)應(yīng)注解。
查詢(xún)操作
在 service 層對(duì)應(yīng)的實(shí)現(xiàn)方法上增加注解
@Cacheable(value = "dict", keyGenerator = "keyGenerator")

value = "dict", keyGenerator = "keyGenerator",這里面?zhèn)魅氲闹稻褪菫榱藰?gòu)造key,keyGenerator就是redis配置類(lèi)里定義的:

接下來(lái)到前端刷新一下列表頁(yè)面,進(jìn)行一次查詢(xún)請(qǐng)求,然后查看下redis:

這個(gè) key 就是按照配置類(lèi)里自定義的規(guī)則構(gòu)建出來(lái)的,再來(lái)查詢(xún)一下這個(gè) key:

緩存里有數(shù)據(jù)了。
導(dǎo)入操作
在 service 層對(duì)應(yīng)的實(shí)現(xiàn)方法上增加注解@CacheEvict(value = "dict", allEntries=true)

測(cè)試一下,我先del刪除掉緩存,然后前端頁(yè)面做一個(gè)導(dǎo)入的操作:

導(dǎo)入成功后,再次查看緩存:

新增成功。
以上就是Spring項(xiàng)目中使用Cache Redis實(shí)現(xiàn)數(shù)據(jù)緩存的詳細(xì)內(nèi)容,更多關(guān)于Spring Cache Redis數(shù)據(jù)緩存的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
- Redis連接超時(shí)異常的處理方法
- 關(guān)于Springboot2.x集成lettuce連接redis集群報(bào)超時(shí)異常Command timed out after 6 second(s)
- 在SpringBoot中注入RedisTemplate實(shí)例異常的解決方案
- dubbo服務(wù)使用redis注冊(cè)中心的系列異常解決
- Redis做預(yù)定庫(kù)存緩存功能設(shè)計(jì)使用
- 詳解Spring Cache使用Redisson分布式鎖解決緩存擊穿問(wèn)題
- 利用Redis進(jìn)行數(shù)據(jù)緩存的項(xiàng)目實(shí)踐
- GoFrame?gredis緩存DoVar及Conn連接對(duì)象的自動(dòng)序列化
- Redis+Caffeine兩級(jí)緩存的實(shí)現(xiàn)
- Redis緩存三大異常的處理方案梳理總結(jié)
相關(guān)文章
基于創(chuàng)建Web項(xiàng)目運(yùn)行時(shí)出錯(cuò)的解決方法(必看篇)
下面小編就為大家?guī)?lái)一篇基于創(chuàng)建Web項(xiàng)目運(yùn)行時(shí)出錯(cuò)的解決方法。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-08-08
Java線程中的Thread.yield()詳細(xì)解析
這篇文章主要介紹了Java線程中的Thread.yield()詳細(xì)解析,yield()讓當(dāng)前線程從運(yùn)行狀態(tài)?轉(zhuǎn)為?就緒狀態(tài),以允許具有相同優(yōu)先級(jí)的其他線程獲得運(yùn)行機(jī)會(huì),需要的朋友可以參考下2023-11-11
JpaRepository如何實(shí)現(xiàn)增刪改查并進(jìn)行單元測(cè)試
這篇文章主要介紹了JpaRepository如何實(shí)現(xiàn)增刪改查并進(jìn)行單元測(cè)試,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-11-11
Fluent Mybatis學(xué)習(xí)之Update語(yǔ)法實(shí)踐
Fluent MyBatis是一個(gè)MyBatis的增強(qiáng)工具,沒(méi)有對(duì)mybatis做任何修改。本篇文章將詳細(xì)介紹對(duì)Fluent Mybatis中的update語(yǔ)法進(jìn)行驗(yàn)證。代碼具有一定價(jià)值,感興趣的小伙伴可以學(xué)習(xí)一下2021-11-11

