模型和定制

Riker需要Model来设置整个系统中使用的消息类型，并指定提供核心服务的模块。 Model是一个可以在Rust类型上实现的特性，然后用于创建ActorSystem。

Model Trait

让我们来看看Model特征：

  1. pub trait Model : Sized {
  2.     /// The message type used throughout the system.
  3.     /// `Actor.receive` expects this type
  4.     type Msg: Message;
  6.     /// Dispatcher executes actors and futures
  7.     type Dis: Dispatcher;
  9.     /// Logger provides global logging, e.g. info!("hello");
  10.     type Log: LoggerProps<Msg = Self::Msg>;
  12.     /// Dead letters subscribes to the dead letters channel
  13.     type Ded: DeadLetterProps<Msg = Self::Msg>;
  15.     /// Timer provides message scheduling, e.g. `ctx.schedule_once`
  16.     type Tmr: TimerFactory<Msg = Self::Msg>;
  18.     /// Event store provides the storage system for events/messages
  19.     type Evs: EventStore<Msg=Self::Msg>;
  21.     type Tcp: IoManagerProps<Msg = Self::Msg>;
  22.     type Udp: IoManagerProps<Msg = Self::Msg>;
  23. }

模型特征由用于定制Riker系统的各种特征类型组成，包括消息类型。

默认模型

riker-default crate提供了一个默认模型，它使用默认的Riker模块，但仍允许您指定消息类型（协议）。

使用默认模型：

  1. extern crate riker;
  2. extern crate riker_default;
  4. use riker::actors::*;
  5. use riker_default::DefaultModel;
  7. // Get a default model with String as the message type
  8. let model: DefaultModel<String> = DefaultModel::new();
  9. let sys = ActorSystem::new(&model).unwrap();

默认模型有助于启动应用程序的初始阶段。 它也是集成测试的不错选择。 当您准备好使用其他模块时，例如特定数据库的事件存储模块，您可以使用自己的模型。

自定义模型

由于Model是一个特征，它可以在一个简单的结构上实现。

让我们看看如何创建模型来更改事件存储和日志记录模块：

  1. extern crate riker;
  2. extern crate riker_default;
  4. use riker::actors::*;
  5. use riker_default::*; // <-- we're still going to use some default modules
  7. struct MyModel;
  9. impl Model for MyModel {
  10.     type Msg = String;
  11.     type Dis = ThreadPoolDispatcher;
  12.     type Ded = DeadLettersActor<Self::Msg>;
  13.     type Tmr = BasicTimer<Self::Msg>;
  14.     type Evs = Redis<Self::Msg>; // <-- a module to provide Redis storage 
  15.     type Tcp = TcpManager<Self::Msg>;
  16.     type Udp = TcpManager<Self::Msg>;
  17.     type Log = MyLogger<Self::Msg>; // <-- our own Log module
  18. }
  20. let sys = ActorSystem::new(&MyModel).unwrap();