Testing

测试并发系统比单线程应用程序更困难，因为测试本身和应用程序在不同的线程上运行。 此外，由于Riker的弹性自我修复方法，恐慌被隔离，处理和故障组件重新启动，检测测试失败证明是具有挑战性的。

为了帮助简化测试，riker-testkit引入了一个“探测器”，可以通过消息传递或作为 Actor道具的一部分发送给 Actor。 然后，探针可以将值发送回测试线程。

以下是测试actor重启的示例：

  1. #[macro_use]
  2. extern crate riker_testkit;
  4. type TestProbe = ChannelProbe<(), ()>;
  6. #[derive(Clone, Debug)]
  7. enum TestMsg {
  8.     Probe(TestProbe),
  9.     Panic,
  10. }
  12. impl Into<ActorMsg<TestMsg>> for TestMsg {
  13.     fn into(self) -> ActorMsg<TestMsg> {
  14.         ActorMsg::User(self)
  15.     }
  16. }
  18. struct MyActor;
  20. impl MyActor {
  21.     fn new() -> BoxActor<TestMsg> {
  22.         Box::new(MyActor)
  23.     }
  24. }
  26. impl Actor for MyActor {
  27.     type Msg = TestMsg;
  29.     fn receive(&mut self,
  30.                 _ctx: &Context<Self::Msg>,
  31.                 msg: Self::Msg,
  32.                 _sender: Option<ActorRef<Self::Msg>>)
  33.     {
  34.         match msg {
  35.             TestMsg::Panic => {
  36.                 // panic the actor to simulate failure
  37.                 panic!("// TEST PANIC // TEST PANIC // TEST PANIC //");
  38.             }
  39.             TestMsg::Probe(probe) => {
  40.                 // received probe
  41.                 // let's emit () empty tuple back to listener
  42.                 probe.event(());
  43.             }
  44.         };
  45.     }
  46. }
  48. #[test]
  49. fn panic_actor() {
  50.     let model: DefaultModel<TestMsg> = DefaultModel::new();
  51.     let sys = ActorSystem::new(&model).unwrap();
  53.     let props = Props::new(Box::new(MyActor::new));
  54.     let actor = sys.actor_of(props, "my-actor").unwrap();
  56.     // Make the test actor panic
  57.     actor.tell(TestMsg::Panic, None);
  59.     // Prepare a probe
  60.     let (probe, listen) = probe::<()>();
  62.     // Send the probe to the panicked actor
  63.     // which would have been restarted
  64.     actor.tell(TestMsg::Probe(probe), None);
  66.     // Testkit provides a macro to assert the result
  67.     // that gets emmitted from the probe to the listener.
  68.     // Here we're expecting () empty tuple.
  69.     p_assert_eq!(listen, ());
  70. }

此测试显示我们的actor在失败后成功重启。 它能够继续接收消息，在这种情况下是探测。 宏p_assert_eq！ 等待（块）侦听器，直到从探测器接收到值。