คุณจัดการ background job และ queue อย่างไร?

Question

Accepted Answer

สำหรับ **background job** (งานที่ไม่ควรบล็อก HTTP response) NestJS ผสานรวมกับ **BullMQ** (queue ที่ใช้ Redis เป็นฐานหลัง) ผ่าน `@nestjs/bullmq` คุณเพิ่ม job เข้า queue และประมวลผลแบบ asynchronous ใน worker แยกต่างหาก ทำให้ request เร็วและจัดการงานหนักหรืองานที่เลื่อนเวลาได้อย่างน่าเชื่อถือ

## ปัญหาที่ queue ช่วยแก้

```text
Some work is too slow or shouldn't block the request:
  ✗ sending emails, processing images/video, generating reports, calling slow APIs
  → doing it inline makes the user wait and risks timeouts/failures
  ✓ QUEUE the work → respond immediately → a worker processes it in the background
```

## การตั้งค่า queue

```ts
@Module({
  imports: [
    BullModule.forRoot({ connection: { host: "localhost", port: 6379 } }),  // Redis
    BullModule.registerQueue({ name: "email" }),                            // a named queue
  ],
})
export class AppModule {}
```

## การเพิ่ม job เข้า queue (ฝั่ง producer)

```ts
@Injectable()
export class NotificationService {
  constructor(@InjectQueue("email") private emailQueue: Queue) {}

async register(user: User) {
    await this.saveUser(user);
    // queue the email INSTEAD of sending it inline → respond to the user immediately
    await this.emailQueue.add("welcome", { userId: user.id }, {
      attempts: 3,                          // retry up to 3 times on failure
      backoff: { type: "exponential", delay: 5000 },
      delay: 60000,                          // optionally delay the job
    });
  }
}
```

producer เพิ่ม job (พร้อมตัวเลือกอย่าง retry, backoff, delay) และคืนค่ากลับทันที ผู้ใช้ไม่ต้องรอให้อีเมลถูกส่ง

## การประมวลผล job (ฝั่ง worker/consumer)

```ts
@Processor("email")
export class EmailProcessor extends WorkerHost {
  async process(job: Job) {
    switch (job.name) {
      case "welcome":
        await this.sendWelcomeEmail(job.data.userId);   // the actual work, in the background
        break;
    }
  }
}
```

worker `@Processor` จะดึง job จาก queue มาประมวลผลและทำงานจริงแบบ asynchronous แยกออกจากวงจร request/response (และยังสามารถรันใน process แยกได้ด้วย)

## สิ่งที่ queue มอบให้

```text
✓ Async processing — offload slow work, respond to users instantly
✓ Retries & backoff — failed jobs retry automatically (reliability)
✓ Delayed/scheduled jobs — run work later or on a schedule (repeatable jobs)
✓ Rate limiting & concurrency control — bound how fast/many jobs run
✓ Persistence (via Redis) — jobs survive restarts; not lost if the app crashes
✓ Decoupling — producers and workers scale independently
```

## ทำไมจึงสำคัญ

การประมวลผล background job ด้วย queue จำเป็นต่อการสร้าง back-end ที่แข็งแกร่ง ตอบสนองได้ดี และ scale ได้ และการเข้าใจการผสานรวม BullMQ ของ NestJS เป็นความรู้ระดับ senior ที่สำคัญ

คุณค่าหลักคือการ offload งานที่ไม่ควรบล็อก HTTP response เช่น การส่งอีเมล, การประมวลผลภาพ/วิดีโอ, การสร้างรายงาน, การ sync ข้อมูล หรือการเรียก external service ที่ช้า

การทำงานเหล่านี้แบบ inline ทำให้ผู้ใช้ต้องรอ เสี่ยงต่อ request timeout และสูญเสียงานหากล้มเหลว ในขณะที่การ **queue** มันให้คุณตอบกลับได้ทันที ขณะที่ **worker** เบื้องหลังประมวลผลมันอย่างน่าเชื่อถือ

นอกเหนือจากการ offload แบบ async, queue ยังมอบฟีเจอร์ระดับ production ที่สำคัญ ได้แก่ **การ retry อัตโนมัติพร้อม backoff** (ความยืดหยุ่นต่อความล้มเหลวชั่วคราว), **job ที่เลื่อนเวลาและตั้งเวลา**, **การควบคุม concurrency/rate-limiting** และ **persistence** (job ที่ใช้ Redis เป็นฐานหลังอยู่รอดจาก crash/restart ทำให้งานไม่สูญหาย)

มันยัง **decouple** producer ออกจาก consumer ทำให้ scale ได้อย่างอิสระ

การรู้วิธีตั้งค่า queue, เพิ่ม job พร้อมตัวเลือกที่เหมาะสม (retry, delay) และประมวลผลมันใน worker เป็นสิ่งที่มีค่าสำหรับการออกแบบแอปพลิเคชันจริงที่จัดการงานหนักหรืองานที่เลื่อนเวลาได้อย่างเรียบร้อย

นี่เป็นแพทเทิร์นที่พบบ่อยและสำคัญในระบบ NestJS ระดับ production และสะท้อนถึงความเข้าใจที่เป็นผู้ใหญ่ในการสร้าง back-end ที่ตอบสนองและน่าเชื่อถือซึ่งเกินกว่าการจัดการ request-response แบบง่ายๆ