org.apache.dubbo.common.URL.getAbsolutePath()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(11.2k)|赞(0)|评价(0)|浏览(97)

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

URL.getAbsolutePath介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-dubbo

@Override
public String getAbsolutePath() {
  return super.getAbsolutePath();
}

代码示例来源：origin: apache/incubator-dubbo

@Override
public String getAbsolutePath() {
  return super.getAbsolutePath();
}

代码示例来源：origin: apache/incubator-dubbo

public FileGroup(URL url) {
  super(url);
  String path = url.getAbsolutePath();
  file = new File(path);
  checkModifiedFuture = scheduledExecutorService.scheduleWithFixedDelay(new Runnable() {
    @Override
    public void run() {
      // Check the file change
      try {
        check();
      } catch (Throwable t) { // Defensive fault tolerance
        logger.error("Unexpected error occur at reconnect, cause: " + t.getMessage(), t);
      }
    }
  }, 2000, 2000, TimeUnit.MILLISECONDS);
}

代码示例来源：origin: apache/incubator-dubbo

public FileGroup(URL url) {
  super(url);
  String path = url.getAbsolutePath();
  file = new File(path);
  checkModifiedFuture = scheduledExecutorService.scheduleWithFixedDelay(new Runnable() {
    @Override
    public void run() {
      // Check the file change
      try {
        check();
      } catch (Throwable t) { // Defensive fault tolerance
        logger.error("Unexpected error occur at reconnect, cause: " + t.getMessage(), t);
      }
    }
  }, 2000, 2000, TimeUnit.MILLISECONDS);
}

代码示例来源：origin: apache/incubator-dubbo

