Actix - Rust 的Actor异步并发框架

Actix - Rust 的Actor异步并发框架

actix

官网

Actix 基于Tokio和Future，开箱具有异步非阻塞事件驱动并发能力，其实现低层级Actor模型来提供无锁并发模型，而且同时提供同步Actor，具有快速、可靠，易可扩展。

Actix之上是高性能Actix-web框架，很容易上手。使用Actix-web开发的应用程序将在本机可执行文件中包含HTTP服务器。你可以把它放在另一个像nginx这样的HTTP服务器上。但即使完全不存在另一个HTTP服务器(像nginx)的情况下，Actix-web也足以提供HTTP 1和HTTP 2支持以及SSL/TLS。这对于构建微服务分发非常有用。

特性：

• 异步/同步 actors

• Actor 在本地/线程上下文中通信

• 使用 Futures 进行异步消息处理

• 支持 HTTP1/HTTP2(actix-web)

• Actor 监控

• 类型化消息 (No Any type)

示例

extern crate actix;
extern crate futures;
use futures::Future;
use actix::prelude::*;
struct MyActor {
   count: usize,
}
impl Actor for MyActor {
    type Context = Context<Self>;
}

struct Ping(usize);

impl Message for Ping {
    type Result = usize;
}
impl Handler<Ping> for MyActor {
    type Result = usize;

    fn handle(&mut self, msg: Ping, ctx: &mut Context<Self>) -> Self::Result {
        self.count += msg.0;
        self.count
    }
}

fn main() {
    let system = System::new("test");

    // start new actor
    let addr = MyActor{count: 10}.start();

    // send message and get future for result
    let res = addr.send(Ping(10));

    Arbiter::spawn(
        res.map(|res| {
            # System::current().stop();
            println!("RESULT: {}", res == 20);
        })
        .map_err(|_| ()));

    system.run();
}