Notifikasi yang Mudah di NestJS Menggunakan Peristiwa Sisi Server untuk Operasi Massal

Mengirim Pemberitahuan Secara Massal dengan Server-Side Events (SSE) di NestJS

Solusi ini menunjukkan pendekatan backend dalam menggunakan NestJS dengan Prisma dan Server-Side Events (SSE) untuk operasi massal. Ini mencakup arsitektur berbasis peristiwa dan sistem antrian.

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

Pembaruan Real-Time untuk Penyisipan Massal Menggunakan NestJS dan React

Contoh frontend ini menggunakan React untuk mendengarkan Peristiwa Sisi Server dan memperbarui UI secara dinamis saat data diterima. Ini memastikan karyawan mendapat pemberitahuan secara real-time setelah penyisipan massal.

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

Pemberitahuan Pengujian Unit untuk Operasi Penyisipan Massal

Tes Jest ini memastikan emisi peristiwa dan mekanisme pemberitahuan berfungsi dengan benar di backend untuk Peristiwa Sisi Server di 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);
  });
});

Pertanyaan Umum Tentang SSE di NestJS

1. Apa manfaat menggunakan Peristiwa Sisi Server dibandingkan WebSockets?
2. SSE lebih sederhana untuk diimplementasikan dan menggunakan HTTP, sehingga ramah terhadap firewall. Tidak seperti WebSockets, ini hanya memerlukan satu koneksi searah, yang efisien untuk pembaruan waktu nyata.
3. Bisakah saya menggunakan @Sse dengan beberapa titik akhir di pengontrol?
4. Ya, Anda dapat mendefinisikan banyak @Sse titik akhir di pengontrol yang sama untuk menyajikan aliran data yang berbeda ke klien berdasarkan kebutuhan spesifik.
5. Bagaimana cara menangani kesalahan selama pemrosesan antrian?
6. Dengan BullMQ, Anda dapat menentukan opsi percobaan ulang dan menggunakan pendengar acara seperti @OnWorkerEvent('failed') untuk mencatat kesalahan dan memproses ulang pekerjaan jika perlu.
7. Apakah Prisma createMany metode mendukung pengembalian transaksi?
8. Ya, milik Prisma createMany dapat dibungkus dalam suatu transaksi. Jika ada operasi dalam transaksi yang gagal, semua operasi dibatalkan untuk konsistensi.
9. Apa yang terjadi jika klien terputus selama aliran SSE?
10. Server berhenti mengirimkan pembaruan setelah mendeteksi pemutusan sambungan. Anda dapat menerapkan logika koneksi ulang pada klien menggunakan EventSource API.
11. Bisakah SSE digunakan untuk komunikasi dua arah?
12. Tidak, SSE bersifat searah (server-ke-klien). Untuk komunikasi dua arah, gunakan aliran WebSockets atau HTTP2.
13. Bagaimana cara mengamankan titik akhir SSE di NestJS?
14. Gunakan penjaga atau middleware, seperti @UseGuards, untuk menerapkan autentikasi dan otorisasi untuk titik akhir SSE Anda.
15. Bisakah SSE bekerja dengan klien non-browser?
16. Ya, klien mana pun yang mendukung HTTP dan streaming peristiwa (mis., Node.js, cURL) dapat menggunakan aliran SSE.
17. Berapa jumlah maksimum klien yang dapat terhubung ke titik akhir SSE?
18. Hal ini bergantung pada konfigurasi server Anda dan batasan sumber daya. Penyeimbangan beban dan pengelompokan dapat membantu meningkatkan skala untuk mendukung lebih banyak klien.
19. Apakah mungkin mengirim data JSON melalui SSE?
20. Ya, Anda dapat membuat serial objek ke string JSON dan mengirimkannya menggunakan new MessageEvent di NestJS.

Notifikasi Real-Time yang Efektif di NestJS

Menerapkan sistem real-time menggunakan SSE di NestJS menyederhanakan komunikasi antara server dan klien. Metode ini mengurangi beban server dibandingkan dengan polling konstan dan memungkinkan penargetan notifikasi yang tepat. Misalnya, alat HR dapat memberi tahu 200 karyawan di bagian Penjualan tentang voucher baru tanpa mengganggu orang lain. 🎯

Dengan alat seperti BullMQ dan Prisma, pengaturan ini memastikan pemrosesan tugas yang tidak sinkron dan operasi database yang efisien. Fleksibilitas arsitektur berbasis peristiwa menjadikannya solusi terukur untuk berbagai kebutuhan real-time, meningkatkan keterlibatan pengguna dan keandalan sistem.