DubboConfig optimise

javahongxi · Dec 3, 2018 · c267f25 · c267f25
1 parent 7de3583
commit c267f25
Show file tree

Hide file tree

Showing 6 changed files with 18 additions and 18 deletions.
diff --git a/...sumer-boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/consumer/config/DubboConfig.java b/...sumer-boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/consumer/config/DubboConfig.java
@@ -13,14 +13,13 @@ public class DubboConfig {
 
     /**
      * 配置文件里配置默认的，这里配置其他需要的
-     * @param otherZK
-     * @return
      */
-    @Bean("otherZK")
-    public RegistryConfig registryConfig(@Value("${registry.zk.other}") String otherZK) {
+    @Bean("otherRegistry")
+    public RegistryConfig otherRegistry(@Value("${registry.other.address}") String address,
+                                      @Value("${registry.other.id}") String id) {
         RegistryConfig registry = new RegistryConfig();
-        registry.setId("otherZK");
-        registry.setAddress(otherZK);
+        registry.setAddress(address);
+        registry.setId(id);
         return registry;
     }
 }
diff --git a/...bbo-consumer-boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/consumer/rpc/DemoRpc.java b/...bbo-consumer-boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/consumer/rpc/DemoRpc.java
@@ -15,7 +15,7 @@ public class DemoRpc {
     @Reference(version = "1.0.0")
     private DemoService demoService;
 
-    @Reference(version = "1.0.0", registry = "otherZK")
+    @Reference(version = "1.0.0", registry = "otherRegistry")
     private OtherService otherService;
 
     public String sayHello(String name) {

diff --git a/whatsmars-dubbo/whatsmars-dubbo-consumer-boot/src/main/resources/application.yml b/whatsmars-dubbo/whatsmars-dubbo-consumer-boot/src/main/resources/application.yml
@@ -17,5 +17,6 @@ dubbo:
     qosPort: 22224
 
 registry:
-  zk:
-    other: zookeeper://127.0.0.1:2181
+  other:
+    address: zookeeper://127.0.0.1:2181
+    id: other
diff --git a/...vider-boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/provider/config/DubboConfig.java b/...vider-boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/provider/config/DubboConfig.java
@@ -13,14 +13,13 @@ public class DubboConfig {
 
     /**
      * 配置文件里配置默认的，这里配置其他需要的
-     * @param otherZK
-     * @return
      */
-    @Bean("otherZK")
-    public RegistryConfig registryConfig(@Value("${registry.zk.other}") String otherZK) {
+    @Bean("otherRegistry")
+    public RegistryConfig otherRegistry(@Value("${registry.other.address}") String address,
+                                      @Value("${registry.other.id}") String id) {
         RegistryConfig registry = new RegistryConfig();
-        registry.setId("otherZK");
-        registry.setAddress(otherZK);
+        registry.setAddress(address);
+        registry.setId(id);
         return registry;
     }
 }
diff --git a/...boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/provider/service/OtherServiceImpl.java b/...boot/src/main/java/org/hongxi/whatsmars/dubbo/demo/provider/service/OtherServiceImpl.java
@@ -16,7 +16,7 @@
         version = "1.0.0",
         application = "${dubbo.application.id}",
         protocol = "${dubbo.protocol.id}",
-        registry = "otherZK"
+        registry = "otherRegistry"
 )
 public class OtherServiceImpl implements OtherService {
 

diff --git a/whatsmars-dubbo/whatsmars-dubbo-provider-boot/src/main/resources/application.yml b/whatsmars-dubbo/whatsmars-dubbo-provider-boot/src/main/resources/application.yml
@@ -28,5 +28,6 @@ management:
     enabled: false
 
 registry:
-  zk:
-    other: zookeeper://127.0.0.1:2181
+  other:
+    address: zookeeper://127.0.0.1:2181
+    id: other