JAVA SDK
DefaultRegistryClient registryClient = new DefaultRegistryClient(config);
registryClient.init();
其中注册中心相关的属性通过 DefaultRegistryClientConfigBuilder 构建指定,该类包含以下关键属性:
发布数据的关键代码如下:
// 构造发布者注册表
PublisherRegistration registration = new PublisherRegistration("com.alipay.test.demo.service:1.0@DEFAULT");
registration.setAppName("TEST_APP");
Publisher publisher = registryClient.register(registration, "10.10.1.1:12200?xx=yy");
// 如需覆盖上次发布的数据可以使用发布者模型重新发布数据
publisher.republish("10.10.1.1:12200?xx=zz");
发布数据的关键是构造 PublisherRegistration,该类包含三个属性:
订阅数据需要创建两个关键类,分别是 SubscriberDataObserver 和 SubscriberRegistration,前者是收到服务端数据后的回调接口,后者是订阅者注册表,用于向服务端注册订阅信息。
SubscriberDataObserver 仅包含一个方法:
void handleData(String dataId, UserData data);
参数含义
- getLocalZone: 返回当前zone;
- getZoneData: 返回以 zone 为 key,每个 zone 的数据为 value 的数据。
4.2 SubscriberRegistration
SubscriberRegistration 包含以下四个属性:
取消发布订阅的接口如下:
请求参数