2025년 3월 5일

김동환·2025년 3월 6일

TIL bullQueue mafia

Today I Learned (TIL) - Bull Queue 적용하여 이메일 인증 비동기 처리

1. Bull Queue란

Bull Queue는 Redis 기반의 메시지 큐 시스템으로, 백그라운드에서 작업을 처리할 수 있도록 도와준다.
NestJS에서는 @nestjs/bull을 사용하여 쉽게 통합할 수 있다.
이메일 전송과 같이 시간이 오래 걸리는 작업을 비동기적으로 처리하여 서버의 응답 속도를 향상시킬 수 있다.

2. Bull Queue를 사용해야 하는 이유

이메일을 동기적으로 처리하면, SMTP 서버 응답을 기다리느라 응답 속도가 느려질 수 있다.
여러 사용자가 동시에 이메일 인증 요청을 하면, 서버 부하가 증가할 수 있다.
Bull Queue를 사용하면 이메일을 큐에 추가한 후 바로 응답을 반환하고, 백그라운드에서 작업을 처리할 수 있다.

3. Bull Queue 적용 과정

1) Bull Queue 관련 패키지 설치

npm install @nestjs/bull bull

@nestjs/bull: NestJS에서 Bull Queue를 쉽게 사용할 수 있도록 해주는 모듈
bull: Bull Queue의 핵심 라이브러리

2) Redis 설치 및 실행

로컬에서 실행할 경우
```
redis-server
```

Docker를 사용할 경우

docker run --name redis -p 6379:6379 -d redis

3) Bull Queue 등록 (AuthModule 및 UsersModule 수정)

auth.module.ts 수정

import { BullModule } from '@nestjs/bull';

@Module({
  imports: [
    BullModule.registerQueue({
      name: 'email-queue',
      redis: {
        host: 'localhost',
        port: 6379,
      },
    }),
  ],
})

users.module.ts 수정

import { BullModule } from '@nestjs/bull';

@Module({
  imports: [
    BullModule.registerQueue({
      name: 'email-queue',
    }),
  ],
  exports: [BullModule],
})

UsersModule에서 BullModule을 등록하고 exports 설정을 추가하여 다른 모듈에서도 사용할 수 있도록 한다.

4) AuthService에서 이메일 전송을 Bull Queue로 변경

sendVerificationEmail에서 직접 이메일을 전송하는 것이 아니라, Bull Queue에 추가하는 방식으로 변경

import { InjectQueue } from '@nestjs/bull';
import { Queue } from 'bull';

@Injectable()
export class AuthService {
  constructor(@InjectQueue('email-queue') private emailQueue: Queue) {}

  async sendVerificationEmail(email: string, verifyCode: string) {
    await this.emailQueue.add('sendEmail', {
      email,
      verifyCode,
    });
  }
}

5) 이메일을 처리하는 Processor 추가 (email.processor.ts)

import { Process, Processor } from '@nestjs/bull';
import { Job } from 'bull';
import nodemailer from 'nodemailer';

@Processor('email-queue')
export class EmailProcessor {
  @Process('sendEmail')
  async handleSendEmail(job: Job) {
    const { email, verifyCode } = job.data;

    const transporter = nodemailer.createTransport({
      service: 'gmail',
      auth: {
        user: process.env.EMAIL_USER,
        pass: process.env.EMAIL_PASS,
      },
    });

    const mailOptions = {
      from: process.env.EMAIL_USER,
      to: email,
      subject: '이메일 인증 코드',
      text: `인증 코드: ${verifyCode}`,
    };

    try {
      await transporter.sendMail(mailOptions);
    } catch (error) {
      console.error('이메일 발송 실패:', error);
    }
  }
}