[Sunny Braille] 외부 API 호출, 비동기적으로 처리하기! (ft. Spring Event): 트랜잭션은 어떻게 해야할까,,?

@Transactional
public Long register(final MultipartFile file) {
    final String originalFileName = file.getOriginalFilename();
    final String fileName = FileUtil.createRandomFileName(file);

    final String pdfPath = FileUtil.saveFile(file, fileName, Paths.get("src", "main", "pdf"));
    final Translations translations = translationsRepository.save(Translations.of(pdfPath, originalFileName));
    log.info("Saved pdf File in Server. File URI: {}", pdfPath);

    eventPublisher.publishEvent(new OcrRegisterEvent(this, translations));
    log.info("pdf file 저장 이벤트를 발행했습니다!");
    log.info("현재 스레드: {}", Thread.currentThread().getName());

    return translations.getId();
}

그리고 보면 OcrRegisterEvent를 발행한다.

그러면 OcrRegisterEventListener가 깨어나서 첫번째 외부 API를 호출하게 된다.

@Slf4j
@NoArgsConstructor
@Component
public class OcrRegisterEventListener {

    private TranslationsRepository translationsRepository;
    private OcrRegisterClient ocrRegisterClient;
    private ApplicationEventPublisher eventPublisher;

    @Autowired
    public OcrRegisterEventListener(
            final TranslationsRepository translationsRepository,
            final OcrRegisterClient ocrRegisterClient,
            final ApplicationEventPublisher eventPublisher
    ) {
        this.translationsRepository = translationsRepository;
        this.ocrRegisterClient = ocrRegisterClient;
        this.eventPublisher = eventPublisher;
    }

    @Async
    @TransactionalEventListener
    @Transactional(propagation = REQUIRES_NEW)
    public void registerOcr(final OcrRegisterEvent event) {
        log.info("현재 스레드: {}", Thread.currentThread().getName());

        final Long id = event.getTranslations().getId();
        final Translations translations = translationsRepository.getById(id);
        final File file = FileUtil.findFile(translations.getPdfPath());

        translations.startOcr();
        final String pdfId = ocrRegisterClient.requestPdfId(file);
        translations.registerPdfId(pdfId);

        eventPublisher.publishEvent(new OcrStatusEvent(this, id));
    }
}

앞선 방법과 유사하게 마지막에 또 이벤트를 발행한다.

저렇게 해서 계속해서 이벤트가 연쇄적으로 발행되어 클라이언트는 즉시 반환받은 아이디 값을 가지고 있다가,

진행 상태가 어떤지 확인하거나, 언젠가 점역 과정이 완료되었다면 파일을 다운로드 받을 수 있다.

✔️ 외부 API 호출 시 트랜잭션을 어떻게 해야할까,,?

개선된 코드에서 각각 작업을 아래와 같은 트랜잭션으로 묶고 있다.

트랜잭션 1: 클라이언트가 파일을 보내자마자, 그냥 일단 데이터베이스에 저장하고 id 즉시 반환
트랜잭션 2: 1번 외부 API 호출 후 데이터베이스에 상태 update
트랜잭션 3: 2번 외부 API 호출 후 데이터베이스에 상태 update
트랜잭션 4: 3번 외부 API 호출 후 데이터베이스에 상태 update
트랜잭션 5: 4번 외부 API 호출 후 데이터베이스에 상태 update

고민이,, 트랜잭션 2~5에서 외부 API 호출에 대한 부분도 트랜잭션에 포함되고 있다는 것이다.

물론 아직 서비스 규모가 작아서 문제가 되지는 않겠지만, 트랜잭션 유지에는 비용이 들기 때문에 필수가 아니면 제거하는게 좋다.

고려해봤을 때, 각각의 API에 대해서 하나를 호출한 후에 그 결과에 따라서 우리 데이터베이스에 상황을 업데이트한다. (클라이언트가 현재 진행도에 대해서 조회하는 API를 호출했을 때는 자체 데이터베이스만 찔러봐도 반환할 수 있도록)

진행 상황이 업데이트가 교착될 일은 딱히 없을 것 같다.

트랜잭션을 제거하려고 했는데 그렇게 하니, 업데이트가 반영이 되지 않는데 이건 아마도 코드 상의 이슈일 것 같아서 JPA를 암전히 좀더 공부해봐야겠다. (충분히 공부했다 생각했는데 아직도 섣부른거였니...!)

값을 업데이트 하는데 트랜잭션이 필수인건 아니어 보이니, 현재 흐름에서 트랜잭션은 중요한 부분이 아니라 제거하게 된다면 아예 없게 만들 수 있을 것 같다는 생각이 들며,,, 이건 성능개선이니 또 우선순위에서 밀리지 않을까 싶다,,킼키

💋 참고자료

도움이 되었다면, 공감/댓글을 달아주면 깃짱에게 큰 힘이 됩니다!🌟
비밀댓글과 메일을 통해 오는 개인적인 질문은 받지 않고 있습니다. 꼭 공개댓글로 남겨주세요!

저작자표시 비영리 변경금지 (새창열림)

'PROJECT > Sunny Braille' 카테고리의 다른 글

[Sunny Braille] 교내 세션 발표인줄 알았는데 반기문 옆자리인 건에 대하여 (GEEF 2024 초청받음) (23)	2024.03.14
[Sunny Braille] Swagger로 더러워진 내 컨트롤러 코드 인공호흡: 인터페이스로 스웨거 코드 분리하는 방법 (0)	2024.03.04
[Sunny Braille] 팀 합류와 동시에 타이거 팀이 되다..! 장고 코드를 스프링 코드로 바꿔주세요!: Mathpix API 사용해서 수학문제 사진에서 OCR 처리하기 (수식 인식하기) (2)	2024.02.14
[Sunny Braille] 시각장애인을 위한 수학교재 인공지능 점자변환 서비스, 해바라기 팀에 합류하다 (3)	2024.02.07

내 블로그 - 관리자 홈 전환	`Q` `Q`
새 글 쓰기	`W` `W`

글 수정 (권한 있는 경우)	`E` `E`
댓글 영역으로 이동	`C` `C`

이 페이지의 URL 복사	`S` `S`
맨 위로 이동	`T` `T`
티스토리 홈 이동	`H` `H`
단축키 안내	`Shift` + `/` `⇧` + `/`

[Sunny Braille] 외부 API 호출, 비동기적으로 처리하기! (ft. Spring Event): 트랜잭션은 어떻게 해야할까,,?

💋 인트로