Preprosta obvestila v NestJS z uporabo dogodkov na strani strežnika za množične operacije

Množično pošiljanje obvestil s strežniškimi dogodki (SSE) v NestJS

Ta rešitev prikazuje zaledni pristop k uporabi NestJS s Prismo in dogodki na strani strežnika (SSE) za množične operacije. Vključuje arhitekturo, ki temelji na dogodkih, in sistem čakalnih vrst.

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

Posodobitve v realnem času za množične vstavke z uporabo NestJS in React

Ta primer sprednjega dela uporablja React za poslušanje dogodkov na strani strežnika in dinamično posodabljanje uporabniškega vmesnika, ko so podatki prejeti. Zagotavlja, da so zaposleni obveščeni v realnem času po množičnem vstavljanju.

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

Obvestila o testiranju enote za operacije množičnega vstavljanja

Ta preizkus Jest zagotavlja, da oddajanje dogodkov in mehanizem obveščanja pravilno delujeta v ozadju za dogodke na strani strežnika 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);
  });
});

Pogosta vprašanja o SSE v NestJS

1. Kakšne so prednosti uporabe dogodkov na strani strežnika prek spletnih vtičnic?
2. SSE je preprostejši za implementacijo in uporablja HTTP, zaradi česar je prijazen do požarnega zidu. Za razliko od WebSockets zahteva samo eno enosmerno povezavo, ki je učinkovita za posodobitve v realnem času.
3. Ali lahko uporabim @Sse z več končnimi točkami v krmilniku?
4. Da, lahko določite več @Sse končne točke v istem krmilniku za streženje različnih podatkovnih tokov strankam glede na specifične potrebe.
5. Kako obravnavam napake med obdelavo čakalne vrste?
6. Z BullMQ lahko definirate možnosti ponovnega poskusa in uporabite poslušalce dogodkov, kot je @OnWorkerEvent('failed') za beleženje napak in po potrebi ponovno obdelavo opravil.
7. Ali Prisma createMany metoda podpira povratne transakcije?
8. Ja, Prisma createMany se lahko zavije v transakcijo. Če katera koli operacija v transakciji ne uspe, se zaradi doslednosti vse operacije povrnejo nazaj.
9. Kaj se zgodi, če odjemalec prekine povezavo med tokom SSE?
10. Strežnik preneha pošiljati posodobitve, ko zazna prekinitev povezave. Na odjemalcu lahko implementirate logiko ponovne povezave z uporabo EventSource API.
11. Ali se SSE lahko uporablja za dvosmerno komunikacijo?
12. Ne, SSE je enosmeren (od strežnika do odjemalca). Za dvosmerno komunikacijo uporabite tokove WebSockets ali HTTP2.
13. Kako zavarujem končne točke SSE v NestJS?
14. Uporabite varovala ali vmesno opremo, npr @UseGuards, za uveljavitev avtentikacije in avtorizacije za vaše končne točke SSE.
15. Ali lahko SSE deluje z odjemalci brez brskalnika?
16. Da, vsak odjemalec, ki podpira HTTP in pretakanje dogodkov (npr. Node.js, cURL), lahko uporablja tokove SSE.
17. Kakšno je največje število odjemalcev, ki se lahko povežejo s končno točko SSE?
18. To je odvisno od konfiguracije vašega strežnika in omejitev virov. Izravnavanje obremenitve in združevanje v gruče lahko pomagata povečati obseg za podporo več odjemalcem.
19. Ali je mogoče poslati podatke JSON prek SSE?
20. Da, predmete lahko serializirate v nize JSON in jih pošljete z uporabo new MessageEvent v NestJS.

Učinkovita obvestila v realnem času v NestJS

Izvajanje sistemov v realnem času z uporabo SSE v NestJS poenostavlja komunikacijo med strežnikom in odjemalci. Ta metoda zmanjša obremenitev strežnika v primerjavi s stalnim anketiranjem in omogoča natančno ciljanje za obvestila. Na primer, kadrovsko orodje lahko obvesti 200 zaposlenih v prodaji o novih vavčerjih, ne da bi motilo druge. 🎯

Z orodji, kot sta BullMQ in Prisma, ta nastavitev zagotavlja asinhrono obdelavo opravil in učinkovite operacije baze podatkov. Prilagodljivost arhitekture, ki temelji na dogodkih, jo naredi razširljivo rešitev za različne zahteve v realnem času, kar izboljšuje sodelovanje uporabnikov in zanesljivost sistema.