Bezproblémové upozornenia v NestJS pomocou udalostí na strane servera pre hromadné operácie

Hromadné odosielanie upozornení s udalosťami na strane servera (SSE) v NestJS

Toto riešenie demonštruje backendový prístup k používaniu NestJS s Prisma a Server-Side Events (SSE) pre hromadné operácie. Zahŕňa architektúru riadenú udalosťami a systém radenia.

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

Aktualizácie pre hromadné vkladanie v reálnom čase pomocou NestJS a React

Tento príklad frontendu používa React na počúvanie udalostí na strane servera a dynamickú aktualizáciu používateľského rozhrania pri prijímaní údajov. Zabezpečuje, aby boli zamestnanci informovaní v reálnom čase po hromadnom vkladaní.

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

Upozornenia na testovanie jednotiek pre operácie hromadného vkladania

Tento test Jest zaisťuje, že mechanizmus vysielania udalostí a oznamovania funguje správne v backende pre udalosti na strane servera 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. Aké sú výhody používania udalostí na strane servera cez WebSockets?
2. SSE je jednoduchšia na implementáciu a používa HTTP, vďaka čomu je priateľská k firewallu. Na rozdiel od WebSockets vyžaduje iba jedno jednosmerné pripojenie, čo je efektívne pre aktualizácie v reálnom čase.
3. Môžem použiť @Sse s viacerými koncovými bodmi v ovládači?
4. Áno, môžete definovať viacero @Sse koncové body v tom istom radiči, aby mohli klientom poskytovať rôzne dátové toky na základe špecifických potrieb.
5. Ako riešim chyby počas spracovania frontu?
6. S BullMQ môžete definovať možnosti opakovania a používať poslucháčov udalostí ako @OnWorkerEvent('failed') zaznamenať chyby a v prípade potreby znova spracovať úlohy.
7. Robí Prisma createMany metóda podporuje vrátenie transakcií?
8. Áno, Prisma's createMany možno zabaliť do transakcie. Ak ktorákoľvek operácia v transakcii zlyhá, všetky operácie sa kvôli konzistencii vrátia späť.
9. Čo sa stane, ak sa klient odpojí počas streamu SSE?
10. Server prestane odosielať aktualizácie, keď zistí odpojenie. Logiku opätovného pripojenia môžete implementovať na klientovi pomocou EventSource API.
11. Dá sa SSE použiť na obojsmernú komunikáciu?
12. Nie, SSE je jednosmerný (server-to-client). Pre obojsmernú komunikáciu použite WebSockets alebo HTTP2 streamy.
13. Ako zabezpečím koncové body SSE v NestJS?
14. Použite chrániče alebo middleware, napr @UseGuardsna vynútenie autentifikácie a autorizácie pre vaše koncové body SSE.
15. Môže SSE pracovať s klientmi mimo prehliadača?
16. Áno, každý klient, ktorý podporuje HTTP a streamovanie udalostí (napr. Node.js, cURL), môže využívať streamy SSE.
17. Aký je maximálny počet klientov, ktorí sa môžu pripojiť ku koncovému bodu SSE?
18. Závisí to od konfigurácie servera a limitov zdrojov. Vyvažovanie záťaže a klastrovanie môžu pomôcť pri škálovaní na podporu viacerých klientov.
19. Je možné odosielať údaje JSON cez SSE?
20. Áno, objekty môžete serializovať do reťazcov JSON a odosielať ich pomocou new MessageEvent v NestJS.

Efektívne upozornenia v reálnom čase v NestJS

Implementácia systémov v reálnom čase pomocou SSE v NestJS zjednodušuje komunikáciu medzi serverom a klientmi. Táto metóda znižuje zaťaženie servera v porovnaní s neustálym dotazovaním a umožňuje presné zacielenie upozornení. Napríklad HR nástroj môže upozorniť 200 zamestnancov na predaj o nových poukážkach bez toho, aby rušil ostatných. 🎯

S nástrojmi ako BullMQ a Prisma toto nastavenie zaisťuje asynchrónne spracovanie úloh a efektívne operácie s databázou. Flexibilita architektúry založenej na udalostiach z neho robí škálovateľné riešenie pre rôzne požiadavky v reálnom čase, čím sa zvyšuje zapojenie používateľov a spoľahlivosť systému.