이벤트 기반 아키텍처란 무엇인가요?

비즈니스는 고객 상호작용부터 센서 측정값에 이르기까지 다양한 트리거에 즉각적으로 반응할 수 있는 시스템을 점점 더 필요로 합니다. 기존의 요청-응답 모델은 유용하지만 이러한 동적 환경에 필요한 민첩성이나 확장성을 항상 제공하지는 못할 수 있습니다. 이벤트 기반 아키텍처(EDA)는 반응성이 뛰어나고 복원력이 우수하며 확장 가능한 애플리케이션을 빌드하기 위한 강력한 패러다임을 제공할 수 있습니다. 이벤트의 생성, 감지, 소비, 반응을 촉진할 수 있는 소프트웨어 아키텍처 패턴입니다.

4:17

이벤트 기반 아키텍처 이해

이벤트 기반 아키텍처의 정의

이벤트 기반 아키텍처는 서비스가 느슨하게 결합되어 있고 이벤트의 생성 및 소비를 통해 통신하는 소프트웨어 애플리케이션을 설계하기 위한 모델입니다. '이벤트'는 유의미한 발생 또는 시스템 상태의 변경을 의미합니다. 고객이 주문을 하거나, 센서가 온도 변화를 감지하거나, 새로운 파일이 스토리지에 업로드되거나, 데이터베이스 레코드가 업데이트되는 등 다양합니다.

서비스가 다른 서비스를 명시적으로 호출하고 응답을 기다리는 기존의 요청 기반 모델과 달리 EDA를 사용하면 서비스가 비동기식으로 작동할 수 있습니다. 이벤트를 생성하는 서비스('제작자' 또는 '게시자')는 이벤트가 발생했음을 알리기만 합니다. 이러한 유형의 이벤트에 관심이 있는 다른 서비스('소비자' 또는 '구독자')는 자체적으로 원하는 시간에 이벤트에 반응할 수 있습니다.

일반적으로 EDA의 주요 구성요소는 다음과 같습니다.

이벤트 제작자: 이벤트를 생성하는 애플리케이션 또는 서비스
이벤트 소비자(또는 구독자): 이벤트를 수신하고 처리하는 애플리케이션 또는 서비스
이벤트 채널(또는 이벤트 버스, 메시지 브로커, 이벤트 라우터): 제작자로부터 이벤트를 수집하고 필터링하여 관심 있는 소비자에게 전달하는 중간 인프라로, 제작자와 소비자를 분리하는 데 중요한 구성요소

이벤트 기반 아키텍처는 어떻게 작동하나요?

이벤트 기반 아키텍처의 워크플로는 일반적으로 일관된 패턴을 따릅니다.

이벤트 발생 및 프로덕션: 서비스 또는 시스템 내에서 중요한 작업이 발생합니다. 예를 들어 사용자가 전자상거래 웹사이트에서 '주문 제출' 버튼을 클릭합니다. 이 초기 작업(이벤트 제작자)을 처리하는 서비스는 주문 ID, 상품, 고객 세부정보 등 발생한 상황에 대한 관련 정보가 포함된 이벤트 객체를 생성합니다.
이벤트 전송: 제작자가 이 이벤트를 이벤트 채널로 전송합니다. 이 채널은 메시지 큐 또는 게시-구독(Pub/Sub) 시스템과 같은 전용 인프라로, 이벤트 흐름을 처리하도록 설계되었습니다.
이벤트 필터링 및 라우팅(이벤트 채널별): 이벤트 채널이 이벤트를 수신합니다. 그런 다음 필터링 규칙을 적용하거나 이벤트 유형, 콘텐츠 또는 주제를 기반으로 이러한 이벤트에 관심을 등록한 다양한 다운스트림 소비자에게 이벤트를 라우팅할 수 있습니다. 예를 들어 'order_placed' 이벤트는 인벤토리 서비스, 알림 서비스, 배송 서비스로 라우팅될 수 있습니다.
이벤트 소비 및 처리: 관심 있는 서비스(소비자)가 채널에서 이벤트를 수신합니다. 각 소비자는 이벤트를 비동기식으로 독립적으로 처리합니다. 전자상거래 예시를 계속 살펴보겠습니다.
인벤토리 서비스는 주문된 상품의 재고 수준을 낮출 수 있습니다.
알림 서비스는 고객에게 주문 확인 이메일을 보낼 수 있습니다.
배송 서비스에서 물류 프로세스를 시작할 수 있습니다.

