Lihtsad märguanded NestJS-is, kasutades hulgitoiminguteks serveripoolseid sündmusi

Märguannete hulgi saatmine serveripoolsete sündmustega (SSE) NestJS-is

See lahendus demonstreerib taustapõhist lähenemisviisi NestJS-i kasutamiseks koos Prisma ja serveripoolsete sündmustega (SSE) hulgitoimingute jaoks. See sisaldab sündmustepõhist arhitektuuri ja järjekorrasüsteemi.

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

Reaalajas värskendused hulgilisamiseks, kasutades NestJS-i ja Reacti

See esiliidese näide kasutab serveripoolsete sündmuste kuulamiseks ja kasutajaliidese dünaamiliseks värskendamiseks andmete vastuvõtmisel funktsiooni React. See tagab, et töötajad saavad pärast hulgi sisestamist reaalajas märguandeid.

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

Seadmete testimise teatised hulgi sisestamise toimingute jaoks

See Jesti test tagab, et sündmuste emissioon ja teavitusmehhanism töötab NestJS-i serveripoolsete sündmuste taustaprogrammis õigesti.

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

Korduma kippuvad küsimused SSE kohta NestJSis

1. Millised on serveripoolsete sündmuste kasutamise eelised WebSocketsi ees?
2. SSE-d on lihtsam rakendada ja see kasutab HTTP-d, muutes selle tulemüürisõbralikuks. Erinevalt WebSocketsist nõuab see ainult ühte ühesuunalist ühendust, mis on tõhus reaalajas värskendamiseks.
3. Kas ma saan kasutada @Sse mitme lõpp-punktiga kontrolleris?
4. Jah, saate määratleda mitu @Sse lõpp-punktid samas kontrolleris, et teenindada klientidele erinevaid andmevooge vastavalt konkreetsetele vajadustele.
5. Kuidas käsitleda vigu järjekorra töötlemisel?
6. BullMQ abil saate määratleda uuesti proovimise valikud ja kasutada sündmuste kuulajaid @OnWorkerEvent('failed') vigade logimiseks ja vajadusel tööde ümbertöötlemiseks.
7. Kas Prisma oma createMany meetodi tugi tehingute tagasivõtmised?
8. Jah, Prisma oma createMany saab sõlmida tehinguga. Kui mõni tehingu toiming ebaõnnestub, tühistatakse kõik toimingud järjepidevuse tagamiseks.
9. Mis juhtub, kui klient katkestab ühenduse SSE voo ajal?
10. Server lõpetab värskenduste saatmise pärast ühenduse katkemise tuvastamist. Taasühendamise loogikat saate kliendis rakendada, kasutades EventSource API.
11. Kas SSE-d saab kasutada kahepoolseks suhtluseks?
12. Ei, SSE on ühesuunaline (server-klient). Kahesuunalise suhtluse jaoks kasutage WebSocketsi või HTTP2 vooge.
13. Kuidas ma saan NestJS-is SSE lõpp-punkte kaitsta?
14. Kasutage kaitsmeid või vahevara, näiteks @UseGuards, et jõustada teie SSE lõpp-punktide autentimine ja autoriseerimine.
15. Kas SSE saab töötada klientidega, kes ei kasuta brauserit?
16. Jah, iga klient, mis toetab HTTP-d ja sündmuste voogesitust (nt Node.js, cURL), võib tarbida SSE-vooge.
17. Kui suur on maksimaalne klientide arv, mis saavad SSE lõpp-punktiga ühenduse luua?
18. See sõltub teie serveri konfiguratsioonist ja ressursipiirangutest. Koormuse tasakaalustamine ja rühmitamine võivad aidata skaleerida, et toetada rohkem kliente.
19. Kas JSON-i andmeid on võimalik saata SSE kaudu?
20. Jah, saate objekte JSON-stringideks järjestada ja neid kasutades saata new MessageEvent NestJS-is.

Tõhusad reaalajas teatised NestJS-is

Reaalajas süsteemide juurutamine kasutades SSE NestJS-is lihtsustab suhtlust serveri ja klientide vahel. See meetod vähendab serveri koormust võrreldes pideva küsitlusega ja võimaldab teatiste täpset sihtimist. Näiteks võib personalitööriist teavitada 200 müügiosakonna töötajat uutest vautšeritest ilma teisi häirimata. 🎯

Selliste tööriistadega nagu BullMQ ja Prisma tagab see seadistus asünkroonse ülesannete töötlemise ja tõhusa andmebaasitoimingud. Sündmuspõhise arhitektuuri paindlikkus muudab selle skaleeritavaks lahenduseks erinevate reaalajas nõudmiste jaoks, suurendades kasutajate kaasamist ja süsteemi töökindlust.