Notificări fără efort în NestJS folosind evenimente la nivelul serverului pentru operațiuni în bloc

Trimiterea notificărilor în bloc cu evenimente server-side (SSE) în NestJS

Această soluție demonstrează o abordare backend pentru utilizarea NestJS cu Prisma și Server-Side Events (SSE) pentru operațiuni în bloc. Include o arhitectură bazată pe evenimente și un sistem de așteptare.

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

Actualizări în timp real pentru inserții în vrac folosind NestJS și React

Acest exemplu de interfață folosește React pentru a asculta evenimentele de pe server și pentru a actualiza dinamic interfața de utilizare pe măsură ce se primesc datele. Se asigură că angajații sunt notificați în timp real după inserările în bloc.

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

Notificări de testare unitară pentru operațiuni de inserare în bloc

Acest test Jest asigură că mecanismul de emitere și notificare a evenimentelor funcționează corect în backend-ul pentru evenimentele de pe server în 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);
  });
});

Întrebări frecvente despre SSE în NestJS

1. Care sunt beneficiile utilizării Server-Side Events peste WebSockets?
2. SSE este mai simplu de implementat și utilizează HTTP, ceea ce îl face prietenos cu firewall-ul. Spre deosebire de WebSockets, necesită doar o singură conexiune unidirecțională, care este eficientă pentru actualizări în timp real.
3. Pot folosi @Sse cu mai multe puncte finale într-un controler?
4. Da, puteți defini mai multe @Sse puncte finale din același controler pentru a furniza fluxuri de date diferite clienților în funcție de nevoi specifice.
5. Cum gestionez erorile în timpul procesării cozii?
6. Cu BullMQ, puteți defini opțiunile de reîncercare și puteți utiliza ascultători de evenimente precum @OnWorkerEvent('failed') pentru a înregistra erorile și a reprocesa joburile dacă este necesar.
7. Are Prisma's createMany metoda suportă derularea tranzacțiilor?
8. Da, de la Prisma createMany poate fi împachetat într-o tranzacție. Dacă orice operațiune din tranzacție eșuează, toate operațiunile sunt anulate pentru consecvență.
9. Ce se întâmplă dacă clientul se deconectează în timpul unui flux SSE?
10. Serverul nu mai trimite actualizări odată ce detectează deconectarea. Puteți implementa logica de reconectare pe client folosind EventSource API.
11. Poate fi folosit SSE pentru comunicarea bidirecțională?
12. Nu, SSE este unidirecțional (de la server la client). Pentru comunicarea bidirecțională, utilizați fluxuri WebSockets sau HTTP2.
13. Cum securizez punctele finale SSE în NestJS?
14. Folosiți apărătoare sau middleware, cum ar fi @UseGuards, pentru a impune autentificarea și autorizarea pentru punctele finale SSE.
15. Poate SSE să lucreze cu clienți non-browser?
16. Da, orice client care acceptă HTTP și streaming de evenimente (de exemplu, Node.js, cURL) poate consuma fluxuri SSE.
17. Care este numărul maxim de clienți care se pot conecta la un punct final SSE?
18. Acest lucru depinde de configurația serverului dvs. și de limitele de resurse. Echilibrarea încărcăturii și gruparea pot ajuta la scalarea pentru a sprijini mai mulți clienți.
19. Este posibil să trimiteți date JSON prin SSE?
20. Da, puteți serializa obiecte în șiruri JSON și le puteți trimite folosind new MessageEvent în NestJS.

Notificări eficiente în timp real în NestJS

Implementarea sistemelor în timp real folosind SSE în NestJS simplifică comunicarea dintre server și clienți. Această metodă reduce încărcarea serverului în comparație cu sondarea constantă și permite direcționarea precisă a notificărilor. De exemplu, un instrument de resurse umane poate notifica 200 de angajați din vânzări despre noi vouchere fără a-i perturba pe alții. 🎯

Cu instrumente precum BullMQ și Prisma, această configurare asigură procesarea sarcinilor asincrone și operațiuni eficiente ale bazei de date. Flexibilitatea arhitecturii bazate pe evenimente o face o soluție scalabilă pentru diferite cerințe în timp real, sporind implicarea utilizatorilor și fiabilitatea sistemului.