lwleen-rpc 1.3.3

介绍

1. 主页 Homepage
2. 基础库 https://crates.io/crates/lwleen-rpc
3. 应用库 https://crates.io/crates/lwleen
4. crates文档 https://docs.rs/lwleen-rpc

RPC 是 Remote Procedure Call（远程过程调用）, 用于组件间数据通信

⚡️ 快速开始

唯一对外接口 信令路由(rpc)

use lwleen_rpc::prelude::*;

let 信令路由c1 =  信令路由::default();
let 信令路由c2 =  信令路由c1.clone();
let 结果 = 信令路由c1.pool异步任务_block阻塞完成(async move{
    let out1 = 信令路由c2.rpc信令路由_心跳("异步测试1").await;
    let out2 = 信令路由c2.rpc信令路由_心跳("同步测试2").block阻塞完成();
    format!("返回结果:  {out1:?}   {out2:?}")
});
println!("{结果:?}");



//---- 测试 stdout ---- 
Ok("返回结果: Ok((\"💖心跳回答: 异步测试1\", 1754650154616267068)) Ok((\"💖心跳回答: 同步测试2\", 1754650154616303301))")

🛸 可扩展

demo代码 https://docs.rs/crate/lwleen-rpc/latest/source/src/mod_demo.rs

1. 使用过程宏gen_特征_derive生成特征代码 (rust孤儿规则)
2. 新建信令表
3. 使用宏impl信令特征!()为信令表实现信令特征, 即执行函数

use lwleen_rpc::prelude::*;

// 1.第一步
#[gen_特征_derive(Demo_模块特征)]
impl 信令路由{
    fn demo(&self,参数:impl Into<String> ) -> impl 信令任务<String>{
        core发布信令任务!(self, 信令表::demo{ 参数:参数.into()  },  信令表::demo_回复 => 返回 )
    }
}

// 2.第二步
#[derive(Clone, Serialize, Deserialize)]//可选特征
enum 信令表{
    demo{参数:String },
    demo_回复{ 返回:String },
}
impl信令特征!(信令表, 执行函数);      // 所有`信令表`必须实现此特征


// 3.第三步
async fn 执行函数(信令路由:信令路由,id:信令ID,单个信令:信令表)->anyhow_Result<信令表>{ 
    match 单个信令{
        信令表::demo{ 参数 }=>{
			return anyhow::Ok(信令表::demo_回复 { 返回: format!("完成demo  {参数} ") });
        }
        _ =>{ return Err(anyhow_err!("信令不存在")); }
    }
}

使用参考应用库 https://crates.io/crates/lwleen

🌈 自定义服务端

use async_std;
let 信令路由c1 = 信令路由::new(rpc类型::none自定义);    // 用于自定义服务端
let 信令路由c2 = 信令路由c1.clone();
std::thread::spawn(move||{
    async_std::task::block_on(async move{
        while let Ok(msg) = 信令路由c2.core信令包_接收通道().recv().await{
            async_std::task::spawn( 信令路由::core信令包_消费执行(&信令路由c2, msg) );
        }
    });
});

✅ 基准测试(代码性能)

Intel(R) Core(TM) i3-7100 CPU @ 3.90GHz

[任意服务端] demo范例_连通测试 block阻塞完成
                        time:   [48.936 ns 49.270 ns 49.686 ns]
Found 12 outliers among 100 measurements (12.00%)
  5 (5.00%) high mild
  7 (7.00%) high severe

[default == default无服务端] demo范例_连通测试 异步
                        time:   [56.226 ns 56.362 ns 56.526 ns]
Found 10 outliers among 100 measurements (10.00%)
  2 (2.00%) high mild
  8 (8.00%) high severe

[futures单线程] demo范例_连通测试 异步
                        time:   [7.6526 µs 7.8649 µs 8.1285 µs]
Found 16 outliers among 100 measurements (16.00%)
  11 (11.00%) high mild
  5 (5.00%) high severe

[rusty_pool线程池] demo范例_连通测试 异步
                        time:   [9.5018 µs 9.6233 µs 9.7548 µs]
Found 12 outliers among 100 measurements (12.00%)
  1 (1.00%) low severe
  1 (1.00%) low mild
  5 (5.00%) high mild
  5 (5.00%) high severe