サーバーサイドイベントを使用した一括操作による 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 などのツールを使用すると、このセットアップにより、非同期タスク処理と効率的なデータベース操作が保証されます。イベントベースのアーキテクチャの柔軟性により、さまざまなリアルタイム要件に対応するスケーラブルなソリューションとなり、ユーザー エンゲージメントとシステムの信頼性が向上します。