이벤트 드리븐

📖 상세 설명

이벤트 드리븐 아키텍처(EDA)는 시스템 컴포넌트가 이벤트를 통해 비동기적으로 통신하는 소프트웨어 설계 패턴입니다. 동기 API 호출(Request-Response) 대신 이벤트 발행-구독(Pub/Sub) 모델을 사용하여 서비스 간 느슨한 결합을 달성합니다.

핵심 개념

• Event (이벤트): "무언가 발생했다"는 불변의 사실. OrderPlaced, UserSignedUp 등
• Producer: 이벤트를 생성하고 발행하는 서비스
• Consumer: 이벤트를 구독하고 처리하는 서비스
• Event Broker: 이벤트를 중개하는 메시지 브로커 (Kafka, RabbitMQ)

EDA의 장점

• 느슨한 결합: Producer는 Consumer를 몰라도 됨
• 확장성: Consumer 수평 확장이 용이
• 탄력성: 일부 서비스 장애가 전체에 영향 안 줌
• 실시간 처리: 이벤트 발생 즉시 반응

💻 코드 예제

Kafka Producer (Node.js)

// services/order/OrderService.ts
import { Kafka } from 'kafkajs';

const kafka = new Kafka({ brokers: ['localhost:9092'] });
const producer = kafka.producer();

export class OrderService {
  async placeOrder(orderData: CreateOrderDTO) {
    // 1. 주문 생성 (도메인 로직)
    const order = Order.create(orderData);
    await this.orderRepository.save(order);

    // 2. 이벤트 발행 (비동기)
    await producer.send({
      topic: 'order-events',
      messages: [{
        key: order.id,
        value: JSON.stringify({
          type: 'OrderPlaced',
          data: {
            orderId: order.id,
            customerId: order.customerId,
            items: order.items,
            totalAmount: order.totalAmount,
          },
          occurredAt: new Date().toISOString(),
        }),
      }],
    });

    return order;
  }
}

Kafka Consumer

// services/notification/NotificationConsumer.ts
import { Kafka } from 'kafkajs';

const kafka = new Kafka({ brokers: ['localhost:9092'] });
const consumer = kafka.consumer({ groupId: 'notification-service' });

async function startConsumer() {
  await consumer.connect();
  await consumer.subscribe({ topic: 'order-events', fromBeginning: false });

  await consumer.run({
    eachMessage: async ({ topic, partition, message }) => {
      const event = JSON.parse(message.value!.toString());

      switch (event.type) {
        case 'OrderPlaced':
          await sendOrderConfirmationEmail(event.data);
          break;
        case 'OrderShipped':
          await sendShippingNotification(event.data);
          break;
      }
    },
  });
}

startConsumer();

AWS EventBridge + Lambda

// 이벤트 발행
import { EventBridge } from '@aws-sdk/client-eventbridge';

const eventBridge = new EventBridge({});

export async function publishOrderEvent(order: Order) {
  await eventBridge.putEvents({
    Entries: [{
      Source: 'com.myapp.orders',
      DetailType: 'OrderPlaced',
      Detail: JSON.stringify({
        orderId: order.id,
        customerId: order.customerId,
        totalAmount: order.totalAmount,
      }),
      EventBusName: 'default',
    }],
  });
}

// Lambda Consumer (이벤트 핸들러)
export const handler = async (event: any) => {
  const orderEvent = event.detail;

  // 재고 차감 처리
  await inventoryService.decreaseStock(orderEvent.items);

  return { statusCode: 200 };
};

이벤트 스키마 정의

// shared/events/OrderEvents.ts
export interface DomainEvent {
  eventId: string;
  eventType: string;
  aggregateId: string;
  occurredAt: string;
  version: number;
}

export interface OrderPlaced extends DomainEvent {
  eventType: 'OrderPlaced';
  data: {
    orderId: string;
    customerId: string;
    items: Array<{
      productId: string;
      quantity: number;
      unitPrice: number;
    }>;
    totalAmount: number;
    shippingAddress: string;
  };
}

export interface OrderCancelled extends DomainEvent {
  eventType: 'OrderCancelled';
  data: {
    orderId: string;
    reason: string;
    cancelledBy: string;
  };
}

💬 현업 대화 예시

⚠️ 주의사항

🔗 관련 용어

📚 더 배우기

• Designing Event-Driven Systems (Ben Stopford) - Kafka 기반 EDA
• Enterprise Integration Patterns - 메시징 패턴 바이블
• AWS EventBridge Documentation - 서버리스 이벤트 버스