elasticsearch 5.x 系列之六文档索引，更新，查询，删除流程

￡神魔★判官ぃ 2022-05-14 10:53 291阅读 0赞

### 一、elasticsearch index 索引流程 ###

步骤：  
客户端向Node1 发送索引文档请求  
Node1 根据文档ID(\_id字段)计算出该文档应该属于shard0，然后请求路由到Node3的P0分片上。  
Node3在P0上执行了请求。如果请求成功，则将请求并行的路由至Node1，Node2的R0上。当所有的Replicas报告成功后，Node3向请求的Node(Node1)发送成功报告，Node1再报告至Client。  
当客户端收到执行成功后，操作已经在Primary shard和所有的replica shards上执行成功了  
![elasticsearch-写数据流程][elasticsearch-]

### 二、 elasticsearch 数据读取流程 ###

1.客户端发送Get请求到NODE1。  
2.接着NODE1使用文档的\_id决定文档属于R0 分片，然后获取R0的所有副本的地址。这次，它将请求路由至NODE2。  
3.NODE2将文档返回给NODE1，NODE1将文档返回给客户端。 对于读请求，请求节点(NODE1)将在每次请求到来时都选择一个不同的replica。  
shard来达到负载均衡。使用轮询策略轮询问所有的replica shards。  
![elasticsearch-取数据流程][elasticsearch- 1]

### 三、 elasticsearch 数据更新流程 ###

1.客户端发送更新操作请求至NODE1  
2.NODE1将请求路由至NODE3，Primary shard所在的位置  
3.NODE3从P0读取文档，改变source字段的JSON内容，然后试图重新对修改后的数据在P0做索引。如果此时这个文档已经被其他的进程修改了，那么它将重新执行3步骤，这个过程如果超过了retryon\_conflict设置的次数，就放弃。  
4.如果NODE3成功更新了文档，它将并行的将新版本的文档同步到NODE1和NODE2的replica shards重新建立索引。一旦所有的replica  
shards报告成功，NODE3向被请求的节点(NODE1)返回成功，然后NODE1向客户端返回成功。  
![1448990-20180727115215250-220025529.png][]

### 四、 elasticsearch 删除数据 ###

(流程和数据索引类似，删除只是标记这个文档不可用，并不是立即删除)
    客户端向 Node 1 发送删除请求。
    节点使用文档的 _id 确定文档属于分片 0 。请求会被转发到 Node 3`，因为分片 0 的主分片目前被分配在 `Node 3 上。
    Node 3 在主分片上面执行请求。如果成功了，它将请求并行转发到 Node 1 和 Node 2 的副本分片上。一旦所有的副本分片都报告成功, Node 3 将向协调节点报告成功，协调节点向客户端报告成功。

![1448990-20180727115901745-1724662407.png][]

[elasticsearch-]: /images/20220514/30072d7b2cbf4b73af987220198a4923.png
[elasticsearch- 1]: /images/20220514/c8f941ca47ca4a44a87e06316359b92d.png
[1448990-20180727115215250-220025529.png]: /images/20220514/0eb2cd2e873e419a9f6a9dce0aeb92d8.png
[1448990-20180727115901745-1724662407.png]: /images/20220514/69aa40c4a3814b7a9485e92a3d37cf10.png