Время ожидания запроса POST API - PullRequest
Новая
       13

Время ожидания запроса POST API

0 голосов
/ 24 апреля 2020

Я пытаюсь вызвать POST API к нашему внешнему API через API PROXY. У меня возникают проблемы с тайм-аутом при вызове API. Я использовал ниже restTemplate, чтобы сделать запрос API. Но в то же время я реализовал повторную попытку для шаблона на случай тайм-аута. Я могу избежать этой проблемы, повторяя этот запрос API снова. Но я хотел бы выяснить причину root, чтобы полностью решить эту проблему. Может ли кто-нибудь помочь мне с этим

StackTrace: 

    org.springframework.web.client.ResourceAccessException: I/O error on POST request for "https://localhost:8080/test": Operation timed out (Read failed); nested exception is java.net.SocketException: Operation timed out (Read failed)


 private static final int HTTP_CLIENT_RETRY_COUNT = 3;
        private static final int MAXIMUM_TOTAL_CONNECTION = 10;
        private static final int MAXIMUM_CONNECTION_PER_ROUTE = 5;
        private static final int CONNECTION_VALIDATE_AFTER_INACTIVITY_MS = 10 * 1000;
        public static RestTemplate createRestTemplate(int connectionTimeoutMs, int readTimeoutMs, ObjectMapper objectMapper) {
            HttpClientBuilder clientBuilder = HttpClients.custom();
            PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();
            // Set the maximum number of total open connections.
            connectionManager.setMaxTotal(MAXIMUM_TOTAL_CONNECTION);
            // Set the maximum number of concurrent connections per route, which is 2 by default.
            connectionManager.setDefaultMaxPerRoute(MAXIMUM_CONNECTION_PER_ROUTE);
            connectionManager.setValidateAfterInactivity(CONNECTION_VALIDATE_AFTER_INACTIVITY_MS);
            clientBuilder.setConnectionManager(connectionManager);
            clientBuilder.setRetryHandler(new DefaultHttpRequestRetryHandler(HTTP_CLIENT_RETRY_COUNT, true, new ArrayList<>()) {
                @Override
                public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {
                    LOGGER.info("Retry request, execution count: {}, exception: {}", executionCount, exception);
                    return super.retryRequest(exception, executionCount, context);
                }
            });
            HttpComponentsClientHttpRequestFactory httpRequestFactory = new HttpComponentsClientHttpRequestFactory(clientBuilder.build());
            httpRequestFactory.setConnectTimeout(connectionTimeoutMs);
            httpRequestFactory.setConnectionRequestTimeout(readTimeoutMs);
            httpRequestFactory.setReadTimeout(readTimeoutMs);
            RestTemplate restTemplate = new RestTemplate(httpRequestFactory);
            List<ClientHttpRequestInterceptor> interceptors = new ArrayList<ClientHttpRequestInterceptor>();
            interceptors.add(new LoggingRequestInterceptor());
            restTemplate.setInterceptors(interceptors);
            restTemplate.setRequestFactory(new BufferingClientHttpRequestFactory(httpRequestFactory));
            MappingJackson2HttpMessageConverter messageConverter = restTemplate.getMessageConverters().stream().filter(MappingJackson2HttpMessageConverter.class::isInstance)
                    .map(MappingJackson2HttpMessageConverter.class::cast).findFirst().orElseThrow(() -> new RuntimeException("MappingJackson2HttpMessageConverter not found"));
            messageConverter.setObjectMapper(objectMapper);
            restTemplate.getMessageConverters().stream().filter(StringHttpMessageConverter.class::isInstance).map(StringHttpMessageConverter.class::cast).forEach(a -> {
                a.setWriteAcceptCharset(false);
                a.setDefaultCharset(StandardCharsets.UTF_8);
            });
            return restTemplate;
}
...