Page History

이장에서 추가적으로 알게되는것

1. 단순한 문자열이 아닌 객체를 전송하는 방법 ( 자동 시리얼라이즈가 됩니다. )
2. 액터를 스레드프로그래밍없이 확장하고 분배하는방법 ( 대표적인 라운드 로빈풀을 샘플로 사용하였으며,다양한 라우터를 활용할수 있습니다.)
3. 동시성 처리를 위한 스레드 모델과 액터모델의 차이점

    public class PrintPage
    {
        public int SeqNo { get; set; }
        
        public int DelayForPrint { get; set; }  //프리팅에 걸리는 시간 조작

        public string Content { get; set; }

        public override string ToString()
        {
            return $"SeqNo:{SeqNo} Content:{Content}";
        }
    }

public class PrinterActor : ReceiveActor
    {
        private readonly ILoggingAdapter logger = Context.GetLogger();
        private readonly string id;

        public PrinterActor()
        {
            id = Guid.NewGuid().ToString();
            logger.Info($"프린터 액터 생성:{id}");
            
			// 스위치문이 아닌, 메시지 Type에따른 분기처리를 생성자에서 셋팅하는것이
			// 패턴 매칭이라고도 불립니다.  ( ex> 어떠한 type에 특정 조건이 들어왔을때 )
			// 더 다양한 메시지 기능을 추가하고 싶을때 아래와같은 형택의 코드를 Type별로 추가하면 됩니다.
			// 아래 함수는 델리게이트에 등록되며,생성시마다 호출되는것이 아니고 메시지가 올때마다 호출됩니다.
            ReceiveAsync<PrintPage>(async page =>
            {
                logger.Debug($"프린터 요청 들어옴:{page}");
                await Task.Delay(page.DelayForPrint);
                logger.Debug($"페이지 출력 완료:{page}");
            });            
        }
    }

    [Route("api/[controller]")]
    [ApiController]
    public class PrinterController : Controller
    {
        private IActorRef printerActor;

        public PrinterController()
        {
            printerActor = AkkaLoad.ActorSelect("printer")
        }

        // POST api/values
        [HttpPost]
        public void Post([FromBody] PrintPage value)
        {
            // 프린팅을 요청한다.
            printerActor.Tell(value);
        }        
    }

AkkaLoad.RegisterActor(
	"printer", //여기서 지정한 네이밍은,편리하게 액터 참조를 얻어내기위해 커스텀하게 작성된 네이밍입니다.
	actorSystem.ActorOf(Props.Create<PrinterActor>()
			.WithRouter(new RoundRobinPool(1)),
			"printerActor" // 이 네이밍은 액터시스템내에 고유한 액터명입니다.(공식)
));