类型: "message"

对于常规消息，对象还将包含

• address: (字符串，必需) 目标地址。
• body: (对象，必需) 消息内容，作为 JSON 对象。
• headers: (对象，可选) 以 JSON 对象形式表示的标题，其值为字符串。
• replyAddress: (字符串，可选) 回复地址。
• send: (布尔值，必需) 如果消息是发送，则为 true，如果为发布，则为 false。

当客户端的消息请求回复，并且该回复失败时，对象将包含以下内容

• failureCode: (数字，必需) 失败代码
• failureType: (字符串，必需) 失败名称
• message: (字符串，必需) 表明失败的异常的消息

从客户端到网桥的消息

JSON 对象必须包含一个 type 键，其值为字符串。以下显示了每种类型及其对应的键

类型: "send", 类型: "publish"

• 地址: (字符串，必需) 目标地址
• body: (对象，必需) 消息内容，作为 JSON 对象。
• headers: (对象，可选) 以 JSON 对象形式表示的标题，其值为字符串。
• replyAddress: (字符串，可选) 回复地址。

类型: "register", 类型: "unregister"

• 地址: (字符串，必需) 目标地址
• headers: (对象，可选) 以 JSON 对象形式表示的标题，其值为字符串。

类型: "ping"

ping 不需要额外的键。

示例

        let task = future::Eventbus::connect(IpAddr::from_str("127.0.0.1").unwrap(), 12345);
        let task = task.and_then(|(eventbus, readstream, writestream)| {
            tokio::spawn(readstream.into_future().map(|_|()).map_err(|e|()));
            tokio::spawn(writestream.into_future().map(|_|()).map_err(|e|()));
            futures::future::ok(eventbus)
        });
        let task = task.and_then(|eventbus:Eventbus|{
            let test_reply=eventbus.send_reply("test".to_string(),json!({
                "aaaa":"bbbb"
            })).unwrap().and_then(|response|{
                println!("{:?}",response);
                futures::future::ok(())
            });
            test_reply
        });
        tokio::run(task.map_err(|e|()));

依赖关系

future

• futures = "0.1"

Json

• serde_json = "1.0"
• serde = "1.0"
• serde_derive = "1.0"

Bytes

• bytes = "0.4"