ElasticSearch入门之es的分片交互过程, es添加文档分片流程, es删除文档分片流程, es删除文档分片流程 13

逃离我推掉我的手 2021-10-14 04:30 749阅读 0赞

# 1. es添加文档分片交互流程 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70]

1.  客户端发送一个索引的请求给node1
2.  node1接收到请求后,会根据请求中携带的参数"**文档id**"判断出该文档应该存储在具体哪一个shard中.  
    **shard = hash(rounting) % number\_of\_primary\_shards**  
    比如, 计算出的结果是该条数据存在在shard0分片上.  
    node1通过元数据信息可以知道shard0存在于哪一个节点上, 如图是node3节点, 于是node1会把请求转发给node3
3.  node3接收到请求之后会将请求并行的分发给shard0的所有副本中(R0,R1), 也就是存在于node1和node2中的副本;  
    如果所有的副本都成功地接受了请求,并成功的存储了数据. 就会向node3回复一个**成功确认**  
    当node3接收到了所有副本的**成功**的确认消息, 则最后向客户端返回一个**Success**的消息.

# 2. es删除文档分片交互流程 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70 1]  
该过程可以分为四个阶段来描述：

1.  客户端向node 1发送一个文档删除的请求。
2.  同样的node 1通过请求中**文档的 \_id** 值判断出该文档应该被存储在shard 0 这个分片中，并且node 1知道shard 0的primary shard位于node3这个节点上。因此node1会把这个请求转发到node3。
3.  node3接收到请求后，在主分片上面执行删除请求
4.  如果node3成功地删除了文档，node3将会请求并行地发给其余所有的**副本**所在node中。  
    这些node也同样操作删除，执行后则向node3发送一个**成功确认**，当node 3接收到所有的成功确认之后，  
    再向客户端发送一个删除成功的信息。

# 3 es查询文档分片交互流程 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70 2]  
检索文档的时候，我们并不知道文档在集群中的哪个位置，所以一般情况下不得不去询问index中的**每一个shard**，然后将结果拼接成一个大的已排好序的汇总结果列表；

1.  客户端发送一个检索请求给node3，此时node3会创建一个空的优先级队列并且配置好分页参数from与size。
2.  node3将检所请求发送给index中的每一个shard（primary 和 replica），每一个在本地执行检索，并将结果添加到本地的优先级队列中；
3.  每个shard返回本地优先级序列中所记录的\_id与**score值**，并发送node3。Node3将这些值合并到自己的本地的优先级队列中，并做全局的排序（node 3将它们合并成一条汇总的结果），返回给客户端。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70]: /images/20211013/f9475482f638460b9fb9131ebd86bacf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70 1]: /images/20211013/ce94f17b9ff64ba4afa7117d2fabd9dc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjY0MTkwOQ_size_16_color_FFFFFF_t_70 2]: /images/20211013/fa453dbba93a4580b24ab1a67ab60ec7.png

发表评论取消回复

表情：

评论列表（有 0 条评论，749人围观）

还没有评论，来说两句吧...

相关阅读

相关 Elasticsearch 文档到分片路由算法查询文档到分片路由信息

根据文档ID计算HASH值，然后对主分片数量进行取模，得到对应的主分片，也可以使用指定参数，进行HASH值的计算，让特定的文档落在特定的分片上。添加测试文档

比眉伴天荒/ 2023年01月16日 03:22/ 0 赞/ 148 阅读

相关深入ES分片

文章目录（1）倒排索引不可变的好处？（2）什么是per-segment search？

亦凉/ 2022年12月19日 06:17/ 0 赞/ 164 阅读

相关 Elasticsearch(033)：es中Document（文档）之删除文档

一、概述在[上一小节][Link 1]中，我们学习了文档的定义和新增语法。当然，有新增操作，相反的就会有删除操作。es中的文档的删除操作分为两类: `主键删除` 和`查

曾经终败给现在/ 2022年12月03日 15:59/ 0 赞/ 839 阅读

相关 ElasticSearch 初识文档与索引、分片

文档 Elasticsearch 是面向文档的，意味着它存储整个对象或文档，文档是ElasticSearch 可搜索数据的最小单位。 \- 文档类

亦凉/ 2022年11月30日 15:44/ 0 赞/ 273 阅读

相关【Elasticsearch】 es primary shard 主分片 PrimaryOperationTransportHandler

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ub

╰+哭是因爲堅強的太久メ/ 2022年10月07日 02:59/ 0 赞/ 165 阅读

相关 elasticsearch es 手动操作分片设置

动态设置es索引副本数量 curl -XPUT 'http://168.7.1.67:9200/log4j-emobilelog/_settings' -d '

深碍√TFBOYSˉ_/ 2022年07月14日 14:36/ 0 赞/ 581 阅读

相关 mongodb移除分片删除分片上数据库和添加分片

首先我们要移除的分片之后再次添加此分片时会出现添加失败的情况，需要在添加的分片上登录进行删除此分片之前数据库的历史数据比如testdb，删除分片上的数据库之后就可重新添加此分片

小灰灰/ 2022年06月02日 12:16/ 0 赞/ 708 阅读

相关 ElasticSearch入门之es集群数据存储分片副本模式, es专业术语 04

1. 概述 es是面向文档(document oriented)的, 这意味着它可以存储整个对象或文档(document). 然而它不仅仅是存储, 还会索引(index)

小灰灰/ 2021年10月18日 14:50/ 0 赞/ 582 阅读

相关 ElasticSearch入门之es的分片交互过程, es添加文档分片流程, es删除文档分片流程, es删除文档分片流程 13

1. es添加文档分片交互流程 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cH

逃离我推掉我的手/ 2021年10月14日 04:30/ 0 赞/ 750 阅读

相关关于es集群分片设计注意事项

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQw

深藏阁楼爱情的钟/ 2021年10月09日 07:48/ 0 赞/ 337 阅读