Spring WebFlux BlockingIterator.hasNext() 阻塞问题排查求助

针对你遇到的负载测试3小时后iterator.hasNext()阻塞的问题，结合已有排查动作，给出以下具体排查方向：

1. 验证SSE连接的超时配置有效性 #

你提到设置了读取超时但无效，需确认底层HTTP客户端的超时配置是否适配SSE流式场景：

• 如果使用Reactor Netty作为WebClient底层客户端，需区分响应超时（responseTimeout，整个请求的总超时）和读取超时（readTimeout，两次数据帧的间隔超时）。SSE是持续流式传输，应配置readTimeout来检测服务器静默断开的情况，示例配置：

  HttpClient httpClient = HttpClient.create()
      .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000)
      .responseTimeout(Duration.ofMinutes(1))
      .doOnConnected(conn -> 
          conn.addHandlerLast(new ReadTimeoutHandler(30, TimeUnit.SECONDS)));
  WebClient webClient = WebClient.builder().clientConnector(new ReactorClientHttpConnector(httpClient)).build();
  

• 手动模拟服务器断开连接，验证客户端是否触发超时错误，确认配置生效。

2. 捕获全局未处理的Reactor错误 #

当前错误处理链可能未覆盖所有异常场景，比如底层IO线程抛出的错误、被Reactor丢弃的错误：

• 添加全局Reactor错误钩子，捕获所有未被处理的异常（包括Error类）：

  Hooks.onErrorDropped(t -> log.error("Reactor dropped error", t));
  Hooks.onOperatorError((t, e) -> {
      log.error("Reactor operator error", e);
      return e;
  });
  

• 扩展错误处理链，覆盖所有Throwable类型而非仅Error：

  .onErrorMap(Throwable.class, e -> {
      log.error("Unhandled throwable", e);
      return new RuntimeException("Wrapped Throwable", e);
  });
  

3. 监控Flux的生命周期状态 #

添加生命周期日志，确认Flux是否处于未完成、未出错的挂起状态：

myFlux = client.get()
    ...
    .exchangeToFlux(...)
    .doOnError(t -> log.error("Flux error occurred", t))
    .doOnComplete(() -> log.info("Flux completed successfully"))
    .doOnCancel(() -> log.info("Flux was cancelled"))
    .doOnTerminate(() -> log.info("Flux terminated (completed/error/cancel)"))
    .onErrorMap(...);

如果日志中无terminate相关记录，说明Flux始终处于活跃状态，未收到完成/错误/取消信号。

4. 排查JVM线程与资源状态 #

问题复现时立即采集以下信息：

• 用jstack导出线程栈，查看阻塞线程的调用链：
  • 定位hasNext()方法的等待对象（如BlockingIterable内部队列、锁）
  • 检查Reactor Netty IO线程状态，是否阻塞在NIO操作上
• 用jmap或监控工具检查内存：
  • 排查堆内存/堆外内存泄漏（如DirectBuffer未释放）
  • 监控Reactor Netty连接池指标（如活跃连接数、等待队列长度）

5. 检查SSE服务器端行为 #

挂起可能源于服务器端未正确发送结束信号或静默断开：

• 查看服务器端日志，确认挂起时刻是否出现连接异常、线程池耗尽等情况
• 验证服务器是否会在长时间无数据时主动断开SSE连接，或发送心跳事件维持连接

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