SpringCloud LoadBalancerClient实现负载均衡以及自定义负载策略(一个或多个)
上篇已经介绍了LoadBalancerClient负载策略实现的原理LoadBalancerClient负载策略实现原理,以及整体负载过程实现的介绍。本章主要来具体实现怎样使用LoadBalancerClient实现负载均衡。
1.准备工作
a. 商品服务 作为被消费者服务(也就是被调用的服务),启动3个节点服务端口号为9091,9092,9093,用作负载均衡测试。
b. 订单服务 作为消费者服务(也就是调用者服务),启动一个服务,实现LoadBalanerClient负载均衡。
看下商品服务简单的代码:
主要是为了打印出服务端口号,方便测试负载功能。
订单服务
现在我们实现订单服务代码,通过LoadBalancerClient实现负载
1.指定服务,通过LoadBalancerClient自动获取服务中某一个实例。
@Autowired
LoadBalancerClient loadBalancedClient // 注入LoadBalancerClient
ServiceInstance instance = loadBalancedClient.choose("服务id"); // 获取服务中一个实例
- 获取实例信息,得到指定请求地址
String ippath = instance.getHost(); // 获取实例的ip
int port = instance.getPort(); // 获取实例的端口号
String url = String.format("http://$s:$s/product/getproductinfo",ippath,port"); // 格式化得到完整的请求地址
- 通过RestTemplate 请求远程服务地址
RestTemplate restenplate = new RestTemplate(); // 初始化RestTemplate 类
Map<String,Object> datamap =new HasHMap<>();
datamap = restenplate .getForObject(url,Map.class); // 访问远程地址,并接受返回值
完成代码如下:
以上就是我们的测试整套代码:
测试
- 访问链接http://订单服务ip:订单服务端口号/order/getproductinfo_loadbalanceclient(多次访问观察打印结果)
2. 分析打印结果
我访问了多次,打印结果如上图所示,访问策略为(9092->9093->9091)轮询。根据我们上篇文章所说的,LoadBalancerClient实现负载,默认负载策略为轮询的方式。
自定义负载均衡策略
方式一: properties使用配置形式(此处为springboot项目)
#自定义配置负载均衡策略
productserver.ribbon.NFLoadBalancerRuleClassName= com.netflix.loadbalancer.RandomRule
productserver 为需要负载的服务地址,com.netflix.loadbalancer.RandomRule为服务策略。此处我们配置为随机策略
再次查看访问结果:(随机访问)
方式二 config配置文件配置
- 启动类加上指定负载均衡策略
@RibbonClient(name = "productserver", configuration = RiddonRuleConfig_Productserver1.class)
// name指定服务地址,configuration 指定扫描的配置类地址
- 自定义配置文件类RiddonRuleConfig_Productserver
结果:(轮询策略)
自定义多个服务负载策略
如果业务中有需求,比如两种商品服务(product1,product2),订单服务在访问这两个服务的时候,需要按照不同的负载策略来,这要怎么实现呢?
其实实现方式跟上述一样,只不过需要有点改动。
方式一 properties使用配置形式.
#自定义配置负载均衡策略
productserver.ribbon.NFLoadBalancerRuleClassName= com.netflix.loadbalancer.RandomRule
product2server.ribbon.NFLoadBalancerRuleClassName= com.netflix.loadbalancer.RoundRobinRule
这里可以配置多个服务策略的,productserver为product1商品服务的服务地址,product2server为商品服务2的服务地址,后面跟着不同的策略。
方式二 config配置文件配置
与上面单个服务配置不同点,第一启动类上注解不同这里使用@RibbonClients,第二 加上@ComponentScan 屏蔽自动扫描注解 ,第三策略配置类中需要加上@ExcludeFromComponentScan(自定义注解)。
上面两个新来的玩意为了防止多个服务共享@RibbonClients配置的,具体也不太清楚。。。。
- @RibbonClients内容
@RibbonClients(value = {
@RibbonClient(name = "productserver",configuration = RiddonRuleConfig_Productserver1.class),
@RibbonClient(name = "product2server",configuration = RiddonRuleConfig_Productserver2.class)})
2.@ComponentScan 内容
@ComponentScan(excludeFilters= {@ComponentScan.Filter(type= FilterType.ANNOTATION,value=ExcludeFromComponentScan.class)})
3.策略配置类
4.自定义@ExcludeFromComponentScan注解
以上就这篇文章的全部内容。