إخطارات سهلة في NestJS باستخدام الأحداث من جانب الخادم للعمليات المجمعة

إرسال الإشعارات بشكل مجمّع باستخدام الأحداث من جانب الخادم (SSE) في NestJS

يوضح هذا الحل أسلوب الواجهة الخلفية لاستخدام NestJS مع Prisma والأحداث من جانب الخادم (SSE) للعمليات المجمعة. يتضمن بنية تعتمد على الأحداث ونظام انتظار.

// Backend: AllocateVoucherController
import { Controller, Post, Body, Sse, OnEvent } from '@nestjs/common';
import { AllocateVoucherService } from './allocate-voucher.service';
import { EventEmitter2 } from '@nestjs/event-emitter';
import { Observable } from 'rxjs';
import { map, fromEvent } from 'rxjs';
@Controller('allocate-voucher')
export class AllocateVoucherController {
  constructor(
    private readonly allocateVoucherService: AllocateVoucherService,
    private readonly eventEmitter: EventEmitter2
  ) {}
  @Post()
  async create(@Body() createDto: any) {
    const result = await this.allocateVoucherService.create(createDto);
    return result;
  }
  @Sse('vouchered-employee')
  updatedEmployeeEvent(): Observable<MessageEvent> {
    return fromEvent(this.eventEmitter, 'after-added-voucher').pipe(
      map((data) => new MessageEvent('after-added-voucher', { data })),
    );
  }
}

تحديثات في الوقت الفعلي للإدراجات المجمعة باستخدام NestJS وReact

يستخدم مثال الواجهة الأمامية هذا React للاستماع إلى الأحداث من جانب الخادم وتحديث واجهة المستخدم ديناميكيًا عند تلقي البيانات. فهو يضمن إخطار الموظفين في الوقت الفعلي بعد عمليات الإدراج المجمعة.

// Frontend: React Component for SSE
import React, { useEffect, useState } from 'react';
const EmployeeUpdates = () => {
  const [employees, setEmployees] = useState([]);
  useEffect(() => {
    const eventSource = new EventSource('http://localhost:3000/allocate-voucher/vouchered-employee');
    eventSource.onmessage = (event) => {
      const newEmployee = JSON.parse(event.data);
      setEmployees((prev) => [...prev, newEmployee]);
    };
    return () => eventSource.close();
  }, []);
  return (
    <table>
      <thead>
        <tr><th>Name</th><th>Voucher</th></tr>
      </thead>
      <tbody>
        {employees.map((emp) => (
          <tr key={emp.id}><td>{emp.name}</td><td>{emp.voucher}</td></tr>
        ))}
      </tbody>
    </table>
  );
};
export default EmployeeUpdates;

إشعارات اختبار الوحدة لعمليات الإدخال المجمعة

يضمن اختبار Jest هذا أن تعمل آلية إرسال الحدث والإشعارات بشكل صحيح في الواجهة الخلفية للأحداث من جانب الخادم في NestJS.

// Jest Test: AllocateVoucherService
import { Test, TestingModule } from '@nestjs/testing';
import { AllocateVoucherService } from './allocate-voucher.service';
import { EventEmitter2 } from '@nestjs/event-emitter';
describe('AllocateVoucherService', () => {
  let service: AllocateVoucherService;
  let eventEmitter: EventEmitter2;
  beforeEach(async () => {
    const module: TestingModule = await Test.createTestingModule({
      providers: [AllocateVoucherService, EventEmitter2],
    }).compile();
    service = module.get(AllocateVoucherService);
    eventEmitter = module.get(EventEmitter2);
  });
  it('should emit after-allocate-voucher event', async () => {
    jest.spyOn(eventEmitter, 'emit');
    const result = await service.create({ someData: 'test' });
    expect(eventEmitter.emit).toHaveBeenCalledWith('after-allocate-voucher', result);
  });
});

الأسئلة المتداولة حول SSE في NestJS

