FastJsonRedisSerializer 对 Java Object 写入和读取redis的操作支持

场景

开始学习redis

刚开始学习的时候用的是 redis 的 RedisTemplate，这个比较好上手：

@Autowired private RedisTemplate redisTemplate;

ValueOperations<String, String> vo = redisTemplate.opsForValue();
vo.set("mykey", "this is a value");//存到redis

这是一个 Stirng 的 key ，存了一个 String 的 value。当时我在做一个单点登录系统，想要存入的 value 是一个 Java Object，这时遇到了一个问题，就是怎么通过这个进行 Java Object 的写入和读取。

问题出现

写入的时候很简单，就是将 Java Object 进行 toString() 方法的重写，然后就可以以 String 的方式写入 redis ，但是读取的时候出现了一个麻烦的问题，我是用 Java 默认生成的 toString() 重写方法，出来的是这个格式：

SessionUser{id='1', token='c6f91e444dd3e7ab91541394bc5aa5f8', createTime=1529374760832, lastLoginTime=1529374941717}

因为后续的操作是要用到 Java Object，所以这个字符串读取出来要还原成 Java Object 是一个很头痛的问题，默认方法生成的字符串不是 json 格式，所以不可以通过 json解析获取对象，如果将自己定一个 json 生成的 toString() 方法，工作量大而且对 model 的修改不是很好，万一后面 model 因为数据库表的修改而重新生成，那么 model 又要再来一遍修改。

解决方法

在阅读资料的时候，方向有一个解决方法是用一个序列化工具类来解决，核心思想是用原生的 Jedis 来操作，同时写入的 key 和 value 都是 byte[] 类型。这时在 fastjson 包中找到了一个支持序列化和反序列化的类 FastJsonRedisSerializer 。
写入和读取的使用很简单，

写入：

FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(SessionUser.class);
jedis.set(user.getId().getBytes(), fastJsonRedisSerializer.serialize(sessionUser));

读取：

FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(SessionUser.class);
SessionUser sessionUser = (SessionUser) fastJsonRedisSerializer.deserialize(vo.get(userId).getBytes());

这是最直接的使用方法，可以通过封装成工具类来使用。

public static byte[] getByteArrFromObj(Object obj, Class clazz) {
        FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(clazz);
        return fastJsonRedisSerializer.serialize(obj);
}

public static Object getObjFromByteArr(byte[] byteArr, Class clazz) {
    FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(clazz);
    return fastJsonRedisSerializer.deserialize(byteArr);
}

PS

Java 自带的序列化和反序列化据说效率不行，占用空间也大，故不做推荐。

序列化

Object obj = new Object();//准备序列化的 object
ByteArrayOutputStream baos = new ByteArrayOutputStream();  
ObjectOutputStream oos = new ObjectOutputStream(baos);  
oos.writeObject(object);  
byte[] bytes = baos.toByteArray();  
return bytes;  

反序列化

ByteArrayInputStream bais = new ByteArrayInputStream(bytes);  
ObjectInputStream ois = new ObjectInputStream(bais);  
return ois.readObject();