मोठ्या प्रमाणात ऑपरेशन्ससाठी सर्व्हर-साइड इव्हेंट वापरून NestJS मधील अथक सूचना

बल्क इन्सर्ट ऑपरेशन्ससाठी सुव्यवस्थित सूचना वितरण

कल्पना करा की तुम्ही अशी प्रणाली व्यवस्थापित करत आहात जिथे विभाग, श्रेणी किंवा अनुभव यासारख्या विविध निकषांवर आधारित शेकडो कर्मचाऱ्यांना व्हाउचर नियुक्त केले जातात. सिस्टममध्ये अडथळे निर्माण न करता प्रत्येक कर्मचाऱ्याला कार्यक्षमतेने सूचित करणे हे एक मोठे काम आहे. 🔔 जेव्हा तुम्ही सॉकेट्स किंवा मतदान यंत्रणेतील गुंतागुंत टाळण्याचे उद्दिष्ट ठेवता तेव्हा हे आव्हान आणखी कठीण होते.

अशा परिस्थितीत, सर्व्हर-साइड इव्हेंट्स (SSE) एक शक्तिशाली परंतु सरळ उपाय म्हणून उदयास येतात. तुमच्या NestJS ऍप्लिकेशनमध्ये SSE चा फायदा घेऊन, तुम्ही डायनॅमिक निकषांवर आधारित कर्मचाऱ्यांच्या विशिष्ट गटांना सूचित करण्यासाठी रिअल-टाइम कम्युनिकेशन चॅनेल स्थापित करू शकता. उदाहरणार्थ, जेव्हा विक्री विभागाला व्हाउचरचे वाटप केले जाते, तेव्हा केवळ त्या कर्मचाऱ्यांनाच सूचना प्राप्त झाल्या पाहिजेत, अचूक आणि अर्थपूर्ण अद्यतनांची खात्री करून.

या लेखाद्वारे, आम्ही एक व्यावहारिक उदाहरण पाहू जे NestJS वापरून मोठ्या प्रमाणात समाविष्ट करण्याच्या प्रक्रियेमध्ये SSE कसे समाकलित करायचे हे दर्शविते. बॅकएंडमध्ये इव्हेंट ट्रिगर करण्यापासून ते फ्रंटएंडवरील अपडेट्स ऐकण्यापर्यंत, अखंड कार्यप्रदर्शन राखून आम्ही जीवनचक्र पार करू. 💼

तुम्ही एचआर टूल किंवा फायनान्स ॲप विकसित करत असलात तरीही, हा वर्कफ्लो समजून घेणे तुम्हाला रिअल-टाइममध्ये वैयक्तिकृत सूचना वितरीत करण्यास सक्षम करेल. चला SSE ची साधेपणा आणि ते तुमच्या अनुप्रयोगाचा वापरकर्ता अनुभव कसा वाढवू शकतो ते उलगडू या.

सर्व्हर-साइड इव्हेंट आणि रांगांसह कार्यक्षम सूचना

प्रदान केलेल्या स्क्रिप्ट्स अशा प्रणालीचे वर्णन करतात जिथे डेटाबेसमध्ये मोठ्या प्रमाणात व्हाउचर रेकॉर्ड समाविष्ट केल्यानंतर कर्मचाऱ्यांना रिअल-टाइम सूचना पाठवल्या जातात. मध्ये प्रक्रिया सुरू होते वाटप व्हाउचरकंट्रोलर, जे व्हाउचर वाटप कार्ये तयार करण्यासाठी एंडपॉइंट उघड करते. जेव्हा एखादे कार्य तयार केले जाते, तेव्हा ते नावाच्या इव्हेंटचे उत्सर्जन करते वाटप नंतर-वाउचर. सिस्टम इव्हेंट-चालित आणि मॉड्यूलर आहे याची खात्री करून, त्यानंतरच्या चरणांना ट्रिगर करण्यासाठी हा कार्यक्रम आवश्यक आहे. हे डिझाइन समस्यांचे स्पष्ट पृथक्करण करण्यास अनुमती देते, ज्यामुळे सिस्टम अधिक देखरेख करण्यायोग्य आणि स्केलेबल बनते. 🎯

सेवा स्तरामध्ये, द वाटप व्हाउचरसेवा BullMQ वापरून रांगेतील कार्यांसाठी तर्क हाताळते. प्राप्त केल्यानंतर वाटप नंतर-वाउचर इव्हेंट, ते नावाच्या रांगेत नोकरी जोडते वाटप-व्हाउचर. ही रांग असिंक्रोनस प्रक्रियेस अनुमती देते, हे सुनिश्चित करते की मोठ्या डेटासेटवर प्रक्रिया करत असतानाही सिस्टम प्रतिसादात्मक राहते. उदाहरणार्थ, तुम्ही विक्री विभागातील 200 कर्मचाऱ्यांना व्हाउचरचे वाटप केल्यास, रांग हे सुनिश्चित करते की ऑपरेशन इतर विनंत्या ब्लॉक करत नाही. रांगेच्या कॉन्फिगरेशनमध्ये यासारखे पर्याय समाविष्ट आहेत removeOnComplete काम पूर्ण झाल्यानंतर रेडिस स्वच्छ ठेवण्यासाठी.

