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

Server.getHostPort介绍

暂无

代码示例

代码示例来源：origin: spring-cloud-incubator/spring-cloud-alibaba

static void incrementCallService(String serviceId, Server server) {
    ConcurrentMap<String, ServerWrapper> concurrentHashMap = CALL_SERVICE_COUNT
        .putIfAbsent(serviceId, new ConcurrentHashMap<>());

    if (concurrentHashMap == null) {
      concurrentHashMap = CALL_SERVICE_COUNT.get(serviceId);
    }

    String ipPort = server.getHostPort();
    ServerWrapper serverWraper = concurrentHashMap.putIfAbsent(ipPort,
        new ServerWrapper(server, new AtomicLong()));

    if (serverWraper == null) {
      serverWraper = concurrentHashMap.get(ipPort);
    }
    serverWraper.setServer(server);
    serverWraper.getCallCount().incrementAndGet();
  }
}

代码示例来源：origin: spring-cloud-incubator/spring-cloud-alibaba

final Server server = serverIterator.next();
ansServerList.forEach(ansServer -> {
  if (server.getHostPort()
      .equals(ansServer.getHealthService().toInetAddr())) {
    log.info("Source Server is remove " + server.getHostPort()
        + ", and from ANS Server is override："
        + ansServer.toString());

代码示例来源：origin: codingapi/tx-lcn

private Server getServer(Object key) {
  String localKey = String.format("%s:%s:%s", registration.getServiceId(), registration.getHost(), registration.getPort());
  List<String> appList = sleuthParamListener.beforeBalance(localKey);
  Server balanceServer = null;
  List<Server> servers = getLoadBalancer().getAllServers();
  log.debug("load balanced rule servers: {}", servers);
  for (Server server : servers) {
    for (String appKey : appList) {
      String serverKey = String.format("%s:%s", server.getMetaInfo().getAppName(), server.getHostPort());
      if (serverKey.equals(appKey)) {
        balanceServer = server;
      }
    }
  }
  if (balanceServer == null) {
    Server server = super.choose(key);
    sleuthParamListener.afterNewBalance(String.format("%s:%s", server.getMetaInfo().getAppName(), server.getHostPort()));
    return server;
  } else {
    return balanceServer;
  }
}

代码示例来源：origin: com.netflix.ribbon/ribbon-loadbalancer

public int compare(Server s1, Server s2) {
    return s1.getHostPort().compareTo(s2.getId());
  }
}

代码示例来源：origin: com.netflix.ribbon/ribbon-httpclient

@Override
public boolean connect(Server server, String primeConnectionsURIPath) throws Exception {
  String url = "http://" + server.getHostPort() + primeConnectionsURIPath;
  logger.debug("Trying URL: {}", url);
  HttpUriRequest get = new HttpGet(url);
  HttpResponse response = null;
  try {
    response = client.execute(get);
    if (logger.isDebugEnabled() && response.getStatusLine() != null) {
      logger.debug("Response code:" + response.getStatusLine().getStatusCode());
    }
  } finally {
    get.abort();
  }
  return true;
}

代码示例来源：origin: com.netflix.ribbon/ribbon-loadbalancer

static public String normalizeId(String id) {
  Pair<String, Integer> hostPort = getHostPort(id);
  if (hostPort == null) {
    return null;
  } else {
    return hostPort.first() + ":" + hostPort.second();
  }
}

代码示例来源：origin: com.nepxion/discovery-plugin-strategy

@SuppressWarnings("unchecked")
private boolean applyAddress(Server server, Map<String, String> metadata) {
  String addressValue = getAddressValue(server);
  if (StringUtils.isEmpty(addressValue)) {
    return true;
  }
  String serviceId = server.getMetaInfo().getAppName().toLowerCase();
  Map<String, String> addressMap = JsonUtil.fromJson(addressValue, Map.class);
  String addresses = addressMap.get(serviceId);
  if (addresses == null) {
    return true;
  }
  List<String> addressList = StringUtil.splitToList(addresses, DiscoveryConstant.SEPARATE);
  if (addressList.contains(server.getHostPort()) || addressList.contains(server.getHost())) {
    return true;
  }
  return false;
}

代码示例来源：origin: com.netflix.feign/feign-ribbon

@Override
public Request apply(RequestTemplate input) {
 Server currentServer = lb.chooseServer(null);
 String url = format("%s://%s", scheme, currentServer.getHostPort());
 input.insert(0, url);
 try {
  return input.request();
 } finally {
  lb.getLoadBalancerStats().incrementNumRequests(currentServer);
 }
}

代码示例来源：origin: com.netflix.ribbon/ribbon-loadbalancer

public void setId(String id) {
  Pair<String, Integer> hostPort = getHostPort(id);
  if (hostPort != null) {
    this.id = hostPort.first() + ":" + hostPort.second();
    this.host = hostPort.first();
    this.port = hostPort.second();
    this.scheme = getScheme(id);
  } else {
    this.id = null;
  }
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-netflix-ribbon

private void updateServerInstanceStats(LoadBalancedRetryContext context) {
  ServiceInstance serviceInstance = context.getServiceInstance();
  if (serviceInstance instanceof RibbonServer) {
    Server lbServer = ((RibbonServer)serviceInstance).getServer();
    ServerStats serverStats = lbContext.getServerStats(lbServer);
    serverStats.incrementSuccessiveConnectionFailureCount();
    serverStats.addToFailureCount();                    
    LOGGER.debug(lbServer.getHostPort() + " RetryCount: " + context.getRetryCount() 
      + " Successive Failures: " + serverStats.getSuccessiveConnectionFailureCount() 
      + " CircuitBreakerTripped:" + serverStats.isCircuitBreakerTripped());
  }
}

代码示例来源：origin: com.github.gitssie/play-transport

public void makeInvoke(Server server, HttpUriRequest request, HTTPHandler handler){
  try {
    HttpHost host = determineTarget(request);
    if(server != null) host = new HttpHost(server.getHost(),server.getPort(),host.getSchemeName());
    Span span = tracer.nextSpan().name("HTTPInvoker.invoke").kind(Span.Kind.CLIENT).start();
    span.tag("server",server == null ? host.getHostName() : server.getHostPort());
    span.tag("attempt_count",context.getAttemptCount() + "");
    String reqUri = request.getURI().toString();
    if(LOGGER.isInfoEnabled()) {
      LOGGER.info(request.toString());
    }
    propagationTraceInfo(request, span);
    Promise<HttpResponse> promise = httpClient.execute(host,request);
    promise.onRedeem(new SuccessCallback(span,handler,this,retryHandler), Promise.toExecutor(executionContext));
    promise.onFailure(new FailureCallback(reqUri,span,handler,this,retryHandler),Promise.toExecutor(executionContext));
  } catch (Throwable e) {
    handler.onThrowable(e);
    LOGGER.error("{} http error,with request:{},server:{}",httpClient.getName(),request,server);
  }
}