장애에 대응하기 위해서는 크게 두가지 방법이 있습니다.

• 시스템및 서비스가 절대로 장애가 발생하지 않아서 아무것도 하지않는 경우
• 반대로 모든 장애에 대해 대응책을 세우는것입니다.

전자는 거의 불가능하고, 후자또한 어떠한 장치로 모든것에 대응하는 전략을 세우는것은 아주 어렵고

서비스코드에 썩임으로 서비스코드의 흐름을 복잡하게 만들수가 있습니다.

AKKA자체로 이러한 장애에대한 대응을 자동으로 할수 있는것은 아닙니다.

단지 ,이러한 대응을 일괄적이고 유연한 방법을 제시하고 개발자는 다양한 전략중

하나를 선택하여 그것을 서비스코드와 분리하여 설계할수 있는 장치만 제공을 해줍니다.

    public class Supervisor : UntypedActor
    {
        private readonly ILoggingAdapter log = Context.GetLogger();        

		//장애처리 룰을 정의합니다.(서비스 코드와 완전분리)
        protected override SupervisorStrategy SupervisorStrategy()
        {
            return new OneForOneStrategy(
                maxNrOfRetries: 10,	//최고 시도횟수
                withinTimeRange: TimeSpan.FromMinutes(1),	//최고 시도 시간
                localOnlyDecider: ex =>
                {
                    // Exception별  복구전략
                    if( ex is ArithmeticException )
                        return Directive.Resume;
                    else if( ex is NullReferenceException)
                        return Directive.Restart;
                    else if (ex is ArgumentException)
                        return Directive.Stop;
                    else
                        return Directive.Escalate;                    
                });
        }
       

        protected override void OnReceive(object message)
        {
            if (message is string)
            {
                string msg = message as string;

                if ( msg.Contains("create-") )
                {
                    string childName = msg.Split('-')[1];
                    log.Info("CreateChildActor:" + childName);
                    var childActor = Context.ActorOf<Child>(childName);
                    Context.Watch(childActor);
                    Sender.Tell(childActor);
                }                                                
            }
        }
    }

    public class Child : UntypedActor
    {
        private int state = 0;
        private readonly ILoggingAdapter log = Context.GetLogger();

        protected override void OnReceive(object message)
        {            
            if( message is Exception) //가상의 예외가 발생했다고 가정하고,Let it Crash( 죽게놔둠 )
            {
                throw message as Exception;
            }
            else if (message is int)  // 서비스코드는 예외에대한 어떠한 키워드도 사용할 필요가 없습니다. 
            {
                state = (int)message;
            }
            else if (message is string)
            {
                switch (message as string)
                {
                    case "get":
                        log.Info("Active Check");  //메시지를 받을수 있는지 체크
                        Sender.Tell(state);
                        break;
                }
            }
        }

        protected override void PreRestart(Exception reason, object message)
        {
            log.Info("Actor Restart - reason:" + reason.GetType().Name );   //액터 재 시작된이 야기된 이유를 , 재시작시 알수 있습니다.
        }
    }