Asynchronous Request-Reply Pattern: Giải pháp cho những tác vụ nặng

+--------+         +-------------+         +----------------+         +---------+
| Client |         | API Server  |         | Message Queue  |         | Worker  |
+--------+         +-------------+         +----------------+         +---------+
    |                     |                         |                      |
    | 1. POST /export     |                         |                      |
    |-------------------->|                         |                      |
    |                     | 2. Create Job           |                      |
    |                     | & Push to Queue         |                      |
    |                     |------------------------>|                      |
    |                     |                         | 3. Worker polls      |
    |                     |                         |    for new jobs      |
    |                     |                         |<---------------------|
    | 4. 202 Accepted     |                         |                      |
    |    { statusUrl }    |                         |                      |
    |<--------------------|                         |                      |
    |                     |                         | 5. Process Job       |
    |                     |                         |    (long task)       |
    |                     |                         |   Update DB status   |
    |                     |                         |--------------------->|
    | 5. GET /status/{id} |                         |                      |
    |-------------------->|                         |                      |
    | 6. "PENDING"        |                         |                      |
    |<--------------------|                         |                      |
    |       ...           |                         |                      |
    | (poll again later)  |                         |                      |
    |       ...           |                         |                      |
    | 7. GET /status/{id} |                         |                      |
    |-------------------->|                         |                      |
    | 8. "COMPLETED"      |                         |                      |
    |    { resultUrl }    |                         |                      |
    |<--------------------|                         |                      |
    |                     |                         |                      |

npm init -y
npm install express typescript ts-node @types/express @types/node uuid @types/uuid
npx tsc --init

/src
  ├── server.ts
  ├── types.ts

export type JobStatus = 'PENDING' | 'PROCESSING' | 'COMPLETED' | 'FAILED';

export interface Job {
  id: string;
  status: JobStatus;
  createdAt: Date;
  updatedAt: Date;
  resultUrl?: string;
  error?: string;
}

import express, { Request, Response } from 'express';
import { v4 as uuidv4 } from 'uuid';
import { Job, JobStatus } from './types';

const app = express();
const PORT = 3000;

// --- Mô phỏng Database và Message Queue ---
// Trong thực tế, bạn sẽ dùng Redis/PostgreSQL cho jobStore
// và RabbitMQ/SQS cho messageQueue.
const jobStore = new Map<string, Job>();

// Hàm mô phỏng worker xử lý job trong background
const processExportJob = async (jobId: string) => {
  console.log(`[Worker] Starting job: ${jobId}`);
  
  // 1. Cập nhật trạng thái thành PROCESSING
  const initialJob = jobStore.get(jobId);
  if (!initialJob) return;

  const processingJob: Job = { ...initialJob, status: 'PROCESSING', updatedAt: new Date() };
  jobStore.set(jobId, processingJob);

  // 2. Mô phỏng tác vụ nặng mất 15 giây
  await new Promise(resolve => setTimeout(resolve, 15000));

  // 3. Hoàn thành và cập nhật kết quả
  // Trong thực tế, đây sẽ là link từ S3 hoặc GCS
  const resultUrl = `https://storage.example.com/exports/${jobId}.zip`;
  const completedJob: Job = {
    ...jobStore.get(jobId)!,
    status: 'COMPLETED',
    updatedAt: new Date(),
    resultUrl: resultUrl,
  };
  jobStore.set(jobId, completedJob);
  console.log(`[Worker] Finished job: ${jobId}`);
};

// --- API Endpoints ---

// POST /export -> Bắt đầu một job mới
app.post('/export', (req: Request, res: Response) => {
  const jobId = uuidv4();
  const newJob: Job = {
    id: jobId,
    status: 'PENDING',
    createdAt: new Date(),
    updatedAt: new Date(),
  };

  // Lưu job vào store (tương đương DB)
  jobStore.set(jobId, newJob);

  // Gửi job vào queue (ở đây ta gọi thẳng worker để mô phỏng)
  processExportJob(jobId);

  // Trả về 202 Accepted ngay lập tức
  res.status(202).json({
    message: 'Export request accepted. Check the status URL for progress.',
    jobId: jobId,
    statusUrl: `http://localhost:${PORT}/export/status/${jobId}`
  });
});

// GET /export/status/:jobId -> Kiểm tra trạng thái của job
app.get('/export/status/:jobId', (req: Request, res: Response) => {
  const { jobId } = req.params;
  const job = jobStore.get(jobId);

  if (!job) {
    return res.status(404).json({ error: 'Job not found' });
  }

  // Nếu job đã xong, trả về 200 OK với kết quả
  if (job.status === 'COMPLETED') {
    return res.status(200).json(job);
  }
  
  // Nếu job thất bại, trả về 200 OK với lỗi
  if (job.status === 'FAILED') {
    return res.status(200).json(job);
  }

  // Nếu job đang chạy, trả về 200 OK với trạng thái hiện tại
  // Client sẽ dựa vào đây để quyết định có poll tiếp hay không
  return res.status(200).json({
      status: job.status,
      message: 'Job is still in progress. Please check back later.'
  });
});

app.listen(PORT, () => {
  console.log(`Server is running at http://localhost:${PORT}`);
});

curl -X POST http://localhost:3000/export -v

{
  "message": "Export request accepted. Check the status URL for progress.",
  "jobId": "...",
  "statusUrl": "http://localhost:3000/export/status/..."
}

curl http://localhost:3000/export/status/{your_job_id}