之前学习了一下actor模型的基本原理,做了一个类似功能的项目。非常轻量化,代码很短,项目只依赖了tokio。主要用了一些Rust类型转换的魔法。没有任何unsafe代码,并且原生支持async。
编写一个Actor非常简单,也支持started等生命周期:
pub struct Service1 {}
#[async_trait]
impl Service for Service1 {
async fn started(&mut self, _ctx: &mut Context<Self>) {
println!("Started")
}
}
定义一个消息也只需要实现一个Message trait:
pub struct Messagep {}
pub struct MessageResult {}
impl Message for Message0 {
type Result = MessageResult;
}
之后就可以在Actor上实现Handler:
#[async_trait]
impl Handler<U8> for Service0 {
async fn handler(&mut self, message: U8, _ctx: &mut Context<Self>) -> U8 {
U8(message.0 + 2)
}
}
Ext Link: https://github.com/tiannian/serviceless
1
共 2 条评论, 1 页
评论区
写评论是的,这些东西都挺类似的。实际上原理并不复杂,这个更多是一个学习的产出。
--
👇
zzl221000: 让我想起来一个项目 xtra
让我想起来一个项目 xtra