如何在單元測試中殺死並重啓akka persistent actor以查看它是否保留狀態

Question

在我的單元測試中，有沒有一種方法可以殺死然後重新啓動一個持久actor以檢查它是否可以正確保留狀態（並且，例如，事件序列化/反序列化工作正常）？

Answer 1

// Initialize the actor and a probe for the actor 
val probe = TestProbe() 
val act = system.actorOf(Props[MyActor], "name") 

// send messages to the actor to change state 
// Validate that the state has changed 

// Send a message to terminate the actor 
act ! PoisonPill 

// wait for the actor to shutdown 
probe.watch(act) 
probe.expectTerminated(act) 

// Initialize a new probe and a new instance of the actor, with the assumption 
// that the actor has the same persistence id as the initial one. 
// That actor should now be in the same state as before. 

val probeTwo = TestProbe() 
val rehydrated = system.actorOf(Props[MyActor], "name") 

// Validate the state of the actor. 
// Todo: Put your validation checks here 

以下是關於test actors的一些有用信息。

Answer 2

注意：對於持續演員而言，PoisonPill消息不是推薦的方式來阻止演員。推薦的方法是明確關閉例如：system.stop(act)

http://doc.akka.io/docs/akka/current/scala/persistence.html#Safely_shutting_down_persistent_actors