이벤트 모듈 설계 문서

이벤트 모듈 설계 다이어그램

Event

abstract class Event(  
    val eventId: String,  
    val eventTime: LocalDateTime,  
)

eventId와 eventTime은 필수로 가질 수 있도록 정의하였습니다.

 

@EventDetails

@Target(AnnotationTarget.CLASS)  
@Retention(AnnotationRetention.RUNTIME)  
@DomainEvent  
annotation class EventDetails(  
    val outBox: Boolean = false,  
)

Event 클래스가 비즈니스 로직을 처리하는 과정에서 필요하지 않은 정보를 위한 어노테이션입니다.

• outBox: 해당 이벤트가 외부까지 전달되어야 하는지 여부에 대한 표시입니다.

 

EventListener

interface EventListener<T : Event> {
    fun onEvent(event: T)
}

발행된 Event를 구독하는 책임을 가집니다.
그리고 비즈니스 로직 처리를 위해 수신한 Event를 EventHandler로 전달합니다.

 

 

EventHandler

interface EventHandler<T : Event> {  
    fun handle(event: T)  
}

발행된 Event에 대한 비즈니스 로직을 처리합니다.

 

Message

abstract class Message(payload: MessagePayload) {}

외부 서비스, 인프라와의 통신을 위한 객체입니다.

 

MessagePayload

data class MessagePayload (  
    val eventId: String,  
    val eventType: String,    
    val eventTime: LocalDateTime,  
    val data: Map<String, Any>,  
)

• eventId: Message 식별을 위한 값입니다.
• eventType: 어떤 Event에 해당하는지 식별하기 위한 값입니다.
• eventTime: Message 발행 시간입니다.
• data: Event를 생성하기 위해 필요한 값입니다.

 

MessageMapper

abstract class MessageMapper<T : Event, R : Message> {  
    abstract fun map(event: T): Optional<R>  
}

Event를 외부 서비스, 인프라로 전달하기 위해 Message로 변경합니다.

 

MessageSender

interface MessageSender<T : Message> {  
    fun send(message: T)  
}

Message를 외부 서비스, 인프라로 전달합니다.

 

MessageRelay

interface MessageRelay<T : Message> {  
    fun publish(message: T)  
}

어플리케이션의 Event를 구독하여 Message로 외부에 전달합니다.

 

MessageReverseRelay

interface MessageReverseRelay<T : Event> {  
    fun publish(event: T)  
}

외부에서 구독한 Message를 Event로 변환하여 어플리케이션으로 전달합니다.