|
|
@@ -0,0 +1,63 @@
|
|
|
+package com.tzld.piaoquan.recommend.server.config;
|
|
|
+
|
|
|
+import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
|
|
|
+import org.springframework.beans.factory.annotation.Qualifier;
|
|
|
+import org.springframework.boot.context.properties.ConfigurationProperties;
|
|
|
+import org.springframework.context.annotation.Bean;
|
|
|
+import org.springframework.context.annotation.Configuration;
|
|
|
+import org.springframework.context.annotation.Primary;
|
|
|
+import org.springframework.data.redis.connection.RedisConnectionFactory;
|
|
|
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
|
|
|
+import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
|
|
|
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
|
|
|
+import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;
|
|
|
+import org.springframework.data.redis.core.RedisTemplate;
|
|
|
+import org.springframework.data.redis.serializer.StringRedisSerializer;
|
|
|
+
|
|
|
+@Configuration
|
|
|
+public class FilterRedisTemplateConfig {
|
|
|
+
|
|
|
+ @Bean("filterRedisPool")
|
|
|
+ @ConfigurationProperties(prefix = "spring.filter-redis.lettuce.pool")
|
|
|
+ public GenericObjectPoolConfig<LettucePoolingClientConfiguration> filterRedisPool() {
|
|
|
+ return new GenericObjectPoolConfig<>();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean("filterRedisConfig")
|
|
|
+ @ConfigurationProperties(prefix = "spring.filter-redis")
|
|
|
+ public RedisStandaloneConfiguration filterRedisConfig() {
|
|
|
+ return new RedisStandaloneConfiguration();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean("filterRedisFactory")
|
|
|
+ @Primary
|
|
|
+ public LettuceConnectionFactory factory(@Qualifier("filterRedisPool") GenericObjectPoolConfig<LettucePoolingClientConfiguration> filterRedisPool,
|
|
|
+ @Qualifier("filterRedisConfig") RedisStandaloneConfiguration filterRedisConfig) {
|
|
|
+ LettuceClientConfiguration lettuceClientConfiguration =
|
|
|
+ LettucePoolingClientConfiguration.builder().poolConfig(filterRedisPool).build();
|
|
|
+ return new LettuceConnectionFactory(filterRedisConfig, lettuceClientConfiguration);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean(name = "filterRedisTemplate")
|
|
|
+ public RedisTemplate<String, String> getRedisTemplate(@Qualifier("filterRedisFactory") RedisConnectionFactory factory) {
|
|
|
+ return buildRedisTemplateByString(factory);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 构建redisTemplate 使用string序列化
|
|
|
+ *
|
|
|
+ * @param factory
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private RedisTemplate<String, String> buildRedisTemplateByString(RedisConnectionFactory factory) {
|
|
|
+ RedisTemplate<String, String> redisTemplate = new RedisTemplate<>();
|
|
|
+ redisTemplate.setConnectionFactory(factory);
|
|
|
+ // key的序列化类型 保证可读性
|
|
|
+ redisTemplate.setKeySerializer(new StringRedisSerializer());
|
|
|
+ redisTemplate.setValueSerializer(new StringRedisSerializer());
|
|
|
+ redisTemplate.setHashKeySerializer(new StringRedisSerializer());
|
|
|
+ redisTemplate.setHashValueSerializer(new StringRedisSerializer());
|
|
|
+ return redisTemplate;
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
