mco-rpc

mco-rpc

• 基于 mco，这是一个绿色线程、协程 crate
• 基于 T-L-V，例如：[Tag][Length][Value]
• 支持 json/bincode
• 支持负载均衡（轮询/随机/哈希/最小连接）

如何使用？

mco="0.1"
mco-rpc = "0.1"

• 客户端

use mco_rpc::client::Client;
let c = Client::dial("127.0.0.1:10000").unwrap();
let resp:i32 = c.call("handle", 1).unwrap();
println!("resp=>>>>>>>>>>>>>> :{}", resp);

• 服务器

use mco_rpc::server::Server;
use mco::std::errors::Result;

fn handle(req: i32) -> Result<i32> {
    Ok(req)
}
let mut s = Server::default ();
s.register_fn("handle", handle);
s.register_fn("handle_fn2", |arg:i32| -> Result<i32>{
Ok(1)
});
s.serve("0.0.0.0:10000");