---
id: P-REINFORCE-WIKI-9411F7D5
category: "10_Wiki/💡 Topics/02_Architecture_Principles"
confidence_score: 0.95
tags: ['event-driven-architecture', 'broker-topology', 'mediator-topology', 'eventual-consistency', 'complex-event-processing', 'architecture-principles']
last_reinforced: 2026-05-02
---

# [[Event-Driven Architecture]]

## 📌 Brief 소고 Summary
Event-Driven Architecture(EDA)는 시스템 구성 요소들이 직접적인 요청이 아닌 비동기적인 이벤트(상태의 의미 있는 변화나 작업)의 생성, 감지 및 반응을 통해 통신하는 소프트웨어 아키텍처 패턴입니다 [1-3]. 이 아키텍처는 이벤트 생산자, 소비자, 그리고 이벤트를 전달하는 채널로 구성되어 컴포넌트 간의 결합도를 극도로 낮춥니다 [4-6]. 결과적으로 높은 확장성, 내결함성 및 실시간 응답성을 제공하여 IoT, 실시간 데이터 처리, 대규모 마이크로서비스 시스템 등에 널리 활용됩니다 [4, 7, 8].

## 📖 Core Content
이벤트 기반 아키텍처는 주로 다음의 핵심 구성 요소와 설계 방식으로 이루어집니다.

* **핵심 구성 요소 (Core Components):**
  * **Event Producers (이벤트 생산자):** 사용자 클릭이나 센서 데이터 포착 등 특정 동작이나 상태 변화가 발생했을 때 이벤트를 생성합니다 [4, 9].
  * **Event Consumers (이벤트 소비자/Sinks):** 발생한 이벤트에 반응하여 특정 작업이나 데이터 처리를 수행합니다. 생산자는 소비자의 존재나 처리 방식을 알지 못합니다 [4, 9].
  * **Event Channels (이벤트 채널):** 생산자와 소비자 사이에서 이벤트를 전달하는 경로로, 보통 Kafka, RabbitMQ와 같은 메시지 브로커나 큐를 통해 구현됩니다 [4, 10].
  * **Event Processors (이벤트 처리기):** 이벤트를 소비자에 도달하기 전에 필터링, 변환 또는 라우팅하는 중간 구성 요소입니다 [4].

* **이벤트 처리 스타일 (Event Processing Styles):**
  * **단순 이벤트 처리 (Simple event processing):** 특정 조건의 변화에 직접적으로 관련된 이벤트를 실시간으로 처리하여 후속 작업을 유도합니다 [11].
  * **이벤트 스트림 처리 (Event stream processing):** 일반적이고 의미 있는 이벤트들을 구독자에게 스트리밍하여 실시간 정보 흐름을 주도합니다 [12].
  * **복합 이벤트 처리 (Complex event processing, CEP):** 장기간에 걸쳐 발생하는 여러 이벤트의 인과적, 시간적, 공간적 패턴을 분석하여 이상 징후나 위협, 기회 등을 감지합니다 [13, 14].

* **주요 토폴로지 (Topologies):**
  * **Broker Topology (브로커 토폴로지):** 중앙 조정자 없이 구성 요소가 시스템 전체나 특정 채널로 이벤트를 브로드캐스트하는 방식입니다 [15, 16]. 이른바 'Dumb pipe' 역할을 하며, 확장이 용이하고 결합도가 극히 낮아 응답성과 내결함성이 뛰어나지만 분산된 흐름을 파악하기는 어렵습니다 [15, 17].
  * **Mediator Topology (메디에이터 토폴로지):** 중앙의 이벤트 메디에이터(오케스트레이터)가 이벤트의 흐름, 에러 처리, 복구 등을 제어하는 방식입니다 [15, 18, 19]. 'Smart pipe'로서 복잡한 비즈니스 프로세스나 에러 처리에 유리하지만, 메디에이터가 병목 현상이나 단일 장애점(Single Point of Failure)이 될 위험이 있습니다 [15, 17].

* **이벤트 구조 및 페이로드 전략 (Event Structure & Payload):**
  이벤트 페이로드(본문)를 구성할 때는 모든 필요 데이터를 포함할지(네트워크 대역폭이 커지지만 즉각 처리 가능), 혹은 참조 키(Key/ID)만 포함하여 소비자가 별도 데이터 소스를 조회하게 할지(데이터 일관성은 높으나 성능이 저하될 수 있음)를 결정해야 합니다 [20, 21].

