Frühjahr RestTemplate Verbindungs-Timeout funktioniert nicht

Den folgenden verwandt ist connectTimeout Einstellung.

Fall - unbekannter host

Wenn Sie einen host, der nicht erreichbar ist (z.B.: http://blablablabla/v1/timeout), dann erhalten Sie UnknownHostException so bald wie möglich. AbstractPlainSocketImpl :: connect() :: !addr.isUnresolved() :: throw UnknownHostException ohne timeout. Der host aufgelöst InetAddress.getByName(<host_name>).

Fall - unbekannten-Anschluss

Wenn Sie einen host, der erreichbar ist, aber keine Verbindung gemacht werden kann, dann erhalten Sie ConnectException - Connection refused: connect so bald wie möglich. Es scheint, dass dies geschieht in einer nativen Methode DualStackPlainSocketImpl :: static native void waitForConnect(int fd, int timeout) throws IOException die aufgerufen wird, aus DualStackPlainSocketImpl :: socketConnect(). Der timeout wird nicht respektiert.

Proxy? wenn ein proxy verwendet wird, könnten sich die Dinge ändern. Mit einem erreichbaren proxy, erhalten Sie möglicherweise die timeout.

Fragen überprüfen diese Antwort wie ist im Zusammenhang mit dem Fall Auftritt.

DNS-Round-Robin mit der gleichen domain zugeordnet mehrere IP-Adressen bewirkt, dass der Klient eine Verbindung zu jedem der IPs bis eine gefunden wird. Daher die connectTimeout() wird eine eigene Strafe für jeden der die IPs in der Liste, die nicht arbeiten. Lesen dieser Artikel für mehr.

Abschluss wenn Sie wollen erhalten die connectTimeout dann könnten Sie brauchen, um Ihre eigenen retry-Logik oder einen proxy verwenden.

Testen connectTimeout, können Sie sich an diese Antwort von verschiedenen Möglichkeiten, der mit einem endpoint, der verhindert, dass eine socket-Verbindung von Abschluss erhalten somit ein timeout. Die Auswahl einer Lösung, können Sie erstellen ein Integrations-test im Frühjahr-boot, die überprüft Ihre Umsetzung. Dies kann ähnlich sein, der nächste test wird für die Prüfung der readTimeout nur, dass für diesen Fall die URL kann geändert werden, in eine, die verhindert, dass eine socket-Verbindung.

Testen readTimeout

Um zu testen, die readTimeout es muss eine erste Verbindung, daher muss der Dienst bis. Dann ein Endpunkt kann vorgesehen werden, dass für jede Anforderung, gibt eine Antwort zurück, mit einer großen Verzögerung.

Kann im Frühjahr starten, um zu erstellen ein Integrations-test:

1. Erstellen Sie die test -

@RunWith(SpringRunner.class)
@SpringBootTest(
        webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT,
        classes = { RestTemplateTimeoutConfig.class, RestTemplateTimeoutApplication.class }
)
public class RestTemplateTimeoutTests {

    @Autowired
    private RestOperations restTemplate;

    @LocalServerPort
    private int port;

    @Test
    public void resttemplate_when_path_exists_and_the_request_takes_too_long_throws_exception() {
        System.out.format("%s - %s\n", Thread.currentThread().getName(), Thread.currentThread().getId());

        Throwable throwable = catchThrowable(() ->
                restTemplate.getForEntity(String.format("http://localhost:%d/v1/timeout", port), String.class));

        assertThat(throwable).isInstanceOf(ResourceAccessException.class);
        assertThat(throwable).hasCauseInstanceOf(SocketTimeoutException.class);
    }
}

2. Konfigurieren RestTemplate

@Configuration
public class RestTemplateTimeoutConfig {

    private final int TIMEOUT = (int) TimeUnit.SECONDS.toMillis(10);

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate(getRequestFactory());
    }

    private ClientHttpRequestFactory getRequestFactory() {
        HttpComponentsClientHttpRequestFactory factory =
                new HttpComponentsClientHttpRequestFactory();

        factory.setReadTimeout(TIMEOUT);
        factory.setConnectTimeout(TIMEOUT);
        factory.setConnectionRequestTimeout(TIMEOUT);
        return factory;
    }
}

3. Spring Boot app, die ausgeführt wird, wenn der test beginnt

@SpringBootApplication
@Controller
@RequestMapping("/v1/timeout")
public class RestTemplateTimeoutApplication {

    public static void main(String[] args) {
        SpringApplication.run(RestTemplateTimeoutApplication.class, args);
    }

    @GetMapping()
    public @ResponseStatus(HttpStatus.NO_CONTENT) void getDelayedResponse() throws InterruptedException {
        System.out.format("Controller thread = %s - %s\n", Thread.currentThread().getName(), Thread.currentThread().getId());
        Thread.sleep(20000);
    }
}

Alternative Möglichkeiten der Konfiguration des RestTemplate

Sie bestehende RestTemplate

@Configuration
public class RestTemplateTimeoutConfig {

    private final int TIMEOUT = (int) TimeUnit.SECONDS.toMillis(10);

    //consider that this is the existing RestTemplate
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    //this will change the RestTemplate settings and create another bean
    @Bean
    @Primary
    public RestTemplate newRestTemplate(RestTemplate restTemplate) {
        SimpleClientHttpRequestFactory factory =
                (SimpleClientHttpRequestFactory) restTemplate.getRequestFactory();

        factory.setReadTimeout(TIMEOUT);
        factory.setConnectTimeout(TIMEOUT);

        return restTemplate;
    }
}

Konfigurieren Sie eine neue RestTemplate mit RequestConfig

@Configuration
public class RestTemplateTimeoutConfig {

    private final int TIMEOUT = (int) TimeUnit.SECONDS.toMillis(10);

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate(getRequestFactoryAdvanced());
    }

    private ClientHttpRequestFactory getRequestFactoryAdvanced() {
        RequestConfig config = RequestConfig.custom()
                .setSocketTimeout(TIMEOUT)
                .setConnectTimeout(TIMEOUT)
                .setConnectionRequestTimeout(TIMEOUT)
                .build();

        CloseableHttpClient client = HttpClientBuilder
                .create()
                .setDefaultRequestConfig(config)
                .build();

        return new HttpComponentsClientHttpRequestFactory(client);
    }
}

Warum nicht lustig mit MockRestServiceServer mit einem RestTemplate ersetzt den Antrag der Fabrik. Daher ist jeder RestTemplate Einstellungen ersetzt werden. Daher ist eine echte app für timeout-Tests möglicherweise die einzige option hier.

Hinweis: schauen Sie auch dieser Artikel über RestTemplate Konfiguration, die auch die timeout-Konfiguration.

InformationsquelleAutor andreim