Versions Compared

Key

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

...

비동기 처리메시지를 액터와 연동함으로 비동기 메시징에 대한 처리를 유연하게 함과 동시에 심플하고 강력한 방법으로 유닛테스트기를 작성할수가 있습니다.


Note

간혹 카프카를 사용하여 활용한 시스템간 메시징 처리시스템이 구현되어야 할경우 Actor사용이 처리시스템을 구현할경우 AKKA 사용이 필요 없을수도 있습니다.하지만 이것은 잘못된 생각입니다.
Kafka와 연동된 커스텀 모듈이 동기처리를 한다거나, 로컬내에서 올바른 분배전략을 세우지 못한다고
유닛테스트가 불가능하다고 하면 Kafka의 끝점연결을 Actor로 하는것을 고려해보십시오
사용해야할 메시징이 늘어남에따라 KafkaTools에서 메시지 검사를 수동으로 하는것이 언젠가 한계가 올것입니다

카프카를 단순한 목적으로 사용하면 상관없겠지만, 우리의 도메인 로직은 카프카의 제공 수준으로만 처리하기엔 부족할수있습니다.

메시지를 한번만전송, 유입량조정 , 유입된 메시지의 유연한 분산처리등 스트림 끝점의 연결은 그에 준하는 스트림 능력을 갖추어야합니다.

이것이 리액티브(https://www.reactive-streams.org/) 가 추구하는 방향이며 

Akka는 Kafka Stream(https://doc.akka.io/docs/alpakka/current/)을 포함하여  Stream을 잘 이해하고 있고, 그에 준하는 능력을 사용할수 있습니다.

  • .net에는 alpakka처럼 공식 인터페이스는 없지만, Akka의 Stream을 활용할수 있습니다.


참고링크