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) 个答案