개요

픽블엽을 진행하면서 하나의 기능에 여러 부가 기능이 따라오게 되었다.
예: 엽서 등록 → DB 저장 → 관리자에게 메일 발송

이처럼 하나의 액션에 여러 책임이 딸려붙기 시작하면 객체지향 5원칙 중 하나인 단일 책임 원칙(SRP)이 쉽게 깨진다.

이 문제를 해결하기 위해 Spring Event를 도입했고, 적용 방법과 실전 적용기(픽블엽 예제)를 아래에 정리해봤다.

Spring Event란?

Spring Event는 컴포넌트 간의 느슨한 연결(loose coupling)을 가능하게 해주는 구조다.
내부적으로는 Observer 패턴으로 구성돼있다.

누군가 어떤 이벤트를 발행하면,
관심 있는 컴포넌트가 리스너로서 그 이벤트를 받아 처리.

🧠 핵심 개념

역할	설명
Publisher	이벤트를 발생시키는 쪽
Event	전달되는 데이터 객체
Listener	이벤트를 구독하고 처리하는 쪽

🔨 적용 방법

이벤트 객체

public class UserRegisteredEvent {
    private final String email;

    public UserRegisteredEvent(String email) {
        this.email = email;
    }

    public String getEmail() {
        return email;
    }
}

이벤트 발행

@Component
@RequiredArgsConstructor
public class UserService {

    private final ApplicationEventPublisher publisher;

    public void registerUser(String email) {
        // 사용자 등록 로직 ...

        // 이벤트 발행
        publisher.publishEvent(new UserRegisteredEvent(email));
    }
}

이벤트 리스너

@Component
public class WelcomeEmailListener {

    @EventListener(UserRegisteredEvent.class)
    public void handleUserRegistered(UserRegisteredEvent event) {
        System.out.println("환영 메일 전송 대상: " + event.getEmail());
        // 메일 전송 로직 ...
    }
}

✍️ 픽블엽 실전 적용기

픽블엽에서는 엽서를 승인할 때 다음 3가지 기능이 한 번에 실행된다.

1. 엽서 상태 변경 (pre_posts테이블 status컬럼 수정)
2. 실제 엽서 등록 (posts 테이블)
3. 작성자에게 승인 메일 전송

이때 1~2번은 트랜잭션 안에서 안전하게 실행되어야 하고, 3번은 부가기능이므로 성공/실패가 트랜잭션 작업에 영향이 없어야하는 조건이 있었다.

---

엽서 승인 Class

@Slf4j
@Service
@RequiredArgsConstructor
@Transactional
public class ConfirmPrePostService {

    private final ApplicationEventPublisher eventPublisher;
    private final GetPrePostService getPrePostService;
    private final ConfirmPrePostValidator confirmPrePostValidator;

    public void confirm(UpdatePrePostStatusDto dto) {
        log.info("Confirm pre post: {}", dto);
        PrePost prePost = getPrePostService.getPrePost(dto.prePostId());
        confirmPrePostValidator.validateStatus(prePost.getStatus());
        prePost.updateStatus(dto.status(), dto.updatedBy());
        eventPublisher.publishEvent(ConfirmPrePostStatus.confirmPrePost(prePost, dto.updatedBy()));
    }

엽서 등록 Class

@TransactionalEventListener(classes = ConfirmPrePostStatus.class, phase = TransactionPhase.BEFORE_COMMIT)
    public void registerPost(ConfirmPrePostStatus event) {
        log.info("EVENT - Register post: {}", event);
        String geohash = geoHashUtil.encode(event.latitude(), event.longitude());
        MultipartFile img = fileCodecUtil.decodeToMultipartFile(geohash, event.img());
        s3Util.uploadFile(event.type() + "-" + geohash, img);
        Post post = new Post(
                geohash,
                event.name(),
                event.latitude(),
                event.longitude(),
                event.type(),
                event.requester(),
                event.noImg(),
                event.confirmedBy()
        );
        postRepository.save(post);
    }

여기서 @TransactionalEventListener어노테이션과 phase = TransactionPhase.BEFORE_COMMIT 두개를 잘 봐야한다.

• @TransactionalEventListener : 이벤트를 트랜젝션에 포함시키는 Listener.
• phase = TransactionPhase.BEFORE_COMMIT : 트랜잭션이 작업이 커밋 되기전에 실행.
  • 실패 시 전체 작업이 rollback 된다.

Mail 전송 Class

@Slf4j
@Service
@RequiredArgsConstructor
public class ConfirmPrePostMailService {

    private final JavaMailSender javaMailSender;
    private final ConfirmPrePostTemplate confirmPrePostTemplate;

    @Value("${spring.mail.username}")
    private String from;

    @TransactionalEventListener(classes = ConfirmPrePostStatus.class, phase = TransactionPhase.AFTER_COMMIT)
    public void confirmPrePost(ConfirmPrePostStatus event) {
        log.info("EVENT - Sending confirm prePost mail: {}", event);
        String html = confirmPrePostTemplate.build(event);
        MimeMessage message = javaMailSender.createMimeMessage();
        try {
            MimeMessageHelper helper = new MimeMessageHelper(message, true, "UTF-8");
            helper.setTo(event.requester().getEmail());
            helper.setSubject("엽서 등록 승인");
            helper.setFrom(from);
            helper.setText(html, true);
            helper.addInline("img", confirmPrePostTemplate.bindImg(event.img()));
        } catch (MessagingException e) {
            log.error("sendConfirmPrePostMail Exception", e);
            throw new MessagingBuildException("ConfirmPrePostMail");
        }
        javaMailSender.send(message);
    }
}

여기서 중요하게 봐야하는 건 phase = TransactionPhase.AFTER_COMMIT이다.

• phase = TransactionPhase.AFTER_COMMIT : 트랜잭션 작업을 커밋 후 작업을 진행.
  • 메일 발송 실패가 DB 작업에 영향을 주지 않는다.

결론

기존에는 하나의 엽서 승인 Class에서 승인 처리 + 등록 + 메일 전송을 모두 처리했다.
이 방식은 클래스가 3가지 책임을 동시에 가지게 되어 유지보수와 추가 기능을 붙이기가 어려웠다.

Spring Event를 도입한 후에는

• 승인 클래스는 오직 상태 변경만 수행
• 등록/메일 등 후처리는 별도 리스너에서 처리
• 결합도는 낮고, 기능 확장성은 높아짐

✔️ 새로운 후처리를 붙일 때는 기존 클래스 수정 없이
@TransactionalEventListener만 추가하면 끝!

이 처럼 Spring Event를 도입 후 유지보수와 기능 추가 시 이점을 함깨 가져가게 되었다.