요약
이벤트 기반 API는 외부 알림에 웹훅을, 내부 처리에 메시지 큐를 사용합니다. 이벤트를 큐(RabbitMQ, Kafka)에 발행하고, 비동기적으로 처리한 다음, 웹훅을 통해 클라이언트에게 알립니다. 현대적인 PetstoreAPI는 주문 처리, 재고 업데이트, 결제 알림에 이 패턴을 사용합니다.
소개
고객이 주문을 합니다. API는 결제를 청구하고, 재고를 업데이트하고, 이메일을 보내고, 창고에 알리고, 웹훅을 트리거해야 합니다. 이 모든 것을 동기적으로 처리하여 고객을 10초 동안 기다리게 하시겠습니까? 아니면 즉시 응답하고 비동기적으로 처리하시겠습니까?
이벤트 기반 API는 빠르게 응답하고 백그라운드에서 처리합니다. 주문 엔드포인트는 즉시 201 Created를 반환합니다. 이벤트는 백그라운드 처리를 트리거합니다. 웹훅은 완료되면 클라이언트에게 알립니다.
현대적인 PetstoreAPI는 주문, 결제 및 재고에 이벤트 기반 아키텍처를 사용합니다.
Apidog는 웹훅 테스트, 이벤트 흐름 검증 및 비동기 처리 시뮬레이션에 도움을 줍니다.
이벤트 기반 아키텍처
이벤트 기반 API는 어떤 일이 발생할 때 이벤트를 발행합니다. 다른 서비스는 이를 구독하고 반응합니다.
구성 요소
- 이벤트 생산자 (Event Producer) - 이벤트를 발행하는 API 엔드포인트
- 이벤트 버스/큐 (Event Bus/Queue) - 이벤트를 라우팅합니다 (RabbitMQ, Kafka, SQS)
- 이벤트 소비자 (Event Consumer) - 이벤트를 처리하는 백그라운드 워커
- 웹훅 (Webhooks) - 외부 클라이언트에게 알립니다
흐름
Client → POST /orders → API
API → Publish "order.created" → Queue
API → Return 201 Created → Client
Worker → Consume event → Process order
Worker → Publish "order.completed" → Queue
Webhook Worker → Send webhook → Client
외부 이벤트를 위한 웹훅
웹훅은 외부 클라이언트에게 이벤트에 대해 알립니다.
// 주문 생성 시 이벤트 발행
app.post('/v1/orders', async (req, res) => {
const order = await createOrder(req.body);
await eventBus.publish('order.created', {
orderId: order.id,
userId: order.userId,
total: order.total
});
res.status(201).json(order);
});
// 백그라운드 워커가 웹훅 전송
eventBus.subscribe('order.completed', async (event) => {
const webhooks = await getWebhooks(event.userId, 'order.completed');
for (const webhook of webhooks) {
await sendWebhook(webhook.url, {
event: 'order.completed',
data: event
});
}
});
내부 이벤트를 위한 메시지 큐
메시지 큐는 내부 이벤트 처리를 담당합니다.
RabbitMQ 예시
// 발행자
await publishEvent('order.created', { orderId: '019b4132' });
// 소비자
await consumeEvents('order.*', async (event) => {
await processOrder(event);
});
현대적인 PetstoreAPI가 이벤트 기반 API를 구현하는 방법
주문 처리
- POST /orders는 즉시 201을 반환합니다
- `order.created` 이벤트를 발행합니다
- 결제 워커가 결제를 처리합니다
- 재고 워커가 재고를 업데이트합니다
- 이메일 워커가 확인 이메일을 보냅니다
- 웹훅 워커가 클라이언트에게 알립니다
현대적인 PetstoreAPI 이벤트 아키텍처를 참조하십시오.
Apidog로 테스트하기
Apidog는 이벤트 기반 API 테스트를 지원합니다:
- 웹훅 전달 테스트
- 이벤트 페이로드 검증
- 비동기 처리 시뮬레이션
- 재시도 로직 테스트
결론
이벤트 기반 API는 성능과 확장성을 향상시킵니다. 외부 알림에는 웹훅을, 내부 처리에는 메시지 큐를 사용하십시오. 현대적인 PetstoreAPI는 프로덕션 준비가 된 이벤트 기반 패턴을 보여줍니다.
자주 묻는 질문
웹훅과 메시지 큐의 차이점은 무엇인가요?
웹훅은 HTTP를 통해 외부 클라이언트에게 알립니다. 메시지 큐는 내부 서비스 통신을 처리합니다.
어떤 메시지 큐를 사용해야 하나요?
간단함을 위해서는 RabbitMQ를, 높은 처리량(throughput)을 위해서는 Kafka를, 관리형 서비스(managed service)를 위해서는 AWS SQS를 사용하십시오.
웹훅 실패는 어떻게 처리하나요?
지수 백오프(exponential backoff)를 사용하여 재시도 로직을 구현하십시오 (웹훅 안정성 가이드 참조).
메시지 큐 없이 이벤트를 사용할 수 있나요?
네, 하지만 큐는 내구성, 재시도 및 디커플링(결합도 낮춤)을 제공합니다.
이벤트 기반 API는 어떻게 테스트하나요?
웹훅을 테스트하고 이벤트 흐름을 검증하려면 Apidog를 사용하십시오.