Spring Boot中同时存在“JSON 对象模板”和“二进制模板”的处理方式

源码资源网

Spring Boot中同时存在“JSON 对象模板”和“二进制模板”的处理方式

下面把“JSON 对象模板”和“二进制模板”放到同一个配置类里，分别注入使用。

1. package com.example.config;
   
2. 
   
3. import org.springframework.context.annotation.Bean;
   
4. import org.springframework.context.annotation.Configuration;
   
5. import org.springframework.context.annotation.Primary;
   
6. import org.springframework.data.redis.connection.RedisConnectionFactory;
   
7. import org.springframework.data.redis.core.RedisTemplate;
   
8. import org.springframework.data.redis.serializer.ByteArrayRedisSerializer;
   
9. import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
   
10. import org.springframework.data.redis.serializer.StringRedisSerializer;
    
11. 
    
12. @Configuration
    
13. public class RedisTemplateConfig {
    
14. 
    
15.     // 默认：String -> JSON(Object)
    
16.     @Primary
    
17.     @Bean
    
18.     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory cf) {
    
19.         RedisTemplate<String, Object> t = new RedisTemplate<>();
    
20.         t.setConnectionFactory(cf);
    
21.         t.setKeySerializer(StringRedisSerializer.UTF_8);
    
22.         t.setHashKeySerializer(StringRedisSerializer.UTF_8);
    
23. 
    
24.         GenericJackson2JsonRedisSerializer json = new GenericJackson2JsonRedisSerializer();
    
25.         t.setValueSerializer(json);
    
26.         t.setHashValueSerializer(json);
    
27. 
    
28.         t.afterPropertiesSet();
    
29.         return t;
    
30.     }
    
31. 
    
32.     // 二进制：String -> byte[]
    
33.     @Bean(name = "binaryRedisTemplate")
    
34.     public RedisTemplate<String, byte[]> binaryRedisTemplate(RedisConnectionFactory cf) {
    
35.         RedisTemplate<String, byte[]> t = new RedisTemplate<>();
    
36.         t.setConnectionFactory(cf);
    
37.         t.setKeySerializer(StringRedisSerializer.UTF_8);
    
38.         t.setHashKeySerializer(StringRedisSerializer.UTF_8);
    
39.         t.setValueSerializer(ByteArrayRedisSerializer.INSTANCE);
    
40.         t.setHashValueSerializer(ByteArrayRedisSerializer.INSTANCE);
    
41.         t.afterPropertiesSet();
    
42.         return t;
    
43.     }
    
44. }

复制代码

使用示例

1. @Autowired private RedisTemplate<String, Object> redisTemplate;
   
2. @Autowired @Qualifier("binaryRedisTemplate") private RedisTemplate<String, byte[]> binTpl;

复制代码

下面是两个config文件，Spring Boot 可同时存在多个 @Configuration，只要 Bean 名称不冲突即可。建议：

• JSON 用 redisTemplate（覆盖掉 Boot 的默认），或标注 @Primary。
• 二进制单独命名为 binaryRedisTemplate，注入时用 @Qualifier 指定。
  

示例

1. package com.example.config;
   
2. 
   
3. import org.springframework.context.annotation.*;
   
4. import org.springframework.data.redis.connection.RedisConnectionFactory;
   
5. import org.springframework.data.redis.core.RedisTemplate;
   
6. import org.springframework.data.redis.serializer.*;
   
7. 
   
8. @Configuration
   
9. public class RedisJsonConfig {
   
10. 
    
11.     @Primary // 作为默认 RedisTemplate
    
12.     @Bean
    
13.     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory cf) {
    
14.         RedisTemplate<String, Object> t = new RedisTemplate<>();
    
15.         t.setConnectionFactory(cf);
    
16.         t.setKeySerializer(StringRedisSerializer.UTF_8);
    
17.         t.setHashKeySerializer(StringRedisSerializer.UTF_8);
    
18.         GenericJackson2JsonRedisSerializer json = new GenericJackson2JsonRedisSerializer();
    
19.         t.setValueSerializer(json);
    
20.         t.setHashValueSerializer(json);
    
21.         t.afterPropertiesSet();
    
22.         return t;
    
23.     }
    
24. }

复制代码

1. package com.example.config;
   
2. 
   
3. import org.springframework.context.annotation.*;
   
4. import org.springframework.data.redis.connection.RedisConnectionFactory;
   
5. import org.springframework.data.redis.core.RedisTemplate;
   
6. import org.springframework.data.redis.serializer.*;
   
7. 
   
8. @Configuration
   
9. public class RedisBinaryConfig {
   
10. 
    
11.     @Bean(name = "binaryRedisTemplate")
    
12.     public RedisTemplate<String, byte[]> binaryRedisTemplate(RedisConnectionFactory cf) {
    
13.         RedisTemplate<String, byte[]> t = new RedisTemplate<>();
    
14.         t.setConnectionFactory(cf);
    
15.         t.setKeySerializer(StringRedisSerializer.UTF_8);
    
16.         t.setHashKeySerializer(StringRedisSerializer.UTF_8);
    
17.         t.setValueSerializer(ByteArrayRedisSerializer.INSTANCE);
    
18.         t.setHashValueSerializer(ByteArrayRedisSerializer.INSTANCE);
    
19.         t.afterPropertiesSet();
    
20.         return t;
    
21.     }
    
22. }

复制代码

使用时

1. @Autowired private RedisTemplate<String, Object> redisTemplate; // JSON
   
2. @Autowired @Qualifier("binaryRedisTemplate") private RedisTemplate<String, byte[]> binTpl; // 二进制

复制代码

提示

• Boot 自带的 stringRedisTemplate 仍会存在；你定义的 redisTemplate 会覆盖默认的。