DeleteByQueryRequest 套接字超时异常 - java 高级别的客户端 api答案

【问题标题】：DeleteByQueryRequest socket timeout exception - java high level rest client apiDeleteByQueryRequest 套接字超时异常 - java 高级别的客户端 api
【发布时间】：2021-07-10 18:27:14
【问题描述】：

我是 elasticsearch 的初学者，我想删除大量与特定查询匹配的文档。我为此目的使用 DeleteByQueryRequest。我尝试了下面的代码。

String fileName="output2.log";
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("localhost", 9200, "http")));
DeleteByQueryRequest deleteRequest = new DeleteByQueryRequest("_all");
deleteRequest.setQuery(QueryBuilders.termQuery("fileName.keyword",fileName));
deleteRequest.setTimeout(TimeValue.timeValueMinutes(10));
//deleteRequest.setRefresh(true);
BulkByScrollResponse bulkResponse = client.deleteByQuery(deleteRequest, RequestOptions.DEFAULT);
client.close();
System.out.println(bulkResponse.isTimedOut());
System.out.print("Deletion done");

当我运行此代码时，相应的文档会被删除，但此代码会引发以下异常。

java.net.SocketTimeoutException: 30,000 milliseconds timeout on connection http-outgoing-0 [ACTIVE]

可以做些什么来消除这个异常？提前致谢。

【问题讨论】：

标签： elasticsearch socket-timeout-exception elasticsearch-java-api elasticsearch-rest-client elasticsearch-api

【解决方案1】：

经过一些研究，我发现 RestHighLevelClient 的默认套接字超时为 30000 毫秒。我使用下面的代码来延长套接字超时时间。

RestHighLevelClient client = new RestHighLevelClient((RestClient.builder(new 
      HttpHost(localhost,9200,"http"))).setRequestConfigCallback(requestConfigBuilder ->                         
     requestConfigBuilder                        
    .setConnectTimeout(10000)
    .setSocketTimeout(60000)
    .setConnectionRequestTimeout(0)
));

现在您可以在 setSocketTimout() 方法中增加时间限制。

【讨论】：