百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术分类 > 正文

当dubbo序列化遇上Collections.emptyMap()

ztj100 2025-05-30 19:02 6 浏览 0 评论

背景

惯例先交待一下事件的背景,最近在调试接口的时候发现一个奇怪的现象,页面某一处显示的数据在我未对其做更改的情况下发生了变化。通过查看代码发现,页面会发送请求,然后将请求值做一层包装,之后传给其他模块做存储。

过程

一开始怀疑是其他模块动了数据,而且操作错了,经过调试代码发现不是那么回事儿~~,数据在传送之前就已经有问题了。更诡异的是,看上去根本没做啥啊,这代码的简单程度简直和HelloWord差不多了,类似于下面这样的

List<Item> list = items.stream().map(t -> {
    Item item = new Item();
    
    Map<String, Object> extraMap = t.getExtraMap();
    if (extraMap == null) {
        extraMap = new HashMap<>();
        item.setExtraMap(extraMap);
    }
    extraMap.put("decreaseRate", decreaseRateMap.get(t.getId()));
    item.setExtraMap(extraMap);
    return item;
}).collect(Collectors.toList());

其中items是我从DB里面查出来的数据,我这边要做的就是看看items里面extraMap这个字段有没有值,没有就新建一个,然后增加一个KV对赋值给新的对象,组成一个新的集合,decreaseRateMap是一个含有固定值的map。

但是诡异的现象是,decreaseRateMap有两个K-V对,1->0、2->800,然后items也有两个对象,分别对应的id是1和2。按照常理,最终得到的list里面应该有两个item对象,然后分别有有个extraMap属性值,一个是decreaseRate->0,一个是decreaseRate->800 。但是最后得到的结果却是两个都是decreaseRate->800。百思不得其解,打断点,发现直到item在循环中返回,它的extraMap的值还是对的,为啥最后collect就变了呢?

其实光看这段代码是没有问题的,还有一个隐藏剧情,Item是通过dubbo接口获取,里面有个set方法如下:

public void setExtra(String extra) {
    this.extra = extra;
    if(Strings.isNullOrEmpty(extra)){
        this.extraMap= Collections.emptyMap();
    } else{
        this.extraMap = JsonMapper.JSON_NON_EMPTY_MAPPER.fromJson(extra,  MAP_OF_STRING);
    }
}

大致意思就是extra是Item的一个json字段,String型的,落库,而extraMap是一个对应extra的Map,不落库,方便外部查询使用的。因为重写了setExtra方法,所以如果某个Item在数据库表中的extra字段为null,当它从DB被查出来的时候extraMap会被设置为一个空Map。

一切看上去很正常?看一下Collections.emptyMap()的源码:

/**
 * Returns an empty map (immutable).  This map is serializable.
 *
 * <p>This example illustrates the type-safe way to obtain an empty map:
 * <pre>
 *     Map<String, Date> s = Collections.emptyMap();
 * </pre>
 * @implNote Implementations of this method need not create a separate
 * {@code Map} object for each call.  Using this method is likely to have
 * comparable cost to using the like-named field.  (Unlike this method, the
 * field does not provide type safety.)
 *
 * @param <K> the class of the map keys
 * @param <V> the class of the map values
 * @return an empty map
 * @see #EMPTY_MAP
 * @since 1.5
 */
@SuppressWarnings("unchecked")
public static final <K,V> Map<K,V> emptyMap() {
    return (Map<K,V>) EMPTY_MAP;
}

可以看到,使用这个方法比直接new一个map的花费要小,但是这个方法返回的map是immutable的,也就是不可变的,是一个EmptyMap实例,继承自AbstractMap,当尝试对这个map执行put操作时,会抛异常:

Exception in thread "main" java.lang.UnsupportedOperationException
at java.util.AbstractMap.put(AbstractMap.java:209)
at com.example.demo.StreamSetDemo.lambda$main$0(StreamSetDemo.java:43)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382)
at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
at com.example.demo.StreamSetDemo.main(StreamSetDemo.java:46)

细心的同学会发现,不对呀,这个map是不可变的跟你出现的这个问题有半毛钱关系吗?你的代码在执行extraMap.put("decreaseRate", decreaseRateMap.get(t.getId()));这一句时就应该抛异常。没错,照理确实是这样,但是请注意我的标题,所以这里还跟dubbo有关系。一开始我也说了,Item对象是通过dubbo接口获得的,这有什么关系吗?我们来看个例子,这里省略了dubbo的相关配置和接口。

provider:

public class DemoServiceImpl implements DemoService {
    
    @Override
    public List<Item> getItems() {
        Item item1 = new Item();
        item1.setExtraMap(Collections.emptyMap());
        Item item2 = new Item();
        item2.setExtraMap(Collections.emptyMap());
        List<Item> itemList = new ArrayList<>();
        itemList.add(item1);
        itemList.add(item2);
        return itemList;
    }
}

provider启动类:

public class Application {
    public static void main(String[] args) throws Exception {
        ServiceConfig<DemoServiceImpl> service = new ServiceConfig<>();
        service.setApplication(new ApplicationConfig("dubbo-demo-api-provider"));
        service.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234"));
        service.setInterface(DemoService.class);
        service.setRef(new DemoServiceImpl());
        service.export();
        System.in.read();
    }
}

consumer:

