ElasticSearch 7.x 实战入门06

本节的主要内容：ES的乐观锁并发控制原理以及模拟过程

1、ES的乐观锁并发控制

1.1、悲观锁与乐观锁

悲观锁的优点是：方便，直接加锁，对应用程序来说透明，不需要做额外的操作；缺点，并发能力很低，同一时间只能一条线程操作数据

乐观锁的优点是：并发能力很高，不给数据加锁，大量线程并发操作；缺点，麻烦，每次更新的时候，都要先对比版本号，然后可能需要重新加载数据，再次修改，再写；这个过程，可能要重复好几次。

1.2、Elasticsearch内部如何基于_version进行乐观锁并发控制

es内部的多线程异步并发修改时，是基于自己的version版本号进行乐观锁并发控制的

第一次创建一个document的时候，它的version内部版本号就是1；以后，每次对这个document执行修改或者删除操作，都会对这个version版本号自动加1；哪怕是删除，也会对这条数据的版本号加1

举例说明：

某document的初始值 version=1，field=test1，模拟两个线程同时进行修改
先修改的field=test2 ，此时获取的version=1
后修改的field=test3，此时获取的version= 1，后修改先到，更新field=test3，此时version= 2
先修改的后到时，此时会比较一下version号，是否相等，如果不相等的话，那么就直接将field=test2这条数据给扔掉，这样的话就不会让旧的数据,覆盖掉新的数据

2、ES内部并发控制

所有的REST命令都可以在 Kibana 7.6.1上正常运行

（1）先构造一条数据出来

POST /test_index/_create/7
{
  "test_field": "test test"
}

（2）模拟两个客户端，都获取到了同一条数据

GET test_index/_doc/7

​ 返回的结果

{
  "_index" : "test_index",
  "_type" : "_doc",
  "_id" : "7",
  "_version" : 3,
  "_seq_no" : 2,
  "_primary_term" : 1,
  "found" : true,
  "_source" : {
    "test_field" : "test test"
  }
}

（3）其中一个客户端，先更新了一下这个数据

注意

一些老的版本es使用version，但是新版本不支持了，会提示我们用if_seq_no和if_primary_term

先查操作之前当前数据的seq_no，primary_term值比如各自是2和1，在更新的时候url带上if_seq_no=2&if_primary_term=1，指明只有在这个值的情况下才进行更新，否则返回错误

PUT test_index/_doc/7?if_seq_no=2&if_primary_term=1
{
  "test_field": "test client 1"
}

如果重复执行就会报 version_conflict_engine_exception异常

此时就需要基于最新的数据和版本号去进行修改，修改后，带上最新的版本号，可能这个步骤会需要反复执行好几次，才能成功，特别是在多线程并发更新同一条数据很频繁的情况下

//使用最新的_seq_no和_primary_term就可以正常更新了
PUT test_index/_doc/7?if_seq_no=3&if_primary_term=1
{
  "test_field": "test client 1"
}

3、ES基于 external version 进行并发控制

使用外部版本（使用其他数据库作为主要数据存储）

当version_type=external时，只有当你提供的version比es中的_version大的时候，才能完成修改

当document 的_version=1,只有当version>1&version_type=external,才能成功,

比如说使用version=7&version_type=external更新document成功后，该document的_version会设置为7，后续的更新需要基于最新的版本号发起更新

PUT test_index/_doc/7?version=7&version_type=external
{
  "title":"iphone",
  "count":130
}