Lengvi pranešimai sistemoje „NestJS“, naudojant serverio įvykius masinėms operacijoms

Masinis pranešimų siuntimas naudojant serverio įvykius (SSE) „NestJS“.

Šis sprendimas demonstruoja „NestJS“ su „Prisma“ ir serverio pusės įvykiais (SSE) naudojimą masinėms operacijoms. Ji apima įvykiais pagrįstą architektūrą ir eilių sistemą.

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

Masinių įdėklų, naudojant NestJS ir React, naujinimai realiuoju laiku

Šiame sąsajos pavyzdyje naudojama React, kad būtų galima klausytis serverio įvykių ir dinamiškai atnaujinti vartotojo sąsają, kai gaunami duomenys. Tai užtikrina, kad darbuotojai būtų informuoti realiuoju laiku po masinio įterpimo.

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

Įrenginio testavimo pranešimai masinio įterpimo operacijoms

Šis „Jest“ testas užtikrina, kad įvykių perdavimo ir pranešimų mechanizmas tinkamai veiktų serverio įvykių foninėje sistemoje „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);
  });
});

Dažnai užduodami klausimai apie SSE sistemoje NestJS

1. Kokie yra serverio įvykių naudojimo pranašumai, palyginti su „WebSockets“?
2. SSE yra paprasčiau įdiegti ir naudojamas HTTP, todėl jis tinkamas ugniasienei. Skirtingai nei „WebSockets“, jai reikalingas tik vienas vienakryptis ryšys, kuris yra efektyvus naujinimams realiuoju laiku.
3. Ar galiu naudoti @Sse su keliais galiniais taškais valdiklyje?
4. Taip, galite apibrėžti kelis @Sse galutiniai taškai tame pačiame valdiklyje, kad aptarnautų skirtingus duomenų srautus klientams pagal konkrečius poreikius.
5. Kaip tvarkyti klaidas eilės apdorojimo metu?
6. Naudodami „BullMQ“ galite nustatyti pakartotinio bandymo parinktis ir naudoti įvykių klausytojus @OnWorkerEvent('failed') registruoti klaidas ir, jei reikia, iš naujo apdoroti užduotis.
7. Ar Prisma createMany metodo palaikymo operacijų grąžinimas?
8. Taip, Prisma createMany gali būti įtrauktas į sandorį. Jei kuri nors operacijos operacija nepavyksta, visos operacijos atšaukiamos siekiant nuoseklumo.
9. Kas atsitiks, jei klientas atsijungs SSE srauto metu?
10. Serveris nustoja siųsti naujinimus, kai nustato atsijungimą. Galite įdiegti pakartotinio prisijungimo logiką kliente naudodami EventSource API.
11. Ar SSE galima naudoti abipusiam ryšiui palaikyti?
12. Ne, SSE yra vienakryptė (serveris–klientas). Dvikrypčiai komunikacijai naudokite WebSockets arba HTTP2 srautus.
13. Kaip apsaugoti SSE galinius taškus „NestJS“?
14. Naudokite apsaugas ar tarpines programas, pvz @UseGuards, kad būtų užtikrintas jūsų SSE galinių taškų autentifikavimas ir prieigos teisė.
15. Ar SSE gali dirbti su ne naršyklės klientais?
16. Taip, bet kuris klientas, palaikantis HTTP ir įvykių srautinį perdavimą (pvz., Node.js, cURL), gali naudoti SSE srautus.
17. Koks yra didžiausias klientų, galinčių prisijungti prie SSE galutinio taško, skaičius?
18. Tai priklauso nuo jūsų serverio konfigūracijos ir išteklių apribojimų. Apkrovos balansavimas ir grupavimas gali padėti padidinti mastelį ir palaikyti daugiau klientų.
19. Ar galima siųsti JSON duomenis per SSE?
20. Taip, galite suskirstyti objektus į JSON eilutes ir siųsti juos naudodami new MessageEvent „NestJS“.

Veiksmingi pranešimai realiuoju laiku sistemoje „NestJS“.

Realaus laiko sistemų diegimas naudojant SSE NestJS supaprastina ryšį tarp serverio ir klientų. Šis metodas sumažina serverio apkrovą, palyginti su nuolatine apklausa, ir leidžia tiksliai nukreipti pranešimus. Pavyzdžiui, žmogiškųjų išteklių įrankis gali pranešti 200 pardavimo darbuotojų apie naujus kuponus, netrukdydamas kitiems. 🎯

Naudojant tokius įrankius kaip BullMQ ir Prisma, ši sąranka užtikrina asinchroninį užduočių apdorojimą ir efektyvias duomenų bazės operacijas. Dėl įvykiais pagrįstos architektūros lankstumo tai yra keičiamo dydžio sprendimas įvairiems realaus laiko reikalavimams, padidinantis vartotojų įsitraukimą ir sistemos patikimumą.