Message Queue
-
mongo-message-queue 구현하기nestjs 2022. 4. 23. 09:52
계기 서버를 개발하다 보니 특정 주기로 지속적으로 돌면서 요청을 처리하는 Cron Server가 필요했다. 이 요청은 동일한 node에서 오는 것이 아니기 때문에 특정 저장 공간을 공유해서 요청을 처리해야 했는데 이를 기존에는 mongodb-queue - npm (npmjs.com) 을 사용해서 mongodb의 collection하나를 queue로 사용했다. 하지만 mongodb version을 올림에 따라 더 이상 이 모듈을 사용할 수 없게 되어 개발하게 되었다. 개발 1. Schema 정의 const QueuePayload = mongoose.Schema( { type: { type: String, required: true }, //message type data: { type: Object, re..