解决GraphQL订阅+MongoDB因数据量过大引发的连接重置异常

你遇到的io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer异常，确实大概率是一次性拉取过多MongoDB数据，导致Netty连接因负载过高被重置。除了你计划的分页方案，还有以下几种针对性的解决思路：

一、优化数据拉取方式（非分页） #

• 避免一次性全量加载数据：你当前代码中collectList()会把所有Employee数据一次性加载到内存再推送给订阅端，改成流式推送单条或小批量数据，降低单次传输负载：

  @GraphQLSubscription
  fun findAllEmployees(): Publisher<Employee> {
    return employeeRepository.findAll()
                             .flatMap { produceGraphQlSubscriptionSingle(it) }
  }
  

  将返回类型从Publisher<List<Employee>>改为Publisher<Employee>，逐个推送数据，避免内存占用过高和大Payload引发的连接重置。
• MongoDB查询优化：给查询字段添加索引，减少数据库端查询耗时；同时使用projection只返回订阅端需要的字段，缩减数据传输量。

二、调整WebFlux/Netty的连接与超时参数 #

• 增大Netty接收缓冲区：在WebFlux配置中调整Netty的接收缓冲区大小，避免因数据量超出缓冲区限制导致连接重置：

  @Bean
  fun webServerFactoryCustomizer(): WebServerFactoryCustomizer<NettyReactiveWebServerFactory> {
    return WebServerFactoryCustomizer { factory ->
      factory.addServerCustomizers { httpServer ->
        httpServer.tcpConfiguration { tcp ->
          tcp.receiveBufferSize(1024 * 1024) // 设置为1MB，可根据实际数据量调整
        }
      }
    }
  }
  

• 调整超时配置：如果是连接或响应超时引发的重置，可增大WebFlux和GraphQL订阅的超时参数：

  @Bean
  fun webClient(): WebClient {
    return WebClient.builder()
      .clientConnector(ReactorClientHttpConnector(HttpClient.create()
        .responseTimeout(Duration.ofMinutes(5)) // 调整响应超时
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 30000))) // 调整连接超时
      .build()
  }
  

  同时可配置Spring GraphQL的订阅超时：在application.properties中添加spring.graphql.subscription.timeout=300s。

三、采用增量推送策略 #

如果订阅的核心需求是获取数据更新而非全量历史数据，可利用MongoDB的Change Streams监听集合变化，只推送新增或修改的数据：

@GraphQLSubscription
fun employeeUpdates(): Publisher<Employee> {
  return employeeRepository.watch()
                           .map { it.fullDocument }
                           .flatMap { produceGraphQlSubscriptionSingle(it) }
}

这种方式从根源上避免了全量数据拉取的问题，仅关注变化内容。

四、内存资源调优 #

如果全量加载数据导致JVM内存不足，间接引发连接异常，可增大JVM堆内存，比如设置启动参数-Xmx4g（根据服务器硬件配置调整），避免内存不足的异常传播到Netty连接层。

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