前言
本文基于以下版本：
1
2
3
4
5
6
| <!-- 对应的是3.3.0版本的jedis（redis的java客户端） -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<version>2.4.0</version>
</dependency>
|
SpringBoot配置Redis
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
| ## 配置redis连接
spring.redis.host=localhost
spring.redis.port=6379
## 是否使用redis作为cache
#spring.cache.type=none
spring.cache.type=redis
## 默认情况下redis中的数据永不过期
#spring.cache.redis.time-to-live=30s
## 是否存储null值
#spring.cache.redis.cache-null-values=false
## key是否使用前缀
#spring.cache.redis.use-key-prefix=true
#spring.cache.redis.key-prefix=tb-
|
RedisTemplate存储数据到Redis后key值出现\xac\xed\x00\x05
由于SpringData的redis模块用的是jedis包，因此在使用RedisTemplate操作数据时，默认使用的是JDK的序列化器JdkSerializationRedisSerializer。当存入数据到Redis后，原本的String类型或者Hash类型的key值就会变成带有\xac\xed\x00\x05前缀的值。
建议对于String、hash类型的值，使用String序列化器：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
| @EnableCaching
@Configuration
public class RedisConfig {
@Bean
public RedisTemplate<String, Object> redisTemplate(final RedisConnectionFactory redisConnectionFactory) {
final RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
template.setConnectionFactory(redisConnectionFactory);
template.setEnableDefaultSerializer(false);
template.setKeySerializer(RedisSerializer.string());
template.setValueSerializer(RedisSerializer.java());
template.setHashKeySerializer(RedisSerializer.string());
template.setHashValueSerializer(RedisSerializer.string());
template.afterPropertiesSet();
return template;
}
}
|
Redis宕机导致@Cacheable直接抛出异常，服务不可用
当使用@Cacheable来将数据存入Redis时，如果Redis服务器不可达会导致系统直接抛出异常，从而使得服务不可用，正常来说就算Redis挂了也不应该影响原本的业务逻辑的正常运行下去。
需要写一个CacheErrorHandler来对上述异常进行处理：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
| @EnableCaching
@Configuration
@Slf4j
public class RedisConfig extends CachingConfigurerSupport {
/*
* (non-Javadoc)
* @see org.springframework.cache.annotation.CachingConfigurerSupport#errorHandler()
*/
@Override
public CacheErrorHandler errorHandler() {
return new CacheErrorHandler() {
@Override
public void handleCachePutError(final RuntimeException exception, final Cache cache, final Object key, final Object value) {
log.error("Failed to put key '{}' into Redis Cache: {}.", key, cache.getName(), exception);
}
@Override
public void handleCacheGetError(final RuntimeException exception, final Cache cache, final Object key) {
log.error("Failed to get key '{}' from Redis Cache: {}.", key, cache.getName(), exception);
}
@Override
public void handleCacheEvictError(final RuntimeException exception, final Cache cache, final Object key) {
log.error("Failed to evict key '{}' from Redis Cache: {}.", key, cache.getName(), exception);
throw exception;
}
@Override
public void handleCacheClearError(final RuntimeException exception, final Cache cache) {
log.error("Failed to clear Redis Cache: {}.", cache.getName(), exception);
}
};
}
}
|
参考链接
警告
本文最后更新于 January 13, 2022，文中内容可能已过时，请谨慎使用。