public class Application {
    public static void main(String[] args) {
        ReferenceConfig<DemoService> reference = new ReferenceConfig<>();
        reference.setApplication(new ApplicationConfig("dubbo-demo-api-consumer"));
        reference.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234"));
        reference.setInterface(DemoService.class);
        DemoService service = reference.get();
        List<Item> items = service.getItems();
        System.out.println(items);
    }
}

启动provider,然后跑一下consumer,在System.out.println(items)打上断点

我们看到了什么!在consumer端,这里的extraMap从EmptyMap变成了HashMap,所以extraMap可以put了。这不是最令人惊奇的,注意两个item中map的内存地址,都是2446,也就是说,这两个map指向的是同一个对象!这就解释了我一开始碰到的问题,因为两个item中的map指向的是同一个对象,所以第二次put的时候就把第一次的值覆盖了,最终两个item中的map就都变成了最后的那次赋值。

但是这里为什么两个map会是同一个对象呢?这个跟Collections.emptyMap()方法有关,注释说这个方法能够减少消耗,返回不可变集合哪里减少消耗了?关键是,这个方法返回的是一个final型的内部变量

public static final Map EMPTY_MAP = new EmptyMap<>();

所以,如果在程序的不同地方都调用了Collections.emptyMap(),其实返回的是同一个对象。

以下是我关于hessian序列化的猜测了:

dubbo默认使用的hessian序列化会考虑到引用是否相同,所以虽然EmptyMap经历序列化和反序列化后变成了HashMap,但是引用指向相同的特性还是保留了下来,结果就变成了两个HashMap指向了相同的对象。

总结

  1. 序列化的内部机制有时候会有隐藏的坑,小心误踩
  2. Collections的某些方法要注意使用场景,只有确保返回接口不会被修改的情况下再去使用emptyMap()等方法

相关推荐

拒绝躺平,如何使用AOP的环绕通知实现分布式锁

如何在分布式环境下,像用synchronized关键字那样使用分布式锁。比如开发一个注解,叫@DistributionLock,作用于一个方法函数上,每次调方法前加锁,调完之后自动释放锁。可以利用Sp...

「解锁新姿势」 兄dei,你代码需要优化了

前言在我们平常开发过程中,由于项目时间紧张,代码可以用就好,往往会忽视代码的质量问题。甚至有些复制粘贴过来,不加以整理规范。往往导致项目后期难以维护,更别说后续接手项目的人。所以啊,我们要编写出优雅的...

消息队列核心面试点讲解(消息队列面试题)

Rocketmq消息不丢失一、前言RocketMQ可以理解成一个特殊的存储系统,这个存储系统特殊之处数据是一般只会被使用一次,这种情况下,如何保证这个被消费一次的消息不丢失是非常重要的。本文将分析Ro...

秒杀系统—4.第二版升级优化的技术文档二

大纲7.秒杀系统的秒杀活动服务实现...

SpringBoot JPA动态查询与Specification详解:从基础到高级实战

一、JPA动态查询概述1.1什么是动态查询动态查询是指根据运行时条件构建的查询,与静态查询(如@Query注解或命名查询)相对。在业务系统中,80%的查询需求都是动态的,例如电商系统中的商品筛选、订...

Java常用工具类技术文档(java常用工具类技术文档有哪些)

一、概述Java工具类(UtilityClasses)是封装了通用功能的静态方法集合,能够简化代码、提高开发效率。本文整理Java原生及常用第三方库(如ApacheCommons、GoogleG...

Guava 之Joiner 拼接字符串和Map(字符串拼接join的用法)

Guave是一个强大的的工具集合,今天给大家介绍一下,常用的拼接字符串的方法,当然JDK也有方便的拼接字符串的方式,本文主要介绍guava的,可以对比使用基本的拼接的话可以如下操作...

SpringBoot怎么整合Redis,监听Key过期事件?

一、修改Redis配置文件1、在Redis的安装目录2、找到redis.windows.conf文件,搜索“notify-keyspace-events”...

如何使用Python将多个excel文件数据快速汇总?

在数据分析和处理的过程中,Excel文件是我们经常会遇到的数据格式之一。本文将通过一个具体的示例,展示如何使用Python和Pandas库来读取、合并和处理多个Excel文件的数据,并最终生成一个包含...

利用Pandas高效处理百万级数据集,速度提升10倍的秘密武器

处理大规模数据集,尤其是百万级别的数据量,对效率的要求非常高。使用Pandas时,可以通过一些策略和技巧显著提高数据处理的速度。以下是一些关键的方法,帮助你使用Pandas高效地处理大型数据集,从而实...

Python进阶-Day 25: 数据分析基础

目标:掌握Pandas和NumPy的基本操作,学习如何分析CSV数据集并生成报告。课程内容...

Pandas 入门教程 - 第五课: 高级数据操作

在前几节课中,我们学习了如何使用Pandas进行数据操作和可视化。在这一课中,我们将进一步探索一些高级的数据操作技巧,包括数据透视、分组聚合、时间序列处理以及高级索引和切片。高级索引和切片...

原来这才是Pandas!(原来这才是薯片真正的吃法)

听到一些人说,Pandas语法太乱、太杂了,根本记不住。...

python(pandas + numpy)数据分析的基础

数据NaN值排查,统计,排序...

利用Python进行数据分组/数据透视表

1.数据分组源数据表如下所示:1.1分组键是列名分组键是列名时直接将某一列或多列的列名传给groupby()方法,groupby()方法就会按照这一列或多列进行分组。按照一列进行分组...

取消回复欢迎 发表评论: