Простые уведомления в 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. Есть ли у Prisma's createMany метод поддержки откатов транзакций?
8. Да, Призма 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

Реализация систем реального времени с использованием СШЭ в NestJS упрощает связь между сервером и клиентами. Этот метод снижает нагрузку на сервер по сравнению с постоянным опросом и обеспечивает точный таргетинг уведомлений. Например, инструмент управления персоналом может уведомить 200 сотрудников отдела продаж о новых ваучерах, не мешая остальным. 🎯

Благодаря таким инструментам, как BullMQ и Prisma, эта установка обеспечивает асинхронную обработку задач и эффективную работу с базой данных. Гибкость архитектуры, основанной на событиях, делает ее масштабируемым решением для различных требований реального времени, повышая вовлеченность пользователей и надежность системы.