spring-boot-starter-data-redis 乱码

发表于 | 分类于 |

  1. RedisTemplate源码

    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
    38
    39
    40
    41
    42
    43
    44
    45
    public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperations<K, V>, BeanClassLoaderAware {

    	private boolean enableTransactionSupport = false;
    	private boolean exposeConnection = false;
    	private boolean initialized = false;
    	private boolean enableDefaultSerializer = true;
    	private RedisSerializer<?> defaultSerializer;
    	private ClassLoader classLoader;
      
    	private RedisSerializer keySerializer = null;
    	private RedisSerializer valueSerializer = null;
    	private RedisSerializer hashKeySerializer = null;
    	private RedisSerializer hashValueSerializer = null;
    	private RedisSerializer<String> stringSerializer = new StringRedisSerializer();
       
      	....
        //spring-boot-starter-data-redis 默认情况下使用的是JdkSerializationRedisSerializer
        //这个地方是导致redis key乱码的根本原因
        //需要做的就是替换一下keySerializer 和 hashKeySerializer
        if (defaultSerializer == null) {
    		defaultSerializer = new JdkSerializationRedisSerializer(
    			classLoader != null ? classLoader : this.getClass().getClassLoader());
    	}
        
        if (enableDefaultSerializer) {

    			if (keySerializer == null) {
    				keySerializer = defaultSerializer;
    				defaultUsed = true;
    			}
    			if (valueSerializer == null) {
    				valueSerializer = defaultSerializer;
    				defaultUsed = true;
    			}
    			if (hashKeySerializer == null) {
    				hashKeySerializer = defaultSerializer;
    				defaultUsed = true;
    			}
    			if (hashValueSerializer == null) {
    				hashValueSerializer = defaultSerializer;
    				defaultUsed = true;
    			}
    		}
    	}
    }

  2. 重新申明RedisTemplate并设置keySerializer 和 hashKeySerializer

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    @Configuration
    public class RedisConfiguration {
        @Bean
        public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory)
                throws UnknownHostException {
            RedisTemplate<Object, Object> template = new RedisTemplate<Object, Object>();
            template.setKeySerializer(new StringRedisSerializer());
            template.setHashKeySerializer(new StringRedisSerializer());
            template.setConnectionFactory(redisConnectionFactory);
            return template;
        }
    }

    ​

热评文章