本地缓存不一致-记Jackson的MapSerializer序列化

江湖前辈黄药师

发布于 2021-04-19 16:06:46

9960

发布于 2021-04-19 16:06:46

文章被收录于专栏：博客园迁移

踩坑-现象

现象: 线上出现运费险查询接口返回结果不符合预期且短时间内同样的请求参数返回结果不一致

同样的参数短时间内返回结果不一致对应api的业务逻辑没有改变

根本原因:

seller-center应用使用的redisson用的jackson序列化 jackson序列化map时有坑

当map中的key是Integer类型对应的序列化执行器StdKeySerializers序列化后以string存储

value是integer类型对应的序列化执行器NumberSerializers序列化后还是integer

jackson的map序列化核心逻辑

com.fasterxml.jackson.databind.ser.std.MapSerializer#serializeTypedFields

    public void serializeTypedFields(Map<?,?> value, JsonGenerator gen, SerializerProvider provider,
            Object suppressableValue) // since 2.5
        throws IOException
    {
        final Set<String> ignored = _ignoredEntries;
        final boolean checkEmpty = (MARKER_FOR_EMPTY == suppressableValue);
		//循环map 并序列化key  和value
        for (Map.Entry<?,?> entry : value.entrySet()) {
            Object keyElem = entry.getKey();
            JsonSerializer<Object> keySerializer;
            if (keyElem == null) {
                keySerializer = provider.findNullKeySerializer(_keyType, _property);
            } else {
                if (ignored != null && ignored.contains(keyElem)) continue;
                //key是integer的1 !=null  取的默认StdKeySerializers序列化执行器
                keySerializer = _keySerializer;
            }
            final Object valueElem = entry.getValue();
    
            JsonSerializer<Object> valueSer;
            if (valueElem == null) {
                if (_suppressNulls) { // all suppression include null suppression
                    continue;
                }
                valueSer = provider.getDefaultNullValueSerializer();
            } else {
                valueSer = _valueSerializer;
                if (valueSer == null) {
                    //map的第一个entry进来 根据entry的vaule类型匹配序列化执行器
                    //这里value类型integer  --> NumberSerializers
                    valueSer = _findSerializer(provider, valueElem);
                }
                if (checkEmpty) {
                    if (valueSer.isEmpty(provider, valueElem)) {
                        continue;
                    }
                } else if (suppressableValue != null) {
                    if (suppressableValue.equals(valueElem)) {
                        continue;
                    }
                }
            }
            keySerializer.serialize(keyElem, gen, provider);
            try {
                valueSer.serializeWithType(valueElem, gen, provider, _valueTypeSerializer);
            } catch (Exception e) {
                wrapAndThrow(provider, e, value, String.valueOf(keyElem));
            }
        }
    }