Parity JSON-RPC

注意：此 crate 已不再积极开发；如果您正在寻找积极维护的 JSON RPC 实现，请查看我们的 jsonrpsee crate。

JSON-RPC 2.0 规范的 Rust 实现。支持传输无关的 core 和传输服务器，用于 http、ipc、websockets 和 tcp。

新功能！ 支持 客户端。

文档

子项目

• jsonrpc-core
• jsonrpc-core-client
• jsonrpc-http-server
• jsonrpc-ipc-server
• jsonrpc-tcp-server
• jsonrpc-ws-server
• jsonrpc-stdio-server
• jsonrpc-derive
• jsonrpc-server-utils
• jsonrpc-pubsub

示例

• 核心
• 派生
• 发布/订阅

基本用法（使用HTTP传输）

use jsonrpc_http_server::jsonrpc_core::{IoHandler, Value, Params};
use jsonrpc_http_server::ServerBuilder;

fn main() {
	let mut io = IoHandler::default();
	io.add_method("say_hello", |_params: Params| async {
		Ok(Value::String("hello".to_owned()))
	});

	let server = ServerBuilder::new(io)
		.threads(3)
		.start_http(&"127.0.0.1:3030".parse().unwrap())
		.unwrap();

	server.wait();
}

使用派生的基本用法

use jsonrpc_core::Result;
use jsonrpc_derive::rpc;

#[rpc]
pub trait Rpc {
	/// Adds two numbers and returns a result
	#[rpc(name = "add")]
	fn add(&self, a: u64, b: u64) -> Result<u64>;
}

pub struct RpcImpl;
impl Rpc for RpcImpl {
	fn add(&self, a: u64, b: u64) -> Result<u64> {
		Ok(a + b)
	}
}

fn main() {
	let mut io = jsonrpc_core::IoHandler::new();
	io.extend_with(RpcImpl.to_delegate())
}

客户端支持

use jsonrpc_core_client::transports::local;
use jsonrpc_core::{BoxFuture, IoHandler, Result};
use jsonrpc_core::futures::{self, future, TryFutureExt};
use jsonrpc_derive::rpc;

/// Rpc trait
#[rpc]
pub trait Rpc {
	/// Returns a protocol version
	#[rpc(name = "protocolVersion")]
	fn protocol_version(&self) -> Result<String>;

	/// Adds two numbers and returns a result
	#[rpc(name = "add", alias("callAsyncMetaAlias"))]
	fn add(&self, a: u64, b: u64) -> Result<u64>;

	/// Performs asynchronous operation
	#[rpc(name = "callAsync")]
	fn call(&self, a: u64) -> BoxFuture<Result<String>>;
}

struct RpcImpl;

impl Rpc for RpcImpl {
	fn protocol_version(&self) -> Result<String> {
		Ok("version1".into())
	}

	fn add(&self, a: u64, b: u64) -> Result<u64> {
		Ok(a + b)
	}

	fn call(&self, _: u64) -> BoxFuture<Result<String>> {
		Box::pin(future::ready(Ok("OK".to_owned())))
	}
}

fn main() {
	let mut io = IoHandler::new();
	io.extend_with(RpcImpl.to_delegate());

	let (client, server) = local::connect::<gen_client::Client, _, _>(io);
	let fut = client.add(5, 6).map_ok(|res| println!("5 + 6 = {}", res));
	futures::executor::block_on(async move { futures::join!(fut, server) })
		.0
		.unwrap();
}

lib.rs:

与传输无关的jsonrpc库。

目前它只支持服务器端处理请求。

use jsonrpc_core::IoHandler;
use jsonrpc_core::Value;
let mut io = IoHandler::new();
io.add_sync_method("say_hello", |_| {
    Ok(Value::String("Hello World!".into()))
});

let request = r#"{"jsonrpc": "2.0", "method": "say_hello", "params": [42, 23], "id": 1}"#;
let response = r#"{"jsonrpc":"2.0","result":"Hello World!","id":1}"#;

assert_eq!(io.handle_request_sync(request), Some(response.to_string()));