SAF 거래 아키텍처

송신 시스템에서 요청한 메시지를 Queue Producer에 전달한다.

Queue Producer는 수신 받은 메시지를 SAF 큐에 비동기 방식으로 저장한다. (저장하는 SAF 큐의 파티션 수만큼 동시 처리 가능)

Queue Producer는 SAF 큐에 저장 오류시 내부 큐에 저장하여 재처리한다. 비동기 방식으로 SAF 큐에 저장하므로 비동기 호출 전 에러이면 송신시스템에 거래 처리 오류로 응답하고, SAF 큐에 저장하는 도중 에러가 발생하면 재처리를 위해 내부 큐에 저장한다.

Send Error Producer는 내부 큐에 저장된 메시지를 SAF 큐에 저장한다.

Send Error Producer는 SAF 큐에 저장 시 오류가 발생하면 메시지 재처리를 위해 내부 큐에 저장하고, 일정 시간 대기 후 재시도하며, 3회 이상 오류 발생 시 에러 로그 후 메시지를 스킵한다.

Process Consumer는 SAF 큐에서 메시지를 받아 전송 프로세스를 호출한다. SAF 큐의 파티션 수만큼 멀티 스레드로 동작한다.

메시지 전송 프로세스는 메시지를 하나씩 동기 방식으로 수신시스템에 호출한다.

메시지 전송 오류시 처리 횟수를 증가시키고 내부 큐에 저장하여 재처리 한다. 수신시스템에서 메시지를 정상적으로 처리하면 다음 메시지를 처리하고, 그렇지 않으면 처리 횟수를 증가시킨 후 내부 큐에 저장하여 재처리 한다.

Process Error Producer는 내부 큐에 저장된 메시지를 SAF 에러 큐에 저장한다.

Process Error Producer는 SAF 에러 큐에 저장이 안되면 메시지 재전송을 위해 내부 큐에 저장하고, 일정 시간 동안 대기했다가 재시도한다.

Process Error Consumer는 SAF 에러 큐에서 메시지를 받아 메시지 전송 프로세스를 호출하여 재처리한다. 단, Process Error Consumer는 순차처리를 위해 하나의 스레드로 구성되어 있다.

지정된 처리 오류 횟수를 초과한 경우 해당 메시지는 처리할 수 없으므로 스킵한다.

Process Consumer나 Process Error Consumer는 메시지 전송 처리 오류시 처리 횟수를 증가하여 내부 큐에 저장한다.

Process Error Consumer는 SAF 에러 큐에서 저장된 메시지를 읽어온다.

Process Error Consumer는 메시지 전송 전 처리 횟수를 검증하여 재처리 횟수를 초과한 경우 에러 처리하고 해당 메시지는 스킵한다. 재처리 횟수는 시스템 파라미터(SAF_MAX_ERROR_COUNT)에 등록하거나, 등록하지 않으면 기본적으로 3회 재처리 한다. 단, 3회 이상 SAF 에러 큐 저장 오류 발생시 해당 메시지는 에러 로깅 후 스킵한다.

즉시 재처리하지 않고 에러 횟수에 따라서 일정시간 동안 대기 후 재처리 한다. 대기시간은 에러횟수가 증가하면 더 많이 대기하는 구조로, 시스템 파라미터(SAF_RETRY_UNIT_SLEEP_TIME)에 에러 횟수당 대기시간을 등록하며, 기본적으로 5초 대기한다.

단, 수신시스템이 장애인 경우에는 수신시스템 장애에 따른 대기시간이 우선 적용된다. 수신시스템 장애시 처리 방안은 하단에 수신시스템 장애처리를 참조한다.