@Override
protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new HessianHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  final HessianSkeleton skeleton = new HessianSkeleton(impl, type);
  skeletonMap.put(path, skeleton);
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, new HessianSkeleton(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

代码示例来源：origin: apache/incubator-dubbo

@Override
protected <T> Runnable doExport(final T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new InternalHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  skeletonMap.put(path, createExporter(impl, type));
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, createExporter(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

代码示例来源：origin: apache/incubator-dubbo

@Override
protected <T> Runnable doExport(final T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new InternalHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  skeletonMap.put(path, createExporter(impl, type));
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, createExporter(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

代码示例来源：origin: apache/incubator-dubbo

@Override
protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new HessianHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  final HessianSkeleton skeleton = new HessianSkeleton(impl, type);
  skeletonMap.put(path, skeleton);
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, new HessianSkeleton(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

代码示例来源：origin: apache/incubator-dubbo

@Override
public Router getRouter(URL url) {
  try {
    // Transform File URL into Script Route URL, and Load
    // file:///d:/path/to/route.js?router=script ==> script:///d:/path/to/route.js?type=js&rule=<file-content>
    String protocol = url.getParameter(Constants.ROUTER_KEY, ScriptRouterFactory.NAME); // Replace original protocol (maybe 'file') with 'script'
    String type = null; // Use file suffix to config script type, e.g., js, groovy ...
    String path = url.getPath();
    if (path != null) {
      int i = path.lastIndexOf('.');
      if (i > 0) {
        type = path.substring(i + 1);
      }
    }
    String rule = IOUtils.read(new FileReader(new File(url.getAbsolutePath())));
    // FIXME: this code looks useless
    boolean runtime = url.getParameter(Constants.RUNTIME_KEY, false);
    URL script = url.setProtocol(protocol).addParameter(Constants.TYPE_KEY, type)
        .addParameter(Constants.RUNTIME_KEY, runtime)
        .addParameterAndEncoded(Constants.RULE_KEY, rule);
    return routerFactory.getRouter(script);
  } catch (IOException e) {
    throw new IllegalStateException(e.getMessage(), e);
  }
}

代码示例来源：origin: apache/incubator-dubbo

@Override
public Router getRouter(URL url) {
  try {
    // Transform File URL into Script Route URL, and Load
    // file:///d:/path/to/route.js?router=script ==> script:///d:/path/to/route.js?type=js&rule=<file-content>
    String protocol = url.getParameter(Constants.ROUTER_KEY, ScriptRouterFactory.NAME); // Replace original protocol (maybe 'file') with 'script'
    String type = null; // Use file suffix to config script type, e.g., js, groovy ...
    String path = url.getPath();
    if (path != null) {
      int i = path.lastIndexOf('.');
      if (i > 0) {
        type = path.substring(i + 1);
      }
    }
    String rule = IOUtils.read(new FileReader(new File(url.getAbsolutePath())));
    // FIXME: this code looks useless
    boolean runtime = url.getParameter(Constants.RUNTIME_KEY, false);
    URL script = url.setProtocol(protocol).addParameter(Constants.TYPE_KEY, type)
        .addParameter(Constants.RUNTIME_KEY, runtime)
        .addParameterAndEncoded(Constants.RULE_KEY, rule);
    return routerFactory.getRouter(script);
  } catch (IOException e) {
    throw new IllegalStateException(e.getMessage(), e);
  }
}

代码示例来源：origin: apache/incubator-dubbo

@Override
protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer httpServer = serverMap.get(addr);
  if (httpServer == null) {
    httpServer = httpBinder.bind(url, new WebServiceHandler());
    serverMap.put(addr, httpServer);
  }
  final ServerFactoryBean serverFactoryBean = new ServerFactoryBean();
  serverFactoryBean.setAddress(url.getAbsolutePath());
  serverFactoryBean.setServiceClass(type);
  serverFactoryBean.setServiceBean(impl);
  serverFactoryBean.setBus(bus);
  serverFactoryBean.setDestinationFactory(transportFactory);
  serverFactoryBean.create();
  return new Runnable() {
    @Override
    public void run() {
      if(serverFactoryBean.getServer()!= null) {
        serverFactoryBean.getServer().destroy();
      }
      if(serverFactoryBean.getBus()!=null) {
        serverFactoryBean.getBus().shutdown(true);
      }
    }
  };
}

代码示例来源：origin: apache/incubator-dubbo

@Override
protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer httpServer = serverMap.get(addr);
  if (httpServer == null) {
    httpServer = httpBinder.bind(url, new WebServiceHandler());
    serverMap.put(addr, httpServer);
  }
  final ServerFactoryBean serverFactoryBean = new ServerFactoryBean();
  serverFactoryBean.setAddress(url.getAbsolutePath());
  serverFactoryBean.setServiceClass(type);
  serverFactoryBean.setServiceBean(impl);
  serverFactoryBean.setBus(bus);
  serverFactoryBean.setDestinationFactory(transportFactory);
  serverFactoryBean.create();
  return new Runnable() {
    @Override
    public void run() {
      if(serverFactoryBean.getServer()!= null) {
        serverFactoryBean.getServer().destroy();
      }
      if(serverFactoryBean.getBus()!=null) {
        serverFactoryBean.getBus().shutdown(true);
      }
    }
  };
}

代码示例来源：origin: org.apache.dubbo/dubbo

@Override
public String getAbsolutePath() {
  return super.getAbsolutePath();
}

代码示例来源：origin: org.apache.dubbo/dubbo-compatible

@Override
public String getAbsolutePath() {
  return super.getAbsolutePath();
}

代码示例来源：origin: org.apache.dubbo/dubbo

public FileGroup(URL url) {
  super(url);
  String path = url.getAbsolutePath();
  file = new File(path);
  checkModifiedFuture = scheduledExecutorService.scheduleWithFixedDelay(new Runnable() {
    @Override
    public void run() {
      // Check the file change
      try {
        check();
      } catch (Throwable t) { // Defensive fault tolerance
        logger.error("Unexpected error occur at reconnect, cause: " + t.getMessage(), t);
      }
    }
  }, 2000, 2000, TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.apache.dubbo/dubbo-remoting-p2p

public FileGroup(URL url) {
  super(url);
  String path = url.getAbsolutePath();
  file = new File(path);
  checkModifiedFuture = scheduledExecutorService.scheduleWithFixedDelay(new Runnable() {
    @Override
    public void run() {
      // Check the file change
      try {
        check();
      } catch (Throwable t) { // Defensive fault tolerance
        logger.error("Unexpected error occur at reconnect, cause: " + t.getMessage(), t);
      }
    }
  }, 2000, 2000, TimeUnit.MILLISECONDS);
}

代码示例来源：origin: org.apache.dubbo/dubbo

@Override
protected <T> Runnable doExport(final T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new InternalHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  skeletonMap.put(path, createExporter(impl, type));
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, createExporter(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

代码示例来源：origin: org.apache.dubbo/dubbo-rpc-http

@Override
protected <T> Runnable doExport(final T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new InternalHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  skeletonMap.put(path, createExporter(impl, type));
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, createExporter(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

代码示例来源：origin: org.apache.dubbo/dubbo

@Override
protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new HessianHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  final HessianSkeleton skeleton = new HessianSkeleton(impl, type);
  skeletonMap.put(path, skeleton);
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, new HessianSkeleton(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

代码示例来源：origin: org.apache.dubbo/dubbo-rpc-hessian

@Override
protected <T> Runnable doExport(T impl, Class<T> type, URL url) throws RpcException {
  String addr = getAddr(url);
  HttpServer server = serverMap.get(addr);
  if (server == null) {
    server = httpBinder.bind(url, new HessianHandler());
    serverMap.put(addr, server);
  }
  final String path = url.getAbsolutePath();
  final HessianSkeleton skeleton = new HessianSkeleton(impl, type);
  skeletonMap.put(path, skeleton);
  final String genericPath = path + "/" + Constants.GENERIC_KEY;
  skeletonMap.put(genericPath, new HessianSkeleton(impl, GenericService.class));
  return new Runnable() {
    @Override
    public void run() {
      skeletonMap.remove(path);
      skeletonMap.remove(genericPath);
    }
  };
}

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

URL

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    URL类方法

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