com.weibo.api.motan.rpc.URL.getPort()方法的使用及代码示例

x33g5p2x 于2022-02-01 转载在其他

字(10.1k)|赞(0)|评价(0)|浏览(229)

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

URL.getPort介绍

暂无

代码示例

代码示例来源：origin: weibocom/motan

public NettyClient(URL url) {
  super(url);
  timeMonitorFuture = scheduledExecutor.scheduleWithFixedDelay(
      new TimeoutMonitor("timeout_monitor_" + url.getHost() + "_" + url.getPort()),
      MotanConstants.NETTY_TIMEOUT_TIMER_PERIOD, MotanConstants.NETTY_TIMEOUT_TIMER_PERIOD,
      TimeUnit.MILLISECONDS);
}

代码示例来源：origin: weibocom/motan

@Override
protected Registry createRegistry(URL url) {
  String host = ConsulConstants.DEFAULT_HOST;
  int port = ConsulConstants.DEFAULT_PORT;
  if (StringUtils.isNotBlank(url.getHost())) {
    host = url.getHost();
  }
  if (url.getPort() > 0) {
    port = url.getPort();
  }
  //可以使用不同的client实现
  MotanConsulClient client = new ConsulEcwidClient(host, port);
  return new ConsulRegistry(url, client);
}

代码示例来源：origin: weibocom/motan

protected String getLocalHostAddress(List<URL> registryURLs) {
  String localAddress = null;
  Map<String, Integer> regHostPorts = new HashMap<String, Integer>();
  for (URL ru : registryURLs) {
    if (StringUtils.isNotBlank(ru.getHost()) && ru.getPort() > 0) {
      regHostPorts.put(ru.getHost(), ru.getPort());
    }
  }
  InetAddress address = NetUtils.getLocalAddress(regHostPorts);
  if (address != null) {
    localAddress = address.getHostAddress();
  }
  if (NetUtils.isValidLocalHost(localAddress)) {
    return localAddress;
  }
  throw new MotanServiceException("Please config local server hostname with intranet IP first!",
      MotanErrorMsgConstant.FRAMEWORK_INIT_ERROR);
}

代码示例来源：origin: weibocom/motan

private List<URL> createSubscribeUrl(URL subscribeUrl) {
  URL url = this.getUrl();
  List result = new ArrayList(directUrls.size());
  for (URL directUrl : directUrls) {
    URL tmp = subscribeUrl.createCopy();
    tmp.setHost(directUrl.getHost());
    tmp.setPort(directUrl.getPort());
    result.add(tmp);
  }
  return result;
}

代码示例来源：origin: weibocom/motan

public NettyChannel(NettyClient nettyClient) {
  this.nettyClient = nettyClient;
  this.remoteAddress = new InetSocketAddress(nettyClient.getUrl().getHost(), nettyClient.getUrl().getPort());
}

代码示例来源：origin: weibocom/motan

/**
 * 根据motan的url生成consul的serivce id。 serviceid 包括ip＋port＋rpc服务的接口类名
 *
 * @param url
 * @return
 */
public static String convertConsulSerivceId(URL url) {
  if (url == null) {
    return null;
  }
  return convertServiceId(url.getHost(), url.getPort(), url.getPath());
}

代码示例来源：origin: weibocom/motan

private List<URL> mergeResult(URL url, Map<String, Integer> weights) {
  List<URL> finalResult = new ArrayList<URL>();
  if (weights.size() > 1) {
    // 将所有group及权重拼接成一个rule的URL，并作为第一个元素添加到最终结果中
    URL ruleUrl = new URL("rule", url.getHost(), url.getPort(), url.getPath());
    StringBuilder weightsBuilder = new StringBuilder(64);
    for (Map.Entry<String, Integer> entry : weights.entrySet()) {
      weightsBuilder.append(entry.getKey()).append(':').append(entry.getValue()).append(',');
    }
    ruleUrl.addParameter(URLParamType.weights.getName(), weightsBuilder.deleteCharAt(weightsBuilder.length() - 1).toString());
    finalResult.add(ruleUrl);
  }
  for (String key : weights.keySet()) {
    if (groupServiceCache.containsKey(key)) {
      finalResult.addAll(groupServiceCache.get(key));
    } else {
      URL urlTemp = url.createCopy();
      urlTemp.addParameter(URLParamType.group.getName(), key);
      finalResult.addAll(discoverOneGroup(urlTemp));
      registry.subscribeService(urlTemp, this);
    }
  }
  return finalResult;
}

代码示例来源：origin: weibocom/motan

