Pemberitahuan Mudah dalam NestJS Menggunakan Acara Sisi Pelayan untuk Operasi Pukal

Menghantar Pemberitahuan secara Pukal dengan Acara Sisi Pelayan (SSE) dalam NestJS

Penyelesaian ini menunjukkan pendekatan bahagian belakang untuk menggunakan NestJS dengan Prisma dan Acara Sisi Pelayan (SSE) untuk operasi pukal. Ia termasuk seni bina dipacu acara dan sistem baris gilir.

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

Kemas Kini Masa Nyata untuk Sisipan Pukal Menggunakan NestJS dan React

Contoh bahagian hadapan ini menggunakan React untuk mendengar Peristiwa Sisi Pelayan dan mengemas kini UI secara dinamik apabila data diterima. Ia memastikan pekerja mendapat pemberitahuan dalam masa nyata selepas sisipan pukal.

// 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 Sisipan Pukal

Ujian Jest ini memastikan pelepasan peristiwa dan mekanisme pemberitahuan berfungsi dengan betul di bahagian belakang untuk Peristiwa Sisi Pelayan dalam 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);
  });
});

Soalan Lazim Mengenai SSE dalam NestJS

1. Apakah faedah menggunakan Peristiwa Sisi Pelayan berbanding WebSockets?
2. SSE lebih mudah untuk dilaksanakan dan menggunakan HTTP, menjadikannya mesra tembok api. Tidak seperti WebSockets, ia hanya memerlukan satu sambungan satu arah, yang cekap untuk kemas kini masa nyata.
3. Boleh saya guna @Sse dengan berbilang titik akhir dalam pengawal?
4. Ya, anda boleh menentukan berbilang @Sse titik akhir dalam pengawal yang sama untuk menyampaikan aliran data yang berbeza kepada pelanggan berdasarkan keperluan khusus.
5. Bagaimanakah saya mengendalikan ralat semasa pemprosesan baris gilir?
6. Dengan BullMQ, anda boleh menentukan pilihan cuba semula dan menggunakan pendengar acara seperti @OnWorkerEvent('failed') untuk log ralat dan memproses semula kerja jika perlu.
7. Adakah Prisma's createMany kaedah sokongan balik urus niaga?
8. Ya, Prisma createMany boleh dibungkus dalam transaksi. Jika mana-mana operasi dalam urus niaga gagal, semua operasi akan ditarik balik untuk konsistensi.
9. Apakah yang berlaku jika pelanggan memutuskan sambungan semasa aliran SSE?
10. Pelayan berhenti menghantar kemas kini sebaik sahaja ia mengesan pemutusan sambungan. Anda boleh melaksanakan logik sambungan semula pada klien menggunakan EventSource API.
11. Bolehkah SSE digunakan untuk komunikasi dua hala?
12. Tidak, SSE adalah satu arah (pelayan-ke-klien). Untuk komunikasi dua hala, gunakan strim WebSockets atau HTTP2.
13. Bagaimanakah cara saya melindungi titik akhir SSE dalam NestJS?
14. Gunakan pengawal atau perisian tengah, seperti @UseGuards, untuk menguatkuasakan pengesahan dan kebenaran untuk titik akhir SSE anda.
15. Bolehkah SSE berfungsi dengan pelanggan bukan penyemak imbas?
16. Ya, mana-mana pelanggan yang menyokong HTTP dan penstriman acara (cth., Node.js, cURL) boleh menggunakan strim SSE.
17. Berapakah bilangan maksimum pelanggan yang boleh menyambung ke titik akhir SSE?
18. Ini bergantung pada konfigurasi pelayan anda dan had sumber. Pengimbangan beban dan pengelompokan boleh membantu skala untuk menyokong lebih ramai pelanggan.
19. Adakah mungkin untuk menghantar data JSON melalui SSE?
20. Ya, anda boleh menyerikan objek kepada rentetan JSON dan menghantarnya menggunakan new MessageEvent dalam NestJS.

Pemberitahuan Masa Nyata Berkesan dalam NestJS

Melaksanakan sistem masa nyata menggunakan SSE dalam NestJS memudahkan komunikasi antara pelayan dan pelanggan. Kaedah ini mengurangkan beban pelayan berbanding pengundian berterusan dan membolehkan penyasaran tepat untuk pemberitahuan. Sebagai contoh, alat HR boleh memberitahu 200 pekerja dalam Jualan tentang baucar baharu tanpa mengganggu orang lain. 🎯

Dengan alatan seperti BullMQ dan Prisma, persediaan ini memastikan pemprosesan tugas tak segerak dan operasi pangkalan data yang cekap. Fleksibiliti seni bina berasaskan acara menjadikannya penyelesaian berskala untuk pelbagai keperluan masa nyata, meningkatkan penglibatan pengguna dan kebolehpercayaan sistem.