이벤트 소비자란 무엇일까요?

이벤트 기반 아키텍처는 시스템이 이벤트에 대한 정보를 실시간으로 탐지, 처리, 대응 및 공유할 수 있도록 하는 소프트웨어 설계 패턴입니다. EDA 시스템의 가장 큰 장점은 이벤트 발생 즉시 데이터를 전달할 수 있어 이벤트 소비자가 즉각적인 조치를 취할 수 있다는 것입니다.

이벤트 기반 아키텍처의 가장 중요한 측면 중 하나는 이벤트를 생성하고 이에 대응하는 시스템이 분리되거나 느슨하게 결합된다는 것입니다. 예를 들어 이벤트를 소비하는 시스템은 이벤트를 생성하는 시스템과 상호 의존적이지 않으며 정보가 어디에서 유입되는지 알 필요가 없습니다. 즉, 한 서비스에 장애가 발생해도 다른 서비스에 문제가 발생하거나 중단되지 않습니다.

비동기 메시징은 EDA의 또 다른 중요한 특성입니다. 시스템이 응답을 기다린 후에만 조치를 취하는 '요청 및 응답' 모델과 달리, 이벤트 기반 아키텍처의 구성요소는 다른 구성요소의 응답을 기다리지 않고 비동기적으로 통신하며 진행합니다. 이를 통해 구성요소가 이벤트에 즉각적으로 반응하고 데이터를 처리할 수 있기 때문에 EDA 시스템은 실시간 처리와 대량의 데이터를 신속하게 처리할 수 있습니다.

이벤트 소비자는 이벤트 기반 아키텍처의 여러 핵심 구성요소 중 하나입니다. EDA 구성요소에는 다음이 포함됩니다.

• 이벤트: 이벤트는 어떤 일이 발생했거나 상태가 변화했음을 나타내는 신호입니다.
• 이벤트 프로듀서: 이벤트 프로듀서는 IoT 디바이스, 사용자 인터페이스, 데이터베이스, 외부 API, 워크플로우 엔진, 클라우드 서비스, 애플리케이션 모니터 및 기타 기술과 같은 시스템으로, 이벤트를 생성하고 통신합니다.
• 이벤트 메시지: 이벤트 메시지 또는 이벤트 알림에는 이벤트에 대한 정보가 포함됩니다. 일반적으로 JSON 또는 YAML에 있습니다.
• 이벤트 소비자: 이벤트 구독자라고도 하는 이벤트 소비자는 이벤트에 대한 정보를 '수신'하거나 받아들이고, 수신한 정보를 기반으로 작업을 시작합니다. 이벤트 소비자는 보안팀에 잠재적인 유출 사실을 알리거나, 재고 수준을 업데이트하거나, 고객에게 확인 이메일을 보내거나, 워크플로우를 트리거하는 등의 작업을 수행할 수 있습니다.
• 이벤트 라우터: 이벤트 라우터는 생산자와 소비자 간의 중개자 역할을 함으로써 비동기 메시징과 느슨하게 결합된 아키텍처를 가능하게 합니다. 라우터는 프로듀서로부터 이벤트 데이터를 수신하고 특정 이벤트 채널을 구독한 소비자에게 전달하는 이벤트 버스, 메시지 큐, 이벤트 브로커 또는 이벤트 스트림일 수 있습니다.
• 이벤트 프로세서: 이벤트 프로세서는 이벤트 소비자가 수신한 이벤트 데이터를 관리하며, 새 이벤트를 시작하거나 작업을 실행하거나 조치를 수행하는 룰을 적용합니다. 또한 이벤트 프로세서는 이벤트 데이터를 라우팅, 필터링, 변환합니다.

모든 기업, 비즈니스 운영, 비즈니스 프로세스는 이벤트에 의해 주도되고 영향을 받습니다. 기업이 이벤트에 대한 알림을 더 빨리 받고 대응할수록 효율성, 생산성, 경쟁력 측면에서 더 큰 이득을 얻을 수 있습니다. 기업은 이벤트 소비자와 이벤트 기반 아키텍처를 사용해 이벤트에 대한 알림을 즉시 받고 비즈니스와 고객에게 혜택을 줄 수 있는 조치를 즉시 취할 수 있습니다.

이벤트 기반 아키텍처를 통해 기업은 다음과 같은 이점을 누릴 수 있습니다.

