Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Info

스트림처리는 AKKA의 주제에서도 광범위하고 어렵습니다.

배관공 게임도 분명 끝판 스테이지는 어렵듯이 우리는 위와같이 복잡한 스트림처리를 단순화하기위해

그래프 DSL을 이용해보겠습니다.

여러개의 입출력이 필요한 복잡한 스트림 처리를 위해서,

AkkaStream은 그래프 DSL을 사용하여 여러개인 팬인 또는 팬아웃시나리오를

기술할수 있게 해줍니다.

이것은 마치 화이트보드에 그린 프로토콜사양의 그림을

AkkaStream이 제공하는 GraphDSL객체를 활용하여 구성하고 재활용할수 있게합니다.

그리고 그것은 그래프가 의도한대로 실제로 동작을 합니다.

...

간단한 그래프처리를 구현해보기

...


그래프 설명

  • in : 입력은 1~10까지입니다.
  • f1 ~f4 : 각 팬을 지날떄마다 +10씩 더합니다.
  • bcast : 분기가 일어나는 구간이며, 요소가 분기수만큼 복제가 됩니다.
  • merge : 분기된 요소가 다시 집합하는 구간입니다. 

...