1. ما فوائد استخدام الأحداث من جانب الخادم عبر WebSockets؟
2. يعد SSE أسهل في التنفيذ ويستخدم HTTP، مما يجعله صديقًا لجدار الحماية. على عكس WebSockets، فإنه لا يتطلب سوى اتصال واحد أحادي الاتجاه، وهو أمر فعال للتحديثات في الوقت الحقيقي.
3. هل يمكنني استخدام @Sse مع نقاط نهاية متعددة في وحدة تحكم؟
4. نعم، يمكنك تحديد متعددة @Sse نقاط النهاية في نفس وحدة التحكم لخدمة تدفقات البيانات المختلفة للعملاء بناءً على الاحتياجات المحددة.
5. كيف أتعامل مع الأخطاء أثناء معالجة قائمة الانتظار؟
6. باستخدام BullMQ، يمكنك تحديد خيارات إعادة المحاولة واستخدام مستمعي الأحداث مثل @OnWorkerEvent('failed') لتسجيل الأخطاء وإعادة معالجة المهام إذا لزم الأمر.
7. هل بريزما createMany طريقة دعم التراجع عن المعاملات؟
8. نعم بريزما createMany يمكن أن تكون ملفوفة في الصفقة. في حالة فشل أي عملية في المعاملة، يتم التراجع عن كافة العمليات من أجل التناسق.
9. ماذا يحدث إذا انقطع اتصال العميل أثناء تدفق SSE؟
10. يتوقف الخادم عن إرسال التحديثات بمجرد اكتشاف انقطاع الاتصال. يمكنك تنفيذ منطق إعادة الاتصال على العميل باستخدام EventSource واجهة برمجة التطبيقات.
11. هل يمكن استخدام SSE للاتصال ثنائي الاتجاه؟
12. لا، SSE أحادي الاتجاه (من الخادم إلى العميل). للاتصال ثنائي الاتجاه، استخدم تدفقات WebSockets أو HTTP2.
13. كيف أقوم بتأمين نقاط نهاية SSE في NestJS؟
14. استخدم الحراس أو البرامج الوسيطة، مثل @UseGuards، لفرض المصادقة والترخيص لنقاط نهاية SSE الخاصة بك.
15. هل يمكن لـ SSE العمل مع العملاء الذين لا يستخدمون المتصفح؟
16. نعم، يمكن لأي عميل يدعم تدفق HTTP والأحداث (على سبيل المثال، Node.js، cURL) أن يستهلك تدفقات SSE.
17. ما هو الحد الأقصى لعدد العملاء الذين يمكنهم الاتصال بنقطة نهاية SSE؟
18. يعتمد هذا على تكوين الخادم الخاص بك وحدود الموارد. يمكن أن تساعد موازنة التحميل والتجميع على التوسع لدعم المزيد من العملاء.
19. هل من الممكن إرسال بيانات JSON عبر SSE؟
20. نعم، يمكنك إجراء تسلسل للكائنات إلى سلاسل JSON وإرسالها باستخدام new MessageEvent في NestJS.

إشعارات فعالة في الوقت الحقيقي في NestJS

تنفيذ أنظمة الوقت الحقيقي باستخدام SSE في NestJS يبسط الاتصال بين الخادم والعملاء. تعمل هذه الطريقة على تقليل حمل الخادم مقارنةً بالاستقصاء المستمر وتمكين الاستهداف الدقيق للإشعارات. على سبيل المثال، يمكن لأداة الموارد البشرية إخطار 200 موظف في المبيعات بشأن القسائم الجديدة دون تعطيل الآخرين. 🎯

باستخدام أدوات مثل BullMQ وPrisma، يضمن هذا الإعداد معالجة غير متزامنة للمهام وعمليات قاعدة بيانات فعالة. إن مرونة البنية القائمة على الأحداث تجعلها حلاً قابلاً للتطوير لمختلف متطلبات الوقت الفعلي، مما يعزز مشاركة المستخدم وموثوقية النظام.