Vaivattomat ilmoitukset NestJS:ssä käyttämällä palvelinpuolen tapahtumia joukkotoimintoihin

Ilmoitusten lähettäminen joukkona palvelinpuolen tapahtumien (SSE) avulla NestJS:ssä

Tämä ratkaisu esittelee taustaratkaisun NestJS:n käyttämiseen Prisman ja SSE:n (Server-Side Events) kanssa joukkotoimintoihin. Se sisältää tapahtumalähtöisen arkkitehtuurin ja jonojärjestelmän.

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

Reaaliaikaiset päivitykset joukkolisäkkeille NestJS:n ja Reactin avulla

Tämä käyttöliittymäesimerkki käyttää Reactia palvelinpuolen tapahtumien kuuntelemiseen ja käyttöliittymän päivittämiseen dynaamisesti, kun tietoja vastaanotetaan. Se varmistaa, että työntekijät saavat ilmoituksen reaaliajassa joukkolisäysten jälkeen.

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

Yksikkötestausilmoitukset joukkolisäystoimintoihin

Tämä Jest-testi varmistaa, että tapahtumalähetys- ja ilmoitusmekanismi toimii oikein NestJS:n palvelinpuolen tapahtumien taustaohjelmassa.

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

Usein kysyttyjä kysymyksiä SSE:stä NestJS:ssä

1. Mitä etuja on palvelinpuolen tapahtumien käyttämisestä WebSocketsiin verrattuna?
2. SSE on helpompi toteuttaa ja käyttää HTTP:tä, mikä tekee siitä palomuuriystävällisen. Toisin kuin WebSockets, se vaatii vain yhden yksisuuntaisen yhteyden, joka on tehokas reaaliaikaisissa päivityksissä.
3. Voinko käyttää @Sse jossa on useita päätepisteitä ohjaimessa?
4. Kyllä, voit määrittää useita @Sse päätepisteet samassa ohjaimessa palvelemaan erilaisia ​​tietovirtoja asiakkaille erityistarpeiden perusteella.
5. Miten käsittelen virheitä jonon käsittelyn aikana?
6. BullMQ:n avulla voit määrittää uudelleenyritysvaihtoehtoja ja käyttää tapahtumakuuntelijoita, kuten @OnWorkerEvent('failed') kirjaamaan virheet ja tarvittaessa käsittelemään työt uudelleen.
7. Sopii Prismaan createMany menetelmätuen tapahtumien palautukset?
8. Kyllä, Prismassa createMany voidaan kääriä kauppaan. Jos jokin tapahtuman toiminto epäonnistuu, kaikki toiminnot peruutetaan johdonmukaisuuden vuoksi.
9. Mitä tapahtuu, jos asiakas katkaisee yhteyden SSE-streamin aikana?
10. Palvelin lopettaa päivitysten lähettämisen, kun se havaitsee yhteyden katkeamisen. Voit toteuttaa uudelleenkytkentälogiikan asiakkaassa käyttämällä EventSource API.
11. Voidaanko SSE:tä käyttää kaksisuuntaiseen viestintään?
12. Ei, SSE on yksisuuntainen (palvelin-asiakas). Käytä kaksisuuntaiseen tiedonsiirtoon WebSockets- tai HTTP2-streameja.
13. Kuinka suojaan SSE-päätepisteet NestJS:ssä?
14. Käytä suojia tai välituotteita, kuten @UseGuards, pakottaaksesi SSE-päätepisteidesi todennuksen ja valtuutuksen.
15. Voiko SSE toimia muiden kuin selainasiakkaiden kanssa?
16. Kyllä, mikä tahansa asiakas, joka tukee HTTP:tä ja tapahtumien suoratoistoa (esim. Node.js, cURL), voi käyttää SSE-streameja.
17. Mikä on asiakkaiden enimmäismäärä, jotka voivat muodostaa yhteyden SSE-päätepisteeseen?
18. Tämä riippuu palvelimesi kokoonpanosta ja resurssirajoituksista. Kuormituksen tasapainottaminen ja klusterointi voivat auttaa skaalautumaan tukemaan useampia asiakkaita.
19. Onko mahdollista lähettää JSON-tietoja SSE:n kautta?
20. Kyllä, voit sarjoittaa objekteja JSON-merkkijonoihin ja lähettää ne käyttämällä new MessageEvent NestJS:ssä.

Tehokkaat reaaliaikaiset ilmoitukset NestJS:ssä

Reaaliaikaisten järjestelmien käyttöönotto käyttäen SSE NestJS:ssä yksinkertaistaa palvelimen ja asiakkaiden välistä viestintää. Tämä menetelmä vähentää palvelimen kuormitusta verrattuna jatkuvaan kyselyyn ja mahdollistaa ilmoitusten tarkan kohdistamisen. Esimerkiksi HR-työkalu voi ilmoittaa 200 myynnin työntekijälle uusista seteleistä häiritsemättä muita. 🎯

BullMQ:n ja Prisman kaltaisilla työkaluilla tämä asennus varmistaa asynkronisen tehtävien käsittelyn ja tehokkaan tietokantatoiminnan. Tapahtumapohjaisen arkkitehtuurin joustavuus tekee siitä skaalautuvan ratkaisun erilaisiin reaaliaikaisiin vaatimuksiin, mikä parantaa käyttäjien sitoutumista ja järjestelmän luotettavuutta.