Vertx HttpClient가 시간 초과하지 않습니다.

Question

전체 코드가 아니라 내 문제의 코드 스 니펫을 게시하고 있습니다. 다음과 같이 HttpClientOptions을 설정했습니다.

HttpClientOptions clientOptions = new HttpClientOptions() 
       .setDefaultHost(host) 
       .setDefaultPort(port) 
       .setMaxPoolSize(config.getMaxPoolSize()) 
       .setConnectTimeout(config.getTimeout()); 
HttpClient httpClient = vertx.createHttpClient(clientOptions); 

그리고는 나는 다음과 같이 게시 요청이 클라이언트를 사용 :

httpClient.post(ePoint, httpClientResponse -> { 
      httpClientResponse.bodyHandler(body -> { 
        if (body.length() == 0) { 
         ctx.fail(); 
         return; 
        } 
        String bodyString = body.toString(); 
        int statusCode = httpClientResponse.statusCode(); 
        if (statusCode != HttpStatus.SC_CREATED) { 
         ctx.fail(); 
         return; 
        } 
        logger.info(ctx, "blah blah"); 


         ctx.next(); 

       }) 
       .exceptionHandler(throwable -> { 
        ctx.fail(); 
       }); 

을하지만 수신자 측 예외 핸들러에서 시뮬레이션에게 타임 아웃을 할 경우 호출되지 않습니다. 하지만 게시물 요청 예외 처리기에서 다음과 같이 시간 제한을 설정하면 예외가 발생합니다.

httpClient.post(ePoint, httpClientResponse -> { 
     httpClientResponse.bodyHandler(body -> { 
       if (body.length() == 0) { 
        ctx.fail(); 
        return; 
       } 
       String bodyString = body.toString(); 
       int statusCode = httpClientResponse.statusCode(); 
       if (statusCode != HttpStatus.SC_CREATED) { 
        ctx.fail(); 
        return; 
       } 
       logger.info(ctx, "blah blah"); 


        ctx.next(); 

      }).setTimeout(config.getTimeout()) 
      .exceptionHandler(throwable -> { 
       ctx.fail(); 
      }); 

이 버그는 Vertx 버그 또는 디자인입니다.

Answer 1

다음 접근 방식이 효과적입니다. 우리는

HttpClientOptions clientOptions = new HttpClientOptions() 
      .setDefaultHost(host) 
      .setDefaultPort(port) 
      .setMaxPoolSize(config.getMaxPoolSize()) 
      .setConnectTimeout(config.getTimeout()); 

HttpClient httpClient = vertx.createHttpClient(clientOptions); 


HttpClientRequest request = httpClient.request(HttpMethod.GET, url, response -> { 

    //process response 

}).exceptionHandler(e -> { 
    e.printStackTrace(); 
    comp.completeExceptionally(e); 
}); 

request.putHeader("content-type", "application/json") 
    .setTimeout(timeout).end();