package com.doumee.core.utils.redis; 
 | 
import org.springframework.core.convert.converter.Converter; 
 | 
import org.springframework.core.serializer.support.DeserializingConverter; 
 | 
import org.springframework.core.serializer.support.SerializingConverter; 
 | 
import org.springframework.data.redis.serializer.RedisSerializer; 
 | 
import org.springframework.data.redis.serializer.SerializationException; 
 | 
  
 | 
/** 
 | 
 * @author 彭伟 
 | 
 * @date 2018/8/28 9:31 
 | 
 */ 
 | 
public class RedisConverter implements RedisSerializer<Object> { 
 | 
    private Converter<Object, byte[]> serializer = new SerializingConverter();//序列化器 
 | 
    private Converter<byte[], Object> deserializer = new DeserializingConverter();//反序列化器 
 | 
  
 | 
    @Override 
 | 
    public byte[] serialize(Object o) throws SerializationException {//将对象序列化成字节数组 
 | 
        if (o == null) return new byte[0]; 
 | 
        try { 
 | 
            return serializer.convert(o); 
 | 
        } catch (Exception e) { 
 | 
            e.printStackTrace(); 
 | 
            return new byte[0]; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public Object deserialize(byte[] bytes) throws SerializationException {//将字节数组反序列化成对象 
 | 
        if (bytes == null || bytes.length == 0) return null; 
 | 
        try { 
 | 
            return deserializer.convert(bytes); 
 | 
        } catch (Exception e) { 
 | 
            e.printStackTrace(); 
 | 
            return null; 
 | 
        } 
 | 
    } 
 | 
  
 | 
} 
 |