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

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

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

Server.<init>介绍

暂无

代码示例

代码示例来源:origin: spring-cloud/spring-cloud-gateway

@Bean
  public ServerList<Server> ribbonServerList() {
    return new StaticServerList<>(new Server("https", "localhost.domain.doesnot.exist", this.port), new Server("localhost", this.port));
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-gateway

@Bean
public ServerList<Server> ribbonServerList() {
  return new StaticServerList<>(new Server("localhost", this.wsPort));
}

代码示例来源:origin: spring-cloud/spring-cloud-gateway

@Bean
  public ServerList<Server> ribbonServerList() {
    return new StaticServerList<>(new Server("https", "localhost", this.port));
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-gateway

@Bean
  public ServerList<Server> ribbonServerList() {
    return new StaticServerList<>(new Server("localhost", this.port));
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-gateway

@Bean
  public ServerList<Server> ribbonServerList() {
    return new StaticServerList<>(new Server("localhost", this.port));
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-gateway

private ServerWebExchange testFilter(ServerWebExchange exchange, URI uri, int port) {
    exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, uri);

    ArgumentCaptor<ServerWebExchange> captor = ArgumentCaptor.forClass(ServerWebExchange.class);
    when(chain.filter(captor.capture())).thenReturn(Mono.empty());

    SpringClientFactory clientFactory = mock(SpringClientFactory.class);
    ILoadBalancer loadBalancer = mock(ILoadBalancer.class);

    when(clientFactory.getLoadBalancerContext("service1")).thenReturn(new RibbonLoadBalancerContext(loadBalancer));
    when(clientFactory.getLoadBalancer("service1")).thenReturn(loadBalancer);
    when(loadBalancer.chooseServer(any())).thenReturn(new Server("service1-host1", port));

    RibbonLoadBalancerClient client = new RibbonLoadBalancerClient(clientFactory);

    LoadBalancerClientFilter filter = new LoadBalancerClientFilter(client, properties);
    filter.filter(exchange, chain);

    return captor.getValue();
  }
}

代码示例来源:origin: spring-cloud/spring-cloud-kubernetes

EndpointPort port = subset.getPorts().get(FIRST);
for (EndpointAddress address : subset.getAddresses()) {
  result.add(new Server(address.getIp(), port.getPort()));
      || portName.endsWith(port.getName())) {
    for (EndpointAddress address : subset.getAddresses()) {
      result.add(new Server(address.getIp(), port.getPort()));

代码示例来源:origin: spring-cloud/spring-cloud-gateway

when(clientFactory.getLoadBalancer("myservice")).thenReturn(loadBalancer);
when(loadBalancer.chooseServer("11111")).thenReturn(new Server("myservice-host1", 8081));
when(loadBalancer.chooseServer("22222")).thenReturn(new Server("myservice-host2", 8081));

代码示例来源:origin: apache/servicecomb-java-chassis

@Override
protected Object createEndpoint(String transportName, String endpoint, MicroserviceInstance instance) {
 URIEndpointObject uri = new URIEndpointObject(endpoint);
 return new Server(uri.getHostOrIp(), uri.getPort());
}

代码示例来源:origin: apache/servicecomb-java-chassis

@Override
protected Object createEndpoint(String transportName, String endpoint, MicroserviceInstance instance) {
 URIEndpointObject uri = new URIEndpointObject(endpoint);
 return new Server(uri.getHostOrIp(), uri.getPort());
}

代码示例来源:origin: fabric8io/spring-cloud-kubernetes

EndpointPort port = subset.getPorts().get(FIRST);
for (EndpointAddress address : subset.getAddresses()) {
  result.add(new Server(address.getIp(), port.getPort()));
  if (Utils.isNullOrEmpty(portName) || portName.endsWith(port.getName())) {
    for (EndpointAddress address : subset.getAddresses()) {
      result.add(new Server(address.getIp(), port.getPort()));

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

protected List<Server> derive(String value) {
    List<Server> list = Lists.newArrayList();
    if (!Strings.isNullOrEmpty(value)) {
      for (String s: value.split(",")) {
        list.add(new Server(s.trim()));
      }
    }
    return list;
  }
}

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

public List<Server> toServers(String[] ips, HttpHost target) {
  int port = extracPort(target);
  List<Server> servers = new ArrayList<Server>(ips.length + 2);
  Server server;
  for (String ip : ips) {
    server = new Server(ip, port);
    server.setAlive(true);
    servers.add(server);
  }
  return servers;
}

代码示例来源:origin: spring-cloud/spring-cloud-core-tests

@Bean
public ILoadBalancer ribbonLoadBalancer() {
  //because of this, it doesn't use eureka to lookup the server,
  // but the classpath is tested
  BaseLoadBalancer balancer = new BaseLoadBalancer();
  balancer.setServersList(Arrays.asList(new Server("example.com", 80)));
  return balancer;
}

代码示例来源:origin: wildfly-swarm-archive/ARCHIVE-wildfly-swarm

@Override
public List<Server> getInitialListOfServers() {
  String tag = ( this.isSecure ? "https" : "http" );
  return TopologyManager.INSTANCE.registrationsForService(this.appName, tag)
      .stream()
      .map( reg-> new Server( reg.getAddress(), reg.getPort() ))
      .collect(Collectors.toList());
}

代码示例来源:origin: wildfly-swarm-archive/ARCHIVE-wildfly-swarm

@Override
  public List<Server> getUpdatedListOfServers() {
    String tag = ( this.isSecure ? "https" : "http" );
    return TopologyManager.INSTANCE.registrationsForService(this.appName, tag)
        .stream()
        .map( reg-> new Server( reg.getAddress(), reg.getPort() ))
        .collect(Collectors.toList());
  }
}

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

public static void main(String[] args){
      PingUrl p = new PingUrl(false,"/cs/hostRunning");
      p.setExpectedContent("true");
      Server s = new Server("ec2-75-101-231-85.compute-1.amazonaws.com", 7101);
      
      boolean isAlive = p.isAlive(s);
      System.out.println("isAlive:" + isAlive);
    }
}

代码示例来源:origin: net.nikore.gozer/marathon

@Override
public LoadBalancingHttpClient<ByteBuf, ByteBuf> load(String key) throws Exception {
 App app = client.getApp(key);
 List<Server> servers = app.getTasks().stream()
  .map(task -> new Server(task.getHost(), task.getPorts().get(0)))
  .collect(Collectors.toList());
 return RibbonTransport.newHttpClient(LoadBalancerBuilder.newBuilder()
  .buildFixedServerListLoadBalancer(servers));
}

代码示例来源:origin: org.apache.servicecomb/spring-boot-starter-discovery

@Override
protected Object createEndpoint(String transportName, String endpoint, MicroserviceInstance instance) {
 URIEndpointObject uri = new URIEndpointObject(endpoint);
 return new Server(uri.getHostOrIp(), uri.getPort());
}

代码示例来源:origin: jmnarloch/feign-oauth2-spring-cloud-starter

@Bean
  public ILoadBalancer ribbonLoadBalancer() {
    BaseLoadBalancer balancer = new BaseLoadBalancer();
    balancer.setServersList(Collections.singletonList(new Server("localhost", this.port)));
    return balancer;
  }
}

相关文章