## ⚖️ Trade-offs & Caveats
이벤트 기반 아키텍처는 높은 확장성과 유연성을 제공하지만, 다음과 같은 뚜렷한 제약과 고려 사항이 존재합니다.

* **최종 일관성 (Eventual Consistency):** 비동기적 특성으로 인해 생산자와 소비자 간의 상태가 즉각적으로 일치하지 않는 시간이 발생합니다 [22, 23]. 특정 작업에서는 이러한 지연을 허용하도록 시스템과 읽기 작업을 설계해야 하지만, 은행 거래와 같은 강력한 일관성(Strong consistency)이 필요한 시스템에는 부적합할 수 있습니다 [23, 24].
* **디버깅 및 관측성의 복잡성:** 단일 비즈니스 트랜잭션이 다수의 독립적인 생산자, 채널, 소비자를 비동기적으로 거치기 때문에 콜 스택을 추적하기가 매우 어렵습니다 [25]. 이를 해결하기 위해 모든 이벤트에 Correlation ID를 포함하여 로그를 연결하는 사전 설계가 필수적입니다 [25].
* **에러 처리 및 데이터 유실 위험:** 동기식 방식과 달리 비동기 환경에서의 에러 처리는 까다롭습니다 [23]. 처리 중 컴포넌트가 다운되면 이벤트가 유실될 수 있으므로, 재전송 매커니즘, 전용 에러 처리 프로세서, 데드 레터 큐(Dead-Letter Queue), 처리 확인 전까지 큐에 유지하는 방식(Client acknowledge mode) 등을 도입해야 합니다 [23]. 여러 서비스에 걸친 트랜잭션 실패 시에는 보상 트랜잭션(Compensating Transaction)을 통해 완료된 단계를 논리적으로 롤백해야 합니다 [23].
* **구조적 오버헤드 및 비용:** 메시지 브로커(Kafka 등)의 관리 및 클라우드 인프라 유지 비용이 추가되며, 단순한 CRUD 애플리케이션에 적용할 경우 오버엔지니어링(Over-engineering)의 위험이 있습니다 [22, 26].
* **이벤트 순서 및 중복 처리:** 수많은 소비자가 병렬로 동작할 때 이벤트가 순서대로 처리되지 않거나 중복 처리될 위험이 있으므로, 멱등성(Idempotent)을 갖춘 메시지 처리 로직 구현이 요구됩니다 [23].

## 🔗 Knowledge Connections

### Related Concepts

#### [아키텍처 토폴로지 (Architecture Topologies)]
- [[Broker Topology]]
  - 연결 이유: 중앙 통제 없이 이벤트 채널을 통해 컴포넌트들이 비동기적으로 통신하는 EDA의 핵심 구조입니다.
  - 이 개념을 통해 더 깊게 이해할 수 있는 부분: 중앙 조정자 없이 높은 성능, 반응성, 확장성을 달성하는 분산 시스템의 동작 원리 [15, 27].
- [[Mediator Topology]]
  - 연결 이유: 비즈니스 프로세스의 오케스트레이션과 제어를 위해 중앙 메디에이터를 도입하는 대안적 구조입니다.
  - 이 개념을 통해 더 깊게 이해할 수 있는 부분: 복잡한 이벤트 워크플로우 제어, 분산 트랜잭션의 상태 관리 및 오류 복구 처리 방식 [15, 18].

#### [시스템 특성 및 설계 제약 (System Characteristics & Constraints)]
- [[Eventual Consistency]]
  - 연결 이유: EDA 시스템이 강한 일관성을 포기하고 가용성과 파티션 허용성을 선택함에 따라 필연적으로 발생하는 데이터 동기화 지연 상태입니다.
  - 이 개념을 통해 더 깊게 이해할 수 있는 부분: 마이크로서비스 간 비동기 통신 시 데이터 상태 불일치가 발생하는 이유와 이를 시스템적으로 수용하는 방법 [22, 23].
- [[Complex Event Processing]]
  - 연결 이유: 단순한 이벤트를 넘어 다양한 이벤트의 시간적, 공간적 상호작용을 평가하여 의미 있는 패턴을 찾아내는 처리 방식입니다.
  - 이 개념을 통해 더 깊게 이해할 수 있는 부분: 실시간 데이터 스트림에서 이상 징후나 위협, 비즈니스 기회를 감지하는 고급 이벤트 해석 기법 [13, 14].

