Ειδοποιήσεις χωρίς κόπο στο 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 διασφαλίζει ότι ο μηχανισμός εκπομπής συμβάντων και ειδοποίησης λειτουργεί σωστά στο backend για συμβάντα από την πλευρά του διακομιστή στο 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. Ναι, του 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 απλοποιεί την επικοινωνία μεταξύ διακομιστή και πελατών. Αυτή η μέθοδος μειώνει το φόρτο του διακομιστή σε σύγκριση με τη συνεχή δημοσκόπηση και επιτρέπει την ακριβή στόχευση για ειδοποιήσεις. Για παράδειγμα, ένα εργαλείο ανθρώπινου δυναμικού μπορεί να ειδοποιήσει 200 ​​υπαλλήλους στις Πωλήσεις για νέα κουπόνια χωρίς να ενοχλεί άλλους. 🎯

Με εργαλεία όπως το BullMQ και το Prisma, αυτή η ρύθμιση εξασφαλίζει ασύγχρονη επεξεργασία εργασιών και αποτελεσματικές λειτουργίες βάσης δεδομένων. Η ευελιξία της αρχιτεκτονικής που βασίζεται σε συμβάντα την καθιστά μια επεκτάσιμη λύση για διάφορες απαιτήσεις σε πραγματικό χρόνο, ενισχύοντας την αφοσίωση των χρηστών και την αξιοπιστία του συστήματος.