elasticsearch 原理和使用 > elasticsearch 基础操作
进行乐观锁并发控制

1、先建数据:


PUT /test_index/test_type/7
{
  "test_field":"test test"
}


2、然后开两个Kinana的页面,同时去获取数据:

GET /test_index/test_type/7

3、其中一个客户端,先更新了一下这个数据,同时带上es中的版本号。


PUT /test_index/test_type/7?version=1
{
  "test_field":"test client 1"
}

更新成功,数据为:


{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "7",
  "_version": 2,
  "result": "updated",
  "_shards": {
   "total": 2,
   "successful": 1,
   "failed": 0
  },
  "created": false
}


4、另一个客户端尝试基于version=1的数据区修改,带上verison版本号。


PUT /test_index/test_type/7?version=1
{
  "test_field":"test client 1"
}


这个时候就会报错,说明这个version已经被别人修改过了:


{
  "error": {
   "root_cause": [
  {
    "type": "version_conflict_engine_exception",
    "reason": "[test_type][7]: version conflict, current version [2] is different than the one provided [1]",
    "index_uuid": "uLa6sFrZQbOJ_CLnqLyFhA",
    "shard": "3",
    "index": "test_index"
  }
],
"type": "version_conflict_engine_exception",
"reason": "[test_type][7]: version conflict, current version [2] is different than the one provided [1]",
"index_uuid": "uLa6sFrZQbOJ_CLnqLyFhA",
"shard": "3",
"index": "test_index"
  },
  "status": 409
}


5、在乐观锁成功阻止并发问题之后,尝试正确的完成更新

GET /test_index/test_type/7


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


PUT /test_index/test_type/7?version=2
{
  "test_field":"test client 1"
}


这个时候就会更新成功:


{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "7",
  "_version": 3,
  "result": "updated",
  "_shards": {
  "total": 2,
  "successful": 1,
  "failed": 0
  },
  "created": false
}


实验二、external verison进行乐观锁进行并发控制。

也就是说不用它内部的version版本号来控制。es提供了一个feature,就是说,你可以不用它提供的内部_version版本号来进行并发控制,可以基于你自己维护的一个版本号来进行并发控制。举个列子,加入你的数据在mysql里也有一份,然后你的应用系统本身就维护了一个版本号,无论是什么自己生成的,程序控制的。这个时候,你进行乐观锁并发控制的时候,可能并不是想要用es内部的_version来进行控制,而是用你自己维护的那个version来进行控制。


?version=1

?version=1&version_type=external


version_type=external,唯一的区别在于,_version,只有当你提供的version与es中的_version一模一样的时候,才可以进行修改,只要不一样,就报错;当version_type=external的时候,只有当你提供的version比es中的_version大的时候,才能完成修改


es,_version=1,?version=1,才能更新成功

es,_version=1,?version>1&version_type=external,才能成功,比如说?version=2&version_type=external


(1)先构造一条数据


PUT /test_index/test_type/8
{
  "test_field": "test"
}


2)模拟两个客户端同时查询到这条数据

GET /test_index/test_type/8


(3)第一个客户端先进行修改,此时客户端程序是在自己的数据库中获取到了这条数据的最新版本号,比如说是3


PUT /test_index/test_type/8?version=3&version_type=external
{
  "test_field": "test client 1"
}


结果为:


{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "8",
  "_version": 3,
  "result": "updated",
  "_shards": {
  "total": 2,
  "successful": 1,
  "failed": 0
  },
  "created": false
}


(4)模拟第二个客户端,同时拿到了自己数据库中维护的那个版本号,也是3,同时基于version=3发起了修改


PUT /test_index/test_type/8?version=3&version_type=external
{
  "test_field": "test client 2"
}


这个时候是修改不成功的,结果会报错,例如:


{
  "error": {
  "root_cause": [
  {
    "type": "version_conflict_engine_exception",
    "reason": "[test_type][8]: version conflict, current version [3] is higher or equal to the one provided [3]",
    "index_uuid": "uLa6sFrZQbOJ_CLnqLyFhA",
    "shard": "1",
    "index": "test_index"
  }
],
"type": "version_conflict_engine_exception",
"reason": "[test_type][8]: version conflict, current version [3] is higher or equal to the one provided [3]",
"index_uuid": "uLa6sFrZQbOJ_CLnqLyFhA",
"shard": "1",
"index": "test_index"
},
  "status": 409
}


(5)在并发控制成功后,重新基于最新的版本号发起更新

GET /test_index/test_type/8


然后把版本号GET到的版本号要大,然后再去PUT。


PUT /test_index/test_type/8?version=4&version_type=external
{
  "test_field": "test client 2"
}

然后才能更新成功


{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "8",
  "_version": 4,
  "result": "updated",
  "_shards": {
   "total": 2,
   "successful": 1,
   "failed": 0
  },
  "created": false
}