Könnyű értesítések a NestJS-ben szerveroldali események használatával tömeges műveletekhez

Értesítések tömeges küldése szerveroldali eseményekkel (SSE) a NestJS-ben

Ez a megoldás a NestJS Prismával és szerveroldali eseményekkel (SSE) való használatának háttérrendszerét mutatja be tömeges műveletekhez. Eseményvezérelt architektúrát és sorban állási rendszert tartalmaz.

// 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 })),
    );
  }
}

Valós idejű frissítések tömeges beszúrásokhoz a NestJS és a React használatával

Ez a frontend példa a React segítségével figyeli a szerveroldali eseményeket, és dinamikusan frissíti a felhasználói felületet az adatok fogadásakor. Biztosítja, hogy az alkalmazottak valós időben kapjanak értesítést a tömeges beszúrások után.

// 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;

Egységtesztelési értesítések tömeges beszúrási műveletekhez

Ez a Jest-teszt biztosítja, hogy az eseménykibocsátási és értesítési mechanizmus megfelelően működjön a NestJS szerveroldali események háttérrendszerében.

// 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);
  });
});

Gyakran ismételt kérdések az SSE-ről a NestJS-ben

1. Milyen előnyei vannak a szerveroldali események használatának a WebSocketekkel szemben?
2. Az SSE megvalósítása egyszerűbb, és HTTP-t használ, így tűzfalbarát. A WebSocketstől eltérően csak egyetlen egyirányú kapcsolat szükséges, ami hatékony a valós idejű frissítésekhez.
3. Használhatom @Sse több végponttal egy vezérlőben?
4. Igen, több is megadható @Sse végpontok ugyanabban a vezérlőben, hogy különböző adatfolyamokat szolgáltassanak ki az ügyfelek számára egyedi igények alapján.
5. Hogyan kezelhetem a sorfeldolgozás során fellépő hibákat?
6. A BullMQ segítségével újrapróbálkozási lehetőségeket határozhat meg, és például eseményfigyelőket használhat @OnWorkerEvent('failed') a hibák naplózására és a feladatok újrafeldolgozására, ha szükséges.
7. A Prismáé createMany módszer-támogatási tranzakció-visszaállítások?
8. Igen, a Prismáé createMany tranzakcióba burkolható. Ha a tranzakció bármely művelete meghiúsul, az összes műveletet a rendszer visszaállítja a következetesség érdekében.
9. Mi történik, ha az ügyfél megszakad az SSE adatfolyam közben?
10. A kiszolgáló leállítja a frissítések küldését, amint észleli a kapcsolat megszakadását. Az újracsatlakozási logikát a kliens segítségével valósíthatja meg EventSource API.
11. Használható az SSE kétirányú kommunikációra?
12. Nem, az SSE egyirányú (szerver-kliens). Kétirányú kommunikációhoz használjon WebSockets vagy HTTP2 adatfolyamokat.
13. Hogyan biztosíthatom az SSE-végpontokat a NestJS-ben?
14. Használjon védőeszközöket vagy köztes szoftvereket, mint pl @UseGuards, az SSE-végpontok hitelesítésének és engedélyezésének kényszerítéséhez.
15. Működhet az SSE nem böngésző kliensekkel?
16. Igen, minden olyan ügyfél, amely támogatja a HTTP-t és az események adatfolyamát (pl. Node.js, cURL), használhat SSE adatfolyamokat.
17. Maximum hány ügyfelek csatlakozhatnak egy SSE-végponthoz?
18. Ez a szerver konfigurációjától és az erőforrás-korlátoktól függ. A terheléselosztás és a klaszterezés segíthet a méretezésben, hogy több ügyfelet tudjon támogatni.
19. Lehetséges JSON-adatokat küldeni SSE-n keresztül?
20. Igen, sorba rendezheti az objektumokat JSON-karakterláncokká, és elküldheti őket new MessageEvent a NestJS-ben.

Hatékony valós idejű értesítések a NestJS-ben

Valós idejű rendszerek megvalósítása segítségével SSE a NestJS-ben leegyszerűsíti a kommunikációt a szerver és az ügyfelek között. Ez a módszer csökkenti a szerver terhelését az állandó lekérdezéshez képest, és lehetővé teszi az értesítések pontos célzását. Például egy HR-eszköz 200 alkalmazottat értesíthet az értékesítésben az új utalványokról anélkül, hogy megzavarna másokat. 🎯

Az olyan eszközökkel, mint a BullMQ és a Prisma, ez a beállítás biztosítja az aszinkron feladatfeldolgozást és a hatékony adatbázis-műveleteket. Az eseményalapú architektúra rugalmassága skálázható megoldássá teszi a különféle valós idejű követelményekhez, fokozva a felhasználók elkötelezettségét és a rendszer megbízhatóságát.