Mühelose Benachrichtigungen in NestJS mithilfe serverseitiger Ereignisse für Massenvorgänge

Optimierte Benachrichtigungszustellung für Masseneinfügungsvorgänge

Stellen Sie sich vor, Sie verwalten ein System, in dem Hunderten von Mitarbeitern Gutscheine auf der Grundlage verschiedener Kriterien wie Abteilung, Besoldungsgruppe oder Erfahrung zugewiesen werden. Es ist eine gewaltige Aufgabe, jeden Mitarbeiter effizient zu benachrichtigen, ohne dass es zu Engpässen im System kommt. 🔔 Diese Herausforderung wird noch gewaltiger, wenn Sie die Komplexität von Sockets oder Polling-Mechanismen vermeiden möchten.

In solchen Szenarien erweisen sich Server-Side Events (SSE) als leistungsstarke und dennoch unkomplizierte Lösung. Durch die Nutzung von SSE in Ihrer NestJS-Anwendung können Sie einen Echtzeit-Kommunikationskanal einrichten, um bestimmte Gruppen von Mitarbeitern anhand dynamischer Kriterien zu benachrichtigen. Wenn beispielsweise Gutscheine der Vertriebsabteilung zugewiesen werden, sollten nur diese Mitarbeiter Benachrichtigungen erhalten, um präzise und aussagekräftige Aktualisierungen sicherzustellen.

In diesem Artikel befassen wir uns mit einem praktischen Beispiel, das zeigt, wie SSE mithilfe von NestJS in einen Masseneinfügungsprozess integriert wird. Wir durchlaufen den Lebenszyklus, vom Auslösen von Ereignissen im Backend bis zum Warten auf Aktualisierungen im Frontend, und das alles unter Beibehaltung einer reibungslosen Leistung. 💼

Unabhängig davon, ob Sie ein HR-Tool oder eine Finanz-App entwickeln, können Sie mit dem Verständnis dieses Workflows personalisierte Benachrichtigungen in Echtzeit übermitteln. Lassen Sie uns die Einfachheit von SSE enthüllen und wie es das Benutzererlebnis Ihrer Anwendung verbessern kann.

Effiziente Benachrichtigungen mit serverseitigen Ereignissen und Warteschlangen

Die bereitgestellten Skripte veranschaulichen ein System, bei dem nach der Masseneingabe von Gutscheindatensätzen in die Datenbank Echtzeitbenachrichtigungen an Mitarbeiter gesendet werden. Der Prozess beginnt in der AllocateVoucherController, der einen Endpunkt zum Erstellen von Belegzuteilungsaufgaben verfügbar macht. Wenn eine Aufgabe erstellt wird, gibt sie ein Ereignis mit dem Namen aus Nachzuteilungsgutschein. Dieses Ereignis ist für das Auslösen der nachfolgenden Schritte unerlässlich und stellt sicher, dass das System ereignisgesteuert und modular ist. Dieses Design ermöglicht eine klare Trennung der Belange und macht das System dadurch wartbarer und skalierbarer. 🎯

In der Serviceschicht ist die AllocateVoucherService kümmert sich um die Logik für die Warteschlangen-Aufgaben mithilfe von BullMQ. Nach Erhalt der Nachzuteilungsgutschein Bei diesem Ereignis wird der benannten Warteschlange ein Auftrag hinzugefügt Kontingentgutschein. Diese Warteschlange ermöglicht eine asynchrone Verarbeitung und stellt sicher, dass das System auch bei der Verarbeitung großer Datensätze reaktionsfähig bleibt. Wenn Sie beispielsweise 200 Mitarbeitern in der Vertriebsabteilung Gutscheine zuweisen, stellt die Warteschlange sicher, dass der Vorgang keine anderen Anfragen blockiert. Die Konfiguration der Warteschlange umfasst Optionen wie RemoveOnComplete um Redis nach Abschluss des Auftrags sauber zu halten.

