Versions Compared

Old Version 13

changes.mady.by.user PSMON

Saved on

compared with

New Version Current

changes.mady.by.user PSMON

Saved on

Key

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

...

  Akka는 기본적으로 탑레벨 아키텍쳐의 설계방식으로 Actor를 위치시키고 접근을 하며 (최상위부터 생성하여 구조화하는 방식 )

다음과같은 특성이 있습니다.

  • 액터접근 : 트리구조이지만, FullName을 알고있을시 최하위 자식노드에게 직접 리모트 메시지전송이

...

  • 가능합니다.
  • 액터접근 :  someActor의 자식에게 모두 메시지를 보내고 싶으면 someActor/* 를 할수 있습니다.
  • 라우팅화 가능 : 분산처리를 위해 자식노드에게 다양한 라우팅을 지정할수 있습니다. 순차적으로 분산처리 해야한다고하면 라운드 로빈으로 자식 액터 배치가 가능합니다.
  • 리모트 액터 : 모든게 메시징를 통해서만 명령이 전달되며 로컬과 리모트의 차이가 없습니다.
  • 클러스터 : 로컬과 리모트의 차이가 없다란것은 로컬로 개발된 액터가 약간의 코드수정으로 단일지점 병목없는 클러스터화 가능합니다.

Actor의 기본

또한 클러스터 룰정의를 통해 분산환경 구현의 확장이 유연합니다. ( 확장의 유연성)

장애 처리 관점에서 자식의 예외는 부모가 처리하는것을 1원칙으로, 부모의 예외를 자식노드에게 전가시키 지 않습니다.

이로써 상위 감독자에게 장애에대한 룰을 각각 적용할수가 있습니다. ( 장애를 허용하고 이를 유연하게 대처하는 장애 대응 구조 설계가능 )

접근이 가능하다란 말은 대상에게 메시지를 전송시킬수 있다란 의미이지, 객체 자체를 접근할수 있다란 의미는 아닙니다.( 객체 공유는 액터모델에 위배됨 )

...

생성과 Child Actor 생성

Code Block
languagec#
themescalaEmacs
title기본 액터생성
linenumberstrue
    public class MyActor : ReceiveActor
 PrintMyActorRefActor extends Actor {
   override def receive: Receive = {
     private ILoggingAdapter log = Context.GetLogger();

        public MyActor()
        {
         case "printit"   Receive<string>(message => {
      val secondRef = context.actorOf(Props.empty, "second-actor") //자식의 생성은 부모만 할수 있다.
          if (message == "createChild")
                {
                    Context.ActorOf<MyActor>("myChild");
           println(s"Second: $secondRef")
  }
}

val firstRef = system.actorOf(Props[PrintMyActorRefActor], "first-actor")
println(s"First : $firstRef")
firstRef ! "printit"


//액터 생성 순서   first-actor <= second-actor  가 parent <= child 관계가 된다.
First : Actor[akka://testSystem/user/first-actor#1053618476]
Second: Actor[akka://testSystem/user/first-actor/second-actor#-1544706041]

아래와같이, rest의 endpoint 와 유사하게 접근이 가능합니다.

         Sender.Tell("Create Child Succed:myChild");
                }
                else
                {
                    Sender.Tell("RE:" + message);
                }
            });

            Receive<SomeMessage>(message => {
                Sender.Tell("RE:" + message.message);
            });
        }

    }


	IActorRef myActor = actorSystem.ActorOf<MyActor>("myactor");
	myActor.tell("createChild");


액터접근

Code Block
languagec#
themeEmacs
Code Block
languagec#
titleActor접근법
linenumberstrue
var parentActor= system.ActorSelection("akka://testSystem/user/first-actormyactor");
var childActor= system.ActorSelection("akka://testSystem/user/first-actor/second-actormyactor/myChild");

잘설계된 RestAPI의 endpoint 와 접근법이 유사합니다.

어떠한 의미에서 REST-API 설계도 Top-Level 아키텍쳐를 따른다고 볼수 있습니다. ( 상위에서 하위기능으로 분류)

작동방식에서의 차이는 REST-API는 무상태를 지향하지만, 액터의 경우 상태가 있는 서비스 설계에 더 유리합니다.


액터성능

로컬에서만 사용될때는 메모리를 사용하며 , 리모트 전송이 발생할때는 고성능 TCP프로토콜을 활용합니다.

액터의 소멸

로컬에서는 주로 멀티스레드를 관리하는 Dispatcher에 의해 액터의 성능이 결정될수 있으며

리모트에서는 고성능 TCP모듈및 , 원격컴퓨터간 데이터복원을 위한 직렬화에 영향을 받을수 있으며

컴포넌트 형태로 이것은 모두 코드변경없이 가장 빠른모듈로 손쉽게 교체가 가능합니다.


액터의 소멸과 생명주기

 구조적인  이런 구조적인 설계로, 부모의 액터를 정지시키면 자식의 액터를 모두 종류후 마지막에 부모 액터가 종료가됩니다.

이것은 부모가 자식을 책임지는 AKKA의 기본 예외 처리모델과도 부합하며, OOP방식의 소멸순서와도 유사합니다.

상속을 받은 OOP Class의 소멸 순서와도 유사합니다. 

부모가 자식을 관리감독할수 있으며, 장애복구전략에 따라 자식액터를 재생성 할수 있습니다.


Image Added다만 부모에게 발생한 예외를 자식에게 전가시키지 않습니다. ( 예외처리모델에 더 상세하게 설명)


Code Block
languagec#
themeEmacsscala
titleActor 중지
linenumberstrue
    public class StartStopActor1 : ReceiveActor
    {
        private ILoggingAdapter log = Context.GetLogger();

        public StartStopActor1 extends Actor {
  override def preStart(): Unit = {
    println()
        {
            Receive<string>(message => {
                if (message == "stop")
                {
                    Context.Stop(Self);
                }                
            });            
        }

        protected override void PreStart()
        {
            log.Info("first started");
            contextContext.actorOf(Props[StartStopActor2], ActorOf<StartStopActor2>("second");
        }

        protected override defvoid postStopPostStop(): Unit = println
        {
            log.Info("first stopped");
        }

  override def receive: Receive = {
    case "stop" => context.stop(self)
  }
}

class StartStopActor2 extends Actor {
  override def preStart(): Unit = println  }

    public class StartStopActor2 : ReceiveActor
    {
        private ILoggingAdapter log = Context.GetLogger();

        public StartStopActor2()
        {
            Receive<string>(message => {                
            });            
        }

        protected override void PreStart()
        {
            log.Info("second started");

  override def postStop(): Unit = println("second stopped") }

     // Actor.emptyBehavior is a useful placeholder when we don't
  // want to handle any messages in the actor.
  override def receive: Receive = Actor.emptyBehavior
}

val first = system.actorOf(Props[StartStopActor1], "first")
first ! "stop"


   protected override void PostStop()
        {
            log.Info("second stopped");
        }

    }


	IActorRef myActor = actorSystem.ActorOf<StartStopActor1 >("myactor");
	myActor.Tell("stop");

//OutPut
//first started
//second started
//second stopped
//first stopped

...


Supervisor을 통한

...

장애허용시스템

Child 액트가 액터가 장애발생시, 디양한 다양한 복구전략( 3초간 30초동안시도)을 통해 Child액트의 Child액터의 복구가 가능하다가능합니다. 

Code Block
languagec#
themeEmacs
linenumberstrue
var supervisor = BackoffSupervisor.Props(
                    Backoff.OnFailure(
                        childProps,
                        childName: "supervised-actor",
                        minBackoff: TimeSpan.FromSeconds(3),
                        maxBackoff: TimeSpan.FromSeconds(30),
                        randomFactor: 0.2)
                    );



Include Page
webfr:Fault Tolerance
webfr:Fault Tolerance