Roadmap

0.1.x

0.2.x

0.3.x

Usage

[dependencies]rpcx ="0.2.0"

Example

Write the Argument and the Reply

use std::error::ErrorasStdError;use rmp_serdeas rmps;use serde::{Deserialize,Serialize};use rpcx_derive::*;use rpcx_protocol::{Error,ErrorKind,Result,RpcxParam,SerializeType};#[derive(RpcxParam,Default,Debug,Copy,Clone,Serialize,Deserialize)]pubstructArithAddArgs{#[serde(rename ="A")]puba:u64,#[serde(rename ="B")]pubb:u64,}#[derive(RpcxParam,Default,Debug,Copy,Clone,Serialize,Deserialize)]pubstructArithAddReply{#[serde(rename ="C")]pubc:u64,}

Implement the server

use mul_model::{ArithAddArgs,ArithAddReply};use rpcx::*;fnadd(args:ArithAddArgs) ->ArithAddReply{ArithAddReply{c: args.a + args.b}}fnmul(args:ArithAddArgs) ->ArithAddReply{ArithAddReply{c: args.a* args.b}}fnmain(){letmut rpc_server =Server::new("127.0.0.1:8972".to_owned());register_func!(        rpc_server,"Arith","Add",        add,ArithAddArgs,ArithAddReply);register_func!(        rpc_server,"Arith","Mul",        mul,ArithAddArgs,ArithAddReply);    rpc_server.start().unwrap();}

Implement client

use std::collections::hash_map::HashMap;use mul_model::*;use rpcx::Client;use rpcx::{Result,SerializeType};pubfnmain(){letmut c:Client =Client::new("127.0.0.1:8972");    c.start().map_err(|err|println!("{}", err)).unwrap();    c.opt.serialize_type =SerializeType::JSON;letmut a =1;loop{let service_path =String::from("Arith");let service_method =String::from("Mul");let metadata =HashMap::new();let args =ArithAddArgs{a: a,b:10};        a +=1;let reply:Option<Result<ArithAddReply>> =            c.call(service_path, service_method,false, metadata,&args);match reply{Some(Ok(r)) =>println!("received: {:?}", r),Some(Err(err)) =>println!("received err:{}", err),None =>{}}}}

License