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

Compare with Current View Page History

« Previous Version 7 Next »

  라우터는 액터의 목적지 대상 경로를 정의하는 특수한 속성입니다.

동일메시지가 여러개의 경로에 복제 전달될수도 있으며, 최적화된 어떠한 경로에만 갈수도 있습니다.

즉, 메시지 전송 전략에따라 다양한 라우터 선택이 가능합니다.


라우터 설정전략

 라우터 설정은, 코드가 아닌 설정파일을 통해 하는게 일반적입니다. 라우터에 해당하는 고정된 노드는

운영중 변경될수 있기때문입니다. 하지만 어떠한 패턴에의해 동적으로 변경할수 있는 가능성도

있기때문에, 런타임 코드로의 변경도 지원을 합니다.


코드를 통해

예제는 라운드로빈 방식으로 5개의 작업자를 코드로 만든 예입니다.

props 는 액터편에 설명이되었지만, 어떠한 액터를 만들것인가? 액터에대한 옵션설정이라고 보면됩니다.


var props = Props.Create<Worker>().WithRouter(new RoundRobinPool(5));
var actor = system.ActorOf(props, "worker");
var props = new RoundRobinPool(5).Props(Props.Create<Worker>());

설정파일을 통해

예제는 동일한 방식으로, 설정파일을 통해 ( http://getakka.net/articles/concepts/configuration.html )

라운드로빈 라우터를 설정한 모습입니다.


설정파일
akka.actor.deployment {
  /workers {
    router = round-robin-pool
    nr-of-instances = 5
  }
}

설정파일에서, 라운드로빈을 이용해서 처리할 Job 개수를 설정합니다.



실행코드
var props = Props.Create<Worker>().WithRouter(FromConfig.Instance);
var actor = system.ActorOf(props, "workers");

실제 라우팅기능을 하는 Actor를 , 설정파일에서 설정한 룰대로 생성이되고 작동이됩니다.


아래는 개수를 통해 자동생성이아닌, 명시적인 라우터 이름을 설정합니다.

akka.actor.deployment {
  /workers {
    router = round-robin-group
    routees.paths = ["/user/workers/w1", "/user/workers/w2", "/user/workers/w3"]
  }
}

var props = Props.Create<Worker>().WithRouter(FromConfig.Instance);
var actor = system.ActorOf(props, "workers");


Pools VS Groups

Pools : 라우터에게 생성할 인스턴수수만 제공하면  액터생성을 처리합니다. ( 경로지정 없음,관련액터자동생성)

Group : 이미존재하는 액터에대한 그룹화를 하는것으로 ,라우터 구성경로를 직접 지정합니다.  ( 경로지정 ,관련액터 직접생성)


라우터의 종류

이름작동다이어그램특징
round-robin

Round Robin Router

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

Broadcast Router

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

random


랜덤 메시지 전송
consistent-hashing

ConsistentHash Router

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

기본적으로 랜덤이나, 느린놈을 제외하고 특정시간이 지나야 다시 합류시킴(일반적으로 빠른 응답속도 보장용)

옵션:

within = 10s
tail-chopping-router.interval = 20ms
scatter-gather

ScatterGatherFirstCompleted Router

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

SmallestMailbox Router

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

ScatterGatherFirstCompleted Router

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

옵션:

within = 10s


 키설정이 필요한,  consistent-hashing 제외하고 나머지 라우터전략을 옵션을 통해(라우터 이름만 알고 있으면됨)

이루어냅니다.


라우터 테스트


라우터 설정
              actor.deployment {
                /workers {
                router = round-robin-pool
                nr-of-instances = 5
                }
              }

라우터 Type을 선택하고, 인스턴수를 지정합니다. 위 라우터정의표에서 작동 이름만 바꾸면 

전략변경가능합니다.


테스트 액터
    public class ReActor : ReceiveActor
    {
        private ILoggingAdapter log = Context.GetLogger();

        public ReActor()
        {
            Receive<string>(message => {
                string reply = string.Format("I'am {0} RE:{1}", Self.Path, message);
                log.Info(reply);
                Sender.Tell(reply);
            });            
        }
    }

라우터 테스트가 잘되는지 확인하기 위해, 나의 이름을 말하고 "RE"로 받은 메시지 응답을 합니다.


테스트코드
            var props = Props.Create<ReActor>().WithRouter(FromConfig.Instance);
            var actor = actorSystem.ActorOf(props, "workers");
            
            actor.Tell("t1");
            actor.Tell("t2");
            actor.Tell("t3");

해당 라우터에 여러번 메시지를 보냅니다.









  • No labels