Snadná oznámení v NestJS pomocí událostí na straně serveru pro hromadné operace

Hromadné odesílání oznámení pomocí událostí na straně serveru (SSE) v NestJS

Toto řešení demonstruje backendový přístup k používání NestJS s Prisma a Server-Side Events (SSE) pro hromadné operace. Zahrnuje architekturu řízenou událostmi a systém řazení do front.

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

Aktualizace v reálném čase pro hromadné vkládání pomocí NestJS a React

Tento příklad frontendu používá React k naslouchání událostem na straně serveru a dynamicky aktualizuje uživatelské rozhraní při přijímání dat. Zajišťuje, že zaměstnanci budou informováni v reálném čase po hromadném vkládá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;

Upozornění na testování jednotek pro operace hromadného vkládání

Tento test Jest zajišťuje správné fungování mechanismu vysílání událostí a oznamování v backendu pro události na straně serveru v 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);
  });
});

Často kladené otázky o SSE v NestJS

1. Jaké jsou výhody používání událostí na straně serveru přes WebSockets?
2. SSE je jednodušší na implementaci a používá HTTP, díky čemuž je přátelské k firewallu. Na rozdíl od WebSockets vyžaduje pouze jedno jednosměrné připojení, které je efektivní pro aktualizace v reálném čase.
3. Mohu použít @Sse s více koncovými body v řadiči?
4. Ano, můžete definovat více @Sse koncové body ve stejném řadiči pro poskytování různých datových toků klientům na základě specifických potřeb.
5. Jak se vypořádám s chybami během zpracování fronty?
6. S BullMQ můžete definovat možnosti opakování a používat posluchače událostí jako @OnWorkerEvent('failed') protokolovat chyby a v případě potřeby znovu zpracovávat úlohy.
7. Dělá Prisma createMany metoda podporuje vrácení transakcí?
8. Ano, Prisma createMany lze zabalit do transakce. Pokud se některá operace v transakci nezdaří, všechny operace jsou vráceny zpět kvůli konzistenci.
9. Co se stane, když se klient odpojí během streamu SSE?
10. Jakmile server zjistí odpojení, přestane odesílat aktualizace. Logiku opětovného připojení můžete implementovat na klientovi pomocí EventSource API.
11. Lze SSE použít pro obousměrnou komunikaci?
12. Ne, SSE je jednosměrný (server-to-client). Pro obousměrnou komunikaci použijte WebSockets nebo HTTP2 streamy.
13. Jak zajistím koncové body SSE v NestJS?
14. Použijte stráže nebo middleware, jako @UseGuardsk vynucení ověřování a autorizace pro vaše koncové body SSE.
15. Může SSE pracovat s klienty mimo prohlížeč?
16. Ano, každý klient, který podporuje HTTP a streamování událostí (např. Node.js, cURL), může využívat streamy SSE.
17. Jaký je maximální počet klientů, kteří se mohou připojit ke koncovému bodu SSE?
18. To závisí na konfiguraci vašeho serveru a limitech prostředků. Vyrovnávání zátěže a shlukování může pomoci škálovat a podporovat více klientů.
19. Je možné odesílat data JSON přes SSE?
20. Ano, objekty můžete serializovat do řetězců JSON a odesílat je pomocí new MessageEvent v NestJS.

Efektivní oznámení v reálném čase v NestJS

Implementace systémů reálného času pomocí SSE v NestJS zjednodušuje komunikaci mezi serverem a klienty. Tato metoda snižuje zatížení serveru ve srovnání s neustálým dotazováním a umožňuje přesné zacílení oznámení. Například HR nástroj může informovat 200 zaměstnanců v Sales o nových poukázkách, aniž by rušil ostatní. 🎯

S nástroji jako BullMQ a Prisma toto nastavení zajišťuje asynchronní zpracování úloh a efektivní databázové operace. Flexibilita architektury založené na událostech z něj činí škálovatelné řešení pro různé požadavky v reálném čase, což zvyšuje zapojení uživatelů a spolehlivost systému.