本文整理了Java中com.netflix.loadbalancer.Server.<init>()
方法的一些代码示例,展示了Server.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Server.<init>()
方法的具体详情如下:
包路径:com.netflix.loadbalancer.Server
类名称: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;
}
}
内容来源于网络,如有侵权,请联系作者删除!