Arpy：Rust的RPC

定义您的RPC签名，并使用它们与各种客户端/服务器实现一起使用。

项目状态

Arpy处于初期阶段，尚未经过充分测试。

传输实现

Reqwest 和 Reqwasm 客户端可用，以及 Axum 和 Actix 服务器。

用法

定义您的RPC签名，在服务器上实现它们，并在客户端调用它们。这些可以位于不同的crates中，也可以根据您的流程全部在一个crates中。

定义RPC签名

#[derive(MsgId, Serialize, Deserialize, Debug)]
pub struct Add(pub i32, pub i32);

impl FnRemote for Add {
    type Output = i32;
}

#[derive(MsgId, Serialize, Deserialize, Debug)]
pub struct TryMultiply(pub i32, pub i32);

impl FnRemote for TryMultiply {
    type Output = Result<i32, ()>;
}

实现服务器

使用Axum的示例

async fn add(args: &Add) -> i32 {
    args.0 + args.1
}

async fn try_multiply(args: &TryMultiply) -> Result<i32, ()> {
    Ok(args.0 * args.1)
}

let app = Router::new()
    .http_rpc_route("/http", add)
    .http_rpc_route("/http", try_multiply);

Server::bind(&SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 9090))
    .serve(app.into_make_service())
    .await
    .unwrap();

调用远程过程

使用Reqwasm的示例

let connection = http::Connection::new(&format!("http://127.0.0.1:9090/api"));
let result = Add(1, 2).call(&connection).await?;

assert_eq!(3, result);

其他功能

• WebSocket支持，包括
  • 多个同时进行的RPC调用
  • 参数化订阅
• 服务器端事件