Ubesværede meddelelser i NestJS ved hjælp af hændelser på serversiden til masseoperationer

Afsendelse af meddelelser i bulk med Server-Side Events (SSE) i NestJS

Denne løsning demonstrerer en backend-tilgang til brug af NestJS med Prisma og Server-Side Events (SSE) til bulkoperationer. Det inkluderer en begivenhedsdrevet 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 })),
    );
  }
}

Realtidsopdateringer til masseindsatser ved hjælp af NestJS og React

Dette frontend-eksempel bruger React til at lytte til Server-Side Events og opdatere brugergrænsefladen dynamisk, efterhånden som data modtages. Det sikrer, at medarbejdere får besked i realtid efter masseindsættelser.

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

Enhedstestmeddelelser for bulk-indsættelsesoperationer

Denne Jest-test sikrer, at hændelsesudsendelsen og meddelelsesmekanismen fungerer korrekt 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 stillede spørgsmål om SSE i NestJS

1. Hvad er fordelene ved at bruge Server-Side Events over WebSockets?
2. SSE er enklere at implementere og bruger HTTP, hvilket gør det firewall-venligt. I modsætning til WebSockets kræver det kun en enkelt ensrettet forbindelse, hvilket er effektivt til opdateringer i realtid.
3. Kan jeg bruge @Sse med flere endepunkter i en controller?
4. Ja, du kan definere flere @Sse endepunkter i den samme controller for at betjene forskellige datastrømme til klienter baseret på specifikke behov.
5. Hvordan håndterer jeg fejl under købehandling?
6. Med BullMQ kan du definere genforsøgsmuligheder og bruge begivenhedslyttere som @OnWorkerEvent('failed') at logge fejl og genbehandle job, hvis det er nødvendigt.
7. Gør Prisma's createMany metode understøtter tilbagerulning af transaktioner?
8. Ja, hos Prisma createMany kan pakkes ind i en transaktion. Hvis en operation i transaktionen mislykkes, rulles alle operationer tilbage for at opnå konsistens.
9. Hvad sker der, hvis klienten afbryder forbindelsen under en SSE-stream?
10. Serveren stopper med at sende opdateringer, når den registrerer afbrydelsen. Du kan implementere genforbindelseslogik på klienten ved hjælp af EventSource API.
11. Kan SSE bruges til tovejskommunikation?
12. Nej, SSE er ensrettet (server-til-klient). Til tovejskommunikation skal du bruge WebSockets eller HTTP2-streams.
13. Hvordan sikrer jeg SSE-endepunkter i NestJS?
14. Brug afskærmninger eller mellemvarer, f.eks @UseGuards, for at håndhæve godkendelse og autorisation for dine SSE-slutpunkter.
15. Kan SSE arbejde med ikke-browserklienter?
16. Ja, enhver klient, der understøtter HTTP og hændelsesstreaming (f.eks. Node.js, cURL), kan forbruge SSE-streams.
17. Hvad er det maksimale antal klienter, der kan oprette forbindelse til et SSE-slutpunkt?
18. Dette afhænger af din servers konfiguration og ressourcegrænser. Belastningsbalancering og klyngedannelse kan hjælpe med at skalere for at understøtte flere kunder.
19. Er det muligt at sende JSON-data over SSE?
20. Ja, du kan serialisere objekter til JSON-strenge og sende dem vha new MessageEvent i NestJS.

Effektive realtidsmeddelelser i NestJS

Implementering af realtidssystemer vha SSE i NestJS forenkler kommunikationen mellem serveren og klienterne. Denne metode reducerer serverbelastning sammenlignet med konstant polling og muliggør præcis målretning for meddelelser. Eksempelvis kan et HR-værktøj underrette 200 medarbejdere i Salg om nye værdibeviser uden at forstyrre andre. 🎯

Med værktøjer som BullMQ og Prisma sikrer denne opsætning asynkron opgavebehandling og effektiv databasedrift. Fleksibiliteten i begivenhedsbaseret arkitektur gør den til en skalerbar løsning til forskellige realtidskrav, hvilket øger brugerengagementet og systemets pålidelighed.