提交 975e21d2 编写于 作者: A Allen Wang

Improve load balancing example.

上级 23a4528a
...@@ -7,14 +7,15 @@ import rx.Observer; ...@@ -7,14 +7,15 @@ import rx.Observer;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.netflix.client.http.HttpRequest; import com.netflix.client.http.HttpRequest;
import com.netflix.client.http.HttpResponse; import com.netflix.client.http.HttpResponse;
import com.netflix.client.netty.http.NettyHttpClientBuilder.NettyHttpLoadBalancingClientBuilder; import com.netflix.client.netty.http.NettyHttpClient;
import com.netflix.client.netty.http.NettyHttpClientBuilder;
import com.netflix.client.netty.http.NettyHttpLoadBalancingClient; import com.netflix.client.netty.http.NettyHttpLoadBalancingClient;
import com.netflix.loadbalancer.AbstractLoadBalancer; import com.netflix.loadbalancer.AbstractLoadBalancer;
import com.netflix.loadbalancer.Server; import com.netflix.loadbalancer.Server;
public class LoadBalancingExample { public class LoadBalancingExample {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
NettyHttpLoadBalancingClient client = NettyHttpLoadBalancingClientBuilder.newBuilder() NettyHttpClient client = NettyHttpClientBuilder.newBuilder()
.withFixedServerList(Lists.newArrayList(new Server("www.google.com:80"), new Server("www.microsoft.com:80"), new Server("www.yahoo.com:80"))) .withFixedServerList(Lists.newArrayList(new Server("www.google.com:80"), new Server("www.microsoft.com:80"), new Server("www.yahoo.com:80")))
.build(); .build();
HttpRequest request = HttpRequest.newBuilder().uri("/").build(); HttpRequest request = HttpRequest.newBuilder().uri("/").build();
...@@ -40,6 +41,7 @@ public class LoadBalancingExample { ...@@ -40,6 +41,7 @@ public class LoadBalancingExample {
client.observeHttpResponse(request, observer); client.observeHttpResponse(request, observer);
} }
latch.await(); latch.await();
System.out.println(((AbstractLoadBalancer) client.getLoadBalancer()).getLoadBalancerStats()); NettyHttpLoadBalancingClient lbClient = (NettyHttpLoadBalancingClient) client;
System.out.println(((AbstractLoadBalancer) lbClient.getLoadBalancer()).getLoadBalancerStats());
} }
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册