Spring Boot中RestHighLevelClient闲置后抛出SocketTimeoutException求助

我之前处理过类似的AWS ES（现在叫OpenSearch）连接超时问题，你的情况典型是闲置连接被AWS的负载均衡/防火墙主动断开，但客户端连接池还保留无效连接导致的。结合你用的spring-data-elasticsearch 3.2.0.M2和ES 6.4，给你几个可行的解决思路和临时方案：

一、优化RestHighLevelClient的连接配置 #

AWS托管的ES前端的负载均衡一般有默认的闲置连接超时（比如Classic LB是60秒，ALB是350秒），超时后会主动断开TCP连接，但默认的RestHighLevelClient配置没有适配这个逻辑。你需要修改ClientConfiguration，添加连接保活、闲置超时和重试策略：

@Bean
RestHighLevelClient client() {
    ClientConfiguration clientConfiguration = ClientConfiguration.builder()
        .connectedTo(elasticsearchHostAndPort)
        // 调整连接和套接字超时，根据业务场景适当延长
        .withConnectTimeout(Duration.ofSeconds(10))
        .withSocketTimeout(Duration.ofSeconds(10))
        // 设置连接池最大闲置时间，必须小于AWS负载均衡的超时（比如设为45秒，对应LB的60秒超时）
        .withConnectionTimeout(Duration.ofSeconds(45))
        // 启用TCP保活，让操作系统定期发送心跳，避免连接被主动断开
        .withSocketKeepAlive(true)
        // 针对超时异常自动重试，快速规避无效连接
        .withRetryOnTimeout(true)
        .withMaxRetries(3)
        .build();
    return RestClients.create(clientConfiguration).rest();
}

这里几个关键配置的作用：

• withSocketKeepAlive(true)：启用TCP层面的心跳机制，保持连接活跃，防止AWS侧主动断开
• withConnectionTimeout：让客户端在连接闲置到设定时间后主动回收，避免使用无效连接
• withRetryOnTimeout：遇到超时异常时自动重试，降低业务请求失败概率

二、检查版本兼容性问题 #

你当前使用的spring-data-elasticsearch 3.2.0.M2是预览版，它对应的Elasticsearch客户端版本是6.8.x，但你连接的是ES 6.4.x。Spring Data Elasticsearch和ES版本有严格的对应关系：

• 3.1.x 对应 ES 6.4.x
• 3.2.x 对应 ES 6.8.x

版本不匹配可能导致底层客户端和ES服务端的交互逻辑存在兼容性问题，进而引发连接不稳定。建议降级到spring-data-elasticsearch 3.1.x的稳定版（比如3.1.10.RELEASE），完全匹配ES 6.4的版本，这可能解决潜在的隐性问题。

三、临时应急方案：定时发送心跳请求 #

如果暂时没法修改配置或版本，可以通过定时任务定期发送轻量请求，保持连接池里的连接活跃，避免被AWS侧断开：

@Component
@Slf4j
public class EsHeartbeatTask {

    private final RestHighLevelClient esClient;

    public EsHeartbeatTask(RestHighLevelClient esClient) {
        this.esClient = esClient;
    }

    // 每30秒发送一次心跳，时间要小于AWS负载均衡的闲置超时
    @Scheduled(fixedRate = 30000)
    public void sendEsHeartbeat() {
        try {
            // 发送轻量的集群健康请求，不会给ES带来太大负担
            ClusterHealthRequest request = new ClusterHealthRequest();
            esClient.cluster().health(request, RequestOptions.DEFAULT);
        } catch (IOException e) {
            log.warn("ES heartbeat failed, will retry next time", e);
        }
    }
}

注意要确保你的项目已经启用了Spring定时任务（添加@EnableScheduling注解到配置类）。

总结 #

优先尝试调整客户端连接配置，其次检查并修正版本兼容性，定时心跳作为临时过渡方案。一般调整完连接配置后，超时问题就能得到解决。

内容的提问来源于stack exchange，提问作者Fedor