Elasticsearch重新索引后查询结果与索引不一致，如何判断索引就绪？

我有一个Elasticsearch索引，在索引完成后会执行重新索引操作。之后，Java编写的管道会通过聚合查询获取产品属性（比如分类及其数量）并缓存这些值，但发现缓存值和索引实际值不一致。我怀疑是重新索引后立刻查询，此时索引还没完全就绪（重新索引未彻底完成）导致的。我知道在Java中可以给IndexRequest设置刷新策略：

IndexRequest indexRequest = new IndexRequest(indexAlias);
indexRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);

但我的操作是用于聚合查询的SearchRequest，请问该如何判断索引已完全就绪，能读取到最新数据？

1. 在重新索引操作时设置刷新策略 #

重新索引本身属于写入操作，核心是在ReindexRequest上配置刷新策略，确保操作完成后索引数据已可搜索：

ReindexRequest reindexRequest = new ReindexRequest();
reindexRequest.setSourceIndices("source_index");
reindexRequest.setDestIndex("target_index");
// 设置WAIT_UNTIL，等待索引刷新完成后再返回结果
reindexRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
// 执行重新索引请求
client.reindex(reindexRequest, RequestOptions.DEFAULT);

这样重新索引请求会阻塞到索引完全刷新、数据可被查询后才结束，后续的聚合查询就能直接拿到最新值。

2. 查询前主动触发索引刷新 #

如果无法修改重新索引的逻辑，可以在执行SearchRequest前主动调用刷新API：

// 针对目标索引发起刷新请求
RefreshRequest refreshRequest = new RefreshRequest("target_index");
client.indices().refresh(refreshRequest, RequestOptions.DEFAULT);

// 刷新完成后执行聚合查询
SearchRequest searchRequest = new SearchRequest("target_index");
// 构建你的聚合查询逻辑...
SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);

注意：频繁触发刷新会增加ES的性能开销，仅适合这种强一致性要求的场景。

3. 检查索引刷新状态（进阶方案） #

如果需要避免强制刷新，又要确保数据就绪，可以通过索引统计API监控未刷新文档数：

IndicesStatsRequest statsRequest = new IndicesStatsRequest("target_index");
statsRequest.refresh(true); // 仅获取刷新相关统计
IndicesStatsResponse statsResponse = client.indices().stats(statsRequest, RequestOptions.DEFAULT);

// 获取未刷新的文档数量
long unrefreshedDocs = statsResponse.getIndex("target_index").getRefresh().getTotal();
// 循环等待直到未刷新文档数为0（需添加超时控制避免无限等待）
long timeout = System.currentTimeMillis() + 30000; // 30秒超时
while (unrefreshedDocs > 0 && System.currentTimeMillis() < timeout) {
    Thread.sleep(500);
    statsResponse = client.indices().stats(statsRequest, RequestOptions.DEFAULT);
    unrefreshedDocs = statsResponse.getIndex("target_index").getRefresh().getTotal();
}

// 此时执行查询即可获取最新数据

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