DeleteByQueryRequest 套接字超时异常-java 高级rest 客户端api

问题描述

我是 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]

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

解决方法

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

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

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