EventEmitter 리스너를 async로 만들었더니 에러가 조용히 사라지고 서버가 죽기도 합니다

Question

주문 생성되면 후처리(알림 발송, 통계 갱신 등)를 이벤트로 느슨하게 붙이려고 EventEmitter를 쓰고 있어요. 리스너 안에서 await 할 게 있어서 async 함수로 등록했습니다.

orderEvents.on('created', async (order) => {
  await sendNotification(order)  // 여기서 reject되면?
  await updateStats(order)
})
orderEvents.emit('created', order)

문제는 리스너 안에서 에러가 나면 어떤 땐 그냥 조용히 묻혀서 알림이 안 갔는데도 아무 로그가 없고, 어떤 땐 unhandledRejection으로 프로세스가 죽습니다. emit 하는 쪽에서 try/catch로 감싸도 안 잡히고요. 이벤트 기반으로 짜면 안 되는 건가요?

김영삼 · Accepted Answer

이벤트 기반이 문제가 아니라, EventEmitter가 async 리스너를 위해 만들어진 물건이 아니라서 생기는 일이에요. emit()은 리스너들을 동기적으로 순서대로 호출하고 각 리스너가 리턴하는 값을 그냥 버립니다. async 함수는 Promise를 리턴하는데 emit이 그걸 안 받아주니까, 리스너 안에서 reject가 나도 emit 호출부로 전달될 방법이 없어요. 그래서 emit을 try/catch로 감싸도 안 잡히는 겁니다. 그 reject는 아무도 안 받은 채로 붕 떠서 unhandledRejection이 되고, Node 버전/타이밍에 따라 조용히 묻히거나 프로세스를 죽이는 거고요. 원칙은 하나예요. async 리스너는 자기 안에서 에러를 끝까지 스스로 처리해야 합니다. 밖으로 새어나가게 두면 안 돼요. orderEvents.on('created', async (order) => { try { await sendNotification(order) await updateSta

emitter_kyungmin · Answer

아 emit이 Promise를 그냥 버린다는 걸 이제 이해했네요. 일단 try/catch로 다 감싸서 죽는 건 막았고, 알림이랑 정산 통계는 말씀대로 큐로 옮기는 작업 잡았습니다. 명쾌한 설명 감사합니다 🙏

댓글 0