import com.taobao.diamond.domain.ConfigInfoEx; //导入依赖的package包/类
protected Map<String, String> queryAndHold(List<String> dataIds, String unitName) {
    DiamondEnv env = null;

    // TODO 外部直接指定ip进行访问
    if (!TStringUtil.isEmpty(unitName)) {
        env = DiamondUnitSite.getDiamondUnitEnv(unitName);
    } else {
        env = DiamondEnvRepo.defaultEnv;
    }

    BatchHttpResult queryResult = env.batchGetConfig(dataIds, "DEFAULT_GROUP", 30000);
    Map<String, String> result = new HashMap<String, String>();
    if (queryResult.isSuccess()) {
        List<ConfigInfoEx> configs = queryResult.getResult();
        for (ConfigInfoEx config : configs) {
            result.put(config.getDataId(), config.getContent());
        }
        addDatas(result);
    } else {
        log.warn("Batch Query Failed. Status Code is " + queryResult.getStatusCode());
    }
    return result;
}
 

import com.taobao.diamond.domain.ConfigInfoEx; //导入依赖的package包/类
protected Map<String, String> queryAndHold(List<String> dataIds, String unitName) {
    DiamondEnv env = null;

    // TODO 外部直接指定ip进行访问
    if (!TStringUtil.isEmpty(unitName)) {
        env = DiamondUnitSite.getDiamondUnitEnv(unitName);
    } else {
        env = DiamondEnvRepo.defaultEnv;
    }

    BatchHttpResult queryResult = env.batchQuery(dataIds, "DEFAULT_GROUP", 30000);
    Map<String, String> result = new HashMap<String, String>();
    if (queryResult.isSuccess()) {
        List<ConfigInfoEx> configs = queryResult.getResult();
        for (ConfigInfoEx config : configs) {
            result.put(config.getDataId(), config.getContent());
        }
        addDatas(result);
    } else {
        log.warn("Batch Query Failed. Status Code is " + queryResult.getStatusCode());
    }
    return result;
}
 

import com.taobao.diamond.domain.ConfigInfoEx; //导入依赖的package包/类
/**
 * 批量查询
 * 
 * @param groupName
 * @param dataIds
 * @param serverId
 * @return
 */
public BatchContextResult<ConfigInfoEx> batchQuery(String serverId, String groupName, List<String> dataIds);
 

import com.taobao.diamond.domain.ConfigInfoEx; //导入依赖的package包/类
/**
 * 批量新增或更新
 * 
 * @param serverId
 * @param groupName
 * @param dataId2ContentMap
 *            key:dataId,value:content
 * @return
 */
public BatchContextResult<ConfigInfoEx> batchAddOrUpdate(String serverId, String groupName,
        Map<String/* dataId */, String/* content */> dataId2ContentMap);