Hi I'm using the spring RestTemplate
for calling a REST API. The API can be very slow or even offline. My application is building the cache by sending thousands of requests one after the other. The responses can be very slow too, because they contains a lot of data.
I have already increased the Timeout to 120 seconds. My problem now it that the API can be offline and I get a org.apache.http.conn.ConnectionPoolTimeoutException: Timeout waiting for connection from pool
exception.
In the case when the API ist offline, the application should wait and try again until the API is online again.
Can I achieve this in RestTemplate
out of the box without building exception-loops on my own?
Thanks!
I had same situation and done some googling found the solution. Giving answer in hope it help someone else. You can set max try and time interval for each try.
@Bean public RetryTemplate retryTemplate() { int maxAttempt = Integer.parseInt(env.getProperty("maxAttempt")); int retryTimeInterval = Integer.parseInt(env.getProperty("retryTimeInterval")); SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(); retryPolicy.setMaxAttempts(maxAttempt); FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy(); backOffPolicy.setBackOffPeriod(retryTimeInterval); // 1.5 seconds RetryTemplate template = new RetryTemplate(); template.setRetryPolicy(retryPolicy); template.setBackOffPolicy(backOffPolicy); return template; }
And my rest service that i want to execute is below.
retryTemplate.execute(context -> { System.out.println("inside retry method"); ResponseEntity<?> requestData = RestTemplateProvider.getInstance().postAsNewRequest(bundle, ServiceResponse.class, serivceURL, CommonUtils.getHeader("APP_Name")); _LOGGER.info("Response ..."+ requestData); throw new IllegalStateException("Something went wrong"); });
You can also tackle this annotation-driven using Spring Retry. This way you will avoid to implement the template.
Add it to your pom.xml
<dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> <version>1.1.2.RELEASE</version> </dependency>
Enable it for your application/configuration
@SpringBootApplication @EnableRetry public class MyApplication { //... }
Guard methods that are in danger of failure with @Retryable
@Service public class MyService { @Retryable(maxAttempts=5, value = RuntimeException.class, backoff = @Backoff(delay = 15000, multiplier = 2)) public List<String> doDangerousOperationWithExternalResource() { // ... } }
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With