Spring Data Elasticsearch保存实体后findBy查询延迟，如何等待索引更新？

问题原因 #

Elasticsearch是**近实时(NRT)**搜索引擎，默认索引更新后需要等待1秒的刷新间隔，新文档才会出现在搜索结果中。而findById能立刻查到，是因为它调用的是ES的Get API，直接读取文档的原始存储，无需等待索引刷新；findByDestination这类条件查询调用的是Search API，必须等索引刷新完成后才能看到新插入的文档。

解决方法 #

1. 保存时指定刷新策略 #

Spring Data Elasticsearch支持在保存时设置RefreshPolicy，强制索引立即刷新或等待刷新完成：

• 方法一：使用ElasticsearchOperations

  @Autowired
  private ElasticsearchOperations elasticsearchOperations;
  
  // 保存实体时指定IMMEDIATE刷新策略
  WebSocketEntity entity = new WebSocketEntity();
  // 填充实体字段逻辑...
  elasticsearchOperations.save(entity, IndexQuery.builder()
          .withRefreshPolicy(RefreshPolicy.IMMEDIATE)
          .build());
  

• 方法二：自定义Repository方法添加@Refresh注解
  在Repository接口中重写save方法，绑定刷新策略：

  public interface WebSocketRepository extends ElasticsearchRepository<WebSocketEntity, String> {
      @Refresh(refreshPolicy = "immediate")
      @Override
      <S extends WebSocketEntity> S save(S entity);
  
      List<WebSocketEntity> findByDestination(String destination);
  }
  

  注意：RefreshPolicy.IMMEDIATE会立即刷新索引，适合测试或低并发场景；若要平衡性能与实时性，可使用RefreshPolicy.WAIT_UNTIL，它会等待刷新完成后再返回，性能损耗相对更小。

2. 手动触发索引刷新 #

在调用save后，主动触发对应索引的刷新操作：

webSocketRepository.save(entity);
// 刷新WebSocketEntity对应的索引
elasticsearchOperations.indexOps(WebSocketEntity.class).refresh();

3. 调整索引默认刷新间隔（仅测试环境使用） #

测试环境下可将索引的refresh_interval设为0s，实现实时刷新，但生产环境绝对禁止——这会大幅降低ES的写入性能：

@Setting(refreshInterval = "0s")
@Document(indexName = "websockets")
public class WebSocketEntity {
    @Id
    private String sessionId;
    private String destination;
    // 其他字段及getter/setter...
}

补充说明 #

日志中findById能立即查到数据，是因为ES的Get API绕过了搜索倒排索引，直接从Lucene的分段中读取文档数据，不受索引刷新间隔限制；而条件查询依赖倒排索引，必须等待刷新完成才能获取新数据。

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