Ērti paziņojumi pakalpojumā NestJS, izmantojot servera puses notikumus lielapjoma darbībām

Paziņojumu lielapjoma sūtīšana, izmantojot servera puses notikumus (SSE) NestJS

Šis risinājums demonstrē aizmugursistēmas pieeju NestJS izmantošanai ar Prisma un servera puses notikumiem (SSE) lielapjoma operācijām. Tas ietver uz notikumu balstītu arhitektūru un rindu sistēmu.

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

Reāllaika atjauninājumi lielapjoma ievietošanai, izmantojot NestJS un React

Šajā priekšgala piemērā tiek izmantota funkcija React, lai klausītos servera puses notikumus un dinamiski atjauninātu lietotāja saskarni, tiklīdz tiek saņemti dati. Tas nodrošina, ka darbinieki saņem paziņojumus reāllaikā pēc lielapjoma ievietošanas.

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

Paziņojumi par vienību testēšanu lielapjoma ievietošanas darbībām

Šis Jest tests nodrošina, ka notikumu emisijas un paziņošanas mehānisms pareizi darbojas servera puses notikumu aizmugursistēmā 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);
  });
});

Bieži uzdotie jautājumi par SSE pakalpojumā NestJS

1. Kādas ir servera puses notikumu izmantošanas priekšrocības salīdzinājumā ar WebSockets?
2. SSE ir vienkāršāk ieviest un izmanto HTTP, padarot to draudzīgu ugunsmūrim. Atšķirībā no WebSockets, tam ir nepieciešams tikai viens vienvirziena savienojums, kas ir efektīvs reāllaika atjauninājumiem.
3. Vai es varu izmantot @Sse ar vairākiem galapunktiem kontrolierī?
4. Jā, jūs varat definēt vairākus @Sse galapunkti vienā un tajā pašā kontrolierī, lai apkalpotu klientiem dažādas datu plūsmas, pamatojoties uz īpašām vajadzībām.
5. Kā rīkoties ar kļūdām rindas apstrādes laikā?
6. Izmantojot BullMQ, varat definēt atkārtošanas opcijas un izmantot tādus notikumu klausītājus kā @OnWorkerEvent('failed') lai reģistrētu kļūdas un vajadzības gadījumā atkārtoti apstrādātu darbus.
7. Vai Prismā createMany metode atbalsta darījumu atcelšanu?
8. Jā, Prismā createMany var ietīt darījumā. Ja kāda darījuma operācija neizdodas, visas darbības tiek atceltas, lai nodrošinātu konsekvenci.
9. Kas notiek, ja klients atvienojas SSE straumes laikā?
10. Serveris pārtrauc sūtīt atjauninājumus, tiklīdz tas konstatē atvienošanos. Jūs varat ieviest atkārtotas savienojuma loģiku klientam, izmantojot EventSource API.
11. Vai SSE var izmantot divvirzienu saziņai?
12. Nē, SSE ir vienvirziena (no servera uz klientu). Divvirzienu saziņai izmantojiet WebSockets vai HTTP2 straumes.
13. Kā nodrošināt SSE galapunktus NestJS?
14. Izmantojiet aizsargus vai starpprogrammatūru, piemēram @UseGuards, lai ieviestu jūsu SSE galapunktu autentifikāciju un autorizāciju.
15. Vai SSE var strādāt ar klientiem, kas nav pārlūkprogrammas?
16. Jā, jebkurš klients, kas atbalsta HTTP un notikumu straumēšanu (piemēram, Node.js, cURL), var izmantot SSE straumes.
17. Kāds ir maksimālais klientu skaits, kas var izveidot savienojumu ar SSE galapunktu?
18. Tas ir atkarīgs no jūsu servera konfigurācijas un resursu ierobežojumiem. Slodzes līdzsvarošana un klasterizācija var palīdzēt mērogot, lai atbalstītu vairāk klientu.
19. Vai ir iespējams nosūtīt JSON datus, izmantojot SSE?
20. Jā, jūs varat serializēt objektus uz JSON virknēm un nosūtīt tos, izmantojot new MessageEvent pakalpojumā NestJS.

Efektīvi reāllaika paziņojumi pakalpojumā NestJS

Reāllaika sistēmu ieviešana, izmantojot SSE NestJS vienkāršo saziņu starp serveri un klientiem. Šī metode samazina servera slodzi salīdzinājumā ar pastāvīgu aptauju un nodrošina precīzu paziņojumu mērķauditorijas atlasi. Piemēram, HR rīks var informēt 200 pārdošanas darbiniekus par jauniem kuponiem, netraucējot citiem. 🎯

Izmantojot tādus rīkus kā BullMQ un Prisma, šī iestatīšana nodrošina asinhronu uzdevumu apstrādi un efektīvas datu bāzes darbības. Uz notikumiem balstītas arhitektūras elastība padara to par mērogojamu risinājumu dažādām reāllaika prasībām, uzlabojot lietotāju iesaisti un sistēmas uzticamību.