Сброс соединения по пиру io.netty.channel.unix.Errors $ NativeIoException - PullRequest
Новая
       55

Сброс соединения по пиру io.netty.channel.unix.Errors $ NativeIoException

0 голосов
/ 30 октября 2019

Я использую WebClient из spring-boot-starter-webflux. Я постоянно вижу сброс соединения по ошибке однорангового узла из реакторной сети в производственной среде. Затем нетто-реактор повторяет этот неудавшийся запрос через несколько секунд (~ 10-20 секунд). Я не вижу или не могу воспроизвести эту ошибку в более низкой среде. Я не могу определить основную причину этой ошибки, здесь я предоставил свою реализацию ClientHelper и протоколы ошибок, 

import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.http.HttpStatus;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.ClientResponse;
import org.springframework.web.reactive.function.client.WebClient;

public class ClientHelper {

  protected WebClient webClient;

  public <T> T post(Object request, TypeReference typeReference,
                    String uri) {
    try {
      ObjectMapper objectMapper = new ObjectMapper();
      String body = objectMapper.writeValueAsString(request);
      ClientResponse clientResponse =
              getWebClient()
                      .post()
                      .uri(uri)
                      .body(BodyInserters.fromObject(body))
                      .exchange()
                      .block();
      return prepareResponse(clientResponse, typeReference, objectMapper);
    } catch (Exception e) {
      return handleException(e);
    }
  }

  protected <T> T prepareResponse(ClientResponse clientResponse, TypeReference typeReference,
                                  ObjectMapper objectMapper) throws Exception {
    String responseText = clientResponse.bodyToMono(String.class).block();
    if (clientResponse.statusCode() == HttpStatus.OK) {
      return objectMapper.readValue(responseText, typeReference);
    } else {
      throwNewException("Remote service returned a message with statusCode = "
              + clientResponse.statusCode() + "; response = " + responseText,  null);
      return null;
    }
  }

  protected <T> T handleException(Exception e) {
    throwNewException("Communication error. Cause: " + e.getMessage(), e);
    return null;
  }

  protected void throwNewException(String message, Throwable cause) {
    throw new RuntimeException(message, cause);
  }

  public WebClient getWebClient() {
    return WebClient.builder().baseUrl("http://app.corp.com/").build();
  }

2019-10-29 20:56:20,383 DEBUG r.u.Loggers$Slf4JLogger [reactor-http-epoll-8] [] [id: 0x65cf7989, L:/xx.xx.xxx.xxx:xxxxx - R:app.corp.com/xx.xx.xx.xx:xxx] The connection observed an error, the request will be retried
io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

spring-boot-starter-webflux: 2.1.9.RELEASE, реактор-нетто: 0.8.12.RELEASE

Пожалуйста, дайте мне знать, если есть проблема с этой реализацией и / или как решить эту проблему дальше.

1 Ответ

0 голосов
/ 31 октября 2019

Одна из причин, по которой вы столкнетесь с этой проблемой в работе, связана с SSL. Попробуйте настроить тайм-ауты SSL

Например, приведенные ниже настройки относятся к шлюзу Spring Cloud, в котором используется netty:

https://cloud.spring.io/spring-cloud-gateway/multi/multi__tls_ssl.html

spring:
  cloud:
    gateway:
      httpclient:
        ssl:
          handshake-timeout-millis: 10000
          close-notify-flush-timeout-millis: 3000
          close-notify-read-timeout-millis: 0

https://docs.spring.io/spring-boot/docs/current/reference/html/howto.html#howto- настройка веб-клиента-реактора-нетто

...