You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 8 Next »

스냅샷은 앞장 이벤트소싱에서도 부분적으로 사용이되었습니다. 스냅샷은 다양한곳에서 사용될수 있으며 그 컨셉은 간단합니다.

무수히 발생하는 이벤트로 인해 우리가 설계한 어떠한 객체의 상태는 지속적으로 변경된다는 점이며

복원관점에서 연속된 이벤트 재생이 필요하며 이벤트자체를 모두 기록하는것과

모든 이벤트를 기록할필요없이 특정시점의 상태를 복원하기위해, 주기적으로 상태를 원하는 만큼 찍는것입니다.

주로 게임 리플리와같이 게임시작부터 종료까지 게임플레이를 재생하려면 모든 상태보다 발생 이벤트를 기록해야하며

장바구니기능과 같이넣고빼고한 모든것을 기록할 필요없이 마지막 정보인 특정시점의 상태를 기록하는것이 이점입니다.

게임의 경우 고용량의 영상소스없이 재생이 가능하게되며, 언제든 원하면 고해상도의 동영상 제작도 가능해집니다.

장바구니의 경우 마지막 장바구니는 구매시 활용하고 특정시점의 장바구니는 다양한 상품 추천의 근거자료로 사용될수 있습니다. 


모두를 기록해야하나? 특정시점을 기록해야하냐? 저장소(DB)를 포함하여 IT전반적으로 고민하고 선택하는 주제이며

Redo와 Snapshot의 차이로 일반적으로 많이 언급되며 여기서 오라클을 붙인다던지, 이전작업을 복원하는 redo task 를 붙인다던지

다양한 연관 주제에대해 접근이 가능합니다. 

연관 키워드 : difference between redo and snapshot 


AKKA에서 스냅샷의 의미

액터를 통해 수많은 실시간 메시지(이벤트)가 발생하며, 그 메시지는 상태를 수없이 변경을 합니다.

어떠한 기능을위해 그 상태 변경을 우리가 의도한 만큼 저장을 하고 복원을 할수가 있습니다.

복원 전략은 시스템 업데이트뿐만아니라 장애처리 복구전략에서도 동일하게 사용될수가 있습니다.

스냅샷 구현

final case class SnapshotMetadata(persistenceId: String, sequenceNr: Long, timestamp: Long = 0L)


private Object state;
private int snapShotInterval = 1000;

// 스냅샷을 지원하는 메시지 정의
@Override public Receive createReceive() {
  return receiveBuilder().
    match(SaveSnapshotSuccess.class, ss -> {
      SnapshotMetadata metadata = ss.metadata();
      // ...
    }).
    match(SaveSnapshotFailure.class, sf -> {
      SnapshotMetadata metadata = sf.metadata();
      // ...
    }).
    match(String.class, cmd -> {
      persist( "evt-" + cmd, e -> {
        updateState(e);
        if (lastSequenceNr() % snapShotInterval == 0 && lastSequenceNr() != 0)
          saveSnapshot(state);
      });
    }).build();
}

스냅샷 저장에 필요한 메타정의(SnapshotMetadata) 후 자신이 원하는 타이밍에

카메라 셔터(saveSnapshot) 를 누르기만 하면됩니다.


스냅샷 복원

private Object state;

@Override public Receive createReceiveRecover() {
  return receiveBuilder().
    match(SnapshotOffer.class, s -> {
      state = s.snapshot();
      // ...
    }).
    match(String.class, s -> {/* ...*/}).build();
}


또는


@Override
public Recovery recovery() {
  return Recovery.create(
    SnapshotSelectionCriteria
      .create(457L, System.currentTimeMillis()));
}

마지막 상태를 복원(SnapshotOffer)할수도 있고,

각 시간대별 스냅샷은 고유 아이디가 존재함으로

특정 스냅샷(SnapshotSelectionCriteria)을 복원할수도 있습니다.


스냅샷 시도에따른 반응 메시지

MethodSuccessFailure message
saveSnapshot(Any)SaveSnapshotSuccessSaveSnapshotFailure
deleteSnapshot(Long)DeleteSnapshotSuccessDeleteSnapshotFailure
deleteSnapshots(SnapshotSelectionCriteria)DeleteSnapshotsSuccessDeleteSnapshotsFailure

스냅샷은 다양한 이유로(디스크풀및 메모리풀등) 실패가 있을수 있으며

그에 대응하는 코드작성도 가능합니다. 


다양한 활용 샘플 검색:



  • No labels