மொத்த செயல்பாடுகளுக்கான சர்வர்-சைட் நிகழ்வுகளைப் பயன்படுத்தி NestJS இல் சிரமமற்ற அறிவிப்புகள்

NestJS இல் சர்வர்-சைட் நிகழ்வுகளுடன் (SSE) மொத்தமாக அறிவிப்புகளை அனுப்புகிறது

இந்தத் தீர்வு, ப்ரிஸ்மா மற்றும் சர்வர்-சைடு நிகழ்வுகளுடன் (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 மற்றும் ரியாக்டைப் பயன்படுத்தி மொத்த செருகல்களுக்கான நிகழ்நேர புதுப்பிப்புகள்

இந்த முன்னோட்ட உதாரணம், சர்வர் பக்க நிகழ்வுகளைக் கேட்க ரியாக்டைப் பயன்படுத்துகிறது மற்றும் தரவு பெறப்பட்டவுடன் 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;

மொத்த செருகல் செயல்பாடுகளுக்கான அலகு சோதனை அறிவிப்புகள்

இந்த ஜெஸ்ட் சோதனையானது நிகழ்வு உமிழ்வு மற்றும் அறிவிப்பு பொறிமுறையானது 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. WebSockets மூலம் சர்வர்-சைட் நிகழ்வுகளைப் பயன்படுத்துவதன் நன்மைகள் என்ன?
2. SSE செயல்படுத்த எளிதானது மற்றும் HTTP ஐப் பயன்படுத்துகிறது, இது ஃபயர்வாலுக்கு ஏற்றதாக அமைகிறது. WebSockets போலல்லாமல், இதற்கு ஒரே ஒரு திசை இணைப்பு மட்டுமே தேவைப்படுகிறது, இது நிகழ்நேர புதுப்பிப்புகளுக்கு பயனுள்ளதாக இருக்கும்.
3. நான் பயன்படுத்தலாமா @Sse ஒரு கட்டுப்படுத்தியில் பல முனைப்புள்ளிகளுடன்?
4. ஆம், நீங்கள் பலவற்றை வரையறுக்கலாம் @Sse குறிப்பிட்ட தேவைகளின் அடிப்படையில் வாடிக்கையாளர்களுக்கு வெவ்வேறு தரவு ஸ்ட்ரீம்களை வழங்க ஒரே கட்டுப்படுத்தியில் உள்ள இறுதிப்புள்ளிகள்.
5. வரிசை செயலாக்கத்தின் போது பிழைகளை எவ்வாறு கையாள்வது?
6. BullMQ மூலம், நீங்கள் மீண்டும் முயற்சி விருப்பங்களை வரையறுக்கலாம் மற்றும் நிகழ்வு கேட்பவர்களைப் பயன்படுத்தலாம் @OnWorkerEvent('failed') பிழைகளை பதிவு செய்யவும் மற்றும் தேவைப்பட்டால் வேலைகளை மீண்டும் செயலாக்கவும்.
7. ப்ரிஸ்மா தான் createMany முறை ஆதரவு பரிவர்த்தனை திரும்பப்பெறுமா?
8. ஆம், ப்ரிஸ்மா தான் createMany ஒரு பரிவர்த்தனையில் மூடப்பட்டிருக்கும். பரிவர்த்தனையில் ஏதேனும் செயல்பாடு தோல்வியுற்றால், அனைத்து செயல்பாடுகளும் நிலைத்தன்மைக்காக திரும்பப் பெறப்படும்.
9. SSE ஸ்ட்ரீமின் போது கிளையன்ட் துண்டிக்கப்பட்டால் என்ன நடக்கும்?
10. சேவையகம் துண்டிக்கப்பட்டதைக் கண்டறிந்தவுடன் புதுப்பிப்புகளை அனுப்புவதை நிறுத்துகிறது. இதைப் பயன்படுத்தி கிளையண்டில் மீண்டும் இணைக்கும் தர்க்கத்தை நீங்கள் செயல்படுத்தலாம் EventSource API.
11. இருவழித் தொடர்புக்கு SSEஐப் பயன்படுத்த முடியுமா?
12. இல்லை, SSE என்பது ஒரே திசையில் (சர்வர்-டு-கிளையன்ட்). இருதரப்பு தொடர்புக்கு, WebSockets அல்லது 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 இல் பயனுள்ள நிகழ்நேர அறிவிப்புகள்

பயன்படுத்தி நிகழ் நேர அமைப்புகளை செயல்படுத்துதல் எஸ்எஸ்இ NestJS இல் சேவையகத்திற்கும் கிளையண்டுகளுக்கும் இடையிலான தொடர்பை எளிதாக்குகிறது. நிலையான வாக்குப்பதிவுடன் ஒப்பிடும்போது இந்த முறை சர்வர் சுமையை குறைக்கிறது மற்றும் அறிவிப்புகளுக்கான துல்லியமான இலக்கை செயல்படுத்துகிறது. எடுத்துக்காட்டாக, HR கருவியானது விற்பனையில் உள்ள 200 ஊழியர்களுக்கு புதிய வவுச்சர்களைப் பற்றி மற்றவர்களுக்கு இடையூறு விளைவிக்காமல் தெரிவிக்க முடியும். 🎯

BullMQ மற்றும் Prisma போன்ற கருவிகளுடன், இந்த அமைப்பு ஒத்திசைவற்ற பணி செயலாக்கம் மற்றும் திறமையான தரவுத்தள செயல்பாடுகளை உறுதி செய்கிறது. நிகழ்வு அடிப்படையிலான கட்டமைப்பின் நெகிழ்வுத்தன்மையானது பல்வேறு நிகழ் நேரத் தேவைகளுக்கான அளவிடக்கூடிய தீர்வாக அமைகிறது, பயனர் ஈடுபாடு மற்றும் கணினி நம்பகத்தன்மையை மேம்படுத்துகிறது.