如果连接关闭，我该如何处理连接并重新连接？

Question

我需要此客户端长时间保持连接，我如何确保连接？因为这个问题是相关的，所以我正在更新我的问题。如果服务器关闭连接我该怎么办？或者如果客户端关闭连接？我该如何处理它并将客户端重新连接到服务器？

public void consumeServerSentEvent() {
WebClient client = WebClient.create("http://localhost:8080/sse-server");
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!!!"));

}

Answer 1

根据文档retrieve() 返回ClientResponse 的Mono，但对于您的情况，您需要消耗身体的Flux。 试试这样的事情：

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