Подієво-керована архітектура

Спроєктуєте взаємодію компонентів через асинхронні події та визначите межі відповідальності сервісів.

Що таке подієво-керована архітектура

У подієво-керованій архітектурі компоненти взаємодіють через події — повідомлення про факт, який уже відбувся.

Наприклад:

замовлення створено;
платіж підтверджено;
користувача зареєстровано;
товар зарезервовано.

Компонент, який володіє даними та бізнес-правилом, публікує подію. Інші компоненти підписуються на цю подію й виконують власну роботу незалежно від джерела.

text

OrderService
    |
    | OrderCreated
    v
Event Bus
    |
    +--> NotificationService
    +--> AnalyticsService
    +--> BillingService

typescript

import { randomUUID } from 'node:crypto';
import {
  Body,
  Controller,
  Injectable,
  Module,
  Post,
} from '@nestjs/common';
import { NestFactory } from '@nestjs/core';
import { EventEmitter2, EventEmitterModule } from '@nestjs/event-emitter';
import { OnEvent } from '@nestjs/event-emitter';

const ORDER_CREATED = 'order.created';

class CreateOrderDto {
  productId!: string;
  email!: string;
}

class Order {
  constructor(
    readonly id: string,
    readonly productId: string,
    readonly email: string,
    readonly createdAt: Date,
  ) {}
}

class OrderCreatedEvent {
  constructor(
    readonly eventId: string,
    readonly orderId: string,
    readonly productId: string,
    readonly email: string,
    readonly occurredAt: Date,
  ) {}
}

@Injectable()
class OrdersService {
  private readonly orders = new Map<string, Order>();

  constructor(private readonly eventEmitter: EventEmitter2) {}

  createOrder(input: CreateOrderDto): Order {
    const order = new Order(
      randomUUID(),
      input.productId,
      input.email,
      new Date(),
    );

    this.orders.set(order.id, order);

    const event = new OrderCreatedEvent(
      randomUUID(),
      order.id,
      order.productId,
      order.email,
      new Date(),
    );

    this.eventEmitter.emit(ORDER_CREATED, event);

    return order;
  }
}

@Injectable()
class NotificationsService {
  @OnEvent(ORDER_CREATED, { async: true })
  async handleOrderCreated(event: OrderCreatedEvent): Promise<void> {
    await new Promise((resolve) => setTimeout(resolve, 100));

    console.log(
      `Надіслано підтвердження замовлення ${event.orderId} на ${event.email}`,
    );
  }
}

@Controller('orders')
class OrdersController {
  constructor(private readonly ordersService: OrdersService) {}

  @Post()
  create(@Body() input: CreateOrderDto): Order {
    return this.ordersService.createOrder(input);
  }
}

@Module({
  imports: [EventEmitterModule.forRoot()],
  controllers: [OrdersController],
  providers: [OrdersService, NotificationsService],
})
class AppModule {}

async function bootstrap(): Promise<void> {
  const app = await NestFactory.create(AppModule);

  await app.listen(3000);
}

void bootstrap();

typescript

class OrderCreatedEvent {
  constructor(
    readonly eventId: string,
    readonly orderId: string,
    readonly productId: string,
    readonly email: string,
    readonly occurredAt: Date,
  ) {}
}

typescript

@OnEvent('order.created', { async: true })
async handle(event: OrderCreatedEvent): Promise<void> {
  const alreadyProcessed = await this.processedEvents.exists(event.eventId);

  if (alreadyProcessed) {
    return;
  }

  await this.emailService.sendOrderConfirmation(event.email, event.orderId);

  await this.processedEvents.save(event.eventId);
}

Подієво-керована архітектура

Що таке подієво-керована архітектура

Команди та події

Команда

Подія

Межі відповідальності сервісів

Події в NestJS

Приклад взаємодії компонентів

Асинхронність обробників

Структура події

Подія не повинна містити команди

Надійність і повторна обробка

Транзакція та публікація події

Локальні та зовнішні події

Типові помилки

Прямі виклики замість подій

Нечіткі назви подій

Публікація події до збереження даних

Передавання внутрішніх об’єктів

Очікування миттєвого результату

Відсутність ідемпотентності

Підсумок