WebClient 在响应期间过早关闭

Question

我正在使用 Spring webclient 连接到 netty webflux 服务器。

我在消费者空闲 20-30 分钟后收到此错误。

• Webflux 服务器正在 AWS EC2 中运行
• 由部署在 AWS EKS-EC2 中的 Spring 云网关前端
• AWS ELB 作为 Spring 云网关的入口负载均衡器
• 以前，由于 AWS ELB 空闲超时配置，我曾经在 webflux 服务器上超时。所以现在 webflux 服务每 20 秒向客户端发送一次心跳消息

是因为连接从服务器端关闭还是问题出在客户端？

reactor.netty.http.client.PrematureCloseException:
    Connection prematurely closed DURING response

Suppressed:
reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
    Error has been observed at the following site(s):
            |_ checkpoint ? Body from GET https://*** [DefaultClientResponse]

Answer 1

这一般是服务器端关闭空闲连接造成的。

在客户端，您可以通过在ConnectionProvider 构建器上调用maxIdleTime 方法来配置空闲连接的使用时间。示例取自 Connection Pool Reference Docs。

ConnectionProvider.builder("custom")
                .maxConnections(50)
                .maxIdleTime(Duration.ofSeconds(20))
                .maxLifeTime(Duration.ofSeconds(60))
                .build()

maxIdleTime - 此连接在连接池中保持空闲的最长时间（分辨率：毫秒）。默认不指定maxIdleTime。

maxLifeTime - 此连接保持活动的最长时间（分辨率：毫秒）。默认不指定 maxLifeTime。

reference docs 中的此注释对于您看到的目标服务器在客户端之前关闭连接的问题特别关键。

在配置 maxIdleTime 时，应考虑目标服务器上的空闲超时配置。选择等于或小于目标服务器上的配置。这样做可以减少目标服务器关闭连接导致的 I/O 问题。

maxIdleTime JavaDocs

maxLifeTime Javadocs