Для Spring WebFlux WebClient, как отловить исключение Netty, такое как ProxyConnectException - PullRequest
Новая
       5

Для Spring WebFlux WebClient, как отловить исключение Netty, такое как ProxyConnectException

1 голос
/ 08 мая 2019

Я бы хотел изменить в своем приложении Apache HttpComponents Client на Spring WebFlux WebClient. Но я не могу перехватить исключения из Netty, такие как io.netty.handler.proxy.ProxyConnectException.

Я пробовал оператор doOnError, но за этими исключениями они не могут быть перехвачены. 

var timeout = Duration.ofSeconds(3);
        if (proxy != null) {
            HttpClient httpClient = HttpClient.create()
                .tcpConfiguration(tcpClient ->
                    tcpClient.proxy(py -> py.type(ProxyProvider.Proxy.HTTP).host(proxy.getHost()).port(proxy.getPort()).username(proxy.getUser()).password(tmp -> proxy.getPass())).doOnConnected(conn -> conn
                        .addHandlerLast(new ReadTimeoutHandler((int) (timeout.toSeconds() / 2)))
                        .addHandlerLast(new WriteTimeoutHandler((int) (timeout.toSeconds() / 2)))));
            ReactorClientHttpConnector connector = new ReactorClientHttpConnector(httpClient);

            ExchangeStrategies strategies = ExchangeStrategies
                .builder()
                .codecs(clientDefaultCodecsConfigurer -> {
                    clientDefaultCodecsConfigurer.defaultCodecs().jackson2JsonEncoder(new Jackson2JsonEncoder(objectMapper, MediaType.APPLICATION_JSON));
                    clientDefaultCodecsConfigurer.defaultCodecs().jackson2JsonDecoder(new Jackson2JsonDecoder(objectMapper, MediaType.APPLICATION_JSON));

                }).build();

            WebClient webClient = WebClient
                .builder()
                .exchangeStrategies(strategies)
                .clientConnector(connector)
                .build();
            ClientResponse httpException = ClientResponse.create(org.springframework.http.HttpStatus.REQUEST_TIMEOUT).build();



      webClient
      .get()
      .uri("my_uri")
      .accept(MediaType.ALL)
      .header("my_header_key", "my_header_value")
      .exchange().doOnError(ProxyConnectException.class, throwable -> {
                    logger.warn("ProxyConnectException");
                })
      .onErrorReturn(httpException)
      .doOnError(ConnectTimeoutException.class, e -> {
                    logger.warn("ConnectTimeoutException");
                })
      .doOnError(ReadTimeoutException.class, e -> {
                    logger.warn("ReadTimeoutException");
                })
      .doOnError(SSLException.class, e -> {
                    logger.warn("SSLException");
                })
      .doOnError(Exception.class, e -> {
                    logger.warn("Exception");
                })
      .onErrorReturn(httpException)
      .block();

Я хочу просто распечатать журнал и вернуть объект httpException. Но результат не только тот, что я ожидал, мои журналы распечатаны, мой объект возвращен, но я также могу видеть некоторую информацию об исключении следующим образом. Есть ли способ избежать этих исключений? 

io.netty.handler.proxy.ProxyConnectException: http, none, /XXXX:XX => XXXX:XX, timeout
    at io.netty.handler.proxy.ProxyHandler$2.run(ProxyHandler.java:201)
    at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
    at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:127)
    at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
    at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:335)
    at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897)
    at java.base/java.lang.Thread.run(Thread.java:834)
ERROR [reactor-http-epoll-5] HttpClientConnect --- [id: 0x3610bfd0, L:/XXXX:XX ! R:XXXX/XXXX:XX] The connection observed an error
java.nio.channels.ClosedChannelException: null
    at io.netty.handler.ssl.SslHandler.channelInactive(...)(Unknown Source)```

1 Ответ

0 голосов
/ 14 мая 2019

После прочтения исходного кода я обнаружил, что исключение печатается pipeline.netty.http.client . И я уверен, что перехватил исключение, поэтому вся информация стека исключений бесполезна для мне. Что мне нужно сделать, это просто отключить журнал.

<logger name="reactor.netty.http.client" level="OFF"/>

...