• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java ConfigUtils类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.alibaba.dubbo.common.utils.ConfigUtils的典型用法代码示例。如果您正苦于以下问题:Java ConfigUtils类的具体用法?Java ConfigUtils怎么用?Java ConfigUtils使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



ConfigUtils类属于com.alibaba.dubbo.common.utils包,在下文中一共展示了ConfigUtils类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: invoke

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
    if (validation != null && ! invocation.getMethodName().startsWith("$") 
            && ConfigUtils.isNotEmpty(invoker.getUrl().getMethodParameter(invocation.getMethodName(), Constants.VALIDATION_KEY))) {
        try {
            Validator validator = validation.getValidator(invoker.getUrl());
            if (validator != null) {
                validator.validate(invocation.getMethodName(), invocation.getParameterTypes(), invocation.getArguments());
            }
        } catch (RpcException e) {
            throw e;
        } catch (Throwable t) {
            throw new RpcException(t.getMessage(), t);
        }
    }
    return invoker.invoke(invocation);
}
 
开发者ID:dachengxi,项目名称:EatDubbo,代码行数:17,代码来源:ValidationFilter.java


示例2: invoke

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
    if (cacheFactory != null && ConfigUtils.isNotEmpty(invoker.getUrl().getMethodParameter(invocation.getMethodName(), Constants.CACHE_KEY))) {
        Cache cache = cacheFactory.getCache(invoker.getUrl().addParameter(Constants.METHOD_KEY, invocation.getMethodName()));
        if (cache != null) {
            String key = StringUtils.toArgumentString(invocation.getArguments());
            if (cache != null && key != null) {
                Object value = cache.get(key);
                if (value != null) {
                    return new RpcResult(value);
                }
                Result result = invoker.invoke(invocation);
                if (! result.hasException()) {
                    cache.put(key, result.getValue());
                }
                return result;
            }
        }
    }
    return invoker.invoke(invocation);
}
 
开发者ID:dachengxi,项目名称:EatDubbo,代码行数:21,代码来源:CacheFilter.java


示例3: isActive

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
private boolean isActive(Activate activate, URL url) {
    String[] keys = activate.value();
    if (keys == null || keys.length == 0) {
        return true;
    }
    for (String key : keys) {
        for (Map.Entry<String, String> entry : url.getParameters().entrySet()) {
            String k = entry.getKey();
            String v = entry.getValue();
            if ((k.equals(key) || k.endsWith("." + key))
                    && ConfigUtils.isNotEmpty(v)) {
                return true;
            }
        }
    }
    return false;
}
 
开发者ID:dachengxi,项目名称:EatDubbo,代码行数:18,代码来源:ExtensionLoader.java


示例4: checkApplication

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
@SuppressWarnings("deprecation")
protected void checkApplication() {
    // 兼容旧版本
    if (application == null) {
        String applicationName = ConfigUtils.getProperty("dubbo.application.name");
        if (applicationName != null && applicationName.length() > 0) {
            application = new ApplicationConfig();
        }
    }
    if (application == null) {
        throw new IllegalStateException(
                                        "No such application config! Please add <dubbo:application name=\"...\" /> to your spring config.");
    }
    //填充各种Application的信息
    appendProperties(application);
    
    String wait = ConfigUtils.getProperty(Constants.SHUTDOWN_WAIT_KEY);
    if (wait != null && wait.trim().length() > 0) {
        System.setProperty(Constants.SHUTDOWN_WAIT_KEY, wait.trim());
    } else {
        wait = ConfigUtils.getProperty(Constants.SHUTDOWN_WAIT_SECONDS_KEY);
        if (wait != null && wait.trim().length() > 0) {
            System.setProperty(Constants.SHUTDOWN_WAIT_SECONDS_KEY, wait.trim());
        }
    }
}
 
开发者ID:dachengxi,项目名称:EatDubbo,代码行数:27,代码来源:AbstractInterfaceConfig.java


示例5: checkApplication

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
@SuppressWarnings("deprecation")
protected void checkApplication() {
    // 兼容旧版本
    if (application == null) {
        String applicationName = ConfigUtils.getProperty("dubbo.application.name");
        if (applicationName != null && applicationName.length() > 0) {
            application = new ApplicationConfig();
        }
    }
    if (application == null) {
        throw new IllegalStateException(
                                        "No such application config! Please add <dubbo:application name=\"...\" /> to your spring config.");
    }
    appendProperties(application);
    
    String wait = ConfigUtils.getProperty(Constants.SHUTDOWN_WAIT_KEY);
    if (wait != null && wait.trim().length() > 0) {
        System.setProperty(Constants.SHUTDOWN_WAIT_KEY, wait.trim());
    } else {
        wait = ConfigUtils.getProperty(Constants.SHUTDOWN_WAIT_SECONDS_KEY);
        if (wait != null && wait.trim().length() > 0) {
            System.setProperty(Constants.SHUTDOWN_WAIT_SECONDS_KEY, wait.trim());
        }
    }
}
 
