1. 程式人生 > >Spring Data操作Redis時,發現key值出現 \xac\xed\x00\x05t\x00\tb

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

(圖1)

看見了嗎?就是第二行那一串自己冒出來的東西,分析spring-data的org.springframework.data.redis.core.RedisTemplate原始碼以後發現:

  1. private RedisSerializer<?> defaultSerializer = 
    new JdkSerializationRedisSerializer();  
  2. private RedisSerializer keySerializer = null;  
  3. private RedisSerializer valueSerializer = null;  
  4. private RedisSerializer hashKeySerializer = null;  
  5. private RedisSerializer hashValueSerializer = null;  
  6. private RedisSerializer<String> stringSerializer = 
    new StringRedisSerializer();  

發現了一個:

  1. 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中對序列化的一系列操作,發現如下程式碼:
  1. private Converter<Object, byte[]> serializer = new SerializingConverter();  
  2. publicbyte[] serialize(Object object) {  
  3.     if (object == null) {  
  4.         return SerializationUtils.EMPTY_ARRAY;  
  5.     }  
  6.     try {  
  7.         return serializer.convert(object);  
  8.     } catch (Exception ex) {  
  9.         thrownew SerializationException("Cannot serialize", ex);  
  10.     }  
  11. }  

序列化支援的是Object物件,呼叫了SerializingConverter類下的convert方法轉換物件,轉換物件的方法是:

  1. privatefinal Serializer<Object> serializer;  
  2. /** 
  3.  * Serializes the source object and returns the byte array result. 
  4.  */
  5. publicbyte[] convert(Object source) {  
  6.     ByteArrayOutputStream byteStream = new ByteArrayOutputStream(128);  
  7.     try  {  
  8.         this.serializer.serialize(source, byteStream);  
  9.         return byteStream.toByteArray();  
  10.     }  
  11.     catch (Throwable ex) {  
  12.         thrownew SerializationFailedException("Failed to serialize object using " +  
  13.                 this.serializer.getClass().getSimpleName(), ex);  
  14.     }  
  15. }  

原因其實就出現在這裡,解決的辦法就是手動定義序列化的方法,spring-data-redis中還提供了一個序列化的類專門針對string型別的序列化org.springframework.data.redis.serializer.StringRedisSerializer這個類,可以在xml裡面指定:

  1. <beanid="redisTemplate"class="org.springframework.data.redis.core.RedisTemplate"
  2.     p:connection-factory-ref="jedisConnectionFactory">
  3.     <propertyname="keySerializer">
  4.         <beanclass="org.springframework.data.redis.serializer.StringRedisSerializer"/>
  5.     </property>
  6.     <propertyname="valueSerializer">
  7.         <beanclass="org.springframework.data.redis.serializer.StringRedisSerializer"/>
  8.     </property>
  9.     <propertyname="hashKeySerializer">
  10.         <beanclass="org.springframework.data.redis.serializer.StringRedisSerializer"/>
  11.     </property>
  12.     <propertyname="hashValueSerializer">
  13.         <beanclass="org.springframework.data.redis.serializer.StringRedisSerializer"/>
  14.     </property>
  15. </bean>

其中我將redis中基礎型別的key,value和hash型別的key,value都指定為StringRedisSerializer類來進行序列化,然後發現又報錯了,找了一會發現我的程式碼中:

  1. publicvoid setBank(final Bank bank) {  
  2.     // TODO setBank
  3.     final String key = String.format("bank:%s", bank.getId());  
  4.     final Map<String, Object> properties = new HashMap<String, Object>();  
  5.     properties.put("id", bank.getId());  
  6.     properties.put("name", bank.getBank_name());  
  7.     redisTemplate.opsForHash().putAll(key, properties);  
  8. }  

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

  1. publicbyte[] serialize(String string) {  
  2.     return (string == null ? null : string.getBytes(charset));  
  3. }  

所以這裡的型別轉換報錯了,二話不說直接bank.getId().toString(),執行成功,然後進入redis控制檯開啟檢視發現那堆噁心巴拉的\xac\xed\x00\x05t\x00\tb沒有了,大功告成了


(紅色部分)

其實redis在使用中,必須要提前考慮的就是記憶體的佔用問題(部落格中另外一篇文章很經典,闡述了一個外國人做的測試,同樣的儲存可以節約幾十G的記憶體【Redis 記憶體優化】節約記憶體:Instagram的Redis實踐),在設計的時候使用hash可以節約很多的記憶體,而儲存的時候如果每條資料就放一堆\xac\xed\x00\x05t\x00\tb這個東西,肯定是無法直視的

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

以上是個人的拙見,如有哪裡分析的不對的地方,歡迎拍磚