Page History

이장을 통해 추가적으로 알게 되는것

• 액터에 고급 스레드 프로그래밍에서 사용되는 튜닝 옵션 사용하기
• 액터의 성능을 각각 다르게 설정하기

        public HigPassGateActor()
        {
            id = Guid.NewGuid().ToString();
            logger.Info($"하이패스 액터 생성:{id}");

            ReceiveAsync<string>(async msg =>
            {
                //하이패스는 그냥 지나가면됨
                logger.Debug($"{msg}");
            });
        }

        public CashGateActor()
        {
            rnd = new Random();

            id = Guid.NewGuid().ToString();
            logger.Info($"현금정산게이트 액터 생성:{id}");

            ReceiveAsync<string>(async msg =>
            {
                //현금정산에 걸리는시간 1~10초                 
                int delay = rnd.Next(1000, 10000);
                await Task.Delay(delay);
                logger.Debug($"{msg}-{delay}");
            });
        }

	actor.deployment {
		/highpass-gate-pool {
			router = round-robin-pool
			nr-of-instances = 3
		}

		/cashpass-gate-pool {
			router = smallest-mailbox-pool
			nr-of-instances = 7
		}
	}

# 처리속도가 빨라 동시 처리량이 작게 필요한 경우
fast-dispatcher {
	type = Dispatcher
	throughput = 2
}

# 처리속도가 느려 동시 처리량 확보가 필요한 경우(8번째 동시처리는 7번째 동시처리중 하나가 끝날때를 기다림)
slow-dispatcher {
	type = Dispatcher
	throughput = 7
}

AkkaLoad.RegisterActor(
	"highpass",
	actorSystem.ActorOf(Props.Create<HighPassGateActor>()
			.WithDispatcher("fast-dispatcher")
			.WithRouter(FromConfig.Instance),
			"highpass-gate-pool"
));

AkkaLoad.RegisterActor(
	"cashpass",
	actorSystem.ActorOf(Props.Create<CashGateActor>()
			.WithDispatcher("slow-dispatcher")
			.WithRouter(FromConfig.Instance),
			"cashpass-gate-pool"
));