Springboot整合redis實現(xiàn)緩存
引入依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
配置RedisConfig
@EnableCaching
@Configuration
public class RedisConfig {
@Bean
RedisCacheConfiguration redisCacheConfiguration() {
// 讀取redis的默認配置模板
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig();
// 設(shè)置過期時間
config = config.entryTtl(Duration.ofDays(1));
// 設(shè)置KEY的前綴
config.prefixKeysWith("CACHE_");
// 開啟使用KEY前綴
config.usePrefix();
// 設(shè)置允許緩存空值,防止緩存穿透
config.getAllowCacheNullValues();
// 配置key的序列化方式
config.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()));
// 配置value的序列化方式
config = config.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));
return config;
}
}
RedisTemplate常用方法
redisTemplate.opsForValue();//操作字符串
redisTemplate.opsForHash();//操作hash
redisTemplate.opsForList();//操作list
redisTemplate.opsForSet();//操作set
redisTemplate.opsForZSet();//操作有序set
Redis常用緩存注解
注解名 作用
@Cacheable 主要針對方法配置添吗,能夠根據(jù)方法的請求參數(shù)對其結(jié)果進行緩存
@CacheEvict 清空緩存
@CachePut 保證方法被調(diào)用沥曹,又希望結(jié)果被緩存
@EnableCaching 開啟基于注解的緩存
解決緩存穿透、緩存雪崩碟联、緩存擊穿
- 空結(jié)果緩存:解決緩存穿透問題
- 設(shè)置過期時間加隨機值:解決緩存雪崩
- 加鎖:解決緩存擊穿
Redisson整合 可重入鎖 讀寫鎖
官網(wǎng)地址 github redisson wiki
導(dǎo)入依賴
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson-spring-boot-starter</artifactId>
<!--適用于2.2.x版本-->
<version>3.13.1</version>
</dependency>
配置RedissonConfig
@Configuration
public class RedissonConfig {
@Bean
public RedissonClient redisson() {
//1. 創(chuàng)建配置
Config config = new Config();
config.useSingleServer().setAddress("redis://192.168.56.10:6379");
// 2. 根據(jù)config創(chuàng)建出RedissonClient實例
RedissonClient redisson = Redisson.create(config);
return redisson;
}
}
可重入鎖
RLock rLock = redissonClient.getLock("lock");
rLock.lock();
rLock.unlock();
讀寫鎖
// 讀
@GetMapping("read")
public R read() {
RLock lock = redissonClient.getReadWriteLock("rw-lock").readLock();
try {
lock.lock();
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
return R.ok().data("data", "read");
}
// 寫
@GetMapping("write")
public R write() {
RLock lock = redissonClient.getReadWriteLock("rw-lock").writeLock();
try {
lock.lock();
Thread.sleep(8000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
return R.ok().data("data", "write");
}