ಬೃಹತ್ ಕಾರ್ಯಾಚರಣೆಗಳಿಗಾಗಿ ಸರ್ವರ್-ಸೈಡ್ ಈವೆಂಟ್‌ಗಳನ್ನು ಬಳಸಿಕೊಂಡು 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. 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 ನಲ್ಲಿ ಸರ್ವರ್ ಮತ್ತು ಕ್ಲೈಂಟ್‌ಗಳ ನಡುವಿನ ಸಂವಹನವನ್ನು ಸರಳಗೊಳಿಸುತ್ತದೆ. ಈ ವಿಧಾನವು ನಿರಂತರ ಮತದಾನಕ್ಕೆ ಹೋಲಿಸಿದರೆ ಸರ್ವರ್ ಲೋಡ್ ಅನ್ನು ಕಡಿಮೆ ಮಾಡುತ್ತದೆ ಮತ್ತು ಅಧಿಸೂಚನೆಗಳಿಗೆ ನಿಖರವಾದ ಗುರಿಯನ್ನು ಸಕ್ರಿಯಗೊಳಿಸುತ್ತದೆ. ಉದಾಹರಣೆಗೆ, HR ಉಪಕರಣವು ಇತರರಿಗೆ ಅಡ್ಡಿಪಡಿಸದೆಯೇ ಹೊಸ ವೋಚರ್‌ಗಳ ಕುರಿತು ಮಾರಾಟದಲ್ಲಿರುವ 200 ಉದ್ಯೋಗಿಗಳಿಗೆ ಸೂಚಿಸಬಹುದು. 🎯

BullMQ ಮತ್ತು Prisma ನಂತಹ ಸಾಧನಗಳೊಂದಿಗೆ, ಈ ಸೆಟಪ್ ಅಸಮಕಾಲಿಕ ಕಾರ್ಯ ಪ್ರಕ್ರಿಯೆ ಮತ್ತು ಸಮರ್ಥ ಡೇಟಾಬೇಸ್ ಕಾರ್ಯಾಚರಣೆಗಳನ್ನು ಖಾತ್ರಿಗೊಳಿಸುತ್ತದೆ. ಈವೆಂಟ್-ಆಧಾರಿತ ವಾಸ್ತುಶಿಲ್ಪದ ನಮ್ಯತೆಯು ವಿವಿಧ ನೈಜ-ಸಮಯದ ಅವಶ್ಯಕತೆಗಳಿಗೆ ಸ್ಕೇಲೆಬಲ್ ಪರಿಹಾರವಾಗಿದೆ, ಬಳಕೆದಾರರ ನಿಶ್ಚಿತಾರ್ಥ ಮತ್ತು ಸಿಸ್ಟಮ್ ವಿಶ್ವಾಸಾರ್ಹತೆಯನ್ನು ಹೆಚ್ಚಿಸುತ್ತದೆ.