You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 40 Next »

AKKA에서는 다양한 라우팅 전략을  디플로이 환경설정 전략으로 최소의 코드변경만으로 적용가능합니다.

또한 이러한 전략을 적용하기 위해 운영중 장비를 Down없이  다이나믹하게 스케일아웃할수있는 

클러스터로 개념으로 확장 가능합니다.

성능관련 스케일 아웃은 라우팅 전략과 관련이 있고

운영중 장비를 Down없이 스케일 늘리고 줄일수 있는 전략은 클러스터링과 연관이 있다고 볼수 잇습니다.

기술적으로 AKKA내에서 클러스터는 목표는 병목 현상이 없는 탄력적인 분산형 피어 투 피어 네트워크라고 정의 내릴수 있습니다.


RoundRobin



Round Robin Router

단순하게 들어온 메시지 순서대로, 순차적으로 대상 노드를 바꿔가며 전송시 사용

ex>단순한 RestAPI의 성능향상및 특정 노드 장애에 대응하는 다중화구성 ( 기본적으로 Pool에 등록된 Node Crash발생시 해당노드는 해당풀에서 자동제거됨)



Broadcast



Broadcast Router


어떠한 정보의 변경을 모든 노드가 알아야할시, 주로 전체 동기화및 전체 푸시용도


ConsistentHashing



ConsistentHash Router

특정 처리에 대해 해시값기반 베이스로 노드의 변경의 가능성을 최소화할때

ex>

  • 웹소켓 기능 보장 ( 핸드쉐이크과정에서 노드변경이되면 오동작)
  • 자체캐쉬 작동 보장(성능을 위해 노드 자체에 서버 캐시처리를 하였지만, 노드변경시 서버캐시 적용못받음)
  • 최초 설계에의한 제한적 분산(기능적으로 생성한 오브젝트가 예상되는 특정 노드에 있어야하는 경우등)
  • SSL및 서비스 로그인 세션유지 ( 노드변경시 재인증을 받아야하는 성능이슈 )



ScatterGatherFirstCompleted



ScatterGatherFirstCompleted Router

성능을 위해 다중노드로 구성하였으며, 가장 빠르게 처리한 녀석의 결과를 사용할시

ex> 1개의 빠른인스턴스 검색시 인덱스된 데이터가 불규적으로 분산되거나 중복이있을시 , 가장 빠른 결과물을 사용할시


SmallestMailbox



SmallestMailbox Router

덜바쁜 노드우선으로 메시지를 보내고자 할때, 대용량 메시지 전송 보증이 필요할때


TailChopping


 기본적으로 랜덤 라우터이나, 최적 응답시간내에 반응못하면(5s)

마지막까지 처리는 하되 라우터에서 임시제외( 특정시간후 복귀됨-20s )

다음 누군가 접근시 제외되지 않은 녀석중에서 또 랜덤 선택

일반적으로 모두 안정적이나 , 가끔 불특정 노드가 느려지는 상황을 고려하여

안정적인 응답속도 보장을 위한 라우터 전략 , 모두가 느려지는 상황이 자주 발생하면 이전략 사용 못함


추가참고 자료



 같은팀원이 소개해줘서 알게되었는데, RabiitMQ가  중간에는 Queue 를 적용시키고 양 끝단에는 적절한 Route전략을 사용하여

대용량 전송 메시지가 분산처리되어 최대한 메시지 전송 보장을 지원하는 플래폼인듯

여기서 중간 사용되는 Queues 방식이 AKKA에서 언급되는 라우터방식인 SmallestMailBox의 형태와 유사한듯보입니다.


이와같은 메시지 큐 서비스는, MS Azure 에서 원클릭으로도 서비스 생성이 가능합니다.

e-좋은 세상입니다. RabbitMQ도 아마존 클라우드에서 원클릭 생성이 가능한듯 보입니다.


Rabbit MQ를 살펴 보면서 알게되었는데, 양방향 실시간성 분산 메시지 처리에 있어서,

조금더 자유도가 있는 AKKA에서 추구하려는 아키텍쳐와 유사한듯 보입니다.

사육사(관리및 모니터링)가 동물(각종 분산메시지시스템)들을 관리하는 아파치의 컨셉도 독특해보입니다.

이 문서의 목적은 AKKA 툴킷사용으로 한정짓는게 아닌, 학습과정중 알지못했던 분산처리와 관련된 타 플래폼도 알아가는데 의의가 있습니다.

AKKA는 이러한 편리함 시스템을 놔두고 굳이 직접 만드는 고생도 할수 있지만,  유용한 솔류션을 잘 이용하는데 쓰일수도 있습니다.

실시간 시스템을 사용하기위해서는 타 솔류션을 사용하는 플래폼의 입장에서도 RestFul방식보다는, 동시성 실시간 처리로 사용을 해야 활용도가 더 높아질것입니다.

akka kafka , akka rabbit mq  등으로 구글링을 하면 akka의 stream기능으로 제3의 서비스와 실시간 연동하는 자료들 많이 찾을수 있습니다. 


실습 예정:

  • Actor를 분산 배치
  • Actor를 클러스터화
  • 특정 Node를 Up/Down하면서 클러스터 복구력및 확장력 테스트 ( 장비변경및 업데이트 시나리오)


  • No labels