我们上一章在讲解Document数据写入时，提到真正处理请求的那个primary shard会把数据同步给自己的replica shard，同步成功后才返回响应。
事实上，这么说并不完全准确，Elasticsearch其实提供了三种数据同步机制： one ， all ， quorum 。我们可以在请求时带上consistency参数表明采用哪种模式，默认是 quorum 。例如：
put /index/type/id?consistency=quorum
一、数据一致性
1.1 one模式
所谓one模式，就是对于document的写操作（增删改），只要有一个primary shard是active活跃可用的，操作就可以执行。
1.2 all模式
所谓all模式，就是对于document的写操作（增删改），要求必须所有的primary shard和replica shard都是活跃的，才可以执行这个写操作。
1.3 quorum模式
所谓quorum模式，就是对于document的写操作（增删改），写之前必须确保大多数shard都可用，当不满足“大多数”这个条件时，请求就会默认等待1分钟，超过时间就会报timeout错误。我们可以在写操作的时候，加一个timeout参数，比如：
PUT /index/type/id?timeout=30
这样就可以自己控制超时时间。
那么，何谓大多数shard呢？事实上，Elasticsearch是通过一个公式去计算的：
(primary + number_of_replicas) / 2 + 1
举个例子，我们有个索引test_index，一共是1个primary shard，3个replica shard：
PUT /test_index
{
"settings" : {
"number_of_shards" : 1,
"number_of_replicas" : 3
}
}
假设我们有两个ES进程节点，那么shard的分布可能是下面这样的：
此时，(primary + number_of_replicas) / 2 + 1 = (1+3)/2+1 = 3，那么只有当3个shard都是active状态时，写操作才能执行，如果任意一个ES节点挂了，写操作就不能执行了（此时只有2个active shard）。
注意，quorum模式只有当
number_of_replicas>1时才生效，如果不满足条件，请求就会一直wait。
四、总结
本章，我们介绍了Elasticsearch的写一致性原理，特别要注意quorum模式时对于active shard数量的要求，我们在对index进行shard拆分时也要仔细考虑清楚。
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] ，回复【面试题】 即可免费领取。