开发者ID:zhuxiaolei,项目名称:dubbo2,代码行数:26,代码来源:AbstractInterfaceConfig.java


示例6: invoke

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
public Result invoke(Invoker<?> invoker, Invocation invocation) throws JahhanException {
  	String host = ConfigUtils.getProperty("dubbo.protocol.host",NetUtils.getLocalHost());
RpcContext.getContext()
              .setInvoker(invoker)
              .setInvocation(invocation)
              .setLocalAddress(host, 0)
              .setRemoteAddress(invoker.getUrl().getHost(), 
                                invoker.getUrl().getPort());
RpcContext.getContext().setAttachment("request_id", UUID.randomUUID().toString());
RpcContext.getContext().setAttachment("chain_id", BaseVariable.getBaseVariable().getChainId());
      if (invocation instanceof RpcInvocation) {
          ((RpcInvocation)invocation).setInvoker(invoker);
      }
      try {
          return invoker.invoke(invocation);
      } finally {
          RpcContext.getContext().clearAttachments();
      }
  }
 
开发者ID:nince-wyj,项目名称:jahhan,代码行数:20,代码来源:ConsumerContextFilter.java


示例7: AbstractRegistry

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
public AbstractRegistry(URL url) {
    setUrl(url);
    // 启动文件保存定时器
    syncSaveFile = url.getParameter(Constants.REGISTRY_FILESAVE_SYNC_KEY, false);
    String filename = url.getParameter(Constants.FILE_KEY, System.getProperty("user.home") + "/.dubbo/dubbo-registry-" + url.getHost() + ".cache");
    File file = null;
    if (ConfigUtils.isNotEmpty(filename)) {
        file = new File(filename);
        if(! file.exists() && file.getParentFile() != null && ! file.getParentFile().exists()){
            if(! file.getParentFile().mkdirs()){
                throw new IllegalArgumentException("Invalid registry store file " + file + ", cause: Failed to create directory " + file.getParentFile() + "!");
            }
        }
    }
    this.file = file;
    loadProperties();
    notify(url.getBackupUrls());
}
 
开发者ID:xingmima,项目名称:dubbos,代码行数:19,代码来源:AbstractRegistry.java


示例8: invoke

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
    if (cacheFactory != null && ConfigUtils.isNotEmpty(invoker.getUrl().getMethodParameter(invocation.getMethodName(), Constants.CACHE_KEY))) {
        Cache cache = cacheFactory.getCache(invoker.getUrl().addParameter(Constants.METHOD_KEY, invocation.getMethodName()));
        if (cache != null) {
            String key = StringUtils.toArgumentString(invocation.getArguments());
            Object value = cache.get(key);
            if (value != null) {
                return new RpcResult(value);
            }
            Result result = invoker.invoke(invocation);
            if (! result.hasException()) {
                cache.put(key, result.getValue());
            }
            return result;
        }
    }
    return invoker.invoke(invocation);
}
 
开发者ID:linux-china,项目名称:dubbo3,代码行数:19,代码来源:CacheFilter.java


示例9: isActive

import com.alibaba.dubbo.common.utils.ConfigUtils; //导入依赖的package包/类
private boolean isActive(Activate activate, URL url) {
    String[] keys = activate.value();
    if (keys.length == 0) {
        return true;
    }
    for (String key : keys) {
        for (Map.Entry<String, String> entry : url.getParameters().entrySet()) {
            String k = entry.getKey();
            String v = entry.getValue();
            if ((k.equals(key) || k.endsWith("." + key))
                    && ConfigUtils.isNotEmpty(v)) {
                return true;
            }
        }
    }
    return false;
}
 
开发者ID:linux-china,项目名称:dubbo3,代码行数:18,代码来源:ExtensionLoader.java



注:本文中的com.alibaba.dubbo.common.utils.ConfigUtils类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java StreamUtils类代码示例发布时间:2022-05-21
下一篇:
Java Symbol类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap