|
|
@@ -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 LongVideoRedisTemplateConfig {
|
|
|
+
|
|
|
+ @Bean("longVideoRedisPool")
|
|
|
+ @ConfigurationProperties(prefix = "spring.long-video-redis.lettuce.pool")
|
|
|
+ public GenericObjectPoolConfig<LettucePoolingClientConfiguration> redisPool() {
|
|
|
+ return new GenericObjectPoolConfig<>();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean("longVideoRedisConfig")
|
|
|
+ @ConfigurationProperties(prefix = "spring.long-video-redis")
|
|
|
+ public RedisStandaloneConfiguration tairConfig() {
|
|
|
+ return new RedisStandaloneConfiguration();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean("longVideoRedisFactory")
|
|
|
+ @Primary
|
|
|
+ public LettuceConnectionFactory factory(GenericObjectPoolConfig<LettucePoolingClientConfiguration> redisPool,
|
|
|
+ RedisStandaloneConfiguration redisConfig) {
|
|
|
+ LettuceClientConfiguration lettuceClientConfiguration =
|
|
|
+ LettucePoolingClientConfiguration.builder().poolConfig(redisPool).build();
|
|
|
+ return new LettuceConnectionFactory(redisConfig, lettuceClientConfiguration);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Bean(name = "longVideoRedisTemplate")
|
|
|
+ public RedisTemplate<String, String> getRedisTemplate(@Qualifier("longVideoRedisFactory") RedisConnectionFactory factory) {
|
|
|
+ return buildRedisTemplateByString(factory);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 构建redisTemplate 使用string序列化
|
|
|
+ *
|
|
|
+ * @param factory
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public 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;
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
丁云鹏