【大家的项目】仿照actix写了一个actor模型框架: Serviceless

2024-04-26 14:06:14 浏览数 (2)

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原理。

0 人点赞