Rust 與 Java 互通性

使用 Dubbo-rust 呼叫 Dubbo Java 服務

1 前置條件

2 執行 Java Dubbo 提供者範例

Java 版本的 Dubbo 提供者範例 https://github.com/apache/dubbo-samples/tree/master/3-extensions/protocol/dubbo-samples-triple。

複製原始碼、編譯並執行提供者

$ # clone the source code
$ git clone https://github.com/apache/dubbo-samples.git
$ cd dubbo-samples/dubbo-samples-triple/

$ # compile and build
$ mvn clean compile package -DskipTests

$ # run provider
$ java -Dprovider.port=8888 -jar ./target/dubbo-samples-triple-1.0-SNAPSHOT.jar
# … some logs
Dubbo triple stub server started, port=8888

Java 端的介面定義

3 執行 Rust 版本的 Dubbo 消費者

Rust 版本的 Dubbo 消費者 https://github.com/apache/dubbo-samples/tree/master/3-extensions/protocol/dubbo-samples-triple。

複製原始碼、編譯並執行消費者

$ # clone the source code
$ git clone https://github.com/apache/dubbo-rust.git
$ cd dubbo-rust/examples/greeter/

$ # build
$ cargo build

$ # run consumer, call provider
$ ../../target/debug/greeter-client
# unary call
Response: GreeterReply { message: "hello, dubbo-rust" }
# client stream
client streaming, Response: GreeterReply { message: "hello client streaming" }
# bi stream
parts: Metadata { inner: {"content-type": "application/grpc", "date": "Wed, 28 Sep 2022 23:54:56 GMT"} }
reply: GreeterReply { message: "server reply: \"msg1 from client\"" }
reply: GreeterReply { message: "server reply: \"msg2 from client\"" }
reply: GreeterReply { message: "server reply: \"msg3 from client\"" }
trailer: Some(Metadata { inner: {"grpc-message": "poll trailer successfully.", "grpc-accept-encoding": "gzip,identity", "content-type": "application/grpc", "grpc-status": "0"} })
# server stream
parts: Metadata { inner: {"content-type": "application/grpc", "date": "Wed, 28 Sep 2022 23:54:56 GMT"} }
reply: GreeterReply { message: "msg1 from server" }
reply: GreeterReply { message: "msg2 from server" }
reply: GreeterReply { message: "msg3 from server" }
trailer: Some(Metadata { inner: {"content-type": "application/grpc", "grpc-message": "poll trailer successfully.", "grpc-accept-encoding": "gzip,identity", "grpc-status": "0"} })

Rust 端的介面定義


最後修改日期：2022 年 12 月 13 日：修正檢查 (#1720) (8934ab1cb85)