我目前正在试用Netflix Ribbon库,并试图动态更新可用端点列表以实现负载平衡。
我已经成功创建了一个使用基于配置的服务器列表的httpResourceGroup
,例如:
httpResourceGroup = Ribbon.createHttpResourceGroup("searchServiceClient",
ClientOptions.create()
.withMaxAutoRetriesNextServer(3)
.withLoadBalancerEnabled(true)
.withConfigurationBasedServerList(serverList))
但是,我希望能够在httpResourceGroup
中使用DynamicServerList
。我已经设法构建了一个负载均衡器,如下所示:
LoadBalancerBuilder.<Server>newBuilder()
.withDynamicServerList(servicesList)
.buildDynamicServerListLoadBalancer();
但是我找不到一种方法来交换由httpResourceGroup
ClientOptions
配置的负载均衡器。
有人知道我该怎么做吗?
解决方案是在构造HttpResourceGroup
时不指定withConfigurationBasedServerList()
,因为我相信这是针对固定列表的,尽管我不确定。有很多方法可以初始化动态负载均衡器(通常情况下,您永远不会将其交换出去,而是重复使用相同的负载均衡器,并在新的Server
可用或消失时交换出去。最简单的方法可能是通过基于Archaius的配置。
选项1
在类路径上创建一个包含以下的config.properties
文件
ribbon.NIWSServerListClassName=com.example.MyServerList
ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RoundRobinRule
选项2
System.setProperty("ribbon.NIWSServerListClassName", "com.example.MyServerList");
System.setProperty("ribbon.NFLoadBalancerRuleClassName", "com.netflix.loadbalancer.RoundRobinRule");
创建ServerList实现
import java.util.Arrays;
import java.util.List;
import com.netflix.loadbalancer.Server;
import com.netflix.loadbalancer.ServerList;
public class MyServerList implements ServerList<Server> {
@Override
public final List<Server> getUpdatedListOfServers() {
// TODO do some fancy stuff here
return Arrays.asList(new Server("1.2.3.4", 8888), new Server("5.6.7.8", 9999));
}
@Override
public final List<Server> getInitialListOfServers() {
return Arrays.asList(new Server("1.2.3.4", 8888), new Server("5.6.7.8", 9999));
}
}
运行代码
HttpResourceGroup httpResourceGroup = Ribbon.createHttpResourceGroup("searchServiceClient",
ClientOptions.create()
.withMaxAutoRetriesNextServer(3);
HttpRequestTemplate<ByteBuf> recommendationsByUserIdTemplate = httpResourceGroup.newTemplateBuilder("recommendationsByUserId", ByteBuf.class)
.withMethod("GET")
.withUriTemplate("/users/{userId}/recommendations")
.withFallbackProvider(new RecommendationServiceFallbackHandler())
.withResponseValidator(new RecommendationServiceResponseValidator())
.build();
Observable<ByteBuf> result = recommendationsByUserIdTemplate.requestBuilder()
.withRequestProperty("userId", “user1")
.build()
.observe();
听起来您已经有了ServerList
实现,在这里您可以对服务器列表进行任何事件驱动的更新,但保持负载均衡器不变。