Java SDK

1. Maven 坐标

<dependency>
    <groupId>com.alipay.sofa</groupId>
    <artifactId>registry-client-all</artifactId>
    <version>${registry.client.version}</version>
</dependency>

2. 创建 SOFARegistry 客户端实例

构建 SOFARegistry 客户端实例的关键代码如下：

RegistryClientConfig config =  DefaultRegistryClientConfigBuilder.start().setRegistryEndpoint("127.0.0.1").setRegistryEndpointPort(9603).build();
DefaultRegistryClient registryClient = new DefaultRegistryClient(config);
registryClient.init();

其中注册中心相关的属性通过 DefaultRegistryClientConfigBuilder 构建指定，该类包含以下关键属性：

public class DefaultRegistryClientConfigBuilder {
    private String  instanceId;
    private String  zone                      = DEFAULT_ZONE;
    private String  registryEndpoint;
    private int     registryEndpointPort      = 9603;
    private String  dataCenter                = DEFAULT_DATA_CENTER;
    private String  appName;
    private int     connectTimeout            = 3000;
    private int     socketTimeout             = 3000;
    private int     invokeTimeout             = 1000;
    private int     recheckInterval           = 500;
    private int     observerThreadCoreSize    = 5;
    private int     observerThreadMaxSize     = 10;
    private int     observerThreadQueueLength = 1000;
    private int     syncConfigRetryInterval   = 30000;
}

3. 发布数据

发布数据的关键代码如下：

// 构造发布者注册表
PublisherRegistration registration = new PublisherRegistration("com.alipay.test.demo.service:1.0@DEFAULT");
registration.setGroup("TEST_GROUP");
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，该类包含三个属性：

4. 订阅数据

订阅数据的关键代码如下：

// 创建 SubscriberDataObserver 
SubscriberDataObserver subscriberDataObserver = new SubscriberDataObserver() {
    @Override
    public void handleData(String dataId, UserData userData) {
        System.out.println("receive data success, dataId: " + dataId + ", data: " + userData);
    }
};

// 构造订阅者注册表，设置订阅维度，ScopeEnum 共有三种级别 zone, dataCenter, global
String dataId = "com.alipay.test.demo.service:1.0@DEFAULT";
SubscriberRegistration registration = new SubscriberRegistration(dataId, subscriberDataObserver);
registration.setGroup("TEST_GROUP");
registration.setAppName("TEST_APP");
registration.setScopeEnum(ScopeEnum.global);

// 将注册表注册进客户端并订阅数据，订阅到的数据会以回调的方式通知 SubscriberDataObserver
Subscriber subscriber = registryClient.register(registration);

订阅数据需要创建两个关键类，分别是 SubscriberDataObserver 和 SubscriberRegistration，前者是收到服务端数据后的回调接口，后者是订阅者注册表，用于向服务端注册订阅信息。

4.1 SubscriberDataObserver

SubscriberDataObserver 仅包含一个方法：

void handleData(String dataId, UserData data);

参数含义

UserData 包装了数据内容，该类包含以下方法：

public interface UserData {
    Map<String, List<String>> getZoneData();
    String getLocalZone();
}

• getLocalZone: 返回当前zone；
• getZoneData: 返回以 zone 为 key，每个 zone 的数据为 value 的数据。

4.2 SubscriberRegistration

SubscriberRegistration 包含以下四个属性：

5. 注销发布及订阅

取消发布订阅的接口如下：

int unregister(String dataId, String group, RegistryType registryType);

请求参数

方法返回值为 int 类型，表示注销的发布者及订阅者个数。