如何解决Elasticsearch中实体更新与删除事件并发的不一致问题

针对同一文章的删除、更新事件乱序执行，导致删除后又被重建的问题，提供以下几个高效可行的解决方案：

方案1：给删除请求添加外部版本控制，利用版本号确保操作优先级 #

核心思路是让所有操作（更新/删除）都携带业务侧生成的递增版本号，借助Elasticsearch的外部版本控制机制，确保只有版本号更高的操作才能生效，从根源避免旧版本操作覆盖新版本操作。

修改删除逻辑代码： #

private final RestHighLevelClient client;

// 注意：删除事件必须携带该文章的最新版本号（业务侧删除时生成递增版本）
DeleteRequest deleteRequest = new DeleteRequest(index, "article", article.getId());
deleteRequest.version(article.getVersion()); // 绑定删除事件对应的版本号
deleteRequest.versionType(VersionType.EXTERNAL);

try {
    DeleteResponse response = client.delete(deleteRequest, RequestOptions.DEFAULT);
} catch (VersionConflictEngineException e) {
    // 版本冲突：说明已有更高版本的操作（比如更新）先执行，忽略该删除事件
    log.info("Version conflict for document {} when deleting, skip operation", article.getId());
}

更新逻辑保留原有代码，新增异常处理： #

private final RestHighLevelClient client;

IndexRequest request = new IndexRequest(index, "article", article.getId()).source(article);
request.versionType(VersionType.EXTERNAL);
request.version(article.getVersion());

try {
    IndexResponse response = client.index(request, RequestOptions.DEFAULT);
} catch (VersionConflictEngineException e) {
    // 版本冲突：说明已有更高版本的操作（比如删除）先执行，忽略该更新事件
    log.info("Version conflict for document {} when updating, skip operation", article.getId());
}

效果：

• 不管事件顺序如何，只有版本号最高的操作会最终生效
• 如果删除事件版本号 > 更新事件版本号，即使更新先执行，后续删除会覆盖；如果删除先执行，后续更新会因版本冲突失败，不会重建文档

方案2：给更新请求添加「文档存在」条件，避免删除后重建 #

在原有更新逻辑的基础上，添加ifExists(true)约束，让IndexRequest仅在文档存在时执行，同时保留外部版本控制，只需要一次请求即可完成判断+更新，比先查询再更新更高效。

修改后的更新逻辑代码： #

private final RestHighLevelClient client;

IndexRequest request = new IndexRequest(index, "article", article.getId()).source(article);
request.versionType(VersionType.EXTERNAL);
request.version(article.getVersion());
request.ifExists(true); // 仅当文档存在时执行索引操作

try {
    IndexResponse response = client.index(request, RequestOptions.DEFAULT);
} catch (DocumentMissingException e) {
    // 文档已被删除，忽略该更新事件
    log.info("Document {} does not exist, skip update operation", article.getId());
} catch (VersionConflictEngineException e) {
    // 版本冲突，存在更高版本操作，忽略
    log.info("Version conflict for document {}, skip update operation", article.getId());
}

效果：

• 无需额外查询请求，一次操作完成存在性校验+版本校验
• 文档被删除后，更新请求会触发DocumentMissingException，直接忽略即可，不会重建文档

方案3：改用软删除，避免物理删除后的重建 #

放弃物理删除，给文章添加is_deleted布尔字段，删除事件仅标记该字段为true，更新事件仅在is_deleted=false时执行。同时结合版本控制确保操作的正确性。

软删除逻辑代码： #

private final RestHighLevelClient client;

// 软删除：标记is_deleted为true，同时更新版本号
IndexRequest softDeleteRequest = new IndexRequest(index, "article", article.getId())
        .source(Map.of(
                "id", article.getId(),
                // 保留原有业务字段，仅更新删除标记和版本
                "title", article.getTitle(),
                "content", article.getContent(),
                "is_deleted", true,
                "version", article.getVersion()
        ))
        .versionType(VersionType.EXTERNAL)
        .version(article.getVersion());

try {
    IndexResponse response = client.index(softDeleteRequest, RequestOptions.DEFAULT);
} catch (VersionConflictEngineException e) {
    log.info("Version conflict when soft deleting document {}, skip operation", article.getId());
}

更新逻辑代码（带软删除校验）： #

private final RestHighLevelClient client;

// 使用带条件的UpdateRequest，仅当文档未删除且版本更新时执行
UpdateRequest updateRequest = new UpdateRequest(index, "article", article.getId())
        .doc(article)
        .setIfCondition(new ScriptCondition(new Script(
                ScriptType.INLINE, "painless",
                "ctx._source.is_deleted == false && ctx._source.version < params.version",
                Collections.singletonMap("version", article.getVersion())
        )));

try {
    UpdateResponse response = client.update(updateRequest, RequestOptions.DEFAULT);
    if (!response.isResultUpdated()) {
        log.info("Document {} is deleted or version is not newer, skip update", article.getId());
    }
} catch (DocumentMissingException e) {
    log.info("Document {} does not exist, skip update", article.getId());
}

效果：

• 保留历史数据，便于回溯
• 查询时需添加过滤条件is_deleted: false，确保返回有效文档

内容的提问来源于stack exchange，提问作者Rohit Suthar