Spring Retry

분산환경에서 짧은 네트워크 중단 또는 일시적인 서비스 불가한 상황에 발생할 때가 있다. 일부 장애는 지속적으로 발생하여 사람의 개입이나 시스템 변경이 필요할 수 있지만 대부분 일시적이어서 재시도를 통해 해결될 때가 있다. 이때 사용하는 것이 Spring Retry이다.

 

Spring Retry는 추상화된 retry operation을 제공한다. 때문에 개발자들이 retry logic을 어플리케이션에 간편하게 추가할 수 있다. 특히나, 일시적인 오류가 문제가 되는 외부 시스템을 다룰 때 굉장히 유용하다.

 

 

사용 방법

코드에 적절한 종속성을 추가하고 실패 시 재시도해야 하는 메서드에 어노테이션을 달면된다.

@Service
class MyService {

    // Retryable: 최대 3번 재시도, 2초 대기 후 2배씩 증가
    @Retryable(
        value = [RuntimeException::class],
        maxAttempts = 3,
        backoff = Backoff(delay = 2000, multiplier = 2.0)
    )
    fun performTask() {
        println("Executing task...")
        throw RuntimeException("Task failed!")
    }

@Retryable 어노테이션이 getCart()라는 메소드에 exception이 발생했을 경우 세번 retry하라는 것을 의미한다. 

(그렇다면 annotation으로 특정 에러가 발생했을 경우 ErrorCode를 토대로 retry여부를 결정할 수 있지 않을까 싶다. 이건 더 알아봐야겠음)

 

- 특정 Exception이 발생하면 Retry를 하도록 설정하는 방법

@Service
class MyService {

    // Retryable: 최대 3번 재시도, 2초 대기 후 2배씩 증가
    @Retryable(
        value = [NetworkException::class, TimeoutException.class],
        maxAttempts = 3,
        backoff = Backoff(delay = 2000, multiplier = 2.0)
    )
    fun performTask() {
        println("Executing task...")
        throw RuntimeException("Task failed!")
    }

 

 

만약 retry의 시도가 모두 완료되었고 여전이 fail이 발생한다면, spring retry는 recovery mechanism을 제공한다. 개발자들이 fallback을 정의할 수 있도록 되어있다. 

@Service
class MyService {

    // Retryable: 최대 3번 재시도, 2초 대기 후 2배씩 증가
    @Retryable(
        value = [RuntimeException::class],
        maxAttempts = 3,
        backoff = Backoff(delay = 2000, multiplier = 2.0)
    )
    fun performTask() {
        println("Executing task...")
        throw RuntimeException("Task failed!")
    }

    // Recover: 모든 재시도가 실패한 후 실행
    @Recover
    fun recover(e: RuntimeException) {
        println("Recovering from failure: ${e.message}")
    }
}

 

 

Stateful 과 Stateless retry

 

기본적으로 Spring Retry는 stateless이다. 때문에 각각의 retry가 독립적이다. 하지만 stateful한 시스템을 운영하는 특정 경우에는 stateful retry를 사용할 수 있다.