Прості сповіщення в NestJS за допомогою подій на стороні сервера для масових операцій

Масове надсилання сповіщень за допомогою серверних подій (SSE) у NestJS

Це рішення демонструє серверний підхід до використання NestJS із Prisma та серверними подіями (SSE) для групових операцій. Він включає керовану подіями архітектуру та систему черги.

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

Оновлення в реальному часі для масових вставок за допомогою NestJS і React

Цей приклад інтерфейсу використовує React для прослуховування подій на стороні сервера та динамічного оновлення інтерфейсу користувача в міру отримання даних. Це гарантує, що співробітники отримують сповіщення в режимі реального часу після масових вставок.

// 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 гарантує, що механізм надсилання подій і сповіщень працює належним чином у серверній частині для подій на стороні сервера в 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);
  });
});

Поширені запитання про SSE у NestJS

1. Які переваги використання серверних подій над WebSockets?
2. SSE простіше в застосуванні та використовує HTTP, що робить його дружнім до брандмауера. На відміну від WebSockets, для цього потрібне лише одне односпрямоване з’єднання, яке є ефективним для оновлень у реальному часі.
3. Чи можу я використовувати @Sse з кількома кінцевими точками в контролері?
4. Так, ви можете визначити декілька @Sse кінцеві точки в одному контролері, щоб обслуговувати різні потоки даних для клієнтів на основі конкретних потреб.
5. Як усунути помилки під час обробки черги?
6. За допомогою BullMQ ви можете визначити параметри повторних спроб і використовувати прослуховувачі подій, наприклад @OnWorkerEvent('failed') для реєстрації помилок і повторної обробки завдань, якщо необхідно.
7. Чи Призма createMany метод підтримки транзакцій відкатів?
8. Так, Prisma createMany можна загорнути в транзакцію. Якщо будь-яка операція в транзакції завершується помилкою, усі операції відкочуються для узгодженості.
9. Що станеться, якщо клієнт від’єднається під час потоку SSE?
10. Сервер припиняє надсилати оновлення, як тільки він виявляє відключення. Ви можете реалізувати логіку повторного підключення на клієнті за допомогою EventSource API.
11. Чи можна SSE використовувати для двостороннього зв’язку?
12. Ні, SSE є односпрямованим (сервер-клієнт). Для двонаправленого зв’язку використовуйте потоки WebSockets або HTTP2.
13. Як захистити кінцеві точки SSE у NestJS?
14. Використовуйте охоронці або проміжне програмне забезпечення, наприклад @UseGuards, щоб забезпечити автентифікацію та авторизацію для кінцевих точок SSE.
15. Чи може SSE працювати з клієнтами без браузера?
16. Так, будь-який клієнт, який підтримує HTTP і потокове передавання подій (наприклад, Node.js, cURL), може використовувати потоки SSE.
17. Яка максимальна кількість клієнтів, які можуть підключатися до кінцевої точки SSE?
18. Це залежить від конфігурації вашого сервера та обмежень ресурсів. Балансування навантаження та кластеризація можуть допомогти масштабувати для підтримки більшої кількості клієнтів.
19. Чи можна надсилати дані JSON через SSE?
20. Так, ви можете серіалізувати об’єкти в рядки JSON і надсилати їх за допомогою new MessageEvent у NestJS.

Ефективні сповіщення в реальному часі в NestJS

Впровадження систем реального часу з використанням SSE у NestJS спрощує зв’язок між сервером і клієнтами. Цей метод зменшує навантаження на сервер порівняно з постійним опитуванням і забезпечує точне націлювання сповіщень. Наприклад, HR-інструмент може повідомити 200 співробітників відділу продажів про нові ваучери, не заважаючи іншим. 🎯

За допомогою таких інструментів, як BullMQ і Prisma, це налаштування забезпечує асинхронну обробку завдань і ефективні операції з базою даних. Гнучкість архітектури, заснованої на подіях, робить її масштабованим рішенням для різних вимог у реальному часі, підвищуючи залучення користувачів і надійність системи.