🎇 트러블 슈팅

1️⃣ RDB & MongoDB 트랜잭션 분리

문제 상황

문서를 삭제할 때, RDB(MySQL)과 MongoDB에 분산된 데이터가 함께 삭제되어야 한다. 하지만 두 데이터베이스 간에 단일 트랜잭션을 묶는 것은 불가능하며(하나의 @Transactional로 처리 X), 처리 순서나 실패 복구를 잘 설계하지 않으면 두 데이터베이스간 불일치가 발생할 수 있다.

현재 구조:

db	저장 내용
RDB(JPA 기반)	Doc, Branch, Edge와 Save, Commit의 메타데이터 (제목, 설명, 생성/수정 일자 etc)
MongoDB	SaveContent, Block, CommitsBlockSequence (Save와 Commit의 본문, Commit의 블록 리스트)

저장 트랜잭션 설계

저장의 경우 다음과 같은 위험이 발생할 수 있다:

• Mongo 먼저 저장 → 이후 RDB 실패: Mongo에 쓰레기 데이터 남음
• RDB 먼저 저장 → 이후 Mongo 실패: RDB에 내용이 없는 저장이 생김

이를 해결하기 위해 다음과 같은 저장 로직을 고안하였다:

✔ MongoDB 저장 후 → 성공 시 ID를 받아 → RDB에 저장

예시 프로세스: RDB의 @Transactional 안에서 다음 처리 실행

try {
    1. [RDB] MongoID를 제외한 Save 메타데이터를 우선 RDB에 저장

    2. [MongoDB] SaveContent를 MongoDB에 저장 → saveContentId 반환

    3. [RDB] 반환받은 saveContentId를 기존 Save(RDB)에 업데이트

    4. 최종적으로 모든 저장 성공 → 트랜잭션 커밋

} catch (예외 발생 시) {
    - [MongoDB 수동 롤백] 실패한 Mongo 저장 내용 직접 삭제 (saveContentId 등)
    - 예외 종류에 따라 적절한 CustomException 발생 후 
    - 전체 트랜잭션 롤백
}

삭제 트랜잭션 설계

삭제의 경우 다음과 같은 위험이 발생할 수 있다:

• Mongo 삭제 중 예외 → RDB는 이미 삭제 완료 상태 → 롤백 불가로 데이터 정합성 깨짐

• 반대로 Mongo는 삭제됐는데 RDB 트랜잭션이 롤백된다면 → MongoDB에 고아 데이터 발생

삭제는 저장과 달리 RDB만 먼저 삭제되고 MpongoDB에 고아 데이터가 남더라도 UX 관점에서 문제가 없으므로, Mongo 삭제를 RDB 트랜잭션 이후로 분리한다.

이를 해결하기 위해 다음과 같은 삭제 로직을 고안하였다:

✔ 이벤트 기반 처리 + 트랜잭션 분리 + 재시도 + 비동기

1. RDB 삭제

• Doc, Branch, Commit, Save 등(RDB)은 하나의 @Transactional 내에서 삭제
• 동시에 삭제해야할 Mongo 관련 ID를 수집하여 DocDeleteMongoIdsDto에 담고
• eventPublisher.publishEvent()로 삭제 이벤트 발행

2. MongoDB 삭제

• @TransactionalEventListener(phase = AFTER_COMMIT)를 통해 RDB 트랜잭션이 성공적으로 커밋된 후에만 Mongo 삭제를 시도
• @Retryable은 AOP 기반으로 프록시를 통해 호출돼야 작동하기 때문에 이벤트리스너에서 직접 삭제하지 않음 (리스너에서 직접 호출 시 동작 안 함)

3. Mongo 삭제: 재시도

• MongoDB는 Atlas 기준 기본적으로 Replica Set을 지원하므로, 트랜잭션 사용이 가능함
• MongoTransactionManager를 @Bean으로 등록해 트랜잭션 분리

4. 삭제 실패 → @Recover 진입

• 삭제가 3회 모두 실패하면 @Recover 메서드로 이동
• 이 시점에는 트랜잭션 컨텍스트가 종료되어 있으므로, 직접 RDB 저장 시도 시 예외 발생 (no transaction is in progress)
• @Async 로 위임하여 트랜잭션을 새로 생성하고 Mongo 삭제 실패 내역(MongoDeleteFailure)을 저장

5. Mongo 삭제 실패 기록 저장

• @Async + @Transactional 조합으로 새 트랜잭션 컨텍스트를 생성하여 RDB에 Mongo 삭제 실패 내역 저장

6. 실패 내역 재시도: 스케줄러 기반

• 일정 주기(1시간?)로 MongoDeleteFailure 내역 조회
• 삭제 성공 시 resolved = true로 soft delete 처리

2️⃣ 연관관계 CASCADE 오류 및 해결

문제 상황

문서 삭제시 Edgde에서 다음과 같은 에러가 발생했다.

Column 'next_commit_id' cannot be null

다음은 기존의 관련 코드와 ERD이다.

• 문서(Doc) 삭제 방식
  • MongoDB: 삭제할 문서와 관련된 데이터를 dto로 만들어 삭제 이벤트를 발행
  • RDB: cascade = CascadeType.ALL, orphanRemoval = true를 통해 Doc의 삭제로 관리
    • 에러 원인 예상 : Doc 삭제시 Edge보다 Commit이 먼저 제거되며, Edge의 next_commit_id에서 nullable = false 제약조건 위배

    public void delete(Long docId, Long userId) {
        User user = getUserOrThrow(userId);
        Doc doc = getDocByIdAndUserId(docId, userId);

        List<Branch> branches = doc.getBranches();
        MongoIdsDto docDeleteMongoIds = mongoIdsCollector.collectFrom(branches);

        user.removeDocument(doc);
        eventPublisher.publishEvent(docDeleteMongoIds);

• Edgde 엔티티

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "document_id", nullable = false)
    private Doc doc;

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "prev_commit_id", nullable = false)
    private Commit prevCommit;

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "next_commit_id", nullable = false)
    private Commit nextCommit;

• Doc 엔티티

    @ManyToOne(fetch = FetchType.LAZY)
    @JoinColumn(name = "user_id", nullable = false)
    private User user;

    @OneToMany(mappedBy = "doc", cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.LAZY)
    private List<Branch> branches;

    @OneToMany(mappedBy = "doc", cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.LAZY)
    private List<Edge> edges;

• ERD

해결

• DocService에서 doc 삭제시 간선을 먼저 명시적으로 삭제함으로써 해결하였다.

    public void delete(Long docId, Long userId) {
        User user = getUserOrThrow(userId);
        Doc doc = getDocByIdAndUserId(docId, userId);

        List<Edge> edges = doc.getEdges(); // 간선 수집
        List<Branch> branches = doc.getBranches();

        MongoIdsDto docDeleteMongoIds = mongoIdsCollector.collectFrom(branches);
        edgeRepository.deleteAll(edges); //간선 삭제

        user.removeDocument(doc);
        eventPublisher.publishEvent(docDeleteMongoIds);

원인

이 에러의 원인은 orphanRemoval 에 의해 발생한다.

1. edges 컬렉션에서 Edge 객체가 제거됨
2. Hibernate가 영속성 컨텍스트에서 Edge -> Commit 참조를 끊으면서(메모리상 null 설정) UPDATE를 날림
3. DB에서는 nullable = false 제약 조건 때문에 UPDATE 시 에러 발생.
4. 곧 DELETE할 객체인데 FK null 제약이 먼저 걸려서 실패.

즉, DELETE 전 FK null UPDATE가 발생

*아직 다 안 씀

3️⃣ MultipleBagException