Обавештења без напора у НестЈС-у користећи догађаје на страни сервера за масовне операције

Групно слање обавештења са догађајима на страни сервера (ССЕ) у НестЈС-у

Ово решење показује позадински приступ коришћењу НестЈС-а са Присма-ом и догађајима на страни сервера (ССЕ) за групне операције. Укључује архитектуру вођену догађајима и систем чекања.

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

Ажурирања у реалном времену за масовне уметке користећи НестЈС и Реацт

Овај пример фронтенда користи Реацт за слушање догађаја на страни сервера и динамички ажурирање корисничког интерфејса како се подаци примају. Обезбеђује да запослени буду обавештени у реалном времену након масовних уметања.

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

Обавештења о јединичном тестирању за операције масовног уметања

Овај Јест тест обезбеђује да механизам емитовања догађаја и обавештења ради исправно у позадини за догађаје на страни сервера у НестЈС-у.

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

Често постављана питања о ССЕ-у у НестЈС-у

1. Које су предности коришћења догађаја на страни сервера у односу на ВебСоцкетс?
2. ССЕ је једноставнији за имплементацију и користи ХТТП, што га чини погодним за заштитни зид. За разлику од ВебСоцкетс-а, захтева само једну једносмерну везу, која је ефикасна за ажурирања у реалном времену.
3. Могу ли да користим @Sse са више крајњих тачака у контролеру?
4. Да, можете дефинисати више @Sse крајње тачке у истом контролеру за опслуживање различитих токова података клијентима на основу специфичних потреба.
5. Како да поступам са грешкама током обраде реда?
6. Са БуллМК, можете дефинисати опције поновног покушаја и користити слушаоце догађаја као што је @OnWorkerEvent('failed') за евидентирање грешака и поновну обраду послова ако је потребно.
7. Да ли Присма'с createMany метод подршке враћања трансакција?
8. Да, Присма'с createMany може бити умотано у трансакцију. Ако било која операција у трансакцији не успе, све операције се поништавају ради доследности.
9. Шта се дешава ако клијент прекине везу током ССЕ стрима?
10. Сервер престаје да шаље ажурирања када открије прекид везе. Можете имплементирати логику поновног повезивања на клијенту користећи EventSource АПИ.
11. Да ли се ССЕ може користити за двосмерну комуникацију?
12. Не, ССЕ је једносмеран (од сервера до клијента). За двосмерну комуникацију користите ВебСоцкетс или ХТТП2 токове.
13. Како да обезбедим ССЕ крајње тачке у НестЈС-у?
14. Користите чуваре или међуверзије, нпр @UseGuards, да бисте применили аутентификацију и ауторизацију за ваше ССЕ крајње тачке.
15. Може ли ССЕ да ради са клијентима који не користе претраживач?
16. Да, сваки клијент који подржава ХТТП и стриминг догађаја (нпр. Ноде.јс, цУРЛ) може да користи ССЕ стримове.
17. Колики је максималан број клијената који се могу повезати на ССЕ крајњу тачку?
18. Ово зависи од конфигурације вашег сервера и ограничења ресурса. Балансирање оптерећења и груписање могу помоћи у скалирању како би се подржало више клијената.
19. Да ли је могуће слати ЈСОН податке преко ССЕ-а?
20. Да, можете серијализирати објекте у ЈСОН стрингове и послати их користећи new MessageEvent у НестЈС.

Ефикасна обавештења у реалном времену у НестЈС-у

Имплементација система у реалном времену коришћењем ССЕ у НестЈС-у поједностављује комуникацију између сервера и клијената. Овај метод смањује оптерећење сервера у поређењу са сталним анкетирањем и омогућава прецизно циљање за обавештења. На пример, ХР алат може да обавести 200 запослених у продаји о новим ваучерима без ометања других. 🎯

Са алатима као што су БуллМК и Присма, ово подешавање обезбеђује асинхрону обраду задатака и ефикасне операције базе података. Флексибилност архитектуре засноване на догађајима чини је скалабилним решењем за различите захтеве у реалном времену, повећавајући ангажовање корисника и поузданост система.