This is an automated email from the ASF dual-hosted git repository.

liujun pushed a commit to branch cloud-native
in repository https://gitbox.apache.org/repos/asf/dubbo.git

commit a80f6fc61863abc501b4922306df86569d5e7e71
Author: ken.lj <ken.lj...@gmail.com>
AuthorDate: Mon Aug 12 19:44:52 2019 +0800

    change demo
---
 .../bootstrap/DubboServiceProviderBootstrap.java   | 37 +++++++++++++++++++---
 1 file changed, 33 insertions(+), 4 deletions(-)

diff --git 
a/dubbo-bootstrap/src/test/java/org/apache/dubbo/bootstrap/DubboServiceProviderBootstrap.java
 
b/dubbo-bootstrap/src/test/java/org/apache/dubbo/bootstrap/DubboServiceProviderBootstrap.java
index fc2242e..2639d6b 100644
--- 
a/dubbo-bootstrap/src/test/java/org/apache/dubbo/bootstrap/DubboServiceProviderBootstrap.java
+++ 
b/dubbo-bootstrap/src/test/java/org/apache/dubbo/bootstrap/DubboServiceProviderBootstrap.java
@@ -19,7 +19,10 @@ package org.apache.dubbo.bootstrap;
 import org.apache.dubbo.bootstrap.rest.UserService;
 import org.apache.dubbo.bootstrap.rest.UserServiceImpl;
 import org.apache.dubbo.config.ProtocolConfig;
-import org.apache.dubbo.config.builders.RegistryBuilder;
+import org.apache.dubbo.config.RegistryConfig;
+import org.apache.dubbo.config.ServiceConfig;
+
+import java.util.Arrays;
 
 /**
  * Dubbo Provider Bootstrap
@@ -29,21 +32,46 @@ import org.apache.dubbo.config.builders.RegistryBuilder;
 public class DubboServiceProviderBootstrap {
 
     public static void main(String[] args) {
+        multipleRegistries();
+    }
+
+    private static void multipleRegistries() {
         ProtocolConfig restProtocol = new ProtocolConfig();
         restProtocol.setName("rest");
         restProtocol.setId("rest");
         restProtocol.setPort(-1);
 
+        RegistryConfig interfaceRegistry = new RegistryConfig();
+        interfaceRegistry.setId("interfaceRegistry");
+        interfaceRegistry.setAddress("zookeeper://127.0.0.1:2181");
+
+        RegistryConfig serviceRegistry = new RegistryConfig();
+        serviceRegistry.setId("serviceRegistry");
+        
serviceRegistry.setAddress("zookeeper://127.0.0.1:2181?registry-type=service");
+
+        ServiceConfig<EchoService> echoService = new ServiceConfig<>();
+        echoService.setInterface(EchoService.class.getName());
+        echoService.setRef(new EchoServiceImpl());
+//        echoService.setRegistries(Arrays.asList(interfaceRegistry, 
serviceRegistry));
+
+        ServiceConfig<UserService> userService = new ServiceConfig<>();
+        userService.setInterface(UserService.class.getName());
+        userService.setRef(new UserServiceImpl());
+        userService.setProtocol(restProtocol);
+//        userService.setRegistries(Arrays.asList(interfaceRegistry, 
serviceRegistry));
+
+
         new DubboBootstrap()
                 .application("dubbo-provider-demo")
                 // Zookeeper in service registry type
 //                .registry("zookeeper", builder -> 
builder.address("zookeeper://127.0.0.1:2181?registry-type=service"))
                 // Nacos
 //                .registry("zookeeper", builder -> 
builder.address("nacos://127.0.0.1:8848?registry-type=service"))
-                
.registry(RegistryBuilder.newBuilder().address("consul://127.0.0.1:8500?registry-type=service").build())
+                .registries(Arrays.asList(interfaceRegistry, serviceRegistry))
+//                
.registry(RegistryBuilder.newBuilder().address("consul://127.0.0.1:8500?registry-type=service").build())
                 .protocol(builder -> builder.port(-1).name("dubbo"))
-                .service(builder -> 
builder.id("echo").interfaceClass(EchoService.class).ref(new EchoServiceImpl()))
-                .service(builder -> 
builder.id("user").interfaceClass(UserService.class).ref(new 
UserServiceImpl()).addProtocol(restProtocol))
+                .service(echoService)
+                .service(userService)
                 .start()
                 .await();
     }
@@ -59,4 +87,5 @@ public class DubboServiceProviderBootstrap {
     private static void testDubboTansormation() {
 
     }
+
 }

Reply via email to