public NettyChannelFactory(NettyClient nettyClient) {
  this.nettyClient = nettyClient;
  this.factoryName = "NettyChannelFactory_" + nettyClient.getUrl().getHost() + "_" + nettyClient.getUrl().getPort();
}

代码示例来源：origin: weibocom/motan

public NettyChannelFactory(NettyClient nettyClient) {
  super();
  this.nettyClient = nettyClient;
  this.factoryName = "NettyChannelFactory_" + nettyClient.getUrl().getHost() + "_"
      + nettyClient.getUrl().getPort();
}

代码示例来源：origin: weibocom/motan

public DirectRegistry(URL url) {
  super(url);
  String address = url.getParameter("address");
  if (address.contains(",")) {
    try {
      String[] directUrlArray = address.split(",");
      for (String directUrl : directUrlArray) {
        parseDirectUrl(directUrl);
      }
    } catch (Exception e) {
      throw new MotanFrameworkException(
          String.format("parse direct url error, invalid direct registry address %s, address should be ip1:port1,ip2:port2 ..."));
    }
  } else {
    registerDirectUrl(url.getHost(), url.getPort());
  }
}

代码示例来源：origin: weibocom/motan

protected ResteasyWebTarget innerCreateClient(URL url) {
  ResteasyClient client = new ResteasyClientBuilder().build();
  String contextpath = url.getParameter("contextpath", "/");
  if (!contextpath.startsWith("/"))
    contextpath = "/" + contextpath;
  return client.target("http://" + url.getHost() + ":" + url.getPort() + contextpath);
}

代码示例来源：origin: weibocom/motan

public NettyClient(URL url) {
  super(url);
  maxClientConnection = url.getIntParameter(URLParamType.maxClientConnection.getName(),
      URLParamType.maxClientConnection.getIntValue());
  timeMonitorFuture = scheduledExecutor.scheduleWithFixedDelay(
      new TimeoutMonitor("timeout_monitor_" + url.getHost() + "_" + url.getPort()),
      MotanConstants.NETTY_TIMEOUT_TIMER_PERIOD, MotanConstants.NETTY_TIMEOUT_TIMER_PERIOD,
      TimeUnit.MILLISECONDS);
}

代码示例来源：origin: weibocom/motan

/**
 * 默认策略当接口线程池占用达到3/4或者空闲小于150时，限制单个方法请求不能超过总线程数的1/2 需要自定义方法并发限制可以通过actives参数配置
 */
@Override
public void init(Caller<?> caller) {
  if (caller instanceof Provider) {
    String port = String.valueOf(caller.getUrl().getPort());
    totalCount = portTotalMap.get(port);
    if (totalCount == null) {
      portTotalMap.putIfAbsent(port, new AtomicInteger());
      totalCount = portTotalMap.get(port);
    }
    maxThread = caller.getUrl().getIntParameter(URLParamType.maxWorkerThread.getName(), URLParamType.maxWorkerThread.getIntValue());
    totalLimit = maxThread > 600 ? maxThread - 150 : maxThread * 3 / 4;
    int active = caller.getUrl().getIntParameter(URLParamType.actives.getName(), URLParamType.actives.getIntValue());
    if (active > 0) {
      methodLimit = active;
    } else {
      methodLimit = maxThread / 2;
    }
    isProvider = true;
  }
}

代码示例来源：origin: weibocom/motan

@Override
public synchronized boolean open() {
  if (isAvailable()) {
    LoggerUtil.warn("NettyServer ServerChannel already Open: url=" + url);
    return true;
  }
  LoggerUtil.info("NettyServer ServerChannel start Open: url=" + url);
  initServerBootstrap();
  serverChannel = bootstrap.bind(new InetSocketAddress(url.getPort()));
  state = ChannelState.ALIVE;
  StatsUtil.registryStatisticCallback(this);
  LoggerUtil.info("NettyServer ServerChannel finish Open: url=" + url);
  return state.isAliveState();
}

代码示例来源：origin: weibocom/motan

public NettyChannel(NettyClient nettyClient) {
  this.nettyClient = nettyClient;
  this.remoteAddress = new InetSocketAddress(nettyClient.getUrl().getHost(), nettyClient.getUrl().getPort());
  codec = ExtensionLoader.getExtensionLoader(Codec.class).getExtension(nettyClient.getUrl().getParameter(URLParamType.codec.getName(), URLParamType.codec.getValue()));
}

代码示例来源：origin: weibocom/motan

public boolean init() throws Exception {
  methodDescMap = GrpcUtil.getMethodDescriptorByAnnotation(interfaceClazz, url.getParameter(URLParamType.serialize.getName()));
  channel = ManagedChannelBuilder.forAddress(url.getHost(), url.getPort()).usePlaintext(true).build();
  return true;
}

