This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-website.git
The following commit(s) were added to refs/heads/master by this push:
new 2027b15ccb 通过target_os使用Unix套接字连接器通信 (#1895)
2027b15ccb is described below
commit 2027b15ccb9f6cbd2899ed8ef15716df2c2f4a1c
Author: daedalus2022 <[email protected]>
AuthorDate: Thu Jan 19 20:42:34 2023 +0800
通过target_os使用Unix套接字连接器通信 (#1895)
* unix-transport
* unix-transport
* 通过target_os使用Unix套接字连接器通信
Co-authored-by: qunwei <[email protected]>
---
content/zh/docs3-v2/rust-sdk/unix-transport.md | 123 +++++--------------------
1 file changed, 23 insertions(+), 100 deletions(-)
diff --git a/content/zh/docs3-v2/rust-sdk/unix-transport.md
b/content/zh/docs3-v2/rust-sdk/unix-transport.md
index 10487bb7dc..c07d62d541 100644
--- a/content/zh/docs3-v2/rust-sdk/unix-transport.md
+++ b/content/zh/docs3-v2/rust-sdk/unix-transport.md
@@ -8,67 +8,8 @@ description: "介绍使用 Dubbo Rust Triple 协议使用 Unix 套接字连接
本文重点讲解 Dubbo Rust Triple 协议使用Unix 套接，请先查看 [Quick Start](../quick-start) 了解
Dubbo Rust
基本使用，在此查看本文的[完整示例](https://github.com/apache/dubbo-rust/tree/main/examples/greeter)。
-## 1 Triple 使用 Unix 套接字连接器
-
-TripleServer 调整如下。
-
-```rust
-// dubbo/src/protocol/triple/triple_server.rs
-impl TripleServer {
- pub fn new(names: Vec<String>) -> TripleServer {
- Self {
- service_names: names,
- s: DubboServer::new(),
- }
- }
-
- pub async fn serve(mut self, url: String) {
- {
- let lock = super::TRIPLE_SERVICES.read().unwrap();
- for name in self.service_names.iter() {
- if lock.get(name).is_none() {
- tracing::warn!("service ({}) not register", name);
- continue;
- }
- let svc = lock.get(name).unwrap();
-
- self.s = self.s.add_service(name.clone(), svc.clone());
- }
- }
-
- let uri = match http::Uri::from_str(&url) {
- Ok(v) => v,
- Err(err) => {
- tracing::error!("http uri parse error: {}, url: {:?}", err,
&url);
- return;
- }
- };
-
- let authority = match uri.authority() {
- Some(v) => v.to_owned(),
- None => {
- tracing::error!("http authority is none");
- return;
- }
- };
-
- self.s
- .with_listener("unix".to_string())
- .serve(
- authority
- .to_string()
- .to_socket_addrs()
- .unwrap()
- .next()
- .unwrap(),
- )
- .await
- .unwrap();
- }
-}
-
-}
-```
+## 1 使用 Unix 套接字连接器 说明
+> #[cfg(any(target_os = "macos", target_os="unix"))] 当操作系统符合cfg配置时，unix
模块会被编译使用，否则无法使用
## 2 使用 client/connection 使用 Unix 套接字连接器编写逻辑
@@ -76,39 +17,22 @@ impl TripleServer {
```rust
// examples/echo/src/echo/client.rs
-...
-let mut cli = EchoClient::connect("unix://0.0.0.0:8888".to_string());
-...
+// 使用 ClientBuilder 初始化 Client
+let builder =
ClientBuilder::new().with_connector("unix").with_host("unix://127.0.0.1:8888");
+let mut cli = EchoClient::build(builder);
```
-### 2.2 编写 connection
+### 2.2 编写 Server 端
```rust
-// dubbo/src/triple/client/connection.rs
-impl Connection {
- pub fn new() -> Self {
- Connection {
- host: hyper::Uri::default(),
- connector: "unix".to_string(),
- builder: Builder::new(),
- }
- }
-
- pub fn with_connector<C>(mut self, connector: String) -> Self {
- self.connector = connector;
- self
- }
-
- pub fn with_host(mut self, uri: hyper::Uri) -> Self {
- self.host = uri;
- self
- }
-
- pub fn with_builder(mut self, builder: Builder) -> Self {
- self.builder = builder;
- self
- }
-}
+// examples/echo/src/echo/server.rs
+// 通过 serverbuilder 来初始化 Server
+let builder = ServerBuilder::new()
+ .with_listener("unix".to_string())
+ .with_service_names(vec!["grpc.examples.echo.Echo".to_string()])
+ .with_addr("127.0.0.1:8888");
+builder.build().serve().await.unwrap();
+
```
## 3 运行示例
@@ -123,10 +47,7 @@ impl Connection {
```sh
$ cargo run --bin echo-server
-2022-12-05T10:40:20.829798Z INFO dubbo::framework: url:
triple://0.0.0.0:8888//grpc.examples.echo.Echo
-2022-12-05T10:40:20.829830Z DEBUG dubbo::framework: service name:
grpc.examples.echo.Echo, service_config: ServiceConfig { version: "1.0.0",
group: "test", name: "", protocol: "triple", registry: "zookeeper", serializer:
"json", protocol_configs: {"triple": ProtocolConfig { ip: "0.0.0.0", port:
"8888", name: "triple", params: {} }} }
-2022-12-05T10:40:20.829917Z INFO dubbo::framework: protocol: "", service url:
Url { uri: "triple://0.0.0.0:8888//grpc.examples.echo.Echo", protocol:
"triple", location: "0.0.0.0:8888", ip: "0.0.0.0", port: "8888", service_key:
["grpc.examples.echo.Echo"], params: {} }
-2022-12-05T10:40:20.830028Z DEBUG dubbo::triple::transport::listener:
get_listener: "unix"
+2023-01-19T08:36:25.663138Z INFO dubbo::triple::server::builder: server
starting. addr: Some(127.0.0.1:8888)
```
3. 运行client，可以看到 Unix 通信效果
@@ -136,18 +57,20 @@ $ cargo run --bin echo-server
```sh
$ cargo run --bin echo-client
-# unary call
-fake filter: Metadata { inner: {"path": "/grpc.examples.echo.Echo/UnaryEcho",
"tri-unit-info": "dubbo-rust/0.1.0", "grpc-accept-encoding": "gzip",
"authority": "0.0.0.0:8888", "te": "trailers", "method": "POST",
"grpc-encoding": "gzip", "tri-request-time": "1670237034581",
"tri-service-group": "cluster", "content-type": "application/grpc+json",
"tri-service-version": "dubbo-rust/0.1.0", "scheme": "unix", "user-agent":
"dubbo-rust/0.1.0"} }
+2023-01-19T08:38:52.516792Z INFO
dubbo::triple::transport::connector::unix_connector: host is ip address:
"127.0.0.1"
Response: EchoResponse { message: "hello, dubbo-rust" }
+2023-01-19T08:38:52.526697Z INFO
dubbo::triple::transport::connector::unix_connector: host is ip address:
"127.0.0.1"
client streaming, Response: EchoResponse { message: "hello client streaming" }
-parts: Metadata { inner: {"date": "Mon, 05 Dec 2022 10:43:57 GMT",
"content-type": "application/grpc"} }
+2023-01-19T08:38:52.539439Z INFO
dubbo::triple::transport::connector::unix_connector: host is ip address:
"127.0.0.1"
+parts: Metadata { inner: {"content-type": "application/grpc", "date": "Thu, 19
Jan 2023 08:38:52 GMT"} }
reply: EchoResponse { message: "server reply: \"msg1 from client\"" }
reply: EchoResponse { message: "server reply: \"msg2 from client\"" }
reply: EchoResponse { message: "server reply: \"msg3 from client\"" }
-trailer: Some(Metadata { inner: {"grpc-message": "poll trailer successfully.",
"content-type": "application/grpc", "grpc-accept-encoding": "gzip,identity",
"grpc-status": "0"} })
-parts: Metadata { inner: {"content-type": "application/grpc", "date": "Mon, 05
Dec 2022 10:43:58 GMT"} }
+trailer: Some(Metadata { inner: {"grpc-accept-encoding": "gzip,identity",
"grpc-status": "0", "grpc-message": "poll trailer successfully.",
"content-type": "application/grpc"} })
+2023-01-19T08:38:52.645035Z INFO
dubbo::triple::transport::connector::unix_connector: host is ip address:
"127.0.0.1"
+parts: Metadata { inner: {"content-type": "application/grpc", "date": "Thu, 19
Jan 2023 08:38:52 GMT"} }
reply: EchoResponse { message: "msg1 from server" }
reply: EchoResponse { message: "msg2 from server" }
reply: EchoResponse { message: "msg3 from server" }
-trailer: Some(Metadata { inner: {"grpc-status": "0", "grpc-message": "poll
trailer successfully.", "grpc-accept-encoding": "gzip,identity",
"content-type": "application/grpc"} })
+trailer: Some(Metadata { inner: {"grpc-status": "0", "content-type":
"application/grpc", "grpc-message": "poll trailer successfully.",
"grpc-accept-encoding": "gzip,identity"} })
```
