com.alipay.sofa.rpc.registry.zk.ZookeeperRegistryHelper.convertConfigToAttribute()方法的使用及代码示例

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

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

ZookeeperRegistryHelper.convertConfigToAttribute介绍

[英]Convert child data to attribute.
[中]将子数据转换为属性。

代码示例

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

/**
 * Convert child data to attribute list.
 *
 * @param configPath  the config path
 * @param currentData the current data
 * @return the attribute list
 */
static List<Map<String, String>> convertConfigToAttributes(String configPath,
                              List<ChildData> currentData) {
  List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
  if (CommonUtils.isEmpty(currentData)) {
    return attributes;
  }
  for (ChildData childData : currentData) {
    attributes.add(convertConfigToAttribute(configPath, childData, false));
  }
  return attributes;
}

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

/**
 * Convert child data to attribute list.
 *
 * @param configPath  the config path
 * @param currentData the current data
 * @return the attribute list
 */
static List<Map<String, String>> convertConfigToAttributes(String configPath,
                              List<ChildData> currentData) {
  List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
  if (CommonUtils.isEmpty(currentData)) {
    return attributes;
  }
  for (ChildData childData : currentData) {
    attributes.add(convertConfigToAttribute(configPath, childData, false));
  }
  return attributes;
}

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

private void notifyListeners(AbstractInterfaceConfig config, String configPath, ChildData data, boolean removeType) {
    List<ConfigListener> configListeners = configListenerMap.get(config);
    if (CommonUtils.isNotEmpty(configListeners)) {
      //转换子节点Data为接口级配置<配置属性名,配置属性值>,例如<timeout,200>
      Map<String, String> attribute = ZookeeperRegistryHelper.convertConfigToAttribute(configPath, data,
        removeType);
      for (ConfigListener listener : configListeners) {
        listener.configChanged(attribute);
      }
    }
  }
}

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

private void notifyListeners(AbstractInterfaceConfig config, String configPath, ChildData data, boolean removeType) {
    List<ConfigListener> configListeners = configListenerMap.get(config);
    if (CommonUtils.isNotEmpty(configListeners)) {
      //转换子节点Data为接口级配置<配置属性名,配置属性值>,例如<timeout,200>
      Map<String, String> attribute = ZookeeperRegistryHelper.convertConfigToAttribute(configPath, data,
        removeType);
      for (ConfigListener listener : configListeners) {
        listener.configChanged(attribute);
      }
    }
  }
}

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

/**
 * Convert child data to attribute list.
 *
 * @param config       the interface config
 * @param overridePath the override path
 * @param currentData  the current data
 * @return the attribute list
 * @throws UnsupportedEncodingException decode exception
 */
static List<Map<String, String>> convertOverrideToAttributes(AbstractInterfaceConfig config,
                               String overridePath,
                               List<ChildData> currentData)
  throws UnsupportedEncodingException {
  List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
  if (CommonUtils.isEmpty(currentData)) {
    return attributes;
  }
  for (ChildData childData : currentData) {
    String url = URLDecoder.decode(childData.getPath().substring(overridePath.length() + 1),
      "UTF-8");
    if (config instanceof ConsumerConfig) {
      //If child data contains system local host, convert config to attribute
      if (StringUtils.isNotEmpty(url) && StringUtils.isNotEmpty(SystemInfo.getLocalHost())
        && url.contains("://" + SystemInfo.getLocalHost() + "?")) {
        attributes.add(convertConfigToAttribute(overridePath, childData, false));
      }
    }
  }
  return attributes;
}

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

/**
 * Convert child data to attribute list.
 *
 * @param config       the interface config
 * @param overridePath the override path
 * @param currentData  the current data
 * @return the attribute list
 * @throws UnsupportedEncodingException decode exception
 */
static List<Map<String, String>> convertOverrideToAttributes(AbstractInterfaceConfig config,
                               String overridePath,
                               List<ChildData> currentData)
  throws UnsupportedEncodingException {
  List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
  if (CommonUtils.isEmpty(currentData)) {
    return attributes;
  }
  for (ChildData childData : currentData) {
    String url = URLDecoder.decode(childData.getPath().substring(overridePath.length() + 1),
      "UTF-8");
    if (config instanceof ConsumerConfig) {
      //If child data contains system local host, convert config to attribute
      if (StringUtils.isNotEmpty(url) && StringUtils.isNotEmpty(SystemInfo.getLocalHost())
        && url.contains("://" + SystemInfo.getLocalHost() + "?")) {
        attributes.add(convertConfigToAttribute(overridePath, childData, false));
      }
    }
  }
  return attributes;
}

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

/**
 * Convert child data to attribute list.
 *
 * @param configPath  the config path
 * @param currentData the current data
 * @return the attribute list
 */
static List<Map<String, String>> convertConfigToAttributes(String configPath,
                              List<ChildData> currentData) {
  List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
  if (CommonUtils.isEmpty(currentData)) {
    return attributes;
  }
  for (ChildData childData : currentData) {
    attributes.add(convertConfigToAttribute(configPath, childData, false));
  }
  return attributes;
}

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

private void notifyListeners(AbstractInterfaceConfig config, String configPath, ChildData data, boolean removeType) {
    List<ConfigListener> configListeners = configListenerMap.get(config);
    if (CommonUtils.isNotEmpty(configListeners)) {
      //转换子节点Data为接口级配置<配置属性名,配置属性值>,例如<timeout,200>
      Map<String, String> attribute = ZookeeperRegistryHelper.convertConfigToAttribute(configPath, data,
        removeType);
      for (ConfigListener listener : configListeners) {
        listener.configChanged(attribute);
      }
    }
  }
}

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

/**
 * Convert child data to attribute list.
 *
 * @param config       the interface config
 * @param overridePath the override path
 * @param currentData  the current data
 * @return the attribute list
 * @throws UnsupportedEncodingException decode exception
 */
static List<Map<String, String>> convertOverrideToAttributes(AbstractInterfaceConfig config,
                               String overridePath,
                               List<ChildData> currentData)
  throws UnsupportedEncodingException {
  List<Map<String, String>> attributes = new ArrayList<Map<String, String>>();
  if (CommonUtils.isEmpty(currentData)) {
    return attributes;
  }
  for (ChildData childData : currentData) {
    String url = URLDecoder.decode(childData.getPath().substring(overridePath.length() + 1),
      "UTF-8");
    if (config instanceof ConsumerConfig) {
      //If child data contains system local host, convert config to attribute
      if (StringUtils.isNotEmpty(url) && StringUtils.isNotEmpty(SystemInfo.getLocalHost())
        && url.contains("://" + SystemInfo.getLocalHost() + "?")) {
        attributes.add(convertConfigToAttribute(overridePath, childData, false));
      }
    }
  }
  return attributes;
}

相关文章