Uanstrengt varsling i NestJS ved bruk av hendelser på serversiden for bulkoperasjoner

Sende varsler i bulk med serversidehendelser (SSE) i NestJS

Denne løsningen demonstrerer en backend-tilnærming til bruk av NestJS med Prisma og Server-Side Events (SSE) for bulkoperasjoner. Det inkluderer en hendelsesdrevet arkitektur og køsystem.

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

Sanntidsoppdateringer for masseinnlegg ved bruk av NestJS og React

Dette frontend-eksemplet bruker React til å lytte til serversidehendelser og oppdatere brukergrensesnittet dynamisk etter hvert som data mottas. Det sikrer at ansatte blir varslet i sanntid etter masseinnsettinger.

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

Varsler om enhetstesting for bulk-innsettingsoperasjoner

Denne Jest-testen sikrer at hendelsesutslipps- og varslingsmekanismen fungerer riktig i backend for Server-Side Events i 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);
  });
});

Ofte stilte spørsmål om SSE i NestJS

1. Hva er fordelene med å bruke serversidehendelser over WebSockets?
2. SSE er enklere å implementere og bruker HTTP, noe som gjør den brannmurvennlig. I motsetning til WebSockets, krever det bare en enkelt enveisforbindelse, noe som er effektivt for sanntidsoppdateringer.
3. Kan jeg bruke @Sse med flere endepunkter i en kontroller?
4. Ja, du kan definere flere @Sse endepunkter i samme kontroller for å betjene ulike datastrømmer til klienter basert på spesifikke behov.
5. Hvordan håndterer jeg feil under købehandling?
6. Med BullMQ kan du definere alternativer for gjenforsøk og bruke hendelseslyttere som @OnWorkerEvent('failed') å logge feil og behandle jobber på nytt om nødvendig.
7. Gjør Prisma sin createMany metode støtter tilbakeføring av transaksjoner?
8. Ja, hos Prisma createMany kan pakkes inn i en transaksjon. Hvis en operasjon i transaksjonen mislykkes, rulles alle operasjoner tilbake for konsistens.
9. Hva skjer hvis klienten kobler fra under en SSE-strøm?
10. Serveren slutter å sende oppdateringer når den oppdager frakoblingen. Du kan implementere reconnect logic på klienten ved å bruke EventSource API.
11. Kan SSE brukes til toveiskommunikasjon?
12. Nei, SSE er enveis (server-til-klient). For toveis kommunikasjon, bruk WebSockets eller HTTP2-strømmer.
13. Hvordan sikrer jeg SSE-endepunkter i NestJS?
14. Bruk vakter eller mellomvare, som @UseGuards, for å håndheve autentisering og autorisasjon for SSE-endepunktene dine.
15. Kan SSE fungere med klienter som ikke er nettlesere?
16. Ja, enhver klient som støtter HTTP og hendelsesstrømming (f.eks. Node.js, cURL) kan konsumere SSE-strømmer.
17. Hva er det maksimale antallet klienter som kan koble til et SSE-endepunkt?
18. Dette avhenger av serverens konfigurasjon og ressursgrenser. Lastbalansering og klynging kan bidra til å skalere for å støtte flere kunder.
19. Er det mulig å sende JSON-data over SSE?
20. Ja, du kan serialisere objekter til JSON-strenger og sende dem ved hjelp av new MessageEvent i NestJS.

Effektive sanntidsvarsler i NestJS

Implementering av sanntidssystemer ved hjelp av SSE i NestJS forenkler kommunikasjonen mellom serveren og klientene. Denne metoden reduserer serverbelastningen sammenlignet med konstant polling og muliggjør presis målretting for varsler. Et HR-verktøy kan for eksempel varsle 200 ansatte i Salg om nye bilag uten å forstyrre andre. 🎯

Med verktøy som BullMQ og Prisma, sikrer dette oppsettet asynkron oppgavebehandling og effektiv databaseoperasjon. Fleksibiliteten til hendelsesbasert arkitektur gjør den til en skalerbar løsning for ulike sanntidskrav, noe som forbedrer brukerengasjementet og systemets pålitelighet.