마패 (MaskPass)

1. 상황 및 문제

2. 원인 분석

3. 해결 단계

1. Step 1. completeWithError()로 끊긴 연결 즉시 강제 종료

   전송 실패가 감지되면 completeWithError()로 emitter를 즉시 종료해, 끊긴 연결이 서버에 남지 않게 했습니다.

2. Step 2. 45초 주기 Heartbeat로 죽은 연결 조기 감지

   주기적으로 heartbeat 이벤트를 보내, 이미 끊긴 연결에서 전송 예외가 빨리 발생하도록 만들었습니다. 감지가 빨라지면 정리도 빨라집니다.

3. Step 3. Nginx proxy_read_timeout 3600s → 80s

   Heartbeat 주기(45초)보다 여유 있게 80초로 줄여, 정상 연결은 유지되면서 죽은 커넥션은 Nginx 레벨에서도 빠르게 회수되게 했습니다.

   location /sse {
       proxy_pass http://app;
       proxy_read_timeout 80s;  # heartbeat 45s + 여유
       proxy_set_header Connection '';
       proxy_http_version 1.1;
   }

4. 검증 및 결과

1. 상황 및 문제

2. 원인 분석

3. 해결 단계

1. Step 1. 후처리를 @Async 이벤트로 분리

   인증 트랜잭션은 응답까지만 책임지고, Redis·RDB·SSE 후처리는 이벤트 발행 후 @Async 리스너가 처리하도록 분리했습니다.

2. Step 2. TaskDecorator로 MDC traceId 전파

   비동기 스레드로 넘어갈 때 MDC 컨텍스트가 유실되지 않도록 TaskDecorator로 traceId를 복사해, 하나의 인증 요청을 동기·비동기 구간에 걸쳐 추적할 수 있게 했습니다.

   public class MdcTaskDecorator implements TaskDecorator {
       @Override
       public Runnable decorate(Runnable runnable) {
           Map<String, String> context = MDC.getCopyOfContextMap();
           return () -> {
               if (context != null) MDC.setContextMap(context);
               try {
                   runnable.run();
               } finally {
                   MDC.clear();
               }
           };
       }
   }

4. 검증 및 결과

1. 상황 및 문제

2. 원인 분석

3. 해결 단계

1. Step 1. AsyncUncaughtExceptionHandler로 실패 가시성 확보

   비동기 예외를 잡아 로깅하는 핸들러를 등록해, 어떤 후처리가 어떤 이유로 실패하는지 먼저 보이게 만들었습니다.

2. Step 2. 보상 트랜잭션으로 부분 실패 롤백

   RDB 기록이 실패하면 이미 증가시킨 Redis 카운트를 되돌리는 보상 로직을 넣어, 두 저장소가 어긋난 채 남지 않게 했습니다.

3. Step 3. Redis List 실패 큐 + @Scheduled 재처리

   보상까지 실패한 건은 Redis List 실패 큐에 적재하고, 스케줄러가 주기적으로 재처리하도록 해 유실 없이 최종 정합성에 수렴하게 했습니다.

4. 검증 및 결과