Redis反序列化异常处理方法

文章目录

- 问题背景
- 问题分析
- 解决方案

问题背景

通过String类型存储，只不过Value是一个自定义对象。暂且叫这个类型为UserBo吧。
当我们通过redisTemplate.opsForValue().set(userId, userBo, 24, TimeUnit.HOURS)存入时并没有什么问题。
可是如果我们通过UserBo userBoCache = (UserBo)redisTemplate.opsForValue().get(userId);方式查看时日志中则会出现报错

Could not read JSON: Could not resolve type id 'com.dps.bo.user.UserBo' as a subtype of `java.lang.Object`

显然对于一个系统而言这是不稳定的。

问题分析

结合报错内容和我们所进行的redis操作可以判断，此问题的原因是我们存入的Value在取出时并不能被转换为UserBo类型的对象。我们暂且称这为反序列化问题。为什么会反序列化失败，原因大抵是我们选用了String类型来存储Object，所以在get时得到的是单纯的String类型，即便打印出来也是UserBo类型对象结构，但仍不能进行强制转换。

解决方案

方案一：修改spring-data-redis中RedisTemplate默认序列化方式
SpringBoot使用spring-data-redis，RedisTemplate默认的序列化方式是用org.springframework.data.redis.serializer.JdkSerializationRedisSerializer这个类来做序列化，而Redis有自己的序列化方式，所以冲突了报出了上面的序列化异常的信息。

// 源码参考：spring-data-redis-2.7.2依赖中部分代码
private @Nullable RedisSerializer<?> defaultSerializer;if (defaultSerializer == null) {defaultSerializer = new JdkSerializationRedisSerializer(classLoader != null ? classLoader : this.getClass().getClassLoader());
}

我们可以在使用到redisTemplate的类中加入下面的配置，指定使用的序列化方式，
将key序列化方式改为 StringRedisSerializer，将value序列化方式改为 GenericJackson2JsonRedisSerializer（Jackson2JsonRedisSerializer可以序列化成功，但是反序列化会失败，用GenericJackson2JsonRedisSerializer即可序列化也可反序列化）。以下两种写法均可——一种是直接更改，一种是配置更改，没什么区别

    private RedisTemplate<String, QuestionTemplate> redisTemplate;//指定用redis的序列化方式进行序列化@Autowired(required = false)public void setRedisTemplate(RedisTemplate redisTemplate) {RedisSerializer stringSerializer = new StringRedisSerializer();//序列化为String//不能反序列化//Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);//序列化为JsonGenericJackson2JsonRedisSerializer serializer = new GenericJackson2JsonRedisSerializer();redisTemplate.setKeySerializer(stringSerializer);redisTemplate.setValueSerializer(serializer);redisTemplate.setHashKeySerializer(stringSerializer);redisTemplate.setHashValueSerializer(serializer);this.redisTemplate = redisTemplate;}

@Configuration
public class RedisConfig {public RedisConfig() {}@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {RedisTemplate<Object, Object> redisTemplate = new RedisTemplate();redisTemplate.setConnectionFactory(connectionFactory);Jackson2JsonRedisSerializer serializer = new GenericJackson2JsonRedisSerializer(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, Visibility.ANY);om.enableDefaultTyping(DefaultTyping.NON_FINAL);serializer.setObjectMapper(om);redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(serializer);redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(serializer);return redisTemplate;}
}

PS：适应场景——有系统框架封装的Redis工具，且<String: Object>的String类型存取场景是使用的框架Redis工具或者系统框架中有RedisTemplate配置类（说白了就是统一配置到处使用。总不能你在哪个业务类里导入了个RedisTemplate你就得在这个业务类下面手动设置key和Value的序列化方式吧）

方案二：自定义Object<->String的序列化与反序列化
UserBo在存入前通过Json工具序列化为String，取出后再通过序列化工具get为UserBo

redisTemplate.opsForValue().set(userId, JSON.toJSONString(userBo), 24, TimeUnit.HOURS);
UserBo userBoCache = JSON.parseObject(redisTemplate.opsForValue().get(userId), UserBo.class);