com.netflix.loadbalancer.Server.isAlive()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(139)

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

Server.isAlive介绍

暂无

代码示例

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

public void markServerDown(Server server) {
  if (server == null || !server.isAlive()) {
    return;
  }
  logger.error("LoadBalancer [{}]:  markServerDown called on [{}]", name, server.getId());
  server.setAlive(false);
  // forceQuickPing();
  notifyServerStatusChangeListener(singleton(server));
}

代码示例来源：origin: org.apache.camel/camel-ribbon

@Override
  public Map<String, String> getMetadata() {
    Map<String, String> meta = metaData != null ? new HashMap<>(metaData) : new HashMap<>();
    ObjectHelper.ifNotEmpty(super.getId(), val -> meta.put("id", val));
    ObjectHelper.ifNotEmpty(super.getZone(), val -> meta.put("zone", val));
    ObjectHelper.ifNotEmpty(super.isAlive(), val -> meta.put("is_alive", Boolean.toString(val)));
    ObjectHelper.ifNotEmpty(super.isReadyToServe(), val -> meta.put("ready_to_server", Boolean.toString(val)));

    return Collections.unmodifiableMap(meta);
  }
}

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

public Server choose(ILoadBalancer lb, Object key) {
  long requestTime = System.currentTimeMillis();
  long deadline = requestTime + maxRetryMillis;
  Server answer = null;
  answer = subRule.choose(key);
  if (((answer == null) || (!answer.isAlive()))
      && (System.currentTimeMillis() < deadline)) {
    InterruptTask task = new InterruptTask(deadline
        - System.currentTimeMillis());
    while (!Thread.interrupted()) {
      answer = subRule.choose(key);
      if (((answer == null) || (!answer.isAlive()))
          && (System.currentTimeMillis() < deadline)) {
        /* pause and retry hoping it's transient */
        Thread.yield();
      } else {
        break;
      }
    }
    task.cancel();
  }
  if ((answer == null) || (!answer.isAlive())) {
    return null;
  } else {
    return answer;
  }
}

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

public void markServerDown(String id) {
  boolean triggered = false;
  id = Server.normalizeId(id);
  if (id == null) {
    return;
  }
  Lock writeLock = upServerLock.writeLock();
  writeLock.lock();
  try {
    final List<Server> changedServers = new ArrayList<Server>();
    for (Server svr : upServerList) {
      if (svr.isAlive() && (svr.getId().equals(id))) {
        triggered = true;
        svr.setAlive(false);
        changedServers.add(svr);
      }
    }
    if (triggered) {
      logger.error("LoadBalancer [{}]:  markServerDown called for server [{}]", name, id);
      notifyServerStatusChangeListener(changedServers);
    }
  } finally {
    writeLock.unlock();
  }
}

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

boolean isAlive = results[i];
Server svr = allServers[i];
boolean oldIsAlive = svr.isAlive();

代码示例来源：origin: ZhongFuCheng3y/msc-Demo

if (server.isAlive()) {
  return (server);

代码示例来源：origin: steellee/sao

if (server.isAlive() && (server.isReadyToServe())) {
  return (server);

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

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

if (server.isAlive()) {
  return (server);

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

if (server.isAlive() && (server.isReadyToServe())) {
  return (server);

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

代码示例来源：origin: roncoo/spring-cloud-demo

private Server choose(ILoadBalancer lb, Object key) {
  if (lb == null) {
    return null;
  }
  Server server = null;
  while (server == null) {
    if (Thread.interrupted()) {
      return null;
    }
    List<Server> upList = lb.getReachableServers(); // 可用的服务实例
    // 只获取端口为：7779的服务实例
    for (Server s : upList) {
      if (s.getPort() == 7779) {
        server = s;
      }
    }
    if (server == null) {
      Thread.yield();
      continue;
    }
    System.out.println("实例IP：" + server.getHost() + " 端口：" + server.getPort());
    if (server.isAlive()) {
      return (server);
    }
    server = null;
    Thread.yield();
  }
  return server;
}

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

server

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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