Actix - Rust 的Actor异步并发框架

## Actix - Rust 的Actor异步并发框架 ### [actix](https://github.com/actix) ### [官网](https://actix.rs/) 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) ### 示例 ```go 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(); } ```