代码示例来源：origin: weibocom/motan

/**
 * 根据服务的url生成consul对应的service
 *
 * @param url
 * @return
 */
public static ConsulService buildService(URL url) {
  ConsulService service = new ConsulService();
  service.setAddress(url.getHost());
  service.setId(ConsulUtils.convertConsulSerivceId(url));
  service.setName(ConsulUtils.convertGroupToServiceName(url.getGroup()));
  service.setPort(url.getPort());
  service.setTtl(ConsulConstants.TTL);
  List<String> tags = new ArrayList<String>();
  tags.add(ConsulConstants.CONSUL_TAG_MOTAN_PROTOCOL + url.getProtocol());
  tags.add(ConsulConstants.CONSUL_TAG_MOTAN_URL + StringTools.urlEncode(url.toFullStr()));
  service.setTags(tags);
  return service;
}

代码示例来源：origin: weibocom/motan

@Override
protected RestServer innerCreateServer(URL url) {
  NettyJaxrsServer server = new NettyJaxrsServer();
  server.setMaxRequestSize(url.getIntParameter(URLParamType.maxContentLength.getName(),
      URLParamType.maxContentLength.getIntValue()));
  ResteasyDeployment deployment = new ResteasyDeployment();
  server.setDeployment(deployment);
  server.setExecutorThreadCount(url.getIntParameter(URLParamType.maxWorkerThread.getName(),
      URLParamType.maxWorkerThread.getIntValue()));
  server.setPort(url.getPort());
  server.setRootResourcePath("");
  server.setSecurityDomain(null);
  deployment.setInjectorFactoryClass(RestfulInjectorFactory.class.getName());
  deployment.getProviderClasses().add(RpcExceptionMapper.class.getName());
  return new EmbedRestServer(server);
}

代码示例来源：origin: weibocom/motan

serverBootstrap.childOption(ChannelOption.TCP_NODELAY, true);
serverBootstrap.childOption(ChannelOption.SO_KEEPALIVE, true);
ChannelFuture channelFuture = serverBootstrap.bind(new InetSocketAddress(url.getPort()));
channelFuture.syncUninterruptibly();
serverChannel = channelFuture.channel();

代码示例来源：origin: weibocom/motan

@Override
protected <T> Exporter<T> createExporter(Provider<T> provider, URL url) {
  String ipPort = url.getServerPortStr();
  GrpcServer server = serverMap.get(ipPort);
  if (server == null) {
    boolean shareChannel =
        url.getBooleanParameter(URLParamType.shareChannel.getName(), URLParamType.shareChannel.getBooleanValue());
    int workerQueueSize = url.getIntParameter(URLParamType.workerQueueSize.getName(), URLParamType.workerQueueSize.getIntValue());
    int minWorkerThread = 0, maxWorkerThread = 0;
    if (shareChannel) {
      minWorkerThread =
          url.getIntParameter(URLParamType.minWorkerThread.getName(), MotanConstants.NETTY_SHARECHANNEL_MIN_WORKDER);
      maxWorkerThread =
          url.getIntParameter(URLParamType.maxWorkerThread.getName(), MotanConstants.NETTY_SHARECHANNEL_MAX_WORKDER);
    } else {
      minWorkerThread =
          url.getIntParameter(URLParamType.minWorkerThread.getName(), MotanConstants.NETTY_NOT_SHARECHANNEL_MIN_WORKDER);
      maxWorkerThread =
          url.getIntParameter(URLParamType.maxWorkerThread.getName(), MotanConstants.NETTY_NOT_SHARECHANNEL_MAX_WORKDER);
    }
    ExecutorService executor =
        new StandardThreadExecutor(minWorkerThread, maxWorkerThread, workerQueueSize, new DefaultThreadFactory("GrpcServer-"
            + url.getServerPortStr(), true));
    server = new GrpcServer(url.getPort(), shareChannel, executor);
    serverMap.putIfAbsent(ipPort, server);
    server = serverMap.get(ipPort);
  }
  return new GrpcExporter<T>(provider, url, server);
}

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

相关文章

热门标签

Java query python Node 开发语言 request Util 数据库 Table 后端算法 Logger Message Element Parser

最新文章

高级程序员和新手小白程序员区别你是那个等级看解决bug速度
浏览(999) 发布于 5个月前
还在用双层for循环吗？太慢了
浏览(924) 发布于 5个月前
我用EasyExcel优化了公司的导出（附踩坑记录）
浏览(966) 发布于 5个月前
记录因Sharding Jdbc批量操作引发的一次fullGC
浏览(801) 发布于 5个月前
进大厂必须要会的单元测试
浏览(800) 发布于 5个月前

URL类方法