주문 접수 후 5분이 지났을 때 접수가 되지 않으면 자동으로 취소하는 기능을 구현하고 싶습니다.

Question

제목 그대로 특정 주문이 생성되고 5분 동안 접수가 되지 않으면 자동으로 주문의 상태를 &#34;취소됨&#34;으로 만들려고 합니다. okky에서 한 선생님이 다음과 같은 내용으로 도움을 주셨는데요, 주문을 받으면 kafka 주문 생성 토픽에 produce 하고 실제 주문을 처리하는 서비스가 주문 처리 후 주문 완료 토픽에 produce 합니다api 서버는 주문 완료 토픽을 consume해서 그 시간이 주문 시간의 5분 이내면 완료 처리해서 db 저장하고, 5분이 넘으면 주문 상태를 취소로 저장합니다근데 이 방법으로는 주문 처리 후 완료 토픽에 produce되지 않으면 쭉 주문접수 상태로 남아있을거라는 생각이 들었습니다. 어떻게 해결할 수 있을까요 ㅠ

Constant · Accepted Answer

지금 이건 메시지큐도 의미가 없고 스프링에 존재하는 스케줄링 시스템도 의미가 없습니다. 스케줄러는 항상 일정시간마다 돌아가니까 주문 발생 후 정확히 5분뒤에 캐치하는 기능을 구현할 수 없습니다. ScheduledExecutorService를 사용하세요.

장독깨기 · Answer

주문 접수 처리를 누가 하나요?주문 접수 처리 여부를 어케 판단하나요?

김을동 · Answer

서비스규모가 작고 별도 이벤트를 받아야 하는게 아니라면 굳이 카프카도 필요 없이그냥 최초 주문 시간 기록 해두고 조회 시 ‘5분 지난 접수되지 않은 건’은 취소로 노출하면 됩니다

집킨 · Answer

주문이 취소된 이벤트는 토픽에서 삭제돼야 하는데 카프카에선 그 방법을 지원하지 않습니다카프카로만 해결 불가능한 요구사항이죠주문 요청 API 에서 받은 주문 요청을 토픽에 Send -> 커넥터를 이용해서 토픽에 들어온 주문 데이터를 요청 상태로 디비에 insert주문 접수 API 에서 처리 후 DB의 상태를 접수로 변경별도 배치를 통해 1분 간격으로 디비를 확인해서 주문 요청 시간부터 5분이 넘은 데이터는 취소 상태로 변경 (앱푸시 이벤트 등이 필요할 경우 주문 취소 토픽으로 send)이런 구조가 어떠시련지

주문 접수 후 5분이 지났을 때 접수가 되지 않으면 자동으로 취소하는 기능을 구현하고 싶습니다.

4개의 답변

기술 목록