이벤트 기반 아키텍처의 이점

이벤트 기반 아키텍처를 도입하면 특히 복잡한 분산 시스템의 경우 수많은 이점을 누릴 수 있습니다.

향상된 확장성

EDA의 서비스는 느슨하게 결합되어 있으며 독립적으로 확장할 수 있습니다. '주문 처리' 서비스에 과부하가 걸린 경우 '사용자 알림' 서비스에 영향을 주지 않고 해당 서비스만 수직 확장할 수 있습니다.

향상된 복원력 및 내결함성

이벤트 기반 아키텍처는 서비스 장애를 격리하여 애플리케이션의 견고성을 높일 수 있습니다. 분리된 특성 덕분에 하나의 소비자 서비스에서 발생한 오작동이 전파되어 시스템 전체가 고장 나는 일이 거의 없습니다.

민첩성과 유연성 향상

개발자는 시스템의 다른 부분에 미치는 영향을 최소화하면서 서비스를 추가, 수정 또는 삭제할 수 있습니다. 새로운 서비스는 기존 이벤트 스트림을 구독하여 원래 이벤트 제작자를 변경하지 않고도 새로운 기능을 추가할 수 있습니다.

실시간 대응

이벤트 기반 아키텍처는 시스템이 이벤트에 즉각적으로 대응하도록 지원합니다. 이 기능은 사기 감지, 실시간 분석, 운영 모니터링 등 신속한 조치가 가장 중요한 애플리케이션에 특히 유용합니다.

간소화된 통합

EDA는 기존 애플리케이션, 최신 마이크로서비스, 서드 파티 서비스 등 서로 다른 시스템을 통합하기 위한 유연한 백본 역할을 할 수 있습니다. 각 시스템은 다른 모든 시스템과 직접적인 지점 간 통합이 필요 없이 이벤트를 게시하고 사용할 수 있습니다.

확장성

새로운 기능을 추가하거나 기존 이벤트에 새로운 방식으로 대응하는 것은 관련 이벤트 스트림을 구독하는 새로운 소비자 서비스 배포가 포함되는 경우가 많습니다.

Google Cloud로 비즈니스 문제 해결

신규 고객에게는 Google Cloud에서 사용할 수 있는 $300의 무료 크레딧이 제공됩니다.

이벤트 기반 아키텍처의 사용 사례

EDA의 특성 덕분에 다양한 산업의 광범위한 응용 분야에 적합합니다.

마이크로서비스 조정

EDA는 마이크로서비스 간의 통신과 데이터 흐름을 지원하는 일반적인 패턴입니다. 긴밀한 결합을 유발할 수 있는 직접적인 동기식 API 호출 대신 마이크로서비스는 상태가 변경될 때 이벤트를 게시할 수 있으며, 다른 마이크로서비스는 이러한 이벤트를 구독하여 적절하게 대응할 수 있습니다.

실시간 데이터 처리 및 분석

IoT 센서 데이터, 애플리케이션 로그, 소셜 미디어 피드, 금융 시장 데이터와 같이 속도가 빠른 데이터 스트림을 처리하는 애플리케이션은 EDA를 사용하여 이 정보를 실시간으로 처리, 분석하고 이에 대응할 수 있습니다. 이를 통해 대시보드, 알림 시스템 또는 자동화된 의사 결정 프로세스를 강화할 수 있습니다.

전자상거래 플랫폼

판매에 대한 대응으로 재고 수준을 관리하는 것부터 결제, 배송, 주문 처리 등 다양한 단계를 거쳐 주문을 처리하는 것, 고객 알림을 보내는 것까지, EDA는 온라인 소매업에 내재된 복잡한 비동기식 워크플로를 관리하는 데 도움이 될 수 있습니다. 결제 처리 서비스가 느린 경우에도 주문 이벤트는 재고 예약과 같은 다른 서비스에서 캡처하고 처리할 수 있습니다.

워크플로 자동화 및 비즈니스 프로세스 관리

많은 비즈니스 프로세스는 본질적으로 이벤트 기반입니다. 예를 들어 보험금 청구 제출(이벤트)은 사기 확인, 평가, 고객 커뮤니케이션, 최종적으로 결제 처리와 같은 일련의 다운스트림 활동을 트리거할 수 있습니다. EDA는 이러한 워크플로를 효과적으로 모델링하고 자동화하는 데 도움이 될 수 있습니다.

