ES 创建索引最终都会调用 org/elasticsearch/index/engine/InternalEngine.java 中下面的方法：
public IndexResult index(Index index) throws IOException {注意这里的index中包含有要写入的doc，该方法的执行流程图如下：
注意：结合上边的流程图来看代码，先对整体有个全局的认识，再深入到各个部分深入分析。切勿在对整体不甚了解的情况下，深入到代码细节，切记，切记。
准备文档的索引计划准备索引计划根据是否为主节点分别调用：planIndexingAsPrimary和planIndexingAsNonPrimary函数，接下来我们看下planIndexingAsPrimary的逻辑（位于org/elasticsearch/index/engine/InternalEngine.java 中）。
private IndexingStrategy planIndexingAsPrimary(Index index) throws IOException {这个方法最终返回一个4个IndexingStrategy（索引的策略）中的一个，四个索引的策略分别如下：
optimizedAppendOnlyskipDueToVersionConflictprocessNormallyoverrideExistingAsIfNotThere
不同的策略对应不同的处理逻辑，前面三个是常用的，流程图如下：
对于1的说明：canOptimizeAddDocument函数中只判断autoGeneratedIdTimestamp变量是否不等于-1；如果不等于-1意味着这个这个文档有一个自动生成的id，就意味着这个文档能以optimized的方式加入到索引中。
对于2的说明：为了判断版本是否冲突，首先会根据文档id从内存中的map中获取versionValue，获取不到则从磁盘中获取，如果还获取不到说明之前没有索引过这个文档，则不存在版本冲突的问题。获取到versionValue后会和index.version()进行比较，看是否存在版本冲突。index.version()是在发送索引命令时指定的参数。
对于3的说明：maxUnsafeAutoIdTimestamp用于记录之前处理的文档的autoGeneratedIdTimestamp的最大值，如果不是retry，且autoGeneratedIdTimestamp小于maxUnsafeAutoIdTimestamp，说明之前已经索引过，反之则没建立过索引【这儿存在一个问题，分布式情况下，如何保证到达的顺序（小的autoGereratedIdTimestamp先处理），如果这个id是在到达本机之后才生成的就不存在这个问题（如果是一个进程生成才不存在这个问题，多个进程还是存在这个问题）】。如果是retry，则返回mayHaveBeenIndexBefore(true)，如果autoGenerateIdTimestamp小于maxUnsafeAutoIdTimestamp，无操作，如果大于则将其值设置到maxUnsafeAutoIdTimestamp中
对于4的说明：这四种策略最终都会创建一个IndexingStrategy对象。
final boolean currentNotFoundOrDeleted; 这个文档不存在or已经被删除（versionValue.isDelete()） final boolean useLuceneUpdateDocument; 使用lucene更新文档 final long seqNoForIndexing; lucene中从0开始自增的文档编号 final long versionForIndexing; 版本号 final boolean indexIntoLucene; 与useLuceneUpdateDocument相对，这个是直接写入而非更新 final Optional<IndexResult> earlyResultOnPreFlightError; 之前的错误信息至此，总览图中的1准备文档的索引计划就分析完成了。
索引写入lucene接着开始分析总览中的 ——2：写入lucene返回indexResult。
ing
参考文档：
https://segmentfault.com/a/1190000011272749