DeleteEventListener 내부 로직 비동기 처리 #748
Conversation
📝 Jacoco Test Coverage
|
| asyncDeleteProcessor.deleteDayLogs(dayLogIds); | ||
| asyncDeleteProcessor.deleteItems(itemIds); |
There was a problem hiding this comment.
Item에 DayLogId ForeignKey 걸려있는데 데이로그 먼저 삭제해도 되나요?! 헷갈려서 물어봄
There was a problem hiding this comment.
이거 개발자가 신경 잘 써야겠네요 ㅋㅋㅜ 잘하면 죽은 데이로그에 살아있는 아이템 만들 수 있겠네
There was a problem hiding this comment.
와우 soft Delete를 생각안했네 엄청나군요..
|
|
||
| @Async | ||
| @Transactional(propagation = REQUIRES_NEW) | ||
| @TransactionalEventListener(fallbackExecution = true) | ||
| @TransactionalEventListener |
There was a problem hiding this comment.
fallbackExecution=true 왜 지우셨나용?
There was a problem hiding this comment.
저번에 실험하다가 붙여놓고 까먹었습니다..
대충 요약하면
이런데 그냥 디폴트 해놔도 될듯...!
There was a problem hiding this comment.
현재 메서드에 @Transactional이 붙어있으니 무조건 트랜잭션이 있는 상태에서 이벤트를 처리하므로 상관이 없다는 뜻 맞죠? 👍
|
|
||
| @Component | ||
| @RequiredArgsConstructor | ||
| public class AsyncDeleteProcessor { |
There was a problem hiding this comment.
DeleteEventListener 내부에서 로직을 비동기 메서드로 나눌수도 있었을텐데, delete와 관련된 비동기 작업을 수행하는 ÀsyncDeleteProcessor를 만드신 이유가 뭔가요? 다른 곳에서도 활용될 가능성이 있다고 판단하신건가요? 궁금합니다!
삭제라는 공통점만 있는 비동기 작업들을 AsyncDeleteProcessor로 관리했을 때 단점은 없을까요? 저희는 도메인 컨텍스트를 위주로 패키지를 분리해왔는데 삭제라는 공통점으로 이 친구들을 하나의 클래스로 묶었을 때 이슈는 없을까요?
There was a problem hiding this comment.
-
어싱크 요놈은 내부 메서드에서 못붙입니다.. 그래서 이런 짓을 해버림
-
날카로운 지적입니다.
그래서 다른 방법이 각각의 서비스에다 메서드를 만든 다음 어싱크 붙여서 해당 메서드를 리스너에서 호출하는 건데,
위에 말한대로 가독성 측면에서 별로인거 같구,
서비스에 갑자기 어싱크 하나 띡 달려있는 메서드 있으면 이상한거 같기도 하고 그래서 고민입니다...
그리고 또 다른 고민은 이렇게 안하면 리스너에서 Repository랑 Service 모두 의존하고 있는 형식이라(사실 지금도 이름만 다르지 같은 상황이긴 함) 그것도 좀 걸리긴 했어요..
There was a problem hiding this comment.
굉장한 고민을 하셨군요 디노! ! ! 역시 리더 디노입니다!!! 더 좋은 구조를 고민해보겠습니다! ! !
|
|
||
| @Component | ||
| @RequiredArgsConstructor | ||
| public class AsyncDeleteProcessor { | ||
| @Transactional(propagation = Propagation.REQUIRES_NEW) | ||
| public class TransactionalDeleteProcessor { |
There was a problem hiding this comment.
특정한 로직을 transactional하게 delete해준다는 invoker느낌이 강해지는 것 같네요! 이젠 얘한테 void타입의 delete로직을 수행하는 함수형인터페이스를 넘겨줘서 실행해도 괜찮겠다는 생각이 ......... 들었습니다...
There was a problem hiding this comment.
이런 느낌일까요?
public void invoke(final Long memberId, final DeleteInvoker invoker) {
tripDeleteInvoker.delete(memberId, tripRepository);
}- 함수 호출시
transactionalDeleteProcessor
.invoke(
event.getMemberId(),
(Long memberId, TripRepository repository) -> repository.deleteByMemberId(memberId)
);There was a problem hiding this comment.
굉장합니다! invoke의 인자로 익명클래스만 받아도 될 것 같습니다! memberId라는 인자에 국한되지 않아도 될 것 같습니다. AsyncDeleteProcessor or TransactionalDeleteProcessor라는 클래스를 만들거라면 이 방식도 괜찮아보입니다. 물론 전 Delete가 집중하지 말고 각 도메인별로 이벤트리스너만들자 파이긴합니다!!!
|
|
||
| @Component | ||
| @RequiredArgsConstructor | ||
| public class AsyncDeleteProcessor { | ||
| @Transactional(propagation = Propagation.REQUIRES_NEW) | ||
| public class TransactionalDeleteProcessor { |
There was a problem hiding this comment.
이런 느낌일까요?
public void invoke(final Long memberId, final DeleteInvoker invoker) {
tripDeleteInvoker.delete(memberId, tripRepository);
}- 함수 호출시
transactionalDeleteProcessor
.invoke(
event.getMemberId(),
(Long memberId, TripRepository repository) -> repository.deleteByMemberId(memberId)
);
📄 Summary
🙋🏻 More