https://github.com/tiannian/serviceless
之前学习了一下actor模型的基本原理,做了一个类似功能的项目。非常轻量化,代码很短,项目只依赖了tokio。主要用了一些Rust类型转换的魔法。没有任何unsafe代码,并且原生支持async。
编写一个Actor非常简单,也支持started等生命周期:
代码语言:javascript复制pub struct Service1 {}
#[async_trait]
impl Service for Service1 {
async fn started(&mut self, _ctx: &mut Context<Self>) {
println!("Started")
}
}
定义一个消息也只需要实现一个Message trait:
代码语言:javascript复制pub struct Messagep {}
pub struct MessageResult {}
impl Message for Message0 {
type Result = MessageResult;
}
之后就可以在Actor上实现Handler:
代码语言:javascript复制#[async_trait]
impl Handler<U8> for Service0 {
async fn handler(&mut self, message: U8, _ctx: &mut Context<Self>) -> U8 {
U8(message.0 2)
}
}
小编评:很适合新手入门学习Actor原理。