이벤트 기반 마이크로서비스 구축

192

이벤트 기반 마이크로서비스 구축

표

8-1

오케스트레이션 서비스에서 발행된 이벤트를 구체화

입력 이벤트

ID

서비스

A

서비스

B

서비스

C

서비스

D

100 <

결과

> <

결과

> <

결과

>

완료

101 <

결과

> <

결과

>

전달됨 처리 중

102

전달됨

null null

처리 중

[표

8

-

1

]에서

ID

가

100

인 이벤트는 정상 처리됐고

ID

가

101

,

102

인 이벤트는 각각 상이한

워크플로 단계에 있습니다. 오케스트레이터는 이 결과를 바탕으로 워크플로 로직상 그 다음 단

계를 선택하고 이벤트 처리가 완료되면 서비스

A

,

B

,

C

결과에서 필요한 데이터를 꺼내 최종

출력을 조합합니다. 서비스

A

,

B

,

C

의 작업이 서로 독립적이라면 이벤트가 전달되는 순서만

바꾸어도 워크플로를 변경할 수 있습니다. 다음은 각 입력 스트림에서 이벤트를 받아 소비하고

워크플로 비즈니스 로직에 따라 처리하는 오케스트레이션 예제 코드입니다.

while (true) {

Event[] events = consumer.consume(streams)

for (Event event: events) {

if (event.source == "Input Stream") {

//이벤트 처리, 구체화 상태 업데이트

producer.send("Stream 1", ...) //데이터를 스트림 1로 전송

} else if ...