Spring Data Elasticsearch 2.2.3.RELEASE中如何配置Rest高级客户端的socket超时答案

【问题标题】：How to configure the socket timeout of the Rest high level client in Spring Data Elasticsearch 2.2.3.RELEASESpring Data Elasticsearch 2.2.3.RELEASE中如何配置Rest高级客户端的socket超时
【发布时间】：2020-01-30 17:19:45
【问题描述】：

我将 Spring Boot Starter Data Elasticsearch 2.2.3.RELEASE 与 Elasticsearch v6.8.6 一起使用。我为集群连接配置了 RestHighLevelClient。

现在我在不同的操作中不断收到 SocketTimeoutException：

java.net.SocketTimeoutException: 5,000 milliseconds timeout on connection http-outgoing-95 [ACTIVE]
at org.apache.http.nio.protocol.HttpAsyncRequestExecutor.timeout(HttpAsyncRequestExecutor.java:387) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:92) ~[httpasyncclient-4.1.4.jar!/:4.1.4]
at org.apache.http.impl.nio.client.InternalIODispatch.onTimeout(InternalIODispatch.java:39) ~[httpasyncclient-4.1.4.jar!/:4.1.4]
at org.apache.http.impl.nio.reactor.AbstractIODispatch.timeout(AbstractIODispatch.java:175) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.BaseIOReactor.sessionTimedOut(BaseIOReactor.java:261) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.AbstractIOReactor.timeoutCheck(AbstractIOReactor.java:502) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.BaseIOReactor.validate(BaseIOReactor.java:211) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:280) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:591) ~[httpcore-nio-4.4.13.jar!/:4.4.13]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_201]

我可以在 Spring Boot 应用程序中配置套接字超时吗？如果可以，在哪里。

我尝试配置 ClientConfiguration 的套接字超时我创建了 RestHighLevelClient 没有效果：

    ClientConfiguration clientConfiguration = ClientConfiguration.builder()
            .connectedTo(nodes)
            .withSocketTimeout(Duration.ofSeconds(30))
            .build();

    RestHighLevelClient client = RestClients.create(clientConfiguration).rest();

【问题讨论】：

如何配置您的 Rest Client？我刚刚尝试使用自定义配置（se docs.spring.io/spring-data/elasticsearch/docs/3.2.4.RELEASE/…），它按预期工作

标签： spring spring-boot elasticsearch spring-data-elasticsearch

【解决方案1】：

简而言之，你应该使用setConnectTimeout 方法（构建时 RestClient)。

所以，这是我一直在为 ES (6.5v) 使用的 Java String Boot (2.1.1.RELEASE) 配置（成功设置连接和套接字超时）。

请在直接使用以下源之前正确设置您的 ENV 变量（在 .yml 文件中）。

// yml 设置

elasticsearch:
hosts:
host1: // you can set as an array with > sign
  name: hostname
  port: 9200
username:
password:
connectTimeout: 6000
socketTimeout: 6000

// 配置类

@Configuration
public class ElasticSearchConfig {

  @Autowired
  private Environment environment;

  @Bean(destroyMethod = "close", name = "esHighLevelRestClient")
  public RestHighLevelClient highLevelClient() {
    return new RestHighLevelClient(restClientBuilder());
  }

  @Bean(destroyMethod = "close")
  public RestClient restClient() {
    return restClientBuilder().build();
  }

  private RestClientBuilder restClientBuilder() {
    final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(AuthScope.ANY,
            new UsernamePasswordCredentials(
                    environment.getProperty("elasticsearch.username"),
                    environment.getProperty("elasticsearch.password")));

    // you can set N hosts
    List<HttpHost> hosts = new ArrayList<>();
    hosts.add(new HttpHost(
            environment.getProperty("elasticsearch.hosts.host1.name", String.class),
            environment.getProperty("elasticsearch.hosts.host1.port", Integer.class),
            "http"));

    return RestClient.builder(Iterables.toArray(hosts, HttpHost.class))
            .setRequestConfigCallback(requestConfigBuilder -> requestConfigBuilder
                    .setConnectTimeout(environment.getProperty("elasticsearch.connectTimeout", Integer.class))
                    .setSocketTimeout(environment.getProperty("elasticsearch.socketTimeout", Integer.class)))
            .setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider));
  }}

希望对你有帮助！

【讨论】：

【解决方案2】：

这是我设置套接字连接超时的方式：

// Default is 30 sec, changed to 60 sec   

RestClientBuilder builder = RestClient.builder(new HttpHost(host, port, scheme))
                .setRequestConfigCallback(requestConfigBuilder -> requestConfigBuilder.setSocketTimeout(60 * 1000));

【讨论】：

【解决方案3】：

我在kotlin中的例子：



@Configuration
class ElasticConfig(private val props: ElasticsearchInfo) : AbstractElasticsearchConfiguration() {
    val port = 9200

    @Bean(name = ["restHighLevelClient", "elasticsearchClient"])
    override fun elasticsearchClient(): RestHighLevelClient {
        val timeout = Duration.of(props.timeout ?: 10, SECONDS)
        return create(builder()
            .connectedTo("${props.host}:$port")
            .withConnectTimeout(timeout)
            .withSocketTimeout(timeout)
            .build()).rest()
    }

    @Bean fun elasticsearchRestTemplate(): ElasticsearchRestTemplate = ElasticsearchRestTemplate(elasticsearchClient())
}

【讨论】：