Obavijesti bez napora u NestJS-u korištenjem događaja na strani poslužitelja za skupne operacije

Skupno slanje obavijesti s događajima na strani poslužitelja (SSE) u NestJS-u

Ovo rješenje pokazuje pozadinski pristup korištenju NestJS-a s Prismom i događajima na strani poslužitelja (SSE) za skupne operacije. Uključuje arhitekturu vođenu događajima i sustav čekanja.

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

Ažuriranja u stvarnom vremenu za skupna umetanja pomoću NestJS-a i Reacta

Ovaj primjer sučelja koristi React za slušanje događaja na strani poslužitelja i dinamičko ažuriranje korisničkog sučelja kako se podaci primaju. Osigurava da zaposlenici budu obaviješteni u stvarnom vremenu nakon masovnog umetanja.

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

Obavijesti o testiranju jedinice za operacije masovnog umetanja

Ovaj Jest test osigurava da emisija događaja i mehanizam obavijesti ispravno rade u pozadini za događaje na strani poslužitelja u NestJS-u.

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

Često postavljana pitanja o SSE-u u NestJS-u

1. Koje su prednosti korištenja događaja na strani poslužitelja u odnosu na WebSockets?
2. SSE je jednostavniji za implementaciju i koristi HTTP, što ga čini prilagođenim vatrozidu. Za razliku od WebSockets, zahtijeva samo jednu jednosmjernu vezu, koja je učinkovita za ažuriranja u stvarnom vremenu.
3. Mogu li koristiti @Sse s više krajnjih točaka u kontroleru?
4. Da, možete definirati više @Sse krajnje točke u istom kontroleru za posluživanje različitih tokova podataka klijentima na temelju specifičnih potreba.
5. Kako se mogu nositi s pogreškama tijekom obrade čekanja?
6. Uz BullMQ možete definirati opcije ponovnog pokušaja i koristiti slušatelje događaja poput @OnWorkerEvent('failed') zabilježiti pogreške i ponovno obraditi poslove ako je potrebno.
7. Da li Prisma's createMany metoda podrške vraćanja transakcija?
8. Da, Prismina createMany može se zamotati u transakciju. Ako bilo koja operacija u transakciji ne uspije, sve se operacije vraćaju unatrag radi dosljednosti.
9. Što se događa ako klijent prekine vezu tijekom SSE streama?
10. Poslužitelj prestaje slati ažuriranja nakon što otkrije prekid veze. Možete implementirati logiku ponovnog povezivanja na klijentu pomoću EventSource API.
11. Može li se SSE koristiti za dvosmjernu komunikaciju?
12. Ne, SSE je jednosmjeran (poslužitelj-klijent). Za dvosmjernu komunikaciju koristite WebSockets ili HTTP2 streamove.
13. Kako mogu osigurati SSE krajnje točke u NestJS-u?
14. Koristite štitnike ili posrednike, npr @UseGuards, za provođenje provjere autentičnosti i autorizacije za vaše SSE krajnje točke.
15. Može li SSE raditi s klijentima koji nisu preglednici?
16. Da, svaki klijent koji podržava HTTP i streaming događaja (npr. Node.js, cURL) može koristiti SSE streamove.
17. Koji je najveći broj klijenata koji se mogu spojiti na SSE krajnju točku?
18. To ovisi o konfiguraciji vašeg poslužitelja i ograničenjima resursa. Balansiranje opterećenja i klasteriranje mogu pomoći u skaliranju za podršku više klijenata.
19. Je li moguće slati JSON podatke preko SSE-a?
20. Da, možete serijalizirati objekte u nizove JSON i poslati ih pomoću new MessageEvent u NestJS.

Učinkovite obavijesti u stvarnom vremenu u NestJS-u

Implementacija sustava u stvarnom vremenu korištenjem JJI u NestJS-u pojednostavljuje komunikaciju između poslužitelja i klijenata. Ova metoda smanjuje opterećenje poslužitelja u usporedbi sa stalnim prozivanjem i omogućuje precizno ciljanje za obavijesti. Na primjer, HR alat može obavijestiti 200 zaposlenika u prodaji o novim vaučerima bez ometanja ostalih. 🎯

S alatima kao što su BullMQ i Prisma, ova postavka osigurava asinkronu obradu zadataka i učinkovite operacije baze podataka. Fleksibilnost arhitekture temeljene na događajima čini je skalabilnim rješenjem za različite zahtjeve u stvarnom vremenu, povećavajući angažman korisnika i pouzdanost sustava.