বাল্ক অপারেশনের জন্য সার্ভার-সাইড ইভেন্ট ব্যবহার করে 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. ওয়েবসকেটগুলিতে সার্ভার-সাইড ইভেন্টগুলি ব্যবহার করার সুবিধাগুলি কী কী?
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. আমি কীভাবে নেস্টজেএস-এ এসএসই শেষ পয়েন্টগুলি সুরক্ষিত করব?
14. গার্ড বা মিডলওয়্যার ব্যবহার করুন, যেমন @UseGuards, আপনার SSE এন্ডপয়েন্টের জন্য প্রমাণীকরণ এবং অনুমোদন কার্যকর করতে।
15. SSE কি অ-ব্রাউজার ক্লায়েন্টদের সাথে কাজ করতে পারে?
16. হ্যাঁ, যেকোন ক্লায়েন্ট যেটি HTTP এবং ইভেন্ট স্ট্রিমিং সমর্থন করে (যেমন, Node.js, cURL) SSE স্ট্রিমগুলি ব্যবহার করতে পারে৷
17. একটি SSE এন্ডপয়েন্টের সাথে সংযোগ করতে পারে এমন ক্লায়েন্টের সর্বাধিক সংখ্যা কত?
18. এটি আপনার সার্ভারের কনফিগারেশন এবং সংস্থান সীমার উপর নির্ভর করে। লোড ব্যালেন্সিং এবং ক্লাস্টারিং আরও ক্লায়েন্টদের সমর্থন করার জন্য স্কেল সাহায্য করতে পারে।
19. SSE এর মাধ্যমে কি JSON ডেটা পাঠানো সম্ভব?
20. হ্যাঁ, আপনি JSON স্ট্রিংগুলিতে অবজেক্টকে সিরিয়ালাইজ করতে পারেন এবং সেগুলি ব্যবহার করে পাঠাতে পারেন new MessageEvent নেস্টজেএস-এ।

NestJS-এ কার্যকর রিয়েল-টাইম বিজ্ঞপ্তি

ব্যবহার করে রিয়েল-টাইম সিস্টেম বাস্তবায়ন করা এসএসই NestJS-এ সার্ভার এবং ক্লায়েন্টদের মধ্যে যোগাযোগ সহজতর করে। এই পদ্ধতিটি স্থির ভোটের তুলনায় সার্ভারের লোড হ্রাস করে এবং বিজ্ঞপ্তিগুলির জন্য সুনির্দিষ্ট লক্ষ্যমাত্রা সক্ষম করে। উদাহরণস্বরূপ, একটি এইচআর টুল অন্যদের ব্যাহত না করে নতুন ভাউচার সম্পর্কে বিক্রয়ের 200 কর্মচারীকে অবহিত করতে পারে। 🎯

BullMQ এবং Prisma এর মত টুলের সাথে, এই সেটআপটি অ্যাসিঙ্ক্রোনাস টাস্ক প্রসেসিং এবং দক্ষ ডাটাবেস অপারেশন নিশ্চিত করে। ইভেন্ট-ভিত্তিক আর্কিটেকচারের নমনীয়তা এটিকে বিভিন্ন রিয়েল-টাইম প্রয়োজনীয়তার জন্য একটি মাপযোগ্য সমাধান করে তোলে, ব্যবহারকারীর ব্যস্ততা এবং সিস্টেমের নির্ভরযোগ্যতা বাড়ায়।