有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java早熟关闭异常的原因是什么?

我用的是spring WebFlux,我用的是WebClient, 它工作得很好,我在我的日志中看到了两次这个错误,我怎么知道这个连接问题发生在我的端(客户端)或服务器端关闭了连接,我在这里复制错误:

reactor.netty.http.client.PrematureCloseException: Connection prematurely closed DURING response
    Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException

我的客户端代码与此代码相同:

public void consumeServerSentEvent() {
WebClient client = WebClient.create("http://SERVER-IP:SERVER-PORT/PATH_TO_API");
ParameterizedTypeReference<ServerSentEvent<String>> type
 = new ParameterizedTypeReference<ServerSentEvent<String>>() {};

Flux<ServerSentEvent<String>> eventStream = client.get()
  .uri("/stream-sse")
  .retrieve()
  .bodyToFlux(type);

eventStream.subscribe(
  content -> logger.info("Time: {} - event: name[{}], id [{}], content[{}] ",
    LocalTime.now(), content.event(), content.id(), content.data()),
  error -> logger.error("Error receiving SSE: {}", error),
  () -> logger.info("Completed!!!"));

}


共 (0) 个答案