zoukankan      html  css  js  c++  java
  • Spring Data操作Redis时,发现key值出现 xacxedx00x05tx00 b

    原文链接:http://blog.csdn.net/yunhaibin/article/details/9001198

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

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

    图1

    (图1)

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

    [java] view plain copy
     
    1. private RedisSerializer<?> defaultSerializer = new JdkSerializationRedisSerializer();  
    2.   
    3. private RedisSerializer keySerializer = null;  
    4. private RedisSerializer valueSerializer = null;  
    5. private RedisSerializer hashKeySerializer = null;  
    6. private RedisSerializer hashValueSerializer = null;  
    7. private RedisSerializer<String> stringSerializer = new StringRedisSerializer();  

    发现了一个:

    [java] view plain copy
     
    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中对序列化的一系列操作,发现如下代码:
    [java] view plain copy
     
    1. private Converter<Object, byte[]> serializer = new SerializingConverter();  
    2. public byte[] 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.         throw new SerializationException("Cannot serialize", ex);  
    10.     }  
    11. }  

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

    [java] view plain copy
     
    1. private final Serializer<Object> serializer;  
    2. /** 
    3.  * Serializes the source object and returns the byte array result. 
    4.  */  
    5. public byte[] 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.         throw new 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里面指定:

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

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

    [java] view plain copy
     
    1. public void 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.       
    6.     properties.put("id", bank.getId());  
    7.     properties.put("name", bank.getBank_name());  
    8.       
    9.     redisTemplate.opsForHash().putAll(key, properties);  
    10. }  

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

    [java] view plain copy
     
    1. public byte[] serialize(String string) {  
    2.     return (string == null ? null : string.getBytes(charset));  
    3. }  

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

             

    (红色部分)

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

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

  • 相关阅读:
    云栖大会|盛宴之下,共赴一场视频云的进化论
    云栖大会|感受万物数字化,体验千行视频化
    浅谈语音质量保障:如何测试 RTC 中的音频质量?
    一朵云、一张网、一体化 ——GRTN 打造最佳流媒体场景实践
    穿越时空,跟我一起探索云栖数字谷(2021云栖大会免费送票)
    如何实现 iOS 短视频跨页面的无痕续播?
    如何实现 Android 短视频跨页面的流畅续播?
    揭秘盒马鲜生 Android 短视频秒播优化方案
    SQLServer2012SP1-FullSlipstream-CHS-x64标准版.iso
    mes系统是做什么的?MES是什么全称是什么?
  • 原文地址:https://www.cnblogs.com/aigeileshei/p/7808635.html
Copyright © 2011-2022 走看看