Notificacions sense esforç a NestJS mitjançant esdeveniments del servidor per a operacions massives

Enviament de notificacions a granel amb esdeveniments del servidor (SSE) a NestJS

Aquesta solució demostra un enfocament de backend per utilitzar NestJS amb Prisma i esdeveniments del costat del servidor (SSE) per a operacions massives. Inclou una arquitectura basada en esdeveniments i un sistema de cues.

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

Actualitzacions en temps real per a insercions massives amb NestJS i React

Aquest exemple d'interfície utilitza React per escoltar esdeveniments del servidor i actualitzar la interfície d'usuari de manera dinàmica a mesura que es reben dades. Assegura que els empleats rebin notificacions en temps real després de les insercions massives.

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

Notificacions de proves d'unitat per a operacions d'inserció massiva

Aquesta prova Jest garanteix que el mecanisme d'emissió i notificació d'esdeveniments funcioni correctament al backend per als esdeveniments del servidor a 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);
  });
});

Preguntes freqüents sobre SSE a NestJS

1. Quins són els avantatges d'utilitzar Esdeveniments del costat del servidor sobre WebSockets?
2. SSE és més senzill d'implementar i utilitza HTTP, per la qual cosa és amigable amb el tallafoc. A diferència de WebSockets, només requereix una única connexió unidireccional, que és eficient per a actualitzacions en temps real.
3. Puc utilitzar @Sse amb diversos punts finals en un controlador?
4. Sí, podeu definir múltiples @Sse punts finals del mateix controlador per servir diferents fluxos de dades als clients en funció de les necessitats específiques.
5. Com puc gestionar els errors durant el processament de la cua?
6. Amb BullMQ, podeu definir opcions de reintentar i utilitzar escoltes d'esdeveniments com @OnWorkerEvent('failed') per registrar errors i tornar a processar treballs si cal.
7. El de Prisma createMany mètode admet retrocessos de transaccions?
8. Sí, la de Prisma createMany es pot embolicar en una transacció. Si alguna operació de la transacció falla, totes les operacions es revertiran per a la coherència.
9. Què passa si el client es desconnecta durant un flux SSE?
10. El servidor deixa d'enviar actualitzacions un cop detecta la desconnexió. Podeu implementar la lògica de reconnexió al client mitjançant el EventSource API.
11. Es pot utilitzar SSE per a la comunicació bidireccional?
12. No, SSE és unidireccional (de servidor a client). Per a la comunicació bidireccional, utilitzeu WebSockets o fluxos HTTP2.
13. Com puc protegir els punts finals SSE a NestJS?
14. Utilitzeu guàrdies o intermedis, com ara @UseGuards, per fer complir l'autenticació i l'autorització per als vostres punts finals SSE.
15. Pot SSE treballar amb clients que no són de navegador?
16. Sí, qualsevol client que admeti HTTP i streaming d'esdeveniments (p. ex., Node.js, cURL) pot consumir fluxos SSE.
17. Quin és el nombre màxim de clients que es poden connectar a un punt final SSE?
18. Això depèn de la configuració del servidor i dels límits de recursos. L'equilibri de càrrega i l'agrupació poden ajudar a escalar per donar suport a més clients.
19. És possible enviar dades JSON a través de SSE?
20. Sí, podeu serialitzar objectes a cadenes JSON i enviar-los mitjançant new MessageEvent a NestJS.

Notificacions efectives en temps real a NestJS

Implementació de sistemes en temps real utilitzant SSE a NestJS simplifica la comunicació entre el servidor i els clients. Aquest mètode redueix la càrrega del servidor en comparació amb l'enquesta constant i permet una orientació precisa de les notificacions. Per exemple, una eina de recursos humans pot notificar a 200 empleats de Vendes sobre nous vals sense interrompre els altres. 🎯

Amb eines com BullMQ i Prisma, aquesta configuració garanteix un processament asíncron de tasques i operacions eficients de la base de dades. La flexibilitat de l'arquitectura basada en esdeveniments la converteix en una solució escalable per a diversos requisits en temps real, millorant la implicació dels usuaris i la fiabilitat del sistema.