Elasticsearch创建索引流程

上一篇：ES处理请求的流程

我们延续上一篇来研究一下ES实际是怎么处理创建索引的流程的，我们根据代码一层层点进去看一下

我们看见了什么，这个就是包装了创建索引相关的一些信息，如：路径、以及实体类；根据这个里面的name进行转发，上一篇最后讲了

这里通过client直接执行的

这里的client需要注意，是在node构建的时候创建的NodeClient

在执行execute方法时会走到父类AbstractClient里面去，这个里面就调用了子类实现的doExecute方法

这个方法很重大，这个里面会根据我们传入的action在map里获取他实际执行的TransportAction

这个方法的实现有许多类，但是我们想看的是创建索引的逻辑，所以我们找到
TransportCreateIndexAction的实现

TransportCreateIndexAction里面比较重大的方法就是createIndex，我们点进去看一下

我们一直点进去看一下，实则我们也可以猜想到，后面肯定会提交给一个线程池去执行

看见没有，这里的确 是交给了一个线程池去处理

而且还是一个优先级线程池，线程池的源码我们就不展开讲了，后续会有文章专门讲线程池源码的

我在回过头看看提交的IndexCreationTask线程里面的逻辑

IndexCreationTask.execute里面比较关键的代码就是这一行，在服务器节点创建索引

我们点进去看一下，createIndexService方法一看就是和创建索引相关的逻辑，在继续点进去

我们可以看见创建的IndexService这个类封装了比较核心的创建Shard和删除Shard方法

在就是这里会通过传入的index数据创建一个IndexMetaData(索引元数据)的构造器，在通过构造器模式创建出来索引元数据

根据新的元数据构建一个新的集群状态并且返回

索引创建成功之后则等待指定数量Shard启动

如果为0直接返回

监听集群状态是否发生变化

有发生变化并且满足条件回调监听器的onNewClusterState方法

这个方法会直接将标志位修改为true

标志位为true返回响应