분산처리가능한 API호출을 하는 로드 테스트기를 만들어보자클러스터의 이해가 없어도, API호출 구현체만 작성하면 바로 활용가능하며

로드테스트 팀이있고, 툴을 구매할수 있으면  LoadRunner같은 전문 퍼포먼스 툴사용이 권장되나

이 문서의 목적은, 그럭저럭 쓸만한 분산처리 가능 심플 로드 테스트기를  직접 설계하고 구현해보는것입니다. 

git : https://github.com/psmon/AkkaForNetCore  - 구현이 다된상태이기때문에 자유롭게 활용가능합니다. -오픈유어소스 오픈유어 마인드

//한꺼번에 명령가능한 액터로,TPS조절기가 빌트인 되어있습니다.
public class TPSCommandActor : ReceiveActor
{
	IActorRef batchActor;
	IActorRef throttleLimitWork;
	int seqNo;

	public TPSCommandActor(IActorRef workerPool)
	{
		seqNo = 0;

		// 1초에 한번씩 데이터를 방류하는 배치액터를 생성합니다. -실시간 비동기 FSM 패턴이 사용됨
		batchActor = Context.ActorOf(Props.Create(() => new BatchActor(1)));
		// TPS를 조절하는 조절기를 생성합니다.
		throttleLimitWork = Context.ActorOf(Props.Create(() => new ThrottleLimitWork()));

		//배치액터와 조절기를 연결합니다.
		batchActor.Tell(new SetTarget(throttleLimitWork));
		//조절기에 워커풀을 연결합니다.(라운드로빈풀)
		throttleLimitWork.Tell(new SetTarget(workerPool));

		//기본 능력치를 5로 설정합니다.
		throttleLimitWork.Tell(5);

		//초당 처리능력 실시간 변경가능합니다.
		ReceiveAsync<int>(async limit =>
		{                
			throttleLimitWork.Tell(limit);
		});

		// LoadTest 시작 명령은 이곳으로부터 출발합니다.
		// batchActor -> throttleLimitWork -> _worker
		ReceiveAsync<ApiCallSpec>(async msg =>
		{
			msg.SeqNo = seqNo;  //자동증가번호사용
			//배치처리 Queue에 적재합니다.
			batchActor.Tell(new Queue(msg));
			seqNo++;
		});
	}

	protected override void PreStart()
	{
		Context.IncrementActorCreated();
	}

	protected override void PostStop()
	{
		Context.IncrementActorStopped();
	}
}

    dotnet run  --configuration Release --project AkkaNetCore --environment "Development" --port 5001 --akkaip 127.0.0.1 --akkaport 7100 --roles akkanet --akkaseed akka.tcp://actor-cluster@127.0.0.1:7100 --MonitorTool win
    
    dotnet run --no-build --configuration Release --project AkkaNetCore --environment "Development" --port 5002 --akkaip 127.0.0.1 --akkaport 5102 --roles akkanet,apiwork --akkaseed akka.tcp://actor-cluster@127.0.0.1:7100 --MonitorTool win
    
    dotnet run --no-build --configuration Release --project AkkaNetCore --environment "Development" --port 5003 --akkaip 127.0.0.1 --akkaport 5103 --roles akkanet,apiwork --akkaseed akka.tcp://actor-cluster@127.0.0.1:7100 --MonitorTool win