كيف يدعم NestJS الخدمات الصغيرة (Microservices)؟

Question

Accepted Answer

NestJS لديه **دعم مدمج للخدمات الصغيرة** — يمكنه العمل كخدمة صغيرة تتواصل عبر **نقل بيانات** متنوع (TCP, Redis, NATS, RabbitMQ, Kafka, gRPC) بدلاً من HTTP، باستخدام نموذج برمجة موحد قائم على الرسائل. نفس بنية NestJS (الوحدات والخدمات والحقن التبعي) تنطبق؛ فقط طريقة النقل وأنماط الرسائل تتغير.

## إنشاء خدمة صغيرة

```ts
// a microservice listens on a transport instead of HTTP
const app = await NestFactory.createMicroservice(AppModule, {
  transport: Transport.TCP,             // or REDIS, NATS, RMQ, KAFKA, GRPC
  options: { host: "0.0.0.0", port: 3001 },
});
await app.listen();
```

## أنماط الرسائل مقابل أنماط الأحداث

```ts
@Controller()
export class MathController {
  // REQUEST-RESPONSE: respond to a message and RETURN a result (RPC-style)
  @MessagePattern({ cmd: "sum" })
  sum(data: number[]): number {
    return data.reduce((a, b) => a + b, 0);   // the caller awaits this result
  }

// EVENT-BASED: react to an event, NO response expected (fire-and-forget)
  @EventPattern("order_created")
  handleOrderCreated(data: OrderDto) {
    this.processOrder(data);                   // just react; nothing returned
  }
}
```

أسلوبا اتصال: **`@MessagePattern`** للطلب-الرد (المتصل ينتظر النتيجة، مثل RPC) و**`@EventPattern`** للأحداث (إطلاق وتناسي، غير مترابط — الناشر لا ينتظر).

## استدعاء خدمة صغيرة أخرى (العميل)

```ts
@Injectable()
export class AppService {
  constructor(@Inject("MATH_SERVICE") private client: ClientProxy) {}

async getSum() {
    // send() → request-response (returns an Observable of the result)
    return this.client.send({ cmd: "sum" }, [1, 2, 3]);
    // emit() → fire an event (no response)
    this.client.emit("order_created", orderData);
  }
}
```

`ClientProxy` (مكون عبر `ClientsModule`) يرسل الرسائل/الأحداث إلى خدمات أخرى — `send()` للطلب-الرد، `emit()` للأحداث.

## التطبيقات الهجينة

```ts
// an app can serve HTTP AND connect microservice transports simultaneously
const app = await NestFactory.create(AppModule);
app.connectMicroservice({ transport: Transport.RMQ, options: {...} });
await app.startAllMicroservices();
await app.listen(3000);   // HTTP too
```

## اختيار النقل مهم

```text
TCP   → simple direct service-to-service
Redis/NATS → lightweight pub/sub messaging
RabbitMQ/Kafka → robust message queues/streams (durability, retries, decoupling)
gRPC  → high-performance, strongly-typed RPC (protobuf)
→ Async message brokers (RMQ/Kafka) give decoupling & resilience; gRPC gives speed+typing.
```

## لماذا يهمك هذا

دعم NestJS المدمج للخدمات الصغيرة مهم لأنه يسمح لك ببناء الأنظمة الموزعة باستخدام *نفس* بنية NestJS المألوفة (الوحدات والموفرون والحقن التبعي والمزخرفات) مع استبدال HTTP برسائل نقل موجهة — ميزة إنتاجية واتساق كبيرة.

فهمها مهم لتصميم الأنظمة القابلة للتوسع: **تمييز نمط الرسائل (الطلب-الرد) مقابل نمط الأحداث (إطلاق وتناسي)** يرسم خريطة مباشرة للاختيار الأساسي في اتصالات الخدمات الصغيرة — استدعاءات متزامنة بأسلوب RPC مقابل أحداث غير متزامنة وغير مترابطة (الأخيرة، عبر وسطاء الرسائل، توفر المرونة والارتباط الضعيف الذي يجعل الخدمات الصغيرة قوية).

معرفة كيفية إنشاء خدمات صغيرة وتحديد معالجات الرسائل/الأحداث واستدعاء خدمات أخرى عبر `ClientProxy` وبناء تطبيقات هجينة HTTP + خدمات صغيرة واختيار النقل (نشر/اشتراك خفيف الوزن مقابل قوائم انتظار دائمة مثل Kafka/RabbitMQ مقابل gRPC عالي الأداء) هي معرفة قيمة على مستوى كبير لتصميم الواجهات الخلفية الموزعة.

على الرغم من أن الخدمات الصغيرة تضيف تعقيداً حقيقياً (وليست دائماً الخيار الصحيح على أحادية)، يجعل NestJS التنفيذ نظيفاً ومتسقاً، مما يجعل هذا موضوعاً معمارياً مهماً لبناء أنظمة NestJS موزعة وواسعة النطاق.