redisson序列化采坑那些事儿

2024-03-12 10:57:53 浏览数 (1)

前言

如果对springcloud-gateway有了解的同学,应该会知道springcloud-gateway默认提供了一个基于内存的路由定义仓库。

代码语言:java复制
org.springframework.cloud.gateway.route.InMemoryRouteDefinitionRepository

基于内存的好处,就是快,但是缺点就是网关重启路由就丢失了。为了方便管理网关路由以及保证网关重启,路由不丢失,于是业务部门做了形如图的改造

3aaf5e4b2b26ae1805934247dbc63a62_cb511f0e89b56dd0436484d018277fac.png3aaf5e4b2b26ae1805934247dbc63a62_cb511f0e89b56dd0436484d018277fac.png

就是会有一个gateway的portal面板来管理路由,然后路由规则是保存在redis,gateway从redis取路由规则。其中portal面板由一个小组负责,gateway的路由读取以及相关其他功能(比如协议转换、参数转换等)又是由另外一个小组负责,portal小组使用了redisson来进行redis相关操作,而gateway小组采用redisTemplate进行操作。redis的存储数据结构为hash。以上是业务背景介绍,接下来我们进入正文

正文

gateway小组的redisTemplate的bean定义如下

代码语言:java复制
    @Bean
    @ConditionalOnMissingBean
    public RedisTemplate<String, Object> routeRedisTemplate(LettuceConnectionFactory lettuceConnectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
        redisTemplate.setConnectionFactory(lettuceConnectionFactory);
        redisTemplate.setValueSerializer(RedisSerializer.json());
        redisTemplate.setKeySerializer(RedisSerializer.string());
        redisTemplate.setHashKeySerializer(RedisSerializer.string());
        redisTemplate.afterPropertiesSet();
        Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper objectMapper = new ObjectMapper()
                .registerModule(new ParameterNamesModule())
                .registerModule(new Jdk8Module())
                .registerModule(new JavaTimeModule());
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型,类必须是非final修饰的。序列化时将对象全类名一起保存下来
        objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
        serializer.setObjectMapper(objectMapper);
        redisTemplate.setValueSerializer(serializer);
        redisTemplate.setHashValueSerializer(serializer);
        return redisTemplate;
    }

注: portal小组的redission这边就不贴了,这个redisson,portal小组有进行浅浅的封装,而上面的redisTemplate配置,属于地摊货,百度一抓一大把,因此也没啥敏感,就贴一下。

前面说过,这边路由规则保存的数据结构为hash,其portal小组初版的保存代码形如下

代码语言:java复制
  RBatch batch = redissonClient.createBatch();

        batch.getMap(ROUTE_DEFINITION_REDIS_KEY, new JsonJacksonCodec()).putAllAsync(routeDefinitionMap).onComplete((result, e)->{
            if(e!= null){
                log.error(">>>>>>>>>>>>>>>>> Redis save batch fail",e);
            }
        });
        batch.execute();

结合上面redisTemplate的配置

思考题一:当gateway从redis读取规则,会出现什么情况?

答案是会出现读取转换报错,原因是JsonJacksonCodec()默认生成的hash结构,会带@class:全限定类名,而上面redisTemplate通过Jackson2JsonRedisSerializer反序列化,并没@class:全限定类名。

解法: redisson的序列化方式可以改成用TypedJsonJacksonCodec,这种序列化方式有如下效果

代码语言:java复制
Json Jackson Type codec. Doesn't include `@class` field during data encoding, and doesn't require it for data decoding.

大白话就是忽略@class

思考题二:当改成TypedJsonJacksonCodec后,gateway能正常从redis读取规则吗?

答案是仍然不能,原因是redisTemplate和TypedJsonJacksonCodec使用的objectMapper设置的规则属性不一样

解法: 让redisTemplate和TypedJsonJacksonCodec保持相同的objectMapper设置规则。因此我们可以定义一个JsonJacksonCodec工厂。工厂如下示例代码

代码语言:java复制
public final class JsonJacksonCodecFactory {

    private JsonJacksonCodecFactory() {
    }


    public static TypedJsonJacksonCodec getTypedJsonJacksonCodec(Class<?> mapKeyClass, Class<?> mapValueClass) {
        return new TypedJsonJacksonCodec(mapKeyClass, mapValueClass, getObjectMapper());
    }

    public static TypedJsonJacksonCodec getTypedJsonJacksonCodec(Class<?> mapValueClass) {
        return new TypedJsonJacksonCodec(Object.class, mapValueClass, getObjectMapper());
    }

    private static ObjectMapper getObjectMapper() {
        ObjectMapper objectMapper = new ObjectMapper()
                .registerModule(new ParameterNamesModule())
                .registerModule(new Jdk8Module())
                .registerModule(new JavaTimeModule());
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型,类必须是非final修饰的。序列化时将对象全类名一起保存下来
        objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
        return objectMapper;
    }
}

然后将redisson的序列化切换成用工厂来获取

思考题三:当改成我们自定义的序列化后,gateway能正常从redis读取规则吗?改造后,还有没有其他问题?

答案是因为现在redisTemplate和redisson的value序列化规则保持一致了,而因为网关读取路由规则,是读取整个列表,因此可以正常读取。

改造后,根据key进行路由删除会存在问题,因为redisson使用Jackson进行序列化时,其redis key默认也是用了Jackson进行序列化,这样会造成,key保存在redis,会出现“key”,即会多了双引号。而上面的redisTemplate key的序列化方式,是通过RedisSerializer.string(),这个方式可以保证key是原样输出。

解法: 可以将redisTemplate key的序列化方式也改成用Jackson,不过正常不会这么干。因此解法就是将redisson key序列化方式也改成通过string。那我们要怎么做,我们可以通过再次自定义序列化来解决,不过这种方案我们不推荐了,毕竟如无必要,勿增实体,我们可以直接利用redisson提供的序列化组合器(CompositeCodec)来实现。

示例代码如下

代码语言:java复制
 batch.getMap(ROUTE_DEFINITION_REDIS_KEY, new CompositeCodec(new StringCodec(),JsonJacksonCodecFactory.getTypedJsonJacksonCodec(RouteDefinition.class))).putAllAsync(routeDefinitionMap).onComplete((result, e)->{
            if(e!= null){
                log.error(">>>>>>>>>>>>>>>>> Redis save batch fail",e);
            }
        });

总结

本文的采坑主要就是双方的key,value的编解码没对应上,就是事先没沟通好,其次不知道大家会不会疑问,为什么一个小组用redisTemplate,另一个小组用redission,其实也没别的啥原因,因为一个小组对redisTemplate使用比较多,另一个小组使用redission比较多,大白话就是擅长什么用什么。最后redisson是一个好东西,毕竟是redis son,虎父无犬子

0 人点赞