K8s NGINX Ingress保活Spring WebFlux SSE连接 客户端断开后onDispose未触发

问题根因 #

本地运行无中间代理，客户端断开连接的信号会直接传递到Spring Boot服务触发onDispose；部署到K8s后Nginx Ingress和AWS ALB的默认配置会缓冲流式响应、屏蔽客户端断开信号，导致后端服务感知不到连接终止。

解决步骤 #

1. 配置SSE响应头（Spring侧调整） #

在SSE接口返回响应时强制添加禁用缓冲的头部，尤其是Nginx专属的X-Accel-Buffering头，明确告知Nginx不要缓冲当前流式响应：

// 可以在Controller方法上添加响应头，或者修改返回的Flux全局附加头
@GetMapping(value = "/your-sse-endpoint", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public ResponseEntity<Flux<ServerSentEvent<?>>> sseEndpoint(@RequestParam String queueName) {
    Flux<ServerSentEvent<?>> flux = notificationService.subscribeToNotifications(queueName);
    return ResponseEntity.ok()
            .header(HttpHeaders.CACHE_CONTROL, "no-cache, no-store, max-age=0, must-revalidate")
            .header("X-Accel-Buffering", "no")
            .header(HttpHeaders.CONNECTION, HttpHeaders.KEEP_ALIVE)
            .body(flux);
}

2. 调整Ingress Nginx配置 #

优先给SSE服务对应的Ingress资源添加以下注解，避免修改全局配置影响其他业务：

apiVersion: networking.k8s.io/v1
kind: Ingress
metadata:
  name: sse-service-ingress
  annotations:
    # 核心配置：禁用代理缓冲，SSE流式响应不能启用缓冲
    nginx.ingress.kubernetes.io/proxy-buffering: "off"
    # 客户端断开时立即关闭到上游服务的连接，默认值为off，若之前有过自定义配置需确认
    nginx.ingress.kubernetes.io/proxy-ignore-client-abort: "off"
    # 代理读取超时，需设置为比你的SSE心跳间隔大1~2倍，例如心跳每15秒发送一次则设为30s
    nginx.ingress.kubernetes.io/proxy-read-timeout: "30"
    # 禁用上游连接复用，和你之前设置的全局ConfigMap参数对应
    nginx.ingress.kubernetes.io/upstream-keepalive-connections: "0"
spec:
  # 其余Ingress配置保持不变

3. 调整AWS ALB空闲超时配置 #

你使用了AWS ALB做TLS终止，ALB默认空闲超时时间为60秒，需要将该参数调整为大于SSE心跳间隔的值：
进入AWS EC2控制台→负载均衡器→找到你K8s集群对应的ALB→属性→编辑空闲超时，设置为比心跳间隔大1倍以上即可，例如30秒。

4. Spring侧兜底配置（可选） #

可以给WebFlux底层的Netty服务器开启TCP保活检测，避免网络层异常导致连接假死，在application.properties/application.yml中添加：

# 开启TCP保活
server.netty.tcp-keep-alive=true
# 30秒无数据交互则主动检测连接有效性
server.netty.tcp-user-timeout=30000

验证方法 #

调整完成后模拟客户端断开连接，观察AMQP队列是否被删除，同时可以进入Nginx Ingress Pod查看请求日志，确认连接断开时上游请求也同步终止即可。

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