nacos数据一致性服务执行流程

DataStore的batchGet

上篇说到要进行数据同步了，我们先来看下任务key=com.alibaba.nacos.naming.iplist.ephemeral.命名空间##分组@@服务名，所以可能队列里会有多个这样的服务名。尽管是有多个线程去队列去取，但是如果同样的key很多的话，可能一个线程会取到同样的key多个，不过没关系，后面获取数据的时候只能获取一份最新的。

这里keys可能有相同的，但是dataMap里只能有一份，而且是最新的，所以不用担心。

        public Map<String, Datum> batchGet(List<String> keys) {
            Map<String, Datum> map = new HashMap<>(128);
            for (String key : keys) {
                Datum datum = dataMap.get(key);
                if (datum == null) {
                    continue;
                }
                map.put(key, datum);
            }
            return map;
        }

NamingProxy的syncData数据同步

json序列化之后要进行同步啦：

uri是/distro/datum，这里先点到为止，后面会详细说。

DistroController的onSyncDatum

最终还是调用DistroConsistencyServiceImpl的onPut，进行数据保存和更新通知：

后面就是UDP通知客户端更新了，主要流程可以看上面的图。后面说永久结点的数据同步。

好了，今天就到这里了，希望对学习理解有帮助，大神看见勿喷，仅为自己的学习理解，能力有限，请多包涵。

Java 面试宝典是大明哥全力打造的 Java 精品面试题，它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题，而是一套完整的 Java 知识体系，一套你 Java 知识点的扫盲贴。

它的内容包括：

• 大厂真题：Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
• 原创内容：Java 面试宝典内容全部都是大明哥原创，内容全面且通俗易懂，回答部分可以直接作为面试回答内容。
• 持续更新：一次购买，永久有效。大明哥会持续更新 3+ 年，累计更新 1000+，宝典会不断迭代更新，保证最新、最全面。
• 覆盖全面：本宝典累计更新 1000+，从 Java 入门到 Java 架构的高频面试题，实现 360° 全覆盖。
• 不止面试：内容包含面试题解析、内容详解、知识扩展，它不仅仅只是一份面试题，更是一套完整的 Java 知识体系。
• 宝典详情：https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
• 宝典总览：https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
• 宝典进展：https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道，总字数 42w+。大明哥还在持续更新中，下图是大明哥在 2024-12 月份的更新情况：

想了解详情的小伙伴，扫描下面二维码加大明哥微信【daming091】咨询

同时，大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ，回复【面试题】 即可免费领取。