Page History
| Info | |
|---|---|
| Info | FSM을 간단하게 정리하면 아래와 같습니다.
|
이것은 메시지 처리기에도 적용가능한부분이며, 특정 상태에 따라 메시지를 다르게 처리하는
AKKA에서 제공하는 FSM액터를 재정의 받아서 생성가능합니다.
상태 머신설계
...
해당 액터의 메시지 처리기를 다음과 같이 설계한다고 가정해봅시다.
- 메시지를 일정시간 모아뒀다가 내가 원하는 타이밍에 대상에 보내고 싶다.
- 메시지는 쌓이고 보내는 명령을 하지 않았다면, 특정시간이 내에 자동으로 보내고 싶다.
이것은 일반적으로, 리스트형태로 변환가능한 동일한 Type의 데이터일시 잦은 Update주기를
제한하고자 할때 많이 사용됩니다. 1초이내에 100번 업데이터되는것보다, 1초동안 모은 100개의 데이터를
뭉쳐서 주는 방법이 훨씬 효율적이기 때문입니다.
상태설계는 아래와 같이 단순합니다.
- 상태값은 대기와 활동상태 두개를 가진다.
- 특정 시간이 지나면 활동상태로 깨어난다.
- 대기이던 활동이던, 데이터 수신은 가능하다.
샘플 데이터 정의
...
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
// received events
public class SetTarget
{
public SetTarget(IActorRef @ref)
{
Ref = @ref;
}
public IActorRef Ref { get; }
}
public class Queue
{
public Queue(object obj)
{
Obj = obj;
}
public Object Obj { get; }
}
public class Flush { }
// send events
public class Batch
{
public Batch(ImmutableList<object> obj)
{
Obj = obj;
}
public ImmutableList<object> Obj { get; }
}
public enum State
{
Idle,
Active
}
// data
public interface IData { }
public class Uninitialized : IData
{
public static Uninitialized Instance = new Uninitialized();
private Uninitialized() { }
}
public class Todo : IData
{
public Todo(IActorRef target, ImmutableList<object> queue)
{
Target = target;
Queue = queue;
}
public IActorRef Target { get; }
public ImmutableList<object> Queue { get; }
public Todo Copy(ImmutableList<object> queue)
{
return new Todo(Target, queue);
}
} |