ElasticSearch远程主机强迫关闭了一个现有的连接

素颜马尾好姑娘i 2024-03-26 12:36 58阅读 0赞

**问题描述：**项目集成了ElasticSearch实现全文检索，项目启动可正常进行创建索引、检索等操作，长时间无操作后再次请求ES服务报错远程主机强迫关闭了一个现有的连接。调整ElasticSearchConfig配置，问题解决。

![f0a0fa895ae50bed88d1158578cd3d49.png][]

**调整前代码：**

package com.dmp.framework.config;
    
    import lombok.Setter;
    import org.apache.http.HttpHost;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * @author daixin
     * @version 1.0
     * @description: TODO
     * @date 2022/11/23 15:08
     */
    @Setter
    @ConfigurationProperties(prefix = "elasticsearch")
    @Configuration
    public class ElasticSearchConfig {
    
        private String host;
    
        private Integer port;
    
        @Bean
        public RestHighLevelClient restHighLevelClient(){
            RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost(this.host, this.port)));
            return client;
        }
    }

**调整后代码：**

package com.dmp.framework.config;
    
    import lombok.Setter;
    import org.apache.http.HttpHost;
    import org.apache.http.client.config.RequestConfig;
    import org.apache.http.impl.nio.reactor.IOReactorConfig;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestClientBuilder;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import java.util.concurrent.TimeUnit;
    
    /**
     * @author daixin
     * @version 1.0
     * @description: TODO
     * @date 2022/11/23 15:08
     */
    @Setter
    @ConfigurationProperties(prefix = "elasticsearch")
    @Configuration
    public class ElasticSearchConfig {
    
        private String host;
    
        private Integer port;
    
        @Bean
        public RestHighLevelClient restHighLevelClient(){
            RestHighLevelClient client = new RestHighLevelClient(
                    RestClient.builder(
                            new HttpHost(this.host,this.port,"http")
                    ).setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
                        @Override
                        public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder requestConfigBuilder) {
                            return requestConfigBuilder.setConnectTimeout(90000000)//25hours
                                    .setSocketTimeout(90000000);
                        }
                    }).setHttpClientConfigCallback((httpAsyncClientBuilder -> {
                        httpAsyncClientBuilder.disableAuthCaching();//禁用身份验证缓存
                        //显式设置keepAliveStrategy
                        httpAsyncClientBuilder.setKeepAliveStrategy((httpResponse,httpContext) -> TimeUnit.MINUTES.toMillis(3));
                        //显式开启tcp keepalive
                        httpAsyncClientBuilder.setDefaultIOReactorConfig(IOReactorConfig.custom().setSoKeepAlive(true).build());
                        return httpAsyncClientBuilder;
                    }))
            );
            return client;
        }
    }

[f0a0fa895ae50bed88d1158578cd3d49.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/26/b983b2fe29a74b37826321bb5a826080.png