ES客户端更新策略设置（Java）_writerequest.refreshpolicy.wait_until

问题

在Spring中使用ES的客户端更新数据的时候，会出现数据不会立即生效问题。

原因

ES的客户端是异步请求，并不会等待ES所有节点数据更新完毕再响应请求。

思路

通过在客户端设置数据更新刷新策略为WAIT_UNTIL，即等待ES完成对数据对更新再响应客户端即可。

步骤

pom.xml

设置Maven依赖：

<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>7.9.1</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-client</artifactId>
    <version>7.9.1</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.9.1</version>
</dependency>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

client

在Spring中配置ES客户端：

@Bean
    public RestHighLevelClient restHighLevelClient() {
        return new RestHighLevelClient(
                RestClient.builder(
                        new HttpHost("127.0.0.1", 9200, "http")));
    }
1
2
3
4
5
6

更新ES数据

 public static void addData(JSONObject json, String index, String type, String id) {
    try {
      UpdateRequest request = new UpdateRequest(index, type, id);
      request.doc(json);
      request.docAsUpsert(true);
      // 修改刷新策略为等待刷新完成，再结束请求
      request.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
      rClient.update(request, RequestOptions.DEFAULT);
    } catch (IOException e) {
      log.error("写入或更新ES异常:", e);
      throw new HandleException(String.format("写入或更新ES异常：%s", e.getMessage()));
    }
  }
1
2
3
4
5
6
7
8
9
10
11
12
13

ES3种刷新策略

• IMMEDIATE：更新请求发送后，告诉es强制刷新
• NONE:更新请求发送后，告诉es不用刷新
• WAIT_UNTIL:更新请求发送后，等待es中更新的数据可用后再响应客户端（同步）

参考

• Elasticsearch数据刷新策略RefreshPolicy简述
• java-rest-high-document-update
• Enum WriteRequest.RefreshPolicy