如何在单元测试中杀死并重启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