스프링 내장 이벤트를 활용한 로깅 아키텍처 (Pub/Sub 기반 의존성 분리)

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
@Service
public class OrderService {
    private final GeneralLogger generalLogger;
 
    // 강한 결합: 로거 객체를 직접 주입받음
    public OrderService(GeneralLogger generalLogger) {
        this.generalLogger = generalLogger;
    }
 
    @Transactional
    public void createOrder(OrderRequest request) {
        // 1. 핵심 비즈니스 로직 (DB 저장 등)
        // ...
 
        // 2. 로깅을 직접 동기 호출 (문제의 원인)
        generalLogger.log("ORDER", "SUCCESS", request);
    }
}

import java.time.LocalDateTime;
 
public class SystemLogEvent<T> {
    private final String domain;        // 예: "ORDER", "PAYMENT"
    private final String action;        // 예: "CREATE", "SUCCESS"
    private final T payload;            // 실제 데이터 객체
    private final LocalDateTime time;
 
    public SystemLogEvent(String domain, String action, T payload) {
        this.domain = domain;
        this.action = action;
        this.payload = payload;
        this.time = LocalDateTime.now();
    }
 
    // Getter 생략 (Lombok @Getter 활용 권장)
}

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
@Service
public class OrderService {
    private final ApplicationEventPublisher eventPublisher;
 
    public OrderService(ApplicationEventPublisher eventPublisher) {
        this.eventPublisher = eventPublisher;
    }
 
    @Transactional
    public void createOrder(OrderRequest request) {
        // 1. 핵심 비즈니스 로직 (DB 저장 등) 실행
        // ...
 
        // 2. 비즈니스 로직 완료 후 공통 이벤트 규격으로 던짐 (로깅 누락 방지)
        eventPublisher.publishEvent(new SystemLogEvent<>("ORDER", "SUCCESS", request));
    }
}

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.springframework.transaction.event.TransactionPhase;
import org.springframework.transaction.event.TransactionalEventListener;
 
@Component
public class GeneralLoggingSubscriber {
 
    // @Async: 메인 비즈니스 스레드를 막지 않고 백그라운드 스레드에서 처리하여 응답 속도 향상
    @Async
    // AFTER_COMMIT: Publisher의 DB 트랜잭션이 성공적으로 Commit 되었을 때만 로그 기록
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    public void handleLogEvent(SystemLogEvent<?> event) {
        try {
            // 로깅 처리 (예: ELK 전송, 파일 쓰기 등)
            System.out.println(String.format(
                "[로깅 완료] 도메인: %s | 액션: %s | 데이터: %s",
                event.getDomain(), event.getAction(), event.getPayload().toString()
            ));
        } catch (Exception e) {
            // 로깅 중 에러가 발생해도 메인 비즈니스(결제/주문)에는 전혀 영향을 주지 않음 (장애 격리)
        }
    }
}