Skip to content

Commit a75de07

Browse files
lingyufeiFaye Lin
andauthored
Add support for Zookeeper-based config center and metadata reporting in the demo (#15646)
Co-authored-by: Faye Lin <fayel@nvidia.com>
1 parent c831fef commit a75de07

4 files changed

Lines changed: 38 additions & 4 deletions

File tree

dubbo-demo/dubbo-demo-api/dubbo-demo-api-consumer/pom.xml

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,16 @@
4646
<artifactId>dubbo-registry-zookeeper</artifactId>
4747
<version>${project.version}</version>
4848
</dependency>
49+
<dependency>
50+
<groupId>org.apache.dubbo</groupId>
51+
<artifactId>dubbo-configcenter-zookeeper</artifactId>
52+
<version>${project.version}</version>
53+
</dependency>
54+
<dependency>
55+
<groupId>org.apache.dubbo</groupId>
56+
<artifactId>dubbo-metadata-report-zookeeper</artifactId>
57+
<version>${project.version}</version>
58+
</dependency>
4959
<dependency>
5060
<groupId>org.apache.dubbo</groupId>
5161
<artifactId>dubbo-rpc-dubbo</artifactId>

dubbo-demo/dubbo-demo-api/dubbo-demo-api-consumer/src/main/java/org/apache/dubbo/demo/consumer/Application.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919
import org.apache.dubbo.api.demo.DemoService;
2020
import org.apache.dubbo.common.constants.CommonConstants;
2121
import org.apache.dubbo.config.ApplicationConfig;
22+
import org.apache.dubbo.config.ConfigCenterConfig;
23+
import org.apache.dubbo.config.MetadataReportConfig;
2224
import org.apache.dubbo.config.ProtocolConfig;
2325
import org.apache.dubbo.config.ReferenceConfig;
2426
import org.apache.dubbo.config.RegistryConfig;
@@ -31,7 +33,7 @@
3133
public class Application {
3234
private static final Logger logger = LoggerFactory.getLogger(Application.class);
3335

34-
private static final String REGISTRY_URL = "zookeeper://127.0.0.1:2181";
36+
private static final String ZOOKEEPER_URL = "zookeeper://127.0.0.1:2181";
3537

3638
public static void main(String[] args) {
3739
runWithBootstrap();
@@ -42,10 +44,15 @@ private static void runWithBootstrap() {
4244
reference.setInterface(DemoService.class);
4345
reference.setGeneric("true");
4446

47+
ConfigCenterConfig configCenterConfig = new ConfigCenterConfig();
48+
configCenterConfig.setAddress(ZOOKEEPER_URL);
49+
4550
DubboBootstrap bootstrap = DubboBootstrap.getInstance();
4651
bootstrap
4752
.application(new ApplicationConfig("dubbo-demo-api-consumer"))
48-
.registry(new RegistryConfig(REGISTRY_URL))
53+
.configCenter(configCenterConfig)
54+
.registry(new RegistryConfig(ZOOKEEPER_URL))
55+
.metadataReport(new MetadataReportConfig(ZOOKEEPER_URL))
4956
.protocol(new ProtocolConfig(CommonConstants.TRIPLE, -1))
5057
.reference(reference)
5158
.start();

dubbo-demo/dubbo-demo-api/dubbo-demo-api-provider/pom.xml

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,16 @@
5858
<artifactId>dubbo-registry-zookeeper</artifactId>
5959
<version>${project.version}</version>
6060
</dependency>
61+
<dependency>
62+
<groupId>org.apache.dubbo</groupId>
63+
<artifactId>dubbo-configcenter-zookeeper</artifactId>
64+
<version>${project.version}</version>
65+
</dependency>
66+
<dependency>
67+
<groupId>org.apache.dubbo</groupId>
68+
<artifactId>dubbo-metadata-report-zookeeper</artifactId>
69+
<version>${project.version}</version>
70+
</dependency>
6171
<dependency>
6272
<groupId>org.apache.dubbo</groupId>
6373
<artifactId>dubbo-serialization-hessian2</artifactId>

dubbo-demo/dubbo-demo-api/dubbo-demo-api-provider/src/main/java/org/apache/dubbo/demo/provider/Application.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,14 +19,16 @@
1919
import org.apache.dubbo.api.demo.DemoService;
2020
import org.apache.dubbo.common.constants.CommonConstants;
2121
import org.apache.dubbo.config.ApplicationConfig;
22+
import org.apache.dubbo.config.ConfigCenterConfig;
23+
import org.apache.dubbo.config.MetadataReportConfig;
2224
import org.apache.dubbo.config.ProtocolConfig;
2325
import org.apache.dubbo.config.RegistryConfig;
2426
import org.apache.dubbo.config.ServiceConfig;
2527
import org.apache.dubbo.config.bootstrap.DubboBootstrap;
2628

2729
public class Application {
2830

29-
private static final String REGISTRY_URL = "zookeeper://127.0.0.1:2181";
31+
private static final String ZOOKEEPER_URL = "zookeeper://127.0.0.1:2181";
3032

3133
public static void main(String[] args) {
3234
startWithBootstrap();
@@ -37,10 +39,15 @@ private static void startWithBootstrap() {
3739
service.setInterface(DemoService.class);
3840
service.setRef(new DemoServiceImpl());
3941

42+
ConfigCenterConfig configCenterConfig = new ConfigCenterConfig();
43+
configCenterConfig.setAddress(ZOOKEEPER_URL);
44+
4045
DubboBootstrap bootstrap = DubboBootstrap.getInstance();
4146
bootstrap
4247
.application(new ApplicationConfig("dubbo-demo-api-provider"))
43-
.registry(new RegistryConfig(REGISTRY_URL))
48+
.configCenter(configCenterConfig)
49+
.registry(new RegistryConfig(ZOOKEEPER_URL))
50+
.metadataReport(new MetadataReportConfig(ZOOKEEPER_URL))
4451
.protocol(new ProtocolConfig(CommonConstants.DUBBO, -1))
4552
.service(service)
4653
.start()

0 commit comments

Comments
 (0)