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

lalla1

最近在研究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源代码以后发现：



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

发现了一个：



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



[java] 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方法转换对象，转换对象的方法是：



[java] 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里面指定：



[html] 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类来进行序列化，然后发现又报错了，找了一会发现我的代码中：



[java] 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类型的&#20540;，如下：



[java] 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