NHN Cloud Meetup

Java Reactor onErrorContinue 이모저모

thumbnail
  • onErrorContinue는 스트림에서 에러가 발생해도 이를 무시하고 계속 진행할 수 있게 해주는 연산자입니다.
  • onErrorContinueMono, Flux와 같은 Publisher의 구현체에서 제공되는 연산자입니다.
  • onErrorContinue를 사용하면 에러가 발생해도 스트림은 중단되지 않고 정상적으로 작동합니다.
  • onErrorContinue는 모든 업스트림 에러를 무시하기 때문에 사용할 때 주의해야 합니다.
  • onErrorContinue는 업스트림 에러를 무시하고 특정 조건에 따라 재시도하는 기능을 제공하는 연산자입니다.
  • onErrorContinue는 내부적으로 발행 구독을 통해 작동하며, 메인 Subscriber는 동반 Subscriber에게 시그널을 보내 재시도 여부를 확인하고 업스트림을 재구독합니다.
  • onErrorContinue에서는 Context의 값을 사용해 에러와 관련된 필요한 로직을 수행하고 null을 반환합니다.
  • onErrorContinue를 사용하면 에러에 관계없이 다음 작업으로 넘어갈 수 있습니다.
  • onErrorContinue를 사용할 때는 주의해야 하며, 가능한 다른 방법을 고려해야 합니다.