• Testing

    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！ 等待（块）侦听器，直到从探测器接收到值。