当前位置：首页 > article >正文

基于 Postman 和 Elasticsearch 测试乐观锁的操作流程

article 2025/1/4 12:30:48

鱼说，你看不到我眼中的泪，因为我在水中。水说，我能感觉到你的泪，因为你在我心中。 -村上春树

在分布式系统中，多个并发操作对同一资源的修改可能导致数据不一致。为了解决这种问题，Elasticsearch 提供了乐观锁（Optimistic Locking）机制，通过控制文档的 _seq_no 和 _primary_term 来确保更新的原子性。本文将通过 Postman 对 Elasticsearch 进行一次乐观锁机制的测试，模拟多个并发请求对同一文档的操作场景。

1.环境配置

在本文的测试中，使用的 Elasticsearch 服务地址为：http://192.168.56.100:9200。

首先，我们通过 Postman 来测试乐观锁的应用场景。这里假设你已经安装并配置好了 Elasticsearch。

Step 1: 创建文档

通过 POST 请求在 Elasticsearch 中创建一个新的文档：
URL:http://192.168.56.100:9200/chhei/system/100
请求方式： POST

请求体：
{ 
    "name": "chhei"
}

输出结果：
{
    "_index": "chhei",
    "_type": "system",
    "_id": "100",
    "_version": 1,
    "result": "created",
    "_shards": {
        "total": 2,
        "successful": 1,
        "failed": 0
    },
    "_seq_no": 2,
    "_primary_term": 1
}

在这里插入图片描述
通过上面的请求，成功创建了一个名为 chhei 的文档，并分配了文档的 _seq_no 和 _primary_term，这是乐观锁机制中的关键部分。初始版本号为 1，_seq_no 为 2，_primary_term 为 1。

Step 2: 乐观请求 1 —— 更新文档

模拟一次乐观锁请求，通过控制 _seq_no 和 _primary_term 来进行文档更新：

URL: http://192.168.56.100:9200/chhei/system/100?if_seq_no=2&if_primary_term=1
请求方式： POST

请求体：
{
    "name": "chhei01"
}

查询文档：接下来通过 GET 请求查看文档更新后的状态：
URL: http://192.168.56.100:9200/chhei/system/100
请求方式： GET

输出结果：
{
    "_index": "chhei",
    "_type": "system",
    "_id": "100",
    "_version": 2,
    "_seq_no": 3,
    "_primary_term": 1,
    "found": true,
    "_source": {
        "name": "chhei01"
    }
}

在这里插入图片描述
可以看到，文档的 name 字段成功更新为了 chhei01，文档版本号增加到 2，_seq_no 变为 3，_primary_term 保持为 1。

Step 3: 乐观请求 2 —— 模拟版本冲突

尝试使用过期的 _seq_no 和 _primary_term 再次更新文档，模拟一次乐观锁冲突：
URL: http://192.168.56.100:9200/chhei/system/100?if_seq_no=2&if_primary_term=1
请求方式： POST

请求体：
{
    "name": "chhei02"
}

输出结果：
{
    "error": {
        "root_cause": [
            {
                "type": "version_conflict_engine_exception",
                "reason": "[100]: version conflict, required seqNo [2], primary term [1]. current document has seqNo [3] and primary term [1]",
                "index_uuid": "ChcNr4J8QzyOk1SuFzvzdQ",
                "shard": "0",
                "index": "chhei"
            }
        ],
        "type": "version_conflict_engine_exception",
        "reason": "[100]: version conflict, required seqNo [2], primary term [1]. current document has seqNo [3] and primary term [1]",
        "index_uuid": "ChcNr4J8QzyOk1SuFzvzdQ",
        "shard": "0",
        "index": "chhei"
    },
    "status": 409
}