• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

actixrustactor框架学习二pingactordemo代码

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

以下是官方文档的学习,了解基本的actix actor 编程模型

项目初始化

  • cargo 创建
cargo new actor-ping --bin
  • 效果
├── Cargo.toml
└── src
    └── main.rs

添加依赖

  • cargo.toml 配置
[package]
name = "actor-ping"
version = "0.1.0"
authors = ["rongfengliang <[email protected]>"]
edition = "2018"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies]
actix = "0.8"

创建Actor trait

  • actor 代码
use actix::prelude::*;
struct MyActor {
    count: usize,
}
impl Actor for MyActor {
    type Context = Context<Self>;
}
 

说明
每个actor 必须有一个context,后边会有介绍

定义消息

消息是actor 可以接受的数据,消息是任何实现Message trait 的类型

use actix::prelude::*;
struct Ping(usize);
impl Message for Ping {
    type Result = usize;
}
 
 

定义消息的handler

handler 是能处理对应消息实现了Handler trait 的方法

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
    }
}

启动actor 以及处理效果

启动actor 依赖context,上边demo 使用的Context 依赖的基于tokio/future 的context
所以可以使用Actor::start()或者Actor::create(),我们可以使用do_send 发送不需要等待响应
的消息,或者使用send 发送特定消息,start() 以及creat() 都返回一个adress 对象

 
fn main() -> std::io::Result<()> {
    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| {
            println!("RESULT: {}", res == 20);
        })
        .map_err(|_| ()));
    system.run()
}

运行&&效果

  • 运行
cargo run
  • 效果

 

 

参考资料

https://actix.rs/book/actix/sec-1-getting-started.html


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Matlab实现Butterworth滤波器 ...发布时间:2022-07-18
下一篇:
带通滤波 matlab - 蒲公英的花发布时间:2022-07-18
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap