대량 작업을 위해 서버 측 이벤트를 사용하는 NestJS의 간편한 알림

NestJS에서 서버 측 이벤트(SSE)를 사용하여 대량 알림 보내기

이 솔루션은 대량 작업을 위해 Prisma 및 서버 측 이벤트(SSE)와 함께 NestJS를 사용하는 백엔드 접근 방식을 보여줍니다. 여기에는 이벤트 기반 아키텍처와 대기열 시스템이 포함됩니다.

// 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를 사용하여 서버측 이벤트를 수신하고 데이터가 수신될 때 UI를 동적으로 업데이트합니다. 대량 삽입 후 직원이 실시간으로 알림을 받을 수 있습니다.

// 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 테스트는 이벤트 방출 및 알림 메커니즘이 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);
  });
});

NestJS의 SSE에 대해 자주 묻는 질문

1. WebSocket보다 서버측 이벤트를 사용하면 어떤 이점이 있나요?
2. SSE는 구현이 더 간단하고 HTTP를 사용하므로 방화벽 친화적입니다. WebSocket과 달리 단일 단방향 연결만 필요하므로 실시간 업데이트에 효율적입니다.
3. 사용할 수 있나요? @Sse 컨트롤러에 여러 엔드포인트가 있나요?
4. 예, 여러 개를 정의할 수 있습니다 @Sse 특정 요구 사항에 따라 클라이언트에 다양한 데이터 스트림을 제공하기 위해 동일한 컨트롤러의 엔드포인트.
5. 대기열 처리 중 오류를 어떻게 처리합니까?
6. BullMQ를 사용하면 재시도 옵션을 정의하고 다음과 같은 이벤트 리스너를 사용할 수 있습니다. @OnWorkerEvent('failed') 필요한 경우 오류를 기록하고 작업을 다시 처리합니다.
7. 프리즈마는요? createMany 메소드가 트랜잭션 롤백을 지원합니까?
8. 응, 프리즈마 createMany 트랜잭션으로 래핑될 수 있습니다. 트랜잭션의 작업 중 하나라도 실패하면 일관성을 위해 모든 작업이 롤백됩니다.
9. SSE 스트림 중에 클라이언트 연결이 끊어지면 어떻게 되나요?
10. 서버는 연결 끊김을 감지하면 업데이트 전송을 중지합니다. 다음을 사용하여 클라이언트에서 재연결 논리를 구현할 수 있습니다. EventSource API.
11. SSE를 양방향 통신에 사용할 수 있습니까?
12. 아니요, SSE는 단방향(서버-클라이언트)입니다. 양방향 통신의 경우 WebSocket 또는 HTTP2 스트림을 사용하십시오.
13. NestJS에서 SSE 엔드포인트를 어떻게 보호하나요?
14. 다음과 같은 가드나 미들웨어를 사용하세요. @UseGuards, SSE 엔드포인트에 대한 인증 및 권한 부여를 시행합니다.
15. SSE는 브라우저가 아닌 클라이언트와도 작동할 수 있나요?
16. 예, HTTP 및 이벤트 스트리밍(예: Node.js, cURL)을 지원하는 모든 클라이언트는 SSE 스트림을 사용할 수 있습니다.
17. SSE 엔드포인트에 연결할 수 있는 클라이언트의 최대 수는 몇 개입니까?
18. 이는 서버의 구성 및 리소스 제한에 따라 다릅니다. 로드 밸런싱과 클러스터링은 더 많은 클라이언트를 지원하도록 확장하는 데 도움이 됩니다.
19. SSE를 통해 JSON 데이터를 보낼 수 있나요?
20. 예, 객체를 JSON 문자열로 직렬화하고 다음을 사용하여 보낼 수 있습니다. new MessageEvent NestJS에서.

NestJS의 효과적인 실시간 알림

실시간 시스템을 구현하는 방법 SSE NestJS에서는 서버와 클라이언트 간의 통신을 단순화합니다. 이 방법은 지속적인 폴링에 비해 서버 부하를 줄이고 알림에 대한 정확한 타겟팅을 가능하게 합니다. 예를 들어 HR 도구는 다른 직원을 방해하지 않고 영업 부서의 직원 200명에게 새 바우처에 대해 알릴 수 있습니다. 🎯

BullMQ 및 Prisma와 같은 도구를 사용하면 이 설정을 통해 비동기 작업 처리 및 효율적인 데이터베이스 작업이 보장됩니다. 이벤트 기반 아키텍처의 유연성은 다양한 실시간 요구 사항에 대한 확장 가능한 솔루션을 제공하여 사용자 참여와 시스템 안정성을 향상시킵니다.