थोक संचालन के लिए सर्वर-साइड इवेंट का उपयोग करके NestJS में सरल सूचनाएं

NestJS में सर्वर-साइड इवेंट (SSE) के साथ थोक में सूचनाएं भेजना

यह समाधान थोक संचालन के लिए प्रिज्मा और सर्वर-साइड इवेंट्स (एसएसई) के साथ नेस्टजेएस का उपयोग करने के लिए बैकएंड दृष्टिकोण प्रदर्शित करता है। इसमें एक घटना-संचालित वास्तुकला और कतार प्रणाली शामिल है।

// 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 का उपयोग करके बल्क इंसर्ट के लिए रीयल-टाइम अपडेट

यह फ्रंटएंड उदाहरण सर्वर-साइड इवेंट को सुनने और डेटा प्राप्त होने पर यूआई को गतिशील रूप से अपडेट करने के लिए रिएक्ट का उपयोग करता है। यह सुनिश्चित करता है कि थोक प्रविष्टियों के बाद कर्मचारियों को वास्तविक समय में सूचित किया जाए।

// 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 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. WebSockets पर सर्वर-साइड इवेंट का उपयोग करने के क्या लाभ हैं?
2. SSE को लागू करना आसान है और HTTP का उपयोग करता है, जो इसे फ़ायरवॉल-अनुकूल बनाता है। वेबसॉकेट के विपरीत, इसके लिए केवल एक यूनिडायरेक्शनल कनेक्शन की आवश्यकता होती है, जो वास्तविक समय अपडेट के लिए कुशल है।
3. क्या मैं उपयोग कर सकता हूँ @Sse एक नियंत्रक में एकाधिक समापन बिंदुओं के साथ?
4. हाँ, आप एकाधिक को परिभाषित कर सकते हैं @Sse विशिष्ट आवश्यकताओं के आधार पर ग्राहकों को विभिन्न डेटा स्ट्रीम प्रदान करने के लिए एक ही नियंत्रक में एंडपॉइंट।
5. मैं कतार प्रसंस्करण के दौरान त्रुटियों से कैसे निपटूँ?
6. BullMQ के साथ, आप पुनः प्रयास विकल्पों को परिभाषित कर सकते हैं और इवेंट श्रोताओं का उपयोग कर सकते हैं @OnWorkerEvent('failed') यदि आवश्यक हो तो त्रुटियों को लॉग करने और नौकरियों को पुन: संसाधित करने के लिए।
7. क्या प्रिज्मा का createMany विधि समर्थन लेनदेन रोलबैक?
8. हाँ, प्रिज्मा का createMany लेन-देन में लपेटा जा सकता है। यदि लेन-देन में कोई भी ऑपरेशन विफल हो जाता है, तो स्थिरता के लिए सभी ऑपरेशन वापस ले लिए जाते हैं।
9. यदि एसएसई स्ट्रीम के दौरान क्लाइंट डिस्कनेक्ट हो जाए तो क्या होगा?
10. वियोग का पता चलते ही सर्वर अपडेट भेजना बंद कर देता है। आप इसका उपयोग करके क्लाइंट पर रीकनेक्ट लॉजिक लागू कर सकते हैं EventSource एपीआई.
11. क्या एसएसई का उपयोग दोतरफा संचार के लिए किया जा सकता है?
12. नहीं, SSE यूनिडायरेक्शनल (सर्वर-टू-क्लाइंट) है। द्विदिश संचार के लिए, WebSockets या HTTP2 स्ट्रीम का उपयोग करें।
13. मैं NestJS में SSE समापनबिंदु कैसे सुरक्षित करूं?
14. जैसे गार्ड या मिडलवेयर का उपयोग करें @UseGuards, आपके एसएसई एंडपॉइंट के लिए प्रमाणीकरण और प्राधिकरण लागू करने के लिए।
15. क्या एसएसई गैर-ब्राउज़र क्लाइंट के साथ काम कर सकता है?
16. हां, कोई भी क्लाइंट जो HTTP और इवेंट स्ट्रीमिंग (जैसे, Node.js, cURL) का समर्थन करता है, SSE स्ट्रीम का उपभोग कर सकता है।
17. एसएसई एंडपॉइंट से जुड़ने वाले ग्राहकों की अधिकतम संख्या क्या है?
18. यह आपके सर्वर के कॉन्फ़िगरेशन और संसाधन सीमाओं पर निर्भर करता है। लोड संतुलन और क्लस्टरिंग स्केल को अधिक ग्राहकों का समर्थन करने में मदद कर सकता है।
19. क्या SSE पर JSON डेटा भेजना संभव है?
20. हां, आप ऑब्जेक्ट को JSON स्ट्रिंग्स में क्रमबद्ध कर सकते हैं और उनका उपयोग करके भेज सकते हैं new MessageEvent नेस्टजेएस में।

NestJS में प्रभावी वास्तविक समय सूचनाएं

वास्तविक समय प्रणालियों का उपयोग करके कार्यान्वित करना एसएसई NestJS में सर्वर और क्लाइंट के बीच संचार सरल हो जाता है। यह विधि निरंतर मतदान की तुलना में सर्वर लोड को कम करती है और सूचनाओं के लिए सटीक लक्ष्यीकरण सक्षम करती है। उदाहरण के लिए, एक एचआर टूल दूसरों को बाधित किए बिना सेल्स में 200 कर्मचारियों को नए वाउचर के बारे में सूचित कर सकता है। 🎯

बुलएमक्यू और प्रिज्मा जैसे टूल के साथ, यह सेटअप अतुल्यकालिक कार्य प्रसंस्करण और कुशल डेटाबेस संचालन सुनिश्चित करता है। इवेंट-आधारित आर्किटेक्चर का लचीलापन इसे विभिन्न वास्तविक समय की आवश्यकताओं के लिए एक स्केलेबल समाधान बनाता है, जो उपयोगकर्ता जुड़ाव और सिस्टम विश्वसनीयता को बढ़ाता है।