#### [상호 보완적 아키텍처 및 패턴 (Complementary Architectures & Patterns)]
- [[Event Sourcing]]
  - 연결 이유: 데이터의 현재 상태만 저장하는 대신, 상태를 변경한 모든 이벤트를 불변의 로그로 저장하는 설계 패턴입니다.
  - 이 개념을 통해 더 깊게 이해할 수 있는 부분: CQRS와 결합하거나 EDA의 감사 트레일, 시스템 상태 복원 기능을 강화하는 원리 [28, 29].

### Deeper Research Questions

- EDA 환경에서 최종 일관성(Eventual Consistency)으로 인해 발생하는 시스템의 부분적 데이터 불일치 기간 동안 사용자 경험을 어떻게 개선하고 관리할 수 있는가?
- 비즈니스 워크플로우의 복잡성에 따라 브로커 토폴로지와 메디에이터 토폴로지를 혼합(Hybrid)하여 사용할 때의 설계 기준과 기술적 경계는 어떻게 설정해야 하는가?
- 마이크로서비스 간의 분산 트랜잭션 실패 시, EDA 모델에서 보상 트랜잭션(Compensating Transaction)이나 Saga 패턴은 어떻게 설계되고 작동하는가?
- 이벤트 페이로드에 전체 데이터를 포함하는 방식과 키(Key)값만 포함하는 방식 간의 트레이드오프가 네트워크 대역폭 및 데이터 일관성에 미치는 장기적 영향은 무엇인가?
- 대량의 이벤트가 발생하는 IoT 환경 등에서 데이터 손실(Data Loss)을 방지하고 이벤트 순서를 보장하기 위해 스트림(Stream)과 큐(Queue)는 각각 어떻게 다르게 최적화되어 활용되는가?

### Practical Application Contexts

- **Implementation:** RabbitMQ나 Apache Kafka와 같은 메시지 브로커를 활용하여 이벤트 채널 및 큐/스트림을 구성하고, 시스템 간 통신을 비동기적으로 연결합니다 [4, 13, 30].
- **System Design:** 도메인 이벤트와 통합 이벤트를 분리하고(Bounded Context 경계 간 통신), 생산자와 소비자 간의 결합도를 낮추어(Loose coupling) 한 서비스의 장애가 다른 서비스로 전파되지 않도록 설계합니다 [31, 32].
- **Operation / Maintenance:** 개별 이벤트마다 Correlation ID를 부여하여 비동기 환경 전반에 걸친 로그 트레이싱(관측성)을 확보하고, 실패한 이벤트를 Dead-Letter Queue (DLQ)로 보내 운영자가 후속 조치를 할 수 있도록 설정합니다 [23, 25].
- **Learning Path:** 기존의 CRUD 중심적이고 동기적인 사고방식(Request-Response)에서 벗어나, 시스템의 변화를 이벤트 단위로 생각하고 처리하는 이벤트 주도적 사고로 패러다임을 전환해야 합니다 [28].
- **My Project Relevance:** 실시간 알림 서비스, 대용량 트래픽의 전자상거래 주문 처리, 주식 거래 플랫폼, 혹은 센서 데이터를 실시간으로 모아 분석해야 하는 IoT 백엔드 개발 시 적용을 적극 고려해야 합니다 [13, 24, 33].

### Adjacent Topics

- [[Microservices Architecture]]
  - 확장 방향: 마이크로서비스가 상호 독립적으로 확장되고 배포될 때, EDA가 각 서비스 간의 효율적이고 결합도 낮은 비동기 통신을 어떻게 지원하는지 비교 및 탐구 [23, 34, 35].
- [[Command Query Responsibility Segregation (CQRS)]]
  - 확장 방향: 읽기와 쓰기 작업을 분리하는 패턴으로, EDA 및 이벤트 소싱(Event Sourcing)과 어떻게 시너지를 내어 대용량 데이터 조회 성능을 최적화하는지 조사 [36-38].
- [[Service-Oriented Architecture (SOA)]]
  - 확장 방향: 전통적인 서비스 지향 아키텍처가 EDA와 결합된 SOA 2.0으로 진화하며, 기업 환경에서 예측 불가능한 인과 관계 패턴을 어떻게 처리하는지 파악 [39, 40].

---
*Last updated: 2026-05-02*