이번장에서는 Actor의 기능을 확장하여 유용한 몇가지 기능들을 살펴보겠습니다.
Untyped Actor
Untyped Actor
public class MyActorSame : UntypedActor
{
protected override void OnReceive(object message)
{
if(message is string)
{
if (message as string == "createChild")
{
Context.ActorOf<MyActor>("myChild");
Sender.Tell("Create Child Succed:myChild");
}
else
{
Sender.Tell("RE:" + message);
}
}
else if(message is SomeMessage)
{
Sender.Tell("RE:" + (message as SomeMessage).message );
}
}
}
Untyped Actor는, 이전 섹션에서 익힌 ReceiveActor 처럼 생성자에서 Type별로 메시지 처리기를 등록하는게 아닌 , OnReceive에서 다소 직관적으로
수신처리가 가능합니다. 다소 커스텀한 액터 작성시 또는 이방식이 더 익숙할시 이방식으로 액터를 생성하면됩니다.
ACTOR의 확장기능을 설명하기위해 이제부터는 UntypedActor를 사용하여 진행하겠습니다.
Become/Unbecome
사용목적 : 메시지 처리기가 어떠한 메시지에 따라 패턴이 변한다고 가정합시다.
이러한 경우,어떠한 패턴이없다면 상태값을 내부변수로 두고 이값에따라 다중 IF문을 통해
분기처리를 할것입니다. 메시지 처리에대한 중첩 IF문이 발생하기때문에 가독성이 떨어지거나
유지보수가 힘들수 있습니다. 이경우 메시지 처리기를 좀더 유연하게 설계가가능합니다.
FSM(Finite-state machine) 을 지원하기위한 기능입니다.
처리기가 변하는 Actor
//foo 라고하면 행복해졌다가, bar라고하면 화나는 ACTOR , 동일한 상태에서는 상태변경없이 메시지전송
public class HotSwapActor : UntypedActor
{
//기본탑재 로그,이제부터는 시간,스레드,액터정보등이 표시된 console.writeline대신 AKKA LOG를 사용하겠습니다. using Akka.Event
private ILoggingAdapter log = Context.GetLogger();
protected override void OnReceive(object message)
{
log.Info("NORMAL:"+message.ToString());
switch (message as string)
{
case "foo":
log.Info("행복해짐");
Become(Happy);
break;
case "bar":
log.Info("화남");
Become(Angry);
break;
}
}
private void Angry(object message)
{
log.Info("Angry:" + message.ToString());
switch (message as string)
{
case "foo":
log.Info("행복해짐");
Become(Happy);
break;
case "bar":
log.Info("이미 화가났다.");
Sender.Tell("이미 화가났다.");
break;
}
}
private void Happy(object message)
{
log.Info("Happy:" + message.ToString());
switch (message as string)
{
case "foo":
log.Info("이미 행복하다.");
Sender.Tell("이미 행복하다.");
break;
case "bar":
log.Info("화남");
Become(Angry);
break;
}
}
}
TestCode:foo 라고하면 행복해졌다가, bar라고하면 화나는 ACTOR 결국 행복해짐
protected void SomeTest3() //BecomeTest
{
IActorRef myActor = actorSystem.ActorOf<HotSwapActor>("myactor");
myActor.Tell("bar");
myActor.Tell("foo");
myActor.Tell("bar");
myActor.Tell("foo");
myActor.Tell("bar");
myActor.Tell("bar");
myActor.Tell("foo");
}