Versions Compared

Old Version 7

changes.mady.by.user PSMON

Saved on

compared with

New Version 8

changes.mady.by.user PSMON

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
themeEmacs
@Component
@Scope("prototype")
public class MyPersistentActor extends AbstractPersistentActorWithAtLeastOnceDelivery {
	  private final ActorSelection destination;
	  
	  private ActorRef testActor;

	  public MyPersistentActor(ActorSelection destination) {		  
	      this.destination = destination;
	  }

	  @Override public String persistenceId() {
	    return "persistence-id";
	  }

	  @Override
	  public Receive createReceive() {
	    return receiveBuilder().
	      match(String.class, s -> {
	    	//메시지가 전송중
	        persist(new MsgSent(s), evt -> updateState(evt));
	        this.testActor = sender();
	      }).
	      match(Confirm.class, confirm -> {
	    	//전송된 메시지가 확인이됨
	        persist(new MsgConfirmed(confirm.deliveryId), evt -> updateState(evt));
	        
	        //메시지 검증을 하기위한 추가확인(실제는 필요없는 코드)
	        this.testActor.tell("testOK", ActorRef.noSender());
	        
	      }).
	      build();
	  }

	  @Override
	  public Receive createReceiveRecover() {
	    return receiveBuilder().
	        match(Object.class, evt -> updateState(evt)).build();
	  }

	  void updateState(Object event) {
	    if (event instanceof MsgSent) {
	      final MsgSent evt = (MsgSent) event;
	      deliver(destination, deliveryId -> new Msg(deliveryId, evt.s));
	    } else if (event instanceof MsgConfirmed) {
	      final MsgConfirmed evt = (MsgConfirmed) event;
	      confirmDelivery(evt.deliveryId);
	    }
	  }

	  //복구옵션은 지정하지 않음
	  @Override
	  public Recovery recovery() {
	    return Recovery.none();
	  }	  	  
}


수신자 설계

Code Block
languagejava
themeEmacs
@Component
@Scope("prototype")
public class MyDestination extends AbstractActor {
	  @Override
	  public Receive createReceive() {
	    return receiveBuilder()
	      .match(Msg.class, msg -> {
	    	//메시지를 받았으니, 할일을 하고
	    	  
	    	//수신 메시지 확인됨을 보냄...
	        getSender().tell(new Confirm(msg.deliveryId), getSelf());
	      })
	      .build();
	  }
}


Test

Code Block
languagejava
themeEmacs
	protected void persistenceMessage(ActorSystem system,SpringExtension ext) {
	    new TestKit(system) {{
	    	
	    	//메시지 전송 확인을 위한 테스트액터(검증은 제 3자가 해야하는 컨셉)
	    	ActorRef probe = getRef();
	    	
	    	//메시지 목적대상 액터 생성
	    	final ActorRef myDestination = system.actorOf(ext.props("myDestination"),"myDes");	    	
	    	final ActorSelection myDes = system.actorSelection("/user/myDes");
	    	
	    	//재전송가능한 메시지 발송기 생성 ( 옵션은 목적대상 액터선택자 ) 
	        final ActorRef myPersistentActor = system.actorOf( ext.props("myPersistentActor",myDes ) );
	        
	        //myPersistentActor 액터에게 메시지 발생
	        
	        myPersistentActor.tell( "hi1",probe );
	        
	        //메시지경로  myPersistentActor(송신) -> myDes(목적지) -> myPersistentActor(수신확인) -> probe(추가검증)
	        expectMsg("testOK");	// probe의 메시지함에 testOK메시지가 존재하면, 승인절차의 메시지 확인완료
	        
	        //Akka의 TestToolkit은 복잡한 비동기 메시지 테스트를 심플하게 해줍니다.	        
	    }};
	}