mirror of
https://github.com/ktds-dg0501/kt-event-marketing.git
synced 2025-12-06 15:26:23 +00:00
135 lines
3.5 KiB
Plaintext
135 lines
3.5 KiB
Plaintext
@startuml analytics-이벤트생성구독
|
|
!theme mono
|
|
|
|
title Analytics Service - EventCreated 이벤트 구독 처리 내부 시퀀스\n(Kafka Event 구독)
|
|
|
|
participant "Kafka Consumer" as Consumer
|
|
participant "EventCreatedListener" as Listener
|
|
participant "AnalyticsService" as Service
|
|
participant "AnalyticsRepository" as Repository
|
|
participant "CacheService" as Cache
|
|
participant "Redis" as Redis
|
|
database "Analytics DB" as DB
|
|
|
|
note over Consumer
|
|
**Kafka Consumer 설정**
|
|
- Topic: EventCreated
|
|
- Consumer Group: analytics-service
|
|
- Partition Key: eventId
|
|
- At-Least-Once Delivery 보장
|
|
end note
|
|
|
|
Kafka -> Consumer: EventCreated 이벤트 수신\n{\n eventId: "uuid",\n storeId: "uuid",\n title: "이벤트 제목",\n objective: "신규 고객 유치",\n createdAt: "2025-10-22T10:00:00Z"\n}
|
|
activate Consumer
|
|
|
|
Consumer -> Listener: onEventCreated(event)
|
|
activate Listener
|
|
|
|
note right of Listener
|
|
**멱등성 체크**
|
|
- Redis Set에 이벤트 ID 존재 여부 확인
|
|
- 중복 처리 방지
|
|
end note
|
|
|
|
Listener -> Redis: SISMEMBER processed_events {eventId}
|
|
activate Redis
|
|
|
|
alt 이벤트 미처리 (멱등성 보장)
|
|
Redis --> Listener: false (미처리)
|
|
deactivate Redis
|
|
|
|
Listener -> Service: initializeEventStats(event)
|
|
activate Service
|
|
|
|
note right of Service
|
|
**이벤트 통계 초기화**
|
|
- 이벤트 기본 정보 저장
|
|
- 통계 초기값 설정
|
|
* 총 참여자 수: 0
|
|
* 총 노출 수: 0
|
|
* 예상 ROI: 계산 전
|
|
* 매출 증가율: 0%
|
|
end note
|
|
|
|
Service -> Repository: save(eventStatsEntity)
|
|
activate Repository
|
|
|
|
Repository -> DB: 이벤트 통계 초기화\n(이벤트ID, 매장ID, 제목, 목적,\n참여자수/노출수/ROI/매출증가율을\n0으로 초기화하여 저장)
|
|
activate DB
|
|
|
|
DB --> Repository: 1 row inserted
|
|
deactivate DB
|
|
|
|
Repository --> Service: EventStatsEntity
|
|
deactivate Repository
|
|
|
|
note right of Service
|
|
**초기화 완료**
|
|
- 이벤트 통계 DB 생성
|
|
- 향후 ParticipantRegistered 이벤트 수신 시
|
|
실시간 증가
|
|
end note
|
|
|
|
Service -> Cache: delete("analytics:dashboard:{eventId}")
|
|
activate Cache
|
|
|
|
note right of Cache
|
|
**캐시 무효화**
|
|
- 기존 캐시 삭제
|
|
- 다음 조회 시 최신 데이터 갱신
|
|
end note
|
|
|
|
Cache -> Redis: DEL analytics:dashboard:{eventId}
|
|
activate Redis
|
|
|
|
Redis --> Cache: OK
|
|
deactivate Redis
|
|
|
|
Cache --> Service: OK
|
|
deactivate Cache
|
|
|
|
Service -> Redis: SADD processed_events {eventId}
|
|
activate Redis
|
|
|
|
note right of Redis
|
|
**멱등성 처리 완료 기록**
|
|
- Redis Set에 eventId 추가
|
|
- TTL 설정 (7일)
|
|
end note
|
|
|
|
Redis --> Service: OK
|
|
deactivate Redis
|
|
|
|
Service --> Listener: EventStats 초기화 완료
|
|
deactivate Service
|
|
|
|
Listener -> Consumer: ACK (처리 완료)
|
|
deactivate Listener
|
|
|
|
else 이벤트 이미 처리됨 (중복)
|
|
Redis --> Listener: true (이미 처리)
|
|
deactivate Redis
|
|
|
|
note right of Listener
|
|
**중복 이벤트 스킵**
|
|
- At-Least-Once Delivery로 인한 중복
|
|
- 멱등성 보장으로 중복 처리 방지
|
|
end note
|
|
|
|
Listener -> Consumer: ACK (스킵)
|
|
deactivate Listener
|
|
end
|
|
|
|
Consumer --> Kafka: Commit Offset
|
|
deactivate Consumer
|
|
|
|
note over Consumer, DB
|
|
**처리 시간**
|
|
- 이벤트 수신 → 초기화 완료: 약 0.2초
|
|
- DB INSERT: 0.05초
|
|
- Redis 캐시 무효화: 0.01초
|
|
- 멱등성 체크: 0.01초
|
|
end note
|
|
|
|
@enduml
|