< 返回版块

tiannian 发表于 2024-04-24 19:08

Tags:actor, actix

之前学习了一下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

评论区

写评论
作者 tiannian 2024-04-25 01:30

是的,这些东西都挺类似的。实际上原理并不复杂,这个更多是一个学习的产出。

--
👇
zzl221000: 让我想起来一个项目 xtra

zzl221000 2024-04-24 22:27

让我想起来一个项目 xtra

1 共 2 条评论, 1 页