JAVA SDK

    1. DefaultRegistryClient registryClient = new DefaultRegistryClient(config);
    2. registryClient.init();

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

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

    1. // 构造发布者注册表
    2. PublisherRegistration registration = new PublisherRegistration("com.alipay.test.demo.service:1.0@DEFAULT");
    3. registration.setAppName("TEST_APP");
    4. Publisher publisher = registryClient.register(registration, "10.10.1.1:12200?xx=yy");
    5. // 如需覆盖上次发布的数据可以使用发布者模型重新发布数据
    6. publisher.republish("10.10.1.1:12200?xx=zz");

    发布数据的关键是构造 PublisherRegistration,该类包含三个属性:

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

    SubscriberDataObserver 仅包含一个方法:

    1. void handleData(String dataId, UserData data);

    参数含义

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

    4.2 SubscriberRegistration

    SubscriberRegistration 包含以下四个属性:

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

      请求参数