रांगेतील नोकऱ्यांवर प्रक्रिया केली जाते AllotVoucherConsumer वर्ग येथे, संबंधित कर्मचाऱ्यांना ओळखण्यासाठी आणि डेटाबेसमध्ये व्हाउचर रेकॉर्ड समाविष्ट करण्यासाठी तर्क लागू केला जातो. प्रिझ्मा कमांड अनेक तयार करा मध्ये रेकॉर्ड बॅच-इन्सर्ट करण्यासाठी वापरला जातो कर्मचारी व्हाउचर टेबल, जे कार्यक्षमतेसाठी ऑप्टिमाइझ केले आहे. डेटाबेस ऑपरेशन पूर्ण झाल्यानंतर, सदस्यांना सूचित करण्यासाठी आणखी एक कार्यक्रम सोडला जातो. हा इव्हेंट खात्री देतो की मोठ्या प्रमाणात इन्सर्शन यशस्वीरीत्या प्रक्रिया केल्यानंतरच कर्मचाऱ्यांना सूचित केले जाते, सूचना प्रणालीमध्ये विश्वासार्हता जोडली जाते. 🌟

फ्रंटएंडवर, प्रतिक्रिया घटक सर्व्हरने पाठवलेल्या घटना ऐकतो कार्यक्रम स्रोत. कर्मचाऱ्यांना सूचित केल्याप्रमाणे, पृष्ठ रिफ्रेश न करता त्यांचे तपशील UI मध्ये गतिमानपणे अद्यतनित केले जातात. लाइव्ह स्पोर्ट्स स्कोअर किंवा सोशल मीडिया नोटिफिकेशन्स यांसारख्या आधुनिक वेब ॲप्लिकेशन्समध्ये दिसणाऱ्या रिअल-टाइम अपडेट्सप्रमाणेच हा दृष्टिकोन अखंड वापरकर्ता अनुभव प्रदान करतो. उदाहरणार्थ, एचआर विभागातील कर्मचाऱ्यांना विक्रीसाठी अभिप्रेत असलेली अद्यतने दिसणार नाहीत, कारण बॅकएंड वाटप निकषांवर आधारित इव्हेंट्स अचूकपणे फिल्टर करतो. ही विशिष्टता कार्यक्षमता आणि प्रासंगिकता दोन्ही वाढवते, वापरकर्ता-केंद्रित प्रणाली तयार करते. 🖥️

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

१

// 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 सह रिअल-टाइम सिस्टम्स वाढवणे

आम्ही कर्मचाऱ्यांना व्हाउचर वाटपाबद्दल सूचित करण्यासाठी सर्व्हर-साइड इव्हेंट्स (SSE) च्या अंमलबजावणीचा शोध घेतला असताना, रिअल-टाइम सिस्टीममध्ये SSE साठी एक व्यापक वापर प्रकरण आहे. एसएसई अशा परिस्थितीत चमकते जेथे क्लायंटला सतत मतदान न करता सर्व्हर डेटासह अद्यतनित राहण्याची आवश्यकता असते. उदाहरणार्थ, फ्लॅश सेल दरम्यान लाईव्ह इन्व्हेंटरी अपडेट्स ट्रॅक करणाऱ्या ऑनलाइन रिटेल प्लॅटफॉर्मबद्दल विचार करा. SSE चा वापर करून, तुम्ही सर्व कनेक्टेड क्लायंटना अद्ययावत कार्यक्षमतेने पुश करू शकता, हे सुनिश्चित करून की ते अनावश्यक सर्व्हर लोड न करता नवीनतम स्टॉक पातळी पाहतात. हा दृष्टीकोन वापरकर्ता अनुभव अखंड ठेवताना स्केलेबिलिटी सुनिश्चित करतो. 🛒

BullMQ सारख्या प्रगत रांग प्रणालींचा समावेश करणे, जसे की आम्ही केले वाटप-व्हाउचर रांग, बल्क डेटा प्रोसेसिंग टास्कमध्ये मजबुती जोडते. रांग हे सुनिश्चित करते की सर्व्हर रीस्टार्ट झाला तरीही, प्रलंबित कार्ये कायम राहतील आणि प्रक्रिया पुन्हा सुरू होईल. याव्यतिरिक्त, अयशस्वी नोकऱ्या (उदा. तात्पुरत्या डेटाबेस डाउनटाइममुळे) आपोआप पुन्हा प्रयत्न केले जातील याची खात्री करून, पुन्हा प्रयत्न करण्याची यंत्रणा कॉन्फिगर केली जाऊ शकते. उदाहरणार्थ, विभागांमधील 300 कर्मचाऱ्यांना वाटप करताना तात्पुरती त्रुटी आढळल्यास, रांगेची लवचिकता हे सुनिश्चित करते की कोणतीही रेकॉर्ड प्रक्रिया न करता सोडली जाणार नाही, ज्यामुळे तुमच्या सिस्टमची विश्वसनीयता वाढते.

रीअल-टाइम नोटिफिकेशन्सच्या पलीकडे, SSE तपशीलवार सारांश आवश्यक असलेल्या कार्यांसाठी ईमेल सेवा देखील पूरक करू शकते. सर्व व्हाउचर सूचना SSE द्वारे पाठवल्यानंतर, बॅकएंड असिंक्रोनसपणे अहवाल तयार करू शकतो आणि व्यवस्थापकांना एकत्रित ईमेल पाठवू शकतो. हे मल्टी-चॅनेल संप्रेषण तात्काळ सूचना आणि व्यापक फॉलो-अप दोन्ही सुनिश्चित करते, वापरकर्त्याच्या प्राधान्यांच्या विस्तृत श्रेणीची पूर्तता करते. असे एकत्रीकरण तुमच्या सिस्टमची लवचिकता वाढवते, एक चांगला वापरकर्ता अनुभव तयार करते. 📧