بلک آپریشنز کے لیے سرور سائیڈ ایونٹس کا استعمال کرتے ہوئے 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 اور React کا استعمال کرتے ہوئے بلک انسرٹس کے لیے ریئل ٹائم اپڈیٹس

یہ فرنٹ اینڈ مثال سرور سائیڈ ایونٹس کو سننے اور ڈیٹا موصول ہوتے ہی UI کو متحرک طور پر اپ ڈیٹ کرنے کے لیے 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;

بلک انسرٹ آپریشنز کے لیے یونٹ ٹیسٹنگ کی اطلاعات

یہ جیسٹ ٹیسٹ اس بات کو یقینی بناتا ہے کہ ایونٹ کے اخراج اور نوٹیفکیشن کا طریقہ کار 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. ویب ساکٹس پر سرور سائیڈ ایونٹس استعمال کرنے کے کیا فوائد ہیں؟
2. SSE لاگو کرنا آسان ہے اور HTTP کا استعمال کرتا ہے، اسے فائر وال کے موافق بناتا ہے۔ WebSockets کے برعکس، اس کے لیے صرف ایک یک سمت کنکشن کی ضرورت ہوتی ہے، جو حقیقی وقت کی تازہ کاریوں کے لیے کارآمد ہے۔
3. کیا میں استعمال کر سکتا ہوں؟ @Sse ایک کنٹرولر میں متعدد اختتامی نقطوں کے ساتھ؟
4. ہاں، آپ متعدد کی وضاحت کر سکتے ہیں۔ @Sse مخصوص ضروریات کی بنیاد پر کلائنٹس کو مختلف ڈیٹا اسٹریمز فراہم کرنے کے لیے ایک ہی کنٹرولر میں اینڈ پوائنٹس۔
5. قطار پروسیسنگ کے دوران میں غلطیوں کو کیسے ہینڈل کروں؟
6. BullMQ کے ساتھ، آپ دوبارہ کوشش کرنے کے اختیارات کی وضاحت کر سکتے ہیں اور ایونٹ کے سننے والوں کو استعمال کر سکتے ہیں۔ @OnWorkerEvent('failed') غلطیوں کو لاگ ان کرنے اور اگر ضروری ہو تو نوکریوں کو دوبارہ عمل کرنے کے لئے۔
7. Prisma کی ہے createMany طریقہ سپورٹ لین دین رول بیکس؟
8. ہاں، پریزما کا createMany ایک لین دین میں لپیٹ کر سکتے ہیں. اگر لین دین میں کوئی بھی آپریشن ناکام ہو جاتا ہے تو، تمام کارروائیوں کو مستقل مزاجی کے لیے واپس کر دیا جاتا ہے۔
9. اگر کلائنٹ ایک SSE سلسلہ کے دوران منقطع ہو جائے تو کیا ہوتا ہے؟
10. سرور منقطع ہونے کا پتہ لگانے کے بعد اپ ڈیٹس بھیجنا بند کر دیتا ہے۔ آپ کلائنٹ پر دوبارہ منسلک منطق کو استعمال کر سکتے ہیں۔ EventSource API
11. کیا SSE کو دو طرفہ مواصلات کے لیے استعمال کیا جا سکتا ہے؟
12. نہیں، ایس ایس ای یک طرفہ ہے (سرور سے کلائنٹ)۔ دو طرفہ مواصلات کے لیے، 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 جیسے ٹولز کے ساتھ، یہ سیٹ اپ غیر مطابقت پذیر ٹاسک پروسیسنگ اور موثر ڈیٹا بیس آپریشنز کو یقینی بناتا ہے۔ ایونٹ پر مبنی فن تعمیر کی لچک اسے مختلف ریئل ٹائم تقاضوں کے لیے ایک قابل توسیع حل بناتی ہے، جس سے صارف کی مصروفیت اور سسٹم کی وشوسنییتا میں اضافہ ہوتا ہے۔