Toplu İşlemler için Sunucu Tarafı Olaylarını Kullanan NestJS'de Zahmetsiz Bildirimler

NestJS'de Sunucu Tarafı Olayları (SSE) ile Bildirimleri Toplu Olarak Gönderme

Bu çözüm, toplu işlemler için NestJS'nin Prisma ve Sunucu Tarafı Olayları (SSE) ile birlikte kullanılmasına yönelik bir arka uç yaklaşımını göstermektedir. Olay odaklı bir mimari ve kuyruk sistemi içerir.

// 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 ve React Kullanarak Toplu Eklemeler için Gerçek Zamanlı Güncellemeler

Bu ön uç örneği, Sunucu Tarafı Olaylarını dinlemek ve veriler alınırken kullanıcı arayüzünü dinamik olarak güncellemek için React'ı kullanır. Toplu eklemelerden sonra çalışanların gerçek zamanlı olarak bilgilendirilmesini sağlar.

// 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;

Toplu Ekleme İşlemleri için Birim Test Bildirimleri

Bu Jest testi, NestJS'deki Sunucu Tarafı Olayları için arka uçta olay emisyonu ve bildirim mekanizmasının doğru şekilde çalışmasını sağlar.

// 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'de SSE Hakkında Sıkça Sorulan Sorular

1. Sunucu Tarafı Olaylarını WebSockets üzerinden kullanmanın faydaları nelerdir?
2. SSE'nin uygulanması daha kolaydır ve HTTP'yi kullanır, bu da onu güvenlik duvarı dostu hale getirir. WebSocket'lerden farklı olarak yalnızca tek bir tek yönlü bağlantı gerektirir ve bu da gerçek zamanlı güncellemeler için verimlidir.
3. Kullanabilir miyim @Sse bir denetleyicide birden fazla uç nokta var mı?
4. Evet, birden fazla tanımlayabilirsiniz @Sse Belirli ihtiyaçlara göre istemcilere farklı veri akışları sunmak için aynı denetleyicideki uç noktalar.
5. Kuyruk işleme sırasında hataları nasıl ele alabilirim?
6. BullMQ ile yeniden deneme seçeneklerini tanımlayabilir ve aşağıdaki gibi olay dinleyicilerini kullanabilirsiniz: @OnWorkerEvent('failed') hataları günlüğe kaydetmek ve gerekirse işleri yeniden işlemek için.
7. Prisma mı createMany yöntem işlem geri almalarını destekliyor mu?
8. Evet, Prisma'nın createMany bir işleme sarılabilir. İşlemdeki herhangi bir işlem başarısız olursa tutarlılık sağlamak için tüm işlemler geri alınır.
9. Bir SSE akışı sırasında istemcinin bağlantısı kesilirse ne olur?
10. Sunucu, bağlantı kopukluğunu algıladığında güncelleme göndermeyi durdurur. İstemciye yeniden bağlanma mantığını kullanarak uygulayabilirsiniz. EventSource API'dir.
11. SSE iki yönlü iletişim için kullanılabilir mi?
12. Hayır, SSE tek yönlüdür (sunucudan istemciye). Çift yönlü iletişim için WebSockets veya HTTP2 akışlarını kullanın.
13. NestJS'de SSE uç noktalarının güvenliğini nasıl sağlarım?
14. Korumaları veya ara yazılımları kullanın, örneğin @UseGuardsSSE uç noktalarınız için kimlik doğrulamayı ve yetkilendirmeyi zorunlu kılmak için.
15. SSE tarayıcı olmayan istemcilerle çalışabilir mi?
16. Evet, HTTP ve olay akışını destekleyen herhangi bir istemci (ör. Node.js, cURL) SSE akışlarını kullanabilir.
17. Bir SSE uç noktasına bağlanabilecek maksimum istemci sayısı nedir?
18. Bu, sunucunuzun yapılandırmasına ve kaynak sınırlarına bağlıdır. Yük dengeleme ve kümeleme, daha fazla istemciyi destekleyecek şekilde ölçeklendirmeye yardımcı olabilir.
19. JSON verilerini SSE üzerinden göndermek mümkün mü?
20. Evet, nesneleri JSON dizelerine seri hale getirebilir ve bunları kullanarak gönderebilirsiniz. new MessageEvent NestJS'de.

NestJS'de Etkili Gerçek Zamanlı Bildirimler

Gerçek zamanlı sistemlerin uygulanması SSE NestJS'de sunucu ve istemciler arasındaki iletişimi basitleştirir. Bu yöntem, sürekli yoklamaya kıyasla sunucu yükünü azaltır ve bildirimler için hassas hedefleme sağlar. Örneğin, bir İK aracı, diğerlerini rahatsız etmeden Satış bölümündeki 200 çalışana yeni kuponlar hakkında bilgi verebilir. 🎯

BullMQ ve Prisma gibi araçlarla bu kurulum, eşzamansız görev işlemeyi ve verimli veritabanı işlemlerini sağlar. Olay tabanlı mimarinin esnekliği, onu çeşitli gerçek zamanlı gereksinimler için ölçeklenebilir bir çözüm haline getirerek kullanıcı katılımını ve sistem güvenilirliğini artırır.