Transaction outbox 패턴

김성지·2023년 7월 22일

그냥공부

목록 보기

10/10

배경

분산환경에서
Command성 서비스는(create/update/delete) aggregates 들로 묶이는 경우가 많다.
이때 saga에 참여하는 것들은 하나의 트랜잭션 단위로 묶여서 데이터의 정합성을 보장해야 하는 경우가 많다.

전통적으로 two phase commit을 사용했는데..
문제점이 많다(문제점)

그래서 요즘은 domain event가 발생할 때마다
message를 발행하는데 이는 하나의 aggregate에서 여러번 발행된다.
즉 한 aggregate에 포함되는 특정 서비스마다 제어할 수 있는 transaction의 scope를 벗어나게 된다.

각 service마다 기존 트랜잭션(db트랜잭션)의 scope를 벗어나 발행한 event(메시지)로 서비스간 통신하게 되면 여러 문제가 발생한다.

문제 상황 1

seller가 상품을 등록 후
상품 등록 이벤트를 발생시켜
Search DB에 저장하는 가장 기본적인 상황이다.

public class MarketService {

    private final IMarketRepository repository;

    ...

    @Transactional
    public Product registerProduct(RegisterProduct command) {
        validate(command);
        var product = Product.create(command);
        repository.save(product);
        return product;
    }
}

@RestController
public class MarketController {

    private final MarketService service;
    private final IMessagePublisher publisher;

    ...

    @PostMapping(...)
    public void registerProduct(
        @RequestBody RegisterProduct command
    ) {
        Product product = service.registerProduct(command);
        var message = ProductRegistered.from(product);
        publisher.publish(message);
    }
}

위 방식의 문제점은 발행되어야 하는 메시지가 발행되지 않을 수도 있다.
registerProduct 함수가 정상적으로 종료된 후
publisher.publish(message) 가 실패하면
Market DB에는 정상적으로 영속화 되었지만
Search DB에는 해당 정보가 들어있지 않게된다.

이벤트를 발행하는 곳에서 retry Handler를 도입하는 방법이 떠오르지만
외부 메시지 브로커 시스템의 장애가 원인이면 문제를 완벽히 방지할 수 없게된다.
이에 따라 외부 시스템(브로커) 장애가 내부시스템(Market Api Server)에 까지 크게 영향을 미칠 수 있다.

문제 상황 2

1번 상황을 개선하고자 다음과 같은 설계를 적용해보는 상황이다.
의도는 메시지 발행이 실패하면 상품 등록을 실패시키려고 하는 것이다.

@RestController
public class MarketController {

    private final MarketService service;

    ...

    @PostMapping(...)
    public void registerProduct(
        @RequestBody RegisterProduct command
    ) {
        service.registerProduct(command);
    }
}

public class MarketService {

    private final IMarketRepository repository;
    private final IMessagePublisher publisher;

    ...

    @Transactional
    public void registerProduct(RegisterProduct command) {
        validate(command);
        var product = Product.create(command);
        repository.save(product);
        var message = ProductRegistered.from(product);
        publisher.publish(message);
    }
}