lalla1 发表于 2015-11-12 12:49:51

Spring Data操作Redis时,发现key值出现 \xac\xed\x00\x05t\x00\tb


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

先说现象吧,通过redisTemplate下的opsForHash方法存储hash类型的值,操作成功以后,去redis控制台显示keys * 的时候,发现一个奇怪的现象,插入的hash类型的key前面会有一堆的\xac\xed\x00\x05t\x00\tb 这种东西,见图1







(图1)



看见了吗?就是第二行那一串自己冒出来的东西,分析spring-data的org.springframework.data.redis.core.RedisTemplate源代码以后发现:



view
plaincopy


[*]
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();


发现了一个:



view
plaincopy


[*]
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中对序列化的一系列操作,发现如下代码:



view
plaincopy


[*]
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(&quot;Cannot serialize&quot;, ex);
[*]
    }
[*]
}




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



view
plaincopy


[*]
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(&quot;Failed to serialize object using &quot; &#43;
[*]
                this.serializer.getClass().getSimpleName(), ex);
[*]
    }
[*]
}




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



view
plaincopy


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




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



view
plaincopy


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




bank.getId是Integer类型的,因为Hashmap中的key和value也会进行序列化操作,而StringRedisSerializer中的serialize方法只接收String类型的值,如下:



view
plaincopy


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




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

         





(红色部分)





其实redis在使用中,必须要提前考虑的就是内存的占用问题(博客中另外一篇文章很经典,阐述了一个外国人做的测试,同样的存储可以节约几十G的内存【Redis 内存优化】节约内存:Instagram的Redis实践),在设计的时候使用hash可以节约很多的内存,而存储的时候如果每条数据就放一堆\xac\xed\x00\x05t\x00\tb这个东西,肯定是无法直视的



------------------------------------------------------------------------------------------------



以上是个人的拙见,如有哪里分析的不对的地方,欢迎拍砖





原文地址:http://blog.iyunv.com/yunhaibin/article/details/9001198
页: [1]
查看完整版本: Spring Data操作Redis时,发现key值出现 \xac\xed\x00\x05t\x00\tb