Elasticsearch分布式原理集群数据分布机制与分片路由全流程深度剖析前言一、核心前置分布式数据依赖的三大基础组件1.1 主节点Master Node1.2 数据节点Data Node1.3 分片与副本Shard Replica二、ES 分布式数据分布核心总流程图三、第一步数据分片机制 —— 数据如何被拆分3.1 什么是分片3.2 分片分布规则核心3.3 3节点、5主分片、1副本分布示例四、第二步数据路由算法 —— 数据到底存在哪个分片4.1 路由公式ES 默认固定算法4.2 算法作用4.3 实战案例4.4 自定义路由高级五、第三步分布式写入流程 —— 数据如何同步到多节点5.1 分布式写入完整流程图5.2 写入步骤详细拆解5.3 核心特点六、第四步分布式查询流程 —— 数据如何从多节点汇总6.1 分布式查询流程图6.2 查询步骤详细拆解七、第五步分布式容错机制 —— 节点挂了数据怎么办7.1 主分片宕机7.2 数据节点宕机7.3 协调节点宕机八、第六步数据再平衡 —— 扩容节点后数据如何自动迁移8.1 扩容流程8.2 核心优势九、分布式数据分布核心规则生产必须遵守十、总结流程图总结The Begin点点关注收藏不迷路前言Elasticsearch 天生就是分布式搜索引擎能够轻松支撑PB级数据、亿级文档、高并发读写的核心原因就是它拥有一套极其成熟、稳定、高效的分布式数据分布机制。很多开发者只会用ES却不懂数据在集群中如何存储、路由、复制、负载均衡一旦遇到分片不均、数据丢失、扩容故障就束手无策。本文从分布式核心组件、数据路由算法、分片副本分布、写入/查询流程、容错机制五大维度搭配流程图原理图实战案例彻底讲透ES分布式环境下的数据分布原理帮你真正掌握ES分布式精髓。一、核心前置分布式数据依赖的三大基础组件ES 能实现分布式数据分布必须依赖以下核心角色1.1 主节点Master Node管理集群元数据索引、分片、映射、节点状态负责分片分配、负载均衡、故障转移不存储业务数据不执行搜索1.2 数据节点Data Node存储分片Shard真实数据执行写入、查询、聚合、合并数据分布的实际载体1.3 分片与副本Shard Replica主分片Primary Shard数据写入单元一个索引会被切分成N个主分片副本分片Replica Shard主分片的备份提高查询并发容错分片是ES分布式数据分布的最小单元二、ES 分布式数据分布核心总流程图渲染错误:Mermaid 渲染失败: Parse error on line 3: ...B -- C[计算文档路由hash(document_id) % 主分片数 ----------------------^ Expecting SQE, DOUBLECIRCLEEND, PE, -), STADIUMEND, SUBROUTINEEND, PIPE, CYLINDEREND, DIAMOND_STOP, TAGEND, TRAPEND, INVTRAPEND, UNICODE_TEXT, TEXT, TAGSTART, got PS这就是 ES 分布式数据“写入—分布—存储—查询”的完整流程。三、第一步数据分片机制 —— 数据如何被拆分3.1 什么是分片索引非常大 → 单机无法存储ES 自动把索引水平切分成多个小数据块 →分片分片独立存储在不同数据节点实现分布式存储、负载均衡、并行计算3.2 分片分布规则核心主分片与副本分片不会分配在同一个节点防脑裂、防数据丢失同一索引的分片尽量均匀分布在所有节点负载均衡副本分片均匀分布在不同节点提升查询并发3.3 3节点、5主分片、1副本分布示例节点1主分片1、主分片2、副本3、副本4 节点2主分片3、主分片4、副本5、副本1 节点3主分片5、副本1、副本2、副本3均匀分布、互为备份、无单点故障。四、第二步数据路由算法 —— 数据到底存在哪个分片4.1 路由公式ES 默认固定算法目标主分片 hash(文档ID) % 主分片总数4.2 算法作用确保数据均匀分布到所有分片写入时快速定位分片查询时直接定位分片无需广播算法固定永远不会乱4.3 实战案例索引3个主分片文档ID 1001hash(1001) 1010 % 3 1→ 数据写入主分片14.4 自定义路由高级可指定routinguser_id让同一用户数据落在同一个分片查询性能提升10倍。五、第三步分布式写入流程 —— 数据如何同步到多节点5.1 分布式写入完整流程图客户端发送数据协调节点计算路由定位主分片所在节点写入主分片 刷盘并行同步到所有副本分片所有副本返回成功协调节点返回写入成功5.2 写入步骤详细拆解客户端发送数据到任意节点成为协调节点节点计算路由找到目标主分片数据写入主分片主分片并行同步数据到所有副本分片主分片 副本分片全部写入成功返回成功给客户端5.3 核心特点副本同步是并行的速度极快确保强一致性任何副本宕机不影响写入六、第四步分布式查询流程 —— 数据如何从多节点汇总ES 查询分为两个阶段Query查询 Fetch取回6.1 分布式查询流程图客户端查询协调节点广播到所有分片所有分片并行执行查询返回文档ID排序值协调节点合并排序协调节点向对应节点Fetch文档数据节点返回原始文档协调节点封装结果返回6.2 查询步骤详细拆解Query 阶段协调节点将查询发给所有分片所有分片并行搜索返回匹配的文档ID 分数Merge 阶段协调节点全局排序、分页Fetch 阶段向对应节点获取真实数据封装结果返回前端七、第五步分布式容错机制 —— 节点挂了数据怎么办ES 天生高可用依靠副本机制实现自动容错7.1 主分片宕机主节点立即检测到故障提升该分片的副本分片为新主分片数据无丢失、服务不中断故障节点恢复后成为副本分片7.2 数据节点宕机主节点立即重新分配丢失的分片从其他副本同步数据自动恢复集群健康状态7.3 协调节点宕机客户端重试其他节点即可无状态、无影响。八、第六步数据再平衡 —— 扩容节点后数据如何自动迁移8.1 扩容流程新增数据节点加入集群主节点检测到集群不均自动把部分分片从高负载节点迁移到新节点迁移过程不停机、不影响业务最终所有节点负载均匀8.2 核心优势在线扩容自动再平衡水平无限扩展九、分布式数据分布核心规则生产必须遵守主分片与副本绝不分配在同一节点分片大小控制在 30GB~50GB主分片数一旦创建不能修改提前规划副本数 ≥ 1生产至少 1 个副本节点数 ≥ 副本数 1数据均匀分布避免热点节点十、总结流程图索引创建切分成多个主分片分片均匀分布到数据节点创建副本分片实现备份写入路由算法定位分片主副本同步分布式存储查询广播并行搜索结果合并返回故障自动切换副本扩容自动分片再平衡总结Elasticsearch 在分布式环境下的数据分布是一套自动化、高可用、高性能的完整机制核心逻辑可以总结为 5 句话索引切分片分片是分布式最小单元路由算法决定数据存在哪个分片主副分离保证高可用与负载均衡写入并行同步查询并行搜索故障自动转移扩容自动平衡理解这套原理你就能合理规划分片解决集群不均实现无限水平扩容保证生产高可用彻底掌握ES分布式架构精髓The End点点关注收藏不迷路