通过乐观锁解决在并发情况下对elasticsearch进行增删改操作的并发问题

悠悠 2022-12-21 04:50 131阅读 0赞

### 通过乐观锁解决在并发情况下对elasticsearch进行增删改操作的并发问题 ###

官网文档：[传送门][Link 1]

1.老版本是通过version进行管控，本人现在使用的 elasticsearch-6.4.3，这个版本是通过\_seq\_no和\_primary\_term进行管控的

2.我们对下面的的数据进行修改，需要如下请求

> POST 192.168.1.117:9200/my\_doc/\_doc/1?if\_seq\_no=0&if\_primary\_term=1

{ 
        "_index": "my_doc",
        "_type": "_doc",
        "_id": "1",
        "_version": 1,		// 文档发生更改version会发生累加
        "_seq_no": 13,		// 文档版本号，作用同_version（相当于学生编号，每个班级的班主任为学生分配编号，效率要比学校教务处分配来的更加方便）
        "_primary_term": 1,	// 如果存在多个分片，代表某个分片的编号，文档所在位置（相当于班级）
        "found": true,
        "_source": { 
            "id": "1001",
            "name": "capuda-1",
            "desc": "capuda is very good， 卡布达贼牛逼",
            "create_date": "2020-12-11"
        }
    }

当if\_seq\_no和if\_primary\_term这两个值有一个和数据库中对应的\_seq\_no和\_primary\_term这两个字段内容对不上就会出现下面版本冲突的问题，数据也无法正常修改了

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTQ0NTg3OQ_size_16_color_FFFFFF_t_70_pic_center]  
当if\_seq\_no和if\_primary\_term这两个值有一个和数据库中对应的\_seq\_no和\_primary\_term这两个字段内容一致，数据才能正常进行修改

修改如下请求

> POST 192.168.1.117:9200/my\_doc/\_doc/1?if\_seq\_no=13&if\_primary\_term=1  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTQ0NTg3OQ_size_16_color_FFFFFF_t_70_pic_center 1]

[Link 1]: https://www.elastic.co/guide/en/elasticsearch/reference/current/optimistic-concurrency-control.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTQ0NTg3OQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/5112bfd780494f78a82115b2acac5a7c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTQ0NTg3OQ_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/0dee8abd9a17463d81a4e9bb62dc1672.png