데이터 동기화 및 복제

여러 시스템 또는 데이터 스토어에서 데이터를 일관되게 유지해야 하는 경우 EDA를 사용할 수 있습니다. 한 데이터베이스의 변경사항(이벤트)을 게시하여 다른 데이터베이스나 캐시가 이러한 변경 이벤트에 구독하고 자체적으로 업데이트할 수 있습니다.

서버리스 컴퓨팅

서버리스 함수(예: Cloud Run Functions)는 이벤트 기반으로 설계되는 경우가 많습니다. 이는 객체가 클라우드 스토리지에 업로드되거나, 메시지가 큐에 도착하거나, HTTP 요청이 발생하는 등 다양한 이벤트 트리거에 대한 응답으로 실행됩니다. EDA는 서버리스 구성요소를 사용하여 애플리케이션을 빌드하는 데 적합합니다.

금융 서비스

실시간 사기 감지, 주식 시장 모니터링, 거래 처리는 EDA의 짧은 지연 시간과 높은 처리량 기능을 활용하는 중요한 금융 애플리케이션입니다.

Google Cloud는 이벤트 기반 아키텍처를 어떻게 사용하나요?

Google Cloud는 고객이 강력한 이벤트 기반 애플리케이션을 빌드하고 배포할 수 있도록 지원하는 강력한 서비스 제품군을 제공합니다. 플랫폼 자체는 이벤트 기반 원칙을 활용하여 확장 가능하고 복원력이 뛰어난 서비스를 제공합니다. 이벤트 기반 솔루션을 빌드하는 고객을 위해 Google Cloud는 다음과 같은 몇 가지 주요 관리형 서비스를 제공합니다.

Pub/Sub: 전 세계에 분산된 확장 가능하고 안정적인 실시간 메시지 서비스로, EDA에서 이벤트 버스 또는 메시지 브로커 역할을 합니다. Pub/Sub는 서비스가 이벤트를 게시하고 다른 서비스가 이러한 이벤트를 비동기적으로 구독하도록 지원합니다. 게시자와 구독자를 분리하고 '최소 1회' 전송, 푸시(push) 구독 및 풀(pull) 구독, 메시지 필터링과 같은 기능을 지원합니다.
Eventarc: Eventarc는 Cloud Storage 버킷 변경, BigQuery 작업 완료, 커스텀 애플리케이션 이벤트와 같은 이벤트 소스를 이벤트 소비자에게 연결하여 이벤트 흐름을 관리하는 표준화된 방법을 제공할 수 있습니다. 개발자는 이를 통해 이벤트에 대한 응답으로 Cloud Run 서비스, Cloud Run Functions 또는 워크플로를 쉽게 트리거할 수 있습니다.
Cloud Run: 이 완전 관리형 컴퓨팅 플랫폼을 사용하면 스테이트리스(Stateless) 컨테이너를 실행하여 HTTP 요청 또는 Pub/Sub의 이벤트(Eventarc를 통해 이루어지는 경우가 많음)를 통해 호출할 수 있습니다. Cloud Run Functions를 사용하면 서버나 런타임 환경을 관리할 필요 없이 다양한 이벤트에 응답하는 단일 목적의 소규모 코드(함수)를 배포할 수 있습니다. 이벤트 기반 아키텍처 내에서 Cloud Run 서비스는 이벤트 소비자로서 매우 효과적일 수 있으며, 이러한 이벤트로 트리거되는 워크로드를 처리할 수 있습니다.
Workflows: 서버리스 워크플로를 정의, 배포, 관리할 수 있는 완전 관리형 조정 플랫폼입니다. 워크플로는 이벤트(Eventarc 또는 Pub/Sub를 통해)에 의해 트리거될 수 있으며 다양한 Google Cloud 서비스 및 HTTP 기반 API에 대한 호출을 조정할 수 있으므로 복잡한 이벤트 기반 비즈니스 프로세스를 조정하는 데 적합합니다.
Dataflow: 복잡한 이벤트 처리(CEP) 및 스트림 분석의 경우 Dataflow는 통합 스트림 및 일괄 데이터 처리 플랫폼을 제공할 수 있습니다. Pub/Sub에서 이벤트 스트림을 수집하고, 정교한 변환, 집계, 분석을 수행한 다음, 결과를 다른 시스템으로 출력하거나 추가 작업을 트리거할 수 있습니다.