zoukankan      html  css  js  c++  java
  • Elasticsearch 基于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"
    }

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

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

    GET /test_index/test_type/8

    {
    "_index": "test_index",
    "_type": "test_type",
    "_id": "8",
    "_version": 1,
    "found": true,
    "_source": {
    "test_field": "test"
    }
    }

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

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

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

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

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

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

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

    GET /test_index/test_type/8

    {
    "_index": "test_index",
    "_type": "test_type",
    "_id": "8",
    "_version": 2,
    "found": true,
    "_source": {
    "test_field": "test client 1"
    }
    }

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

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

  • 相关阅读:
    (华中科大)江南雨烟 C++ STL 专栏
    MoreWindows 微软认证专家博客目录(白话算法,C++ STL,windows编程)
    「转」基于Jmeter和Jenkins搭建性能测试框架
    【转】docker之Dockerfile实践
    Python 统一动态创建多个model对应的modelForm类(type()函数)
    owasp zap 安全审计工具 安装/拦截请求
    【转】持续集成 Sonar 平台搭建及 Sonar 自定义规则打包部署篇
    【转】SonarQube配置自定义的CheckStyle代码规则
    【转+整理】jenkins与SonarQube集成
    【转】jenkins插件pipeline使用介绍
  • 原文地址:https://www.cnblogs.com/blogabc/p/13735834.html
Copyright © 2011-2022 走看看