fix example

Author: robberphex

config/src/config.rs

@@ -37,11 +37,14 @@ lazy_static! {
 pub struct RootConfig {
     pub name: String,
 
-    #[serde(skip_serializing, skip_deserializing)]
+    #[serde(default)]
     pub service: HashMap<String, ServiceConfig>,
     pub protocols: HashMap<String, ProtocolConfig>,
+
+    #[serde(default)]
     pub registries: HashMap<String, String>,
 
+    #[serde(default)]
     pub provider: ProviderConfig,
 
     #[serde(skip_serializing, skip_deserializing)]

config/src/provider.rs

@@ -23,8 +23,10 @@ use super::service::ServiceConfig;
 
 #[derive(Debug, Default, Serialize, Deserialize, Clone)]
 pub struct ProviderConfig {
+    #[serde(default)]
     pub registry_ids: Vec<String>,
 
+    #[serde(default)]
     pub protocol_ids: Vec<String>,
 
     pub services: HashMap<String, ServiceConfig>,

config/src/service.rs

@@ -32,7 +32,7 @@ pub struct ServiceConfig {
     pub registry: String,
     pub serializer: String,
 
-    // #[serde(skip_serializing, skip_deserializing)]
+    #[serde(default)]
     pub protocol_configs: HashMap<String, ProtocolConfig>,
 }
 

dubbo/src/framework.rs

@@ -65,7 +65,7 @@ impl Dubbo {
                 .insert(name.to_string(), Url::from_url(url).unwrap());
         }
 
-        for (_, c) in conf.provider.services.iter() {
+        for (service_name, c) in conf.provider.services.iter() {
             let u = if c.protocol_configs.is_empty() {
                 let protocol = match conf.protocols.get(&c.protocol) {
                     Some(v) => v.to_owned(),
@@ -74,7 +74,8 @@ impl Dubbo {
                         continue;
                     }
                 };
-                let protocol_url = format!("{}/{}", protocol.to_url(), c.name.clone(),);
+                let protocol_url =
+                    format!("{}/{}/{}", protocol.to_url(), c.name.clone(), service_name);
                 Url::from_url(&protocol_url)
             } else {
                 let protocol = match c.protocol_configs.get(&c.protocol) {
@@ -84,7 +85,8 @@ impl Dubbo {
                         continue;
                     }
                 };
-                let protocol_url = format!("{}/{}", protocol.to_url(), c.name.clone(),);
+                let protocol_url =
+                    format!("{}/{}/{}", protocol.to_url(), c.name.clone(), service_name);
                 Url::from_url(&protocol_url)
             };
             tracing::info!("url: {:?}", u);

examples/greeter/dubbo.yaml

@@ -1,16 +1,14 @@
 name: dubbo
-service:
-  org.apache.dubbo.sample.tri.Greeter:
-    version: 1.0.0
-    group: test
-    protocol: triple
-    registry: ''
-    serializer: json
-    protocol_configs:
-      triple:
-        ip: 0.0.0.0
-        port: '8888'
-        name: triple
+provider:
+  services:
+    org.apache.dubbo.sample.tri.Greeter:
+      version: 1.0.0
+      group: test
+      protocol: triple
+      registry: 'zookeeper'
+      serializer: json
+registries:
+  zookeeper: zookeeper://localhost:2181/
 protocols:
   triple:
     ip: 0.0.0.0