Spring Data Elasticsearch异步字段更新与完成状态标记方案咨询

问题背景 #

我在使用Spring Data Elasticsearch时遇到了这样的业务场景：需要对实体执行查询、部分新增/更新操作，并且要在所有必填字段填充完成后，将completed字段设为true并发送通知。

实体模型 #

public class Entity{
  @Id private String id;
  private String country;
  private String city;
  private boolean completed;
  // 其他3个类似country、city的字段，总计4个需异步填充的字段
}

场景细节 #

• 4个需填充的字段会异步乱序传入应用，必须处理竞态条件
• 当所有4个字段都填充完成时，必须设置completed=true并发送通知

现有尝试与问题 #

在SQL中，我可以通过@Transactional事务实现查询-修改的原子操作：根据ID查询实体、更新对应字段、检查是否所有字段都已填充、设置completed后保存。

但在Elasticsearch中，我最初使用了基础CRUD仓库：

public interface EntityRepository extends ElasticsearchRepository<Entity, String> {
}

这种方案存在明显问题：查询和保存之间数据可能被其他请求修改，导致最终判断字段是否完整时出现错误。

后来我了解到可以用ElasticsearchTemplate执行部分更新（比如收到city时只更新这个字段），但不确定如何正确设置completed字段：如果更新后再查询实体判断是否完成，会存在竞态问题——比如A请求更新city后准备查询，此时B请求已经更新了country，两次查询都会判定实体已完成，最终导致发送重复通知。

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