Spring Data操做Redis时,发现key值出现\xAC\xED\x00\x05t\x00

最近在研究Redis,以及spring data对redis的支持发现了一个奇怪的现象redis

先说现象吧,经过redisTemplate下的opsForHash方法存储hash类型的值,操做成功之后,去redis控制台显示keys * 的时候,发现一个奇怪的现象,插入的hash类型的key前面会有一堆的\xAC\xED\x00\x05t\x00 ,分析spring-data的org.springframework.data.redis.core.RedisTemplate源代码之后发现:spring

private RedisSerializer<?> defaultSerializer = new JdkSerializationRedisSerializer();  
  
private RedisSerializer keySerializer = null;  
private RedisSerializer valueSerializer = null;  
private RedisSerializer hashKeySerializer = null;  
private RedisSerializer hashValueSerializer = null;  
private RedisSerializer<String> stringSerializer = new StringRedisSerializer();

发现了一个:this

private RedisSerializer<?> defaultSerializer = new JdkSerializationRedisSerializer();

由于spring操做redis是在jedis客户端基础上进行的,而jedis客户端与redis交互的时候协议中定义是用byte类型交互,jedis中提供了string类型转为byte[]类型,可是看到spring-data-redis中RedisTemplate<K, V>在操做的时候k,v是泛型的,因此RedisTemplate中有了上面那段代码,在没有特殊定义的状况下,spring默认采用defaultSerializer = new JdkSerializationRedisSerializer();来对key,value进行序列化操做,在通过查看JdkSerializationRedisSerializer中对序列化的一系列操做,发现以下代码:code

private Converter<Object, byte[]> serializer = new SerializingConverter();  
public byte[] serialize(Object object) {  
    if (object == null) {  
        return SerializationUtils.EMPTY_ARRAY;  
    }  
    try {  
        return serializer.convert(object);  
    } catch (Exception ex) {  
        throw new SerializationException("Cannot serialize", ex);  
    }  
}

序列化支持的是Object对象,调用了SerializingConverter类下的convert方法转换对象,转换对象的方法是:orm

private final Serializer<Object> serializer;  
/** 
 * Serializes the source object and returns the byte array result. 
 */  
public byte[] convert(Object source) {  
    ByteArrayOutputStream byteStream = new ByteArrayOutputStream(128);  
    try  {  
        this.serializer.serialize(source, byteStream);  
        return byteStream.toByteArray();  
    }  
    catch (Throwable ex) {  
        throw new SerializationFailedException("Failed to serialize object using " +  
                this.serializer.getClass().getSimpleName(), ex);  
    }  
}

缘由其实就出如今这里,解决的办法就是手动定义序列化的方法,spring-data-redis中还提供了一个序列化的类专门针对string类型的序列化org.springframework.data.redis.serializer.StringRedisSerializer这个类,能够在xml里面指定:xml

<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"  
    p:connection-factory-ref="jedisConnectionFactory">  
    <property name="keySerializer">  
        <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />  
    </property>  
    <property name="valueSerializer">  
        <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />  
    </property>  
    <property name="hashKeySerializer">  
        <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />  
    </property>  
    <property name="hashValueSerializer">  
        <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />  
    </property>  
</bean>

其中我将redis中基础类型的key,value和hash类型的key,value都指定为StringRedisSerializer类来进行序列化,而后发现又报错了,找了一会发现个人代码中:对象

public void setBank(final Bank bank) {  
    // TODO setBank  
    final String key = String.format("bank:%s", bank.getId());  
    final Map<String, Object> properties = new HashMap<String, Object>();  
      
    properties.put("id", bank.getId());  
    properties.put("name", bank.getBank_name());  
      
    redisTemplate.opsForHash().putAll(key, properties);  
}

bank.getId是Integer类型的,由于Hashmap中的key和value也会进行序列化操做,而StringRedisSerializer中的serialize方法只接收String类型的值,以下:get

public byte[] serialize(String string) {  
    return (string == null ? null : string.getBytes(charset));  
}

因此这里的类型转换报错了,二话不说直接bank.getId().toString(),执行成功,而后进入redis控制台打开查看发现那堆恶心巴拉的\xac\xed\x00\x05t\x00\tb没有了,大功告成了string

相关文章
相关标签/搜索