fibers_rpc

Rust RPC library built on top of [fibers] crate.

Documentation

Features

• Asynchronous RPC server/client using [fibers] crate
• Support two type of RPC:
  • Request/response model
  • Notification model
• Strongly typed RPC using [bytecodec] crate
  • You can treat arbitrarily Rust structures that support [serde] as RPC messages
  • It is possible to handle huge structures as RPC messages without compromising efficiency and real-time property by implementing your own encoder/decoder
• Multiplexing multiple RPC messages in a single TCP stream
• Prioritization between messages
• Expose [Prometheus] metrics

Technical Details

See [doc/].

Examples

Simple echo RPC server: ```rust use bytecodec::bytes::{BytesEncoder, RemainingBytesDecoder}; use fibersrpc::{Call, ProcedureId}; use fibersrpc::client::ClientServiceBuilder; use fibers_rpc::server::{HandleCall, Reply, ServerBuilder}; use futures::Future;

// RPC definition struct EchoRpc; impl Call for EchoRpc { const ID: ProcedureId = ProcedureId(0); const NAME: &'static str = "echo";

type Req = Vec<u8>;
type ReqEncoder = BytesEncoder<Vec<u8>>;
type ReqDecoder = RemainingBytesDecoder;

type Res = Vec<u8>;
type ResEncoder = BytesEncoder<Vec<u8>>;
type ResDecoder = RemainingBytesDecoder;

}

// RPC server struct EchoHandler; impl HandleCall for EchoHandler { fn handlecall(&self, request: ::Req) -> Reply { Reply::done(request) } } let serveraddr = "127.0.0.1:1919".parse().unwrap(); let mut builder = ServerBuilder::new(serveraddr); builder.addcallhandler(EchoHandler); let server = builder.finish(fibersglobal::handle()); fibersglobal::spawn(server.maperr(|e| panic!("{}", e)));

// RPC client let service = ClientServiceBuilder::new().finish(fibersglobal::handle()); let servicehandle = service.handle(); fibersglobal::spawn(service.maperr(|e| panic!("{}", e)));

let request = Vec::from(&b"hello"[..]); let response = EchoRpc::client(&servicehandle).call(serveraddr, request.clone()); let response = fibersglobal::execute(response)?; asserteq!(response, request); ```

Informal benchmark result (v0.2.1):

```console $ uname -a Linux DESKTOP 4.4.0-43-Microsoft #1-Microsoft Wed Dec 31 14:42:53 PST 2014 x8664 x8664 x86_64 GNU/Linux

$ lscpu | grep 'Model name:' Model name: Intel(R) Core(TM) i7-7660U CPU @ 2.50GHz

// Runs the example echo server in a shell. $ cargo run --example echo --release -- server

// Executes a benchmark command in another shell. $ echo "hello" | cargo run --example echo --release -- bench -c 1024 -n 1000000

ELAPSED: 8.111424

RPS: 123282.91555218912

```