单元测试actix参与者，向不同类型的参与者发送消息

单元测试Actix参与者向不同类型的参与者发送消息

基础概念

单元测试：是针对程序模块（软件设计的最小单位）进行的正确性检验的测试工作。

Actix：是一个强大的、实用的Rust actor系统，用于构建并发和高性能的应用程序。

参与者（Actor）：在Actix中，参与者是并发执行的实体，它们通过消息进行通信。

类型与应用场景

类型：

系统参与者：管理整个Actor系统的生命周期。
业务逻辑参与者：处理具体的业务逻辑。
接口参与者：作为外部系统与内部Actor系统的桥梁。

应用场景：

微服务架构：每个服务可以作为一个独立的参与者。
实时系统：利用Actix的高并发特性处理实时数据流。
游戏服务器：管理玩家连接、游戏状态等。

示例代码

假设我们有一个简单的系统，其中有两种类型的参与者：UserActor 和 AdminActor。UserActor 可以接收普通用户的消息，而 AdminActor 可以接收管理员的消息。

use actix::prelude::*;

// 定义消息类型
#[derive(Message)]
#[rtype(result = "String")]
struct UserMessage(String);

#[derive(Message)]
#[rtype(result = "String")]
struct AdminMessage(String);

// 用户参与者
struct UserActor;

impl Actor for UserActor {
    type Context = Context<Self>;
}

// 处理用户消息
impl Handler<UserMessage> for UserActor {
    type Result = String;

    fn handle(&mut self, msg: UserMessage, _ctx: &mut Self::Context) -> Self::Result {
        format!("User received: {}", msg.0)
    }
}

// 管理员参与者
struct AdminActor;

impl Actor for AdminActor {
    type Context = Context<Self>;
}

// 处理管理员消息
impl Handler<AdminMessage> for AdminActor {
    type Result = String;

    fn handle(&mut self, msg: AdminMessage, _ctx: &mut Self::Context) -> Self::Result {
        format!("Admin received: {}", msg.0)
    }
}

#[actix_rt::main]
async fn main() {
    let user_addr = UserActor.start();
    let admin_addr = AdminActor.start();

    // 发送消息给用户参与者
    let user_res = user_addr.send(UserMessage("Hello User".to_string())).await;
    match user_res {
        Ok(result) => println!("{}", result.unwrap()),
        Err(e) => eprintln!("Failed to send message to UserActor: {:?}", e),
    }

    // 发送消息给管理员参与者
    let admin_res = admin_addr.send(AdminMessage("Hello Admin".to_string())).await;
    match admin_res {
        Ok(result) => println!("{}", result.unwrap()),
        Err(e) => eprintln!("Failed to send message to AdminActor: {:?}", e),
    }
}