Event Bus
-
이코에코(Eco²) Streams & Scaling for SSE #9: Race Condition 해결과정과 수평확장이코에코(Eco²)/Event Streams & Scaling 2025. 12. 28. 14:52
이전 글: Event Bus Layer 구현 Event Router + Redis Pub/Sub 기반의 SSE HA 아키텍처를 구현했지만, 실제 E2E 테스트에서 중간 이벤트 누락이 관측됐습니다. 이 글에서는 문제 관측부터 디버깅, 해결까지의 과정을 기록합니다.1. 관측된 문제1.1 증상# E2E 테스트 실행curl -s -X POST "https://api.dev.growbin.app/api/v1/scan" \ -H "Authorization: Bearer $TOKEN" \ -H "Content-Type: application/json" \ -d '{"image_url": "..."}'# SSE 스트림 연결curl -s -N "https://api.dev.growbin.app/api/v1/stre..
-
이코에코(Eco²) Streams & Scaling for SSE #7: Event Bus Layer이코에코(Eco²)/Event Streams & Scaling 2025. 12. 27. 21:51
TL;DR이전 포스팅에서 Fan-out 계층의 필요성을 도출했습니다. 이번 포스팅에서는 Event Bus Layer의 실제 구현 과정을 기록합니다.Eco² Event Bus는 Redis Streams를 Durable Buffer(신뢰성 버퍼)로, Pub/Sub를 실시간 전달 채널로 사용하여 SSE Gateway로 fan-out하는 Composite Event Bus 계층입니다. 핵심 내용:Redis Streams Consumer Group 기반 이벤트 소비Pub/Sub로 실시간 fan-out멱등성 보장을 위한 Lua ScriptKafka 패턴과의 비교 및 Redis 기반 재구현배포 과정에서 마주친 트러블슈팅1. 아키텍처 분류: Composite Event Bus1.1 용어 정의Router목적지 결정 (라..