Thông báo dễ dàng trong NestJS bằng cách sử dụng sự kiện phía máy chủ cho hoạt động hàng loạt

Gửi thông báo hàng loạt với các sự kiện phía máy chủ (SSE) trong NestJS

Giải pháp này thể hiện cách tiếp cận phụ trợ để sử dụng NestJS với Prisma và Sự kiện phía máy chủ (SSE) cho các hoạt động hàng loạt. Nó bao gồm một kiến ​​trúc hướng sự kiện và hệ thống xếp hàng.

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

Cập nhật theo thời gian thực để chèn hàng loạt bằng NestJS và React

Ví dụ về giao diện người dùng này sử dụng React để lắng nghe Sự kiện phía máy chủ và cập nhật giao diện người dùng một cách linh hoạt khi nhận được dữ liệu. Nó đảm bảo nhân viên nhận được thông báo theo thời gian thực sau khi chèn hàng loạt.

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

Thông báo kiểm tra đơn vị cho hoạt động chèn hàng loạt

Thử nghiệm Jest này đảm bảo cơ chế thông báo và phát sự kiện hoạt động chính xác trong phần phụ trợ cho Sự kiện phía máy chủ trong 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);
  });
});

Câu hỏi thường gặp về SSE trong NestJS

1. Lợi ích của việc sử dụng Sự kiện phía máy chủ trên WebSockets là gì?
2. SSE dễ triển khai và sử dụng HTTP hơn, khiến nó thân thiện với tường lửa. Không giống như WebSockets, nó chỉ yêu cầu một kết nối một chiều duy nhất, hiệu quả cho việc cập nhật theo thời gian thực.
3. Tôi có thể sử dụng không? @Sse với nhiều điểm cuối trong bộ điều khiển?
4. Có, bạn có thể xác định nhiều @Sse điểm cuối trong cùng một bộ điều khiển để phục vụ các luồng dữ liệu khác nhau cho khách hàng dựa trên nhu cầu cụ thể.
5. Làm cách nào để xử lý lỗi trong quá trình xử lý hàng đợi?
6. Với BullMQ, bạn có thể xác định các tùy chọn thử lại và sử dụng trình xử lý sự kiện như @OnWorkerEvent('failed') để ghi lại lỗi và xử lý lại công việc nếu cần thiết.
7. Liệu Prisma có createMany phương pháp hỗ trợ khôi phục giao dịch?
8. Vâng, của Prisma createMany có thể được gói gọn trong một giao dịch. Nếu bất kỳ thao tác nào trong giao dịch không thành công, tất cả các thao tác sẽ được khôi phục để đảm bảo tính nhất quán.
9. Điều gì xảy ra nếu máy khách ngắt kết nối trong luồng SSE?
10. Máy chủ ngừng gửi bản cập nhật khi phát hiện mất kết nối. Bạn có thể triển khai logic kết nối lại trên máy khách bằng cách sử dụng EventSource API.
11. SSE có thể được sử dụng để liên lạc hai chiều không?
12. Không, SSE là một chiều (từ máy chủ đến máy khách). Để liên lạc hai chiều, hãy sử dụng luồng WebSockets hoặc HTTP2.
13. Làm cách nào để bảo mật điểm cuối SSE trong NestJS?
14. Sử dụng các phần mềm bảo vệ hoặc phần mềm trung gian, như @UseGuards, để thực thi xác thực và ủy quyền cho điểm cuối SSE của bạn.
15. SSE có thể hoạt động với các máy khách không có trình duyệt không?
16. Có, bất kỳ ứng dụng khách nào hỗ trợ HTTP và truyền phát sự kiện (ví dụ: Node.js, cURL) đều có thể sử dụng luồng SSE.
17. Số lượng máy khách tối đa có thể kết nối với điểm cuối SSE là bao nhiêu?
18. Điều này phụ thuộc vào cấu hình máy chủ và giới hạn tài nguyên của bạn. Cân bằng tải và phân cụm có thể giúp mở rộng quy mô để hỗ trợ nhiều khách hàng hơn.
19. Có thể gửi dữ liệu JSON qua SSE không?
20. Có, bạn có thể tuần tự hóa các đối tượng thành chuỗi JSON và gửi chúng bằng cách sử dụng new MessageEvent trong NestJS.

Thông báo thời gian thực hiệu quả trong NestJS

Triển khai hệ thống thời gian thực bằng cách sử dụng SSE trong NestJS đơn giản hóa việc giao tiếp giữa máy chủ và máy khách. Phương pháp này giúp giảm tải máy chủ so với bỏ phiếu liên tục và cho phép nhắm mục tiêu chính xác cho thông báo. Ví dụ: một công cụ nhân sự có thể thông báo cho 200 nhân viên trong bộ phận Bán hàng về các chứng từ mới mà không làm gián đoạn những người khác. 🎯

Với các công cụ như BullMQ và Prisma, thiết lập này đảm bảo xử lý tác vụ không đồng bộ và vận hành cơ sở dữ liệu hiệu quả. Tính linh hoạt của kiến ​​trúc dựa trên sự kiện khiến nó trở thành giải pháp có thể mở rộng cho các yêu cầu thời gian thực khác nhau, nâng cao mức độ tương tác của người dùng và độ tin cậy của hệ thống.