SpringBoot가 Redis를 사용자 정의하여 캐시 직렬화를 구현하는 방법
- WBOY앞으로
- 2023-06-03 11:32:231040검색
1. 맞춤형 RedisTemplate
1.1, Redis API 기본 직렬화 메커니즘
API 기반 Redis 캐시 구현은 데이터 캐싱 작업을 위해 RedisTemplate 템플릿을 사용합니다. 여기에서 RedisTemplate 클래스를 열어 이 클래스의 소스 코드 정보를 확인하세요.
public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperations<K, V>, BeanClassLoaderAware {
// 声明了key、value的各种序列化方式，初始值为空
@Nullable
private RedisSerializer keySerializer = null;
@Nullable
private RedisSerializer valueSerializer = null;
@Nullable
private RedisSerializer hashKeySerializer = null;
@Nullable
private RedisSerializer hashValueSerializer = null;
...
// 进行默认序列化方式设置，设置为JDK序列化方式
public void afterPropertiesSet() {
super.afterPropertiesSet();
boolean defaultUsed = false;
if (this.defaultSerializer == null) {
this.defaultSerializer = new JdkSerializationRedisSerializer(
this.classLoader != null ?
this.classLoader : this.getClass().getClassLoader());
}
...
}
...
}위 RedisTemplate의 핵심 소스 코드를 보면 캐시된 데이터 키와 값에 대한 다양한 직렬화 메소드가 RedisTemplate 내부에 선언되어 있으며 afterPropertiesSet() 메소드에서 초기 값이 모두 비어 있으면 다음과 같이 판단됩니다. 기본 직렬화 매개변수 defaultSerializer가 비어 있고 데이터 기본 직렬화 방법은 JdkSerializationRedisSerializer
로 설정되어 있습니다. 위의 소스 코드 정보 분석을 바탕으로 다음 두 가지 중요한 결론을 도출할 수 있습니다.
(1) RedisTemplate을 사용하여 Redis를 수행하는 경우 데이터 캐싱 작업의 경우 내부 기본 직렬화 방법은 JdkSerializationRedisSerializer입니다. 따라서 데이터 캐싱을 위한 엔터티 클래스는 JDK의 자체 직렬화 인터페이스(예: Serialized)를 구현해야 합니다.
(2) Redis 데이터 캐싱 작업을 수행하기 위해 RedisTemplate을 사용할 때 캐시 직렬화 방법 defaultSerializer가 사용자 정의된 경우 사용자 정의된 직렬화 방법이 사용됩니다.
또한 RedisTemplate 클래스 소스 코드에서 볼 수 있는 다양한 직렬화 유형의 캐시된 데이터 키와 값이 RedisSerializer입니다. RedisSerializer 소스 코드를 입력하면 RedisSerializer에서 지원하는 직렬화 방법을 볼 수 있습니다. (클래스 입력 후 Ctrl+Alt+클래스 이름을 마우스 왼쪽 버튼으로 클릭하면 볼 수 있습니다.)
RedisSerializer가 Redis 직렬화 인터페이스임을 알 수 있습니다. 기본 클래스로 6개의 구현이 있는 이 6개의 구현 클래스는 6개의 서로 다른 데이터 직렬화 방법을 나타냅니다. 그 중 JdkSerializationRedisSerializer는 RedisTemplate 내에서 사용되는 기본 데이터 직렬화 방법이기도 합니다. 개발자는 필요에 따라 지원되는 다른 직렬화 방법(예: JSON 방법)을 선택할 수 있습니다.
1.2 Redis 종속성 이후에 사용자 정의되었습니다. 프로젝트에 도입되면 Spring Boot에서 제공하는 RedisAutoConfiguration 자동 구성이 적용됩니다. RedisAutoConfiguration 클래스를 열고 내부 소스코드에서 RedisTemplate의 정의를 확인하세요
public class RedisAutoConfiguration {
@Bean
@ConditionalOnMissingBean(
name = {"redisTemplate"}
)
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
RedisTemplate<Object, Object> template = new RedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
return template;
}
...
}위에서 언급한 RedisAutoConfiguration 핵심 소스코드에서 볼 수 있듯이 Redis 자동 구성 클래스에서는 Redis 연결 팩토리 RedisConnectionFactory를 통해 RedisTemplate이 초기화됩니다. @ConditionalOnMissingBean은 Annotation 클래스 위에 추가됩니다(이름에서 알 수 있듯이 특정 Bean이 존재하지 않을 때 적용됩니다). 개발자가 redisTemplate이라는 Bean을 사용자 정의하면 기본으로 초기화된 RedisTemplate이 적용되지 않음을 나타내는 데 사용됩니다.
데이터 캐싱 작업을 위해 사용자 정의 직렬화 방법으로 RedisTemplate을 사용하려면 위의 핵심 코드를 참조하여 redisTemplate이라는 Bean 구성 요소를 생성하고 해당 구성 요소에 해당 직렬화 방법을 설정하면 됩니다
다음, 라는 패키지를 생성합니다. 프로젝트에서 com.lagou.config, 패키지 아래에 Redis 사용자 정의 구성 클래스 RedisConfig를 생성하고 위 아이디어에 따라 redisTemplate이라는 Bean 구성 요소를 사용자 정의합니다.
@Configuration
public class RedisConfig {
// 自定义RedisTemplate
@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<Object, Object> template = new RedisTemplate<>();
template.setConnectionFactory(redisConnectionFactory);
// 创建一个JSON格式序列化对象，对缓存数据的key和value进行转换
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
// 解决查询缓存转换异常的问题
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
// 设置RedisTemplate模板api序列化方式为json
template.setDefaultSerializer(jackson2JsonRedisSerializer);
return template;
}
}@Configuration 주석을 통해 RedisConfig 정의 클래스를 구성하고 @를 사용합니다. 메소드 이름의 기본 이름으로 redisTemplate 컴포넌트를 주입하기 위한 Bean 주석입니다(Bean 컴포넌트 이름은 redisTemplate이어야 합니다). 정의된 Bean 컴포넌트에서는 사용자 정의된 Jackson2JsonRedisSerializer 데이터 직렬화 방법을 사용하여 RedisTemplate을 사용자 정의하고, 사용자 정의된 직렬화 방법에서는 데이터 변환 설정
1.3, 효과 테스트
을 위한 ObjectMapper를 정의하여 실행하는 것을 볼 수 있습니다. findById() 메소드는 사용자 주석 정보 Comment를 올바르게 쿼리하고 동일한 쿼리 작업을 반복합니다. 데이터베이스는 SQL 문을 한 번만 실행하며 이는 사용자 정의된 Redis 캐시가 적용됨을 보여줍니다. 
findById() 메서드를 실행하여 사용자 댓글 정보를 쿼리합니다. 댓글은 Redis 캐시 라이브러리에 올바르게 저장되며 데이터는 다음 위치에 캐시됩니다. Redis 서비스가 사용되었습니다. JSON 형식의 저장 표시, 보기 및 관리도 매우 편리합니다. 이는 맞춤형 Redis API 템플릿 도구 RedisTemplate이 효과적임을 나타냅니다.
@Configuration
class RedisCacheConfiguration {
@Bean
public RedisCacheManager cacheManager(RedisConnectionFactory redisConnectionFactory, ResourceLoader resourceLoader) {
RedisCacheManagerBuilder builder = RedisCacheManager
.builder(redisConnectionFactory)
.cacheDefaults(this.determineConfiguration(resourceLoader.getClassLoader()));
List<String> cacheNames = this.cacheProperties.getCacheNames();
if (!cacheNames.isEmpty()) {
builder.initialCacheNames(new LinkedHashSet(cacheNames));
}
return (RedisCacheManager) this.customizerInvoker.customize(builder.build());
}
private org.springframework.data.redis.cache.RedisCacheConfiguration
determineConfiguration(ClassLoader classLoader) {
if (this.redisCacheConfiguration != null) {
return this.redisCacheConfiguration;
} else {
Redis redisProperties = this.cacheProperties.getRedis();
org.springframework.data.redis.cache.RedisCacheConfiguration config = org.springframework.data.redis.cache.RedisCacheConfiguration.defaultCacheConfig();
config = config.serializeValuesWith(SerializationPair.fromSerializer(
new JdkSerializationRedisSerializer(classLoader)));
...
return config;
}
}
}
从上述核心源码中可以看出，同RedisTemplate核心源码类似，RedisCacheConfiguration内部同样通过Redis连接工厂RedisConnectionFactory定义了一个缓存管理器RedisCacheManager；同时定制RedisCacheManager时，也默认使用了JdkSerializationRedisSerializer序列化方式。
如果想要使用自定义序列化方式的RedisCacheManager进行数据缓存操作，可以参考上述核心代码创建一个名为cacheManager的Bean组件，并在该组件中设置对应的序列化方式即可
在Spring Boot 2.X版本中，RedisCacheManager是独立构建的。因此，在SpringBoot 2.X版本中，对RedisTemplate进行自定义序列化机制构建后，仍然无法对RedisCacheManager内部默认序列化机制进行覆盖（这也就解释了基 于注解的Redis缓存实现仍然会使用JDK默认序列化机制的原因），想要基于注解的Redis缓存实现也使用自定义序列化机制，需要自定义RedisCacheManager
2.2、自定义RedisCacheManager
在项目的Redis配置类RedisConfig中，按照上一步分析的定制方法自定义名为cacheManager的Bean组件
@Bean
public RedisCacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
// 分别创建String和JSON格式序列化对象，对缓存数据key和value进行转换
RedisSerializer<String> strSerializer = new StringRedisSerializer();
Jackson2JsonRedisSerializer jacksonSerial = new Jackson2JsonRedisSerializer(Object.class);
// 解决查询缓存转换异常的问题
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
// om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY); // 上面注释过时代码的替代方法
jacksonSerial.setObjectMapper(om);
// 定制缓存数据序列化方式及时效
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
.entryTtl(Duration.ofDays(1)) // 设置缓存数据的时效（设置为了1天）
.serializeKeysWith(RedisSerializationContext.SerializationPair
.fromSerializer(strSerializer)) // 对当前对象的key使用strSerializer这个序列化对象，进行转换
.serializeValuesWith(RedisSerializationContext.SerializationPair
.fromSerializer(jacksonSerial)) // 对value使用jacksonSerial这个序列化对象，进行转换
.disableCachingNullValues();
RedisCacheManager cacheManager = RedisCacheManager
.builder(redisConnectionFactory).cacheDefaults(config).build();
return cacheManager;
}上述代码中，在RedisConfig配置类中使用@Bean注解注入了一个默认名称为方法名的cacheManager组件。在定义的Bean组件中，通过RedisCacheConfiguration对缓存数据的key和value分别进行了序列化方式的定制，其中缓存数据的key定制为StringRedisSerializer（即String格式），而value定制为了Jackson2JsonRedisSerializer（即JSON格式），同时还使用entryTtl(Duration.ofDays(1))方法将缓存数据有效期设置为1天
完成基于注解的Redis缓存管理器RedisCacheManager定制后，可以对该缓存管理器的效果进行测试（使用自定义序列化机制的RedisCacheManager测试时，实体类可以不用实现序列化接口）
위 내용은 SpringBoot가 Redis를 사용자 정의하여 캐시 직렬화를 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!