• 실시간으로 데이터를 처리합니다. EDA에서 비동기 메시징은 구성요소가 이벤트 발생 즉시 응답을 기다리지 않고 통신하고 처리할 수 있음을 의미합니다.
• 실제 이벤트에 신속하게 대응합니다. 이벤트 기반 아키텍처는 이벤트 발생 시 작업을 자동으로 즉각적으로 수행해 응답성을 개선합니다.
• 손쉽게 확장합니다. EDA 구성요소는 분리되거나 느슨하게 결합되기 때문에 워크로드 수요에 따라 개별 구성요소를 독립적으로 확장하거나 축소할 수 있습니다.
• 다운타임이 감소합니다. EDA는 한 서비스나 시스템에 문제가 발생하더라도 다른 구성요소가 계속 작동할 수 있도록 함으로써 안정성과 내고장성을 높입니다.
• 통합 작업과 상호 운용성을 개선합니다. 이벤트 기반 통신의 분리되거나 느슨하게 결합된 특성으로 인해 다양한 시스템이 함께 작동하고 정보를 공유하기가 더 용이합니다.
• 속도가 증가합니다. EDA는 각 구성요소가 서로 기다릴 필요가 없으므로 시스템 속도가 높아집니다.

이벤트를 게시하고 소비하는 두 가지 기본 모델이 있습니다.

게시/구독(Pub/Sub)

이벤트 메시징 모델이라고도 하는 이 모델에서 이벤트 소비자는 다양한 주제를 구독하고 특정 이벤트에 대한 정보를 수신하도록 선택합니다. 이벤트 프로듀서가 이벤트를 게시하면 해당 정보가 이벤트 브로커로 전송되어 필요한 경우 정보를 변환하거나 변환하고 데이터를 대기열에 저장한 다음 이벤트 소비자에게 메시지를 보냅니다. 소비자가 메시지를 수신하면 브로커가 메시지를 삭제합니다.

잘 알려진 Pub/Sub 서비스로는 Apache Kafka, Confluent, Amazon의 Simple Notification Service(SNS), Amazon의 Simple Queue Service(SQS), Azure Web Pub/Sub, GCP의 Pub/Sub가 있습니다.

이벤트 스트리밍 모델

이 접근 방식에서 이벤트 소비자는 이벤트 프로듀서가 브로커에게 전송하는 스트리밍 이벤트 메시지를 구독합니다. Pub/Sub와 달리 메시지는 지속적이므로 일정 기간 동안 저장되고 보관됩니다. 즉, 소비자는 언제든지 스트림에 접속하고 이벤트 메시지에 소급해 접속할 수 있습니다. 소비자는 Pub/Sub와 마찬가지로 게시된 모든 메시지를 수신하는 대신 스트림에서 특정 이벤트만 수신하도록 설정할 수도 있습니다. 이벤트 스트리밍 모델은 또한 이벤트 소비자가 일련의 이벤트의 정보를 기반으로 작업을 수집하고 시작하는 복잡한 이벤트 처리를 가능하게 합니다.

이벤트 스트리밍을 제공하는 기업으로는 AWS EventBridge, AWS Kinesis, Azure Stream Analytics, GCP Dataflow, Apache Beam 등이 있습니다.

이벤트 소비자는 다양한 이벤트 데이터를 수집하고 이에 따라 조치를 취합니다.

• 이커머스: 이벤트 기반 아키텍처는 원활한 경험을 제공하기 위해 고객 행동에 즉각적으로 대응해야 하는 이커머스 시스템의 핵심 요소입니다.
• 사이버 보안: 이벤트 소비자는 보안 이벤트를 실시간으로 처리해 보안팀에 알림을 제공하고, 악성 파일을 차단하거나, 의심스러운 트래픽을 격리할 수 있습니다.
• 마이크로서비스: EDA는 분리된 통신, 모듈성, 확장성, 내고장성 덕분에 마이크로서비스 간 통신에 이상적인 아키텍처입니다.
• 데이터 애널리틱스: 많은 이벤트 소비자가 실시간 데이터를 처리하고 분석해 패턴을 발견하고 방대한 양의 데이터에서 인사이트를 도출합니다. 사기 탐지 시스템은 금융 거래의 비정상을 탐지하도록 설계된 EDA 기술의 일반적인 예입니다.
• 모니터링: EDA 시스템은 시스템 리소스의 상태를 모니터링하고 예측 유지 관리 또는 긴급 개입이 필요할 때 시스템 관리자에게 알리는 데 이상적입니다.
• 사물 인터넷(IoT): IoT 디바이스에서 생성되는 방대한 양의 데이터를 EDA 시스템에서 쉽게 수집하고 모니터링해 실시간 모니터링 및 분석을 제공할 수 있습니다.
• 주식 시장: 거래 업계의 이벤트 소비자는 주식 시장 내 빠르게 변화하는 조건과 이벤트에 따라 매수/매도 주문을 실행하는 자동화된 거래 전략에서 매우 중요합니다.
• 워크플로우: EDA 시스템은 광범위한 이벤트를 기반으로 프로세스와 작업을 트리거해 자동화된 워크플로우를 지원합니다.