Die Queue-Jobs werden von der verarbeitet AllotVoucherConsumer Klasse. Hier wird die Logik zur Identifizierung der relevanten Mitarbeiter und zum Einfügen von Gutscheindatensätzen in die Datenbank implementiert. Der Prisma-Befehl createMany wird zum Batch-Einfügen von Datensätzen in verwendet MitarbeiterGutschein Tabelle, die auf Leistung optimiert ist. Nachdem der Datenbankvorgang abgeschlossen ist, wird ein weiteres Ereignis ausgegeben, um die Abonnenten zu benachrichtigen. Dieses Ereignis stellt sicher, dass Mitarbeiter erst benachrichtigt werden, nachdem die Masseneinfügung erfolgreich verarbeitet wurde, was die Zuverlässigkeit des Benachrichtigungssystems erhöht. 🌟

Im Frontend lauscht die React-Komponente über eine auf die vom Server gesendeten Ereignisse EventSource. Wenn Mitarbeiter benachrichtigt werden, werden ihre Details dynamisch in der Benutzeroberfläche aktualisiert, ohne dass eine Seitenaktualisierung erforderlich ist. Dieser Ansatz bietet ein nahtloses Benutzererlebnis, vergleichbar mit Echtzeitaktualisierungen, die in modernen Webanwendungen wie Live-Sportergebnissen oder Social-Media-Benachrichtigungen zu sehen sind. Beispielsweise sehen Mitarbeiter in der Personalabteilung keine Updates, die für den Vertrieb bestimmt sind, da das Backend Ereignisse präzise nach Zuordnungskriterien filtert. Diese Besonderheit steigert sowohl die Leistung als auch die Relevanz und schafft ein benutzerorientiertes 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 })),
    );
  }
}

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

Verbesserung von Echtzeitsystemen mit SSE in NestJS

Während wir die Implementierung von Server-Side Events (SSE) zur Benachrichtigung von Mitarbeitern über Gutscheinzuteilungen untersucht haben, gibt es einen breiteren Anwendungsfall für SSE in Echtzeitsystemen. SSE glänzt in Szenarien, in denen Clients ohne ständige Abfragen mit Serverdaten auf dem Laufenden bleiben müssen. Denken Sie beispielsweise an eine Online-Einzelhandelsplattform, die während eines Flash-Sales Live-Aktualisierungen des Lagerbestands verfolgt. Mit SSE können Sie Aktualisierungen effizient an alle angeschlossenen Kunden weiterleiten und so sicherstellen, dass diese die neuesten Lagerbestände ohne unnötige Serverlast sehen. Dieser Ansatz gewährleistet Skalierbarkeit und sorgt gleichzeitig für ein nahtloses Benutzererlebnis. 🛒

Die Integration fortschrittlicher Warteschlangensysteme wie BullMQ, wie wir es mit dem gemacht haben Kontingentgutschein Warteschlange, erhöht die Robustheit von Massendatenverarbeitungsaufgaben. Die Warteschlange stellt sicher, dass selbst bei einem Serverneustart ausstehende Aufgaben intakt bleiben und die Verarbeitung fortgesetzt wird. Darüber hinaus können Wiederholungsmechanismen konfiguriert werden, um sicherzustellen, dass fehlgeschlagene Jobs (z. B. aufgrund einer vorübergehenden Datenbankausfallzeit) automatisch wiederholt werden. Wenn beispielsweise bei einer abteilungsübergreifenden Zuweisung von 300 Mitarbeitern ein vorübergehender Fehler auftritt, stellt die Ausfallsicherheit der Warteschlange sicher, dass keine Datensätze unverarbeitet bleiben, was die Zuverlässigkeit Ihres Systems erhöht.

Über Echtzeitbenachrichtigungen hinaus kann SSE auch E-Mail-Dienste für Aufgaben ergänzen, die detaillierte Zusammenfassungen erfordern. Nachdem alle Gutscheinbenachrichtigungen über SSE gesendet wurden, kann das Backend asynchron einen Bericht erstellen und eine konsolidierte E-Mail an Manager senden. Diese Multi-Channel-Kommunikation sorgt sowohl für sofortige Benachrichtigungen als auch für umfassende Nachverfolgungen und berücksichtigt dabei ein breites Spektrum an Benutzerpräferenzen. Eine solche Integration erhöht die Flexibilität Ihres Systems und sorgt für ein umfassendes Benutzererlebnis. 📧