com.alipay.sofa.rpc.registry.zk.ZookeeperProviderObserver类的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(10.4k)|赞(0)|评价(0)|浏览(137)

本文整理了Java中com.alipay.sofa.rpc.registry.zk.ZookeeperProviderObserver类的一些代码示例，展示了ZookeeperProviderObserver类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZookeeperProviderObserver类的具体详情如下：
包路径：com.alipay.sofa.rpc.registry.zk.ZookeeperProviderObserver
类名称：ZookeeperProviderObserver

ZookeeperProviderObserver介绍

[英]ZookeeperObserver for provider node.
[中]提供程序节点的ZookePerObserver。

代码示例

代码示例来源：origin: alipay/sofa-rpc

@Override
  public void childEvent(CuratorFramework client1, PathChildrenCacheEvent event) throws Exception {
    if (LOGGER.isDebugEnabled(config.getAppName())) {
      LOGGER.debugWithApp(config.getAppName(),
        "Receive zookeeper event: " + "type=[" + event.getType() + "]");
    }
    switch (event.getType()) {
      case CHILD_ADDED: //加了一个provider
        providerObserver.addProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_REMOVED: //删了一个provider
        providerObserver.removeProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_UPDATED: // 更新一个Provider
        providerObserver.updateProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      default:
        break;
    }
  }
});

代码示例来源：origin: alipay/sofa-rpc

/**
 * Add provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void addProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive add provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, true);
}

代码示例来源：origin: alipay/sofa-rpc

providerObserver.removeProviderListener(config);
} catch (Exception e) {
  if (!RpcRunningState.isShuttingDown()) {

代码示例来源：origin: alipay/sofa-rpc

providerObserver = new ZookeeperProviderObserver();
providerObserver.addProviderListener(config, providerInfoListener);

代码示例来源：origin: alipay/sofa-rpc

providerObserver = new ZookeeperProviderObserver();
providerObserver.addProviderListener(config, providerInfoListener);

代码示例来源：origin: alipay/sofa-rpc

@Override
  public void childEvent(CuratorFramework client1, PathChildrenCacheEvent event) throws Exception {
    if (LOGGER.isDebugEnabled(config.getAppName())) {
      LOGGER.debugWithApp(config.getAppName(),
        "Receive zookeeper event: " + "type=[" + event.getType() + "]");
    }
    switch (event.getType()) {
      case CHILD_ADDED: //加了一个provider
        providerObserver.addProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_REMOVED: //删了一个provider
        providerObserver.removeProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_UPDATED: // 更新一个Provider
        providerObserver.updateProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      default:
        break;
    }
  }
});

代码示例来源：origin: com.alipay.sofa/sofa-rpc-all

providerObserver = new ZookeeperProviderObserver();
providerObserver.addProviderListener(config, providerInfoListener);

代码示例来源：origin: alipay/sofa-rpc

/**
 * Remove Provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void removeProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive remove provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, false);
}

代码示例来源：origin: alipay/sofa-rpc

providerObserver.removeProviderListener(config);
} catch (Exception e) {
  if (!RpcRunningState.isShuttingDown()) {

代码示例来源：origin: com.alipay.sofa/sofa-rpc-all

@Override
  public void childEvent(CuratorFramework client1, PathChildrenCacheEvent event) throws Exception {
    if (LOGGER.isDebugEnabled(config.getAppName())) {
      LOGGER.debugWithApp(config.getAppName(),
        "Receive zookeeper event: " + "type=[" + event.getType() + "]");
    }
    switch (event.getType()) {
      case CHILD_ADDED: //加了一个provider
        providerObserver.addProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_REMOVED: //删了一个provider
        providerObserver.removeProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      case CHILD_UPDATED: // 更新一个Provider
        providerObserver.updateProvider(config, providerPath, event.getData(),
          finalPathChildrenCache.getCurrentData());
        break;
      default:
        break;
    }
  }
});

代码示例来源：origin: alipay/sofa-rpc

/**
 * Remove Provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void removeProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive remove provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, false);
}

代码示例来源：origin: com.alipay.sofa/sofa-rpc-all

providerObserver.removeProviderListener(config);
} catch (Exception e) {
  if (!RpcRunningState.isShuttingDown()) {

代码示例来源：origin: alipay/sofa-rpc

/**
 * Update Provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void updateProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive update provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, false);
}

代码示例来源：origin: alipay/sofa-rpc

/**
 * Add provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void addProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive add provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, true);
}

代码示例来源：origin: alipay/sofa-rpc

/**
 * Update Provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void updateProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive update provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, false);
}

代码示例来源：origin: com.alipay.sofa/sofa-rpc-all

/**
 * Update Provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void updateProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive update provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, false);
}

代码示例来源：origin: com.alipay.sofa/sofa-rpc-all

/**
 * Add provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void addProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive add provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, true);
}

代码示例来源：origin: com.alipay.sofa/sofa-rpc-all

/**
 * Remove Provider
 *
 * @param config       ConsumerConfig
 * @param providerPath Provider path of zookeeper
 * @param data         Event data
 * @param currentData  provider data list
 * @throws UnsupportedEncodingException decode error
 */
public void removeProvider(ConsumerConfig config, String providerPath, ChildData data, List<ChildData> currentData)
  throws UnsupportedEncodingException {
  if (LOGGER.isInfoEnabled(config.getAppName())) {
    LOGGER.infoWithApp(config.getAppName(),
      "Receive remove provider: path=[" + data.getPath() + "]" + ", data=[" +
        StringSerializer.decode(data.getData()) + "]" + ", stat=[" + data.getStat() + "]" + ", list=[" +
        currentData.size() + "]");
  }
  notifyListeners(config, providerPath, currentData, false);
}

内容来源于网络，如有侵权，请联系作者删除！

ZookeeperProviderObserver

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com