જથ્થાબંધ કામગીરી માટે સર્વર-સાઇડ ઇવેન્ટ્સનો ઉપયોગ કરીને 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 નો ઉપયોગ કરે છે, તેને ફાયરવોલ-ફ્રેંડલી બનાવે છે. વેબસોકેટ્સથી વિપરીત, તેને ફક્ત એક જ દિશાહીન જોડાણની જરૂર છે, જે રીઅલ-ટાઇમ અપડેટ્સ માટે કાર્યક્ષમ છે.
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 માં અસરકારક રીઅલ-ટાઇમ સૂચનાઓ

રીઅલ-ટાઇમ સિસ્ટમનો ઉપયોગ કરીને અમલીકરણ SSE NestJS માં સર્વર અને ક્લાયન્ટ્સ વચ્ચેના સંચારને સરળ બનાવે છે. આ પદ્ધતિ સતત મતદાનની સરખામણીમાં સર્વર લોડ ઘટાડે છે અને સૂચનાઓ માટે ચોક્કસ લક્ષ્યીકરણને સક્ષમ કરે છે. ઉદાહરણ તરીકે, એચઆર ટૂલ વેચાણમાં રહેલા 200 કર્મચારીઓને અન્યને ખલેલ પહોંચાડ્યા વિના નવા વાઉચર વિશે સૂચિત કરી શકે છે. 🎯

BullMQ અને Prisma જેવા ટૂલ્સ સાથે, આ સેટઅપ અસિંક્રોનસ ટાસ્ક પ્રોસેસિંગ અને કાર્યક્ષમ ડેટાબેઝ કામગીરીને સુનિશ્ચિત કરે છે. ઇવેન્ટ-આધારિત આર્કિટેક્ચરની લવચીકતા તેને વિવિધ રીઅલ-ટાઇમ આવશ્યકતાઓ માટે સ્કેલેબલ સોલ્યુશન બનાવે છે, વપરાશકર્તા જોડાણ અને સિસ્ટમની વિશ્વસનીયતામાં વધારો કરે છે.