Enkla aviseringar i NestJS med hjälp av händelser på serversidan för bulkoperationer

Skicka meddelanden i bulk med Server-Side Events (SSE) i NestJS

Denna lösning demonstrerar en backend-metod för att använda NestJS med Prisma och Server-Side Events (SSE) för bulkoperationer. Det inkluderar en händelsedriven arkitektur och kösystem.

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

Realtidsuppdateringar för bulkinserts med NestJS och React

Detta frontend-exempel använder React för att lyssna på Server-Side Events och uppdatera användargränssnittet dynamiskt när data tas emot. Det säkerställer att anställda får meddelande i realtid efter massinsättningar.

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

Aviseringar om enhetstestning för bulkinsertoperationer

Detta Jest-test säkerställer att händelseutsändnings- och meddelandemekanismen fungerar korrekt i backend för Server-Side Events i 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);
  });
});

Vanliga frågor om SSE i NestJS

1. Vilka är fördelarna med att använda Server-Side Events över WebSockets?
2. SSE är enklare att implementera och använder HTTP, vilket gör det brandväggsvänligt. Till skillnad från WebSockets kräver den bara en enkel enkelriktad anslutning, vilket är effektivt för realtidsuppdateringar.
3. Kan jag använda @Sse med flera slutpunkter i en styrenhet?
4. Ja, du kan definiera flera @Sse slutpunkter i samma styrenhet för att servera olika dataströmmar till klienter baserat på specifika behov.
5. Hur hanterar jag fel under köbehandling?
6. Med BullMQ kan du definiera omförsöksalternativ och använda händelseavlyssnare som @OnWorkerEvent('failed') att logga fel och bearbeta jobb om det behövs.
7. Gör Prisma's createMany metod stöder återföring av transaktioner?
8. Ja, hos Prisma createMany kan slås in i en transaktion. Om någon operation i transaktionen misslyckas rullas alla operationer tillbaka för konsekvens.
9. Vad händer om klienten kopplar från under en SSE-ström?
10. Servern slutar skicka uppdateringar när den upptäcker frånkopplingen. Du kan implementera återanslutningslogik på klienten med hjälp av EventSource API.
11. Kan SSE användas för tvåvägskommunikation?
12. Nej, SSE är enkelriktad (server-till-klient). För dubbelriktad kommunikation, använd WebSockets eller HTTP2-strömmar.
13. Hur säkrar jag SSE-ändpunkter i NestJS?
14. Använd skydd eller mellanvaror, som @UseGuards, för att genomdriva autentisering och auktorisering för dina SSE-slutpunkter.
15. Kan SSE fungera med klienter som inte är webbläsare?
16. Ja, alla klienter som stöder HTTP och händelseströmning (t.ex. Node.js, cURL) kan konsumera SSE-strömmar.
17. Vad är det maximala antalet klienter som kan ansluta till en SSE-slutpunkt?
18. Detta beror på din servers konfiguration och resursbegränsningar. Lastbalansering och klustring kan hjälpa till att skala för att stödja fler kunder.
19. Är det möjligt att skicka JSON-data över SSE?
20. Ja, du kan serialisera objekt till JSON-strängar och skicka dem med hjälp av new MessageEvent i NestJS.

Effektiva realtidsmeddelanden i NestJS

Implementering av realtidssystem med hjälp av SSE i NestJS förenklar kommunikationen mellan servern och klienterna. Denna metod minskar serverbelastningen jämfört med konstant polling och möjliggör exakt inriktning för aviseringar. Ett HR-verktyg kan till exempel meddela 200 anställda i Sales om nya vouchers utan att störa andra. 🎯

Med verktyg som BullMQ och Prisma säkerställer denna installation asynkron uppgiftsbehandling och effektiv databasoperation. Flexibiliteten hos händelsebaserad arkitektur gör den till en skalbar lösning för olika realtidskrav, vilket ökar användarens engagemang och systemets tillförlitlighet.