乐趣区

关于java:Ribbon负载均衡

jiezi

上一段代码中应用了简略的消费者 - 服务者模式提供了最简略的微服务，应用 Nacos 做服务注册核心。Ribbon 是带负载平衡的 Http 客户端。

有两种办法实现：

办法一

@EnableDiscoveryClient
@SpringBootApplication
public class NacosDiscoveryConsumerApplication {public static void main(String[] args) {SpringApplication.run(NacosDiscoveryConsumerApplication.class, args);
    }

    @Bean
    public RestTemplate restTemplate(){return new RestTemplate();
    }
}
@RestController
public class HelloController {
    @Autowired
    RestTemplate restTemplate;
    @Autowired
    LoadBalancerClient loadBalancerClient;

    @GetMapping("/hello")
    public String HelloClient(String name){ServiceInstance serviceInstance = loadBalancerClient.choose("nacos-discovery-provider");
        URI uri = serviceInstance.getUri();
        return restTemplate.getForObject(uri + "hello?name=" + name, String.class);
    }
}

LoadBalancerClient类的 choose 负责查找适合的服务 ip。

办法二

@EnableDiscoveryClient
@SpringBootApplication
public class NacosDiscoveryConsumerApplication {public static void main(String[] args) {SpringApplication.run(NacosDiscoveryConsumerApplication.class, args);
    }

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){return new RestTemplate();
    }
}
@RestController
public class HelloController {
    @Autowired
    RestTemplate restTemplate;

    @GetMapping("/hello")
    public String HelloClient(String name){return restTemplate.getForObject("http://nacos-discovery-provider/hello?name=" + name, String.class);
    }
}

在注入 RestTemplateBean 时，同时增加@LoadBalanced 注解，那么调用 getForObject 时就能有负载平衡的性能。

启动两个服务者；

一个是 8086 端口，一个是 8085 端口，而后调用消费者，能够看到轮询调用两个服务者：

如何替换负载平衡策略

Ribbon 提供 7 种负载平衡策略能够抉择：

  • RandomRule

    • 随机策略
    • 随机抉择 server

  • RoundRobinRule

    • 轮询策略
    • 依照程序抉择 server

  • RetryRule

    • 重试策略
    • 在一个配置时间段内，当抉择 server 不胜利，则始终尝试抉择一个可用的 server

  • BestAvailableRule

    • 最低并发策略
    • 一一考查 server，如果 server 断路器关上，则疏忽，再抉择其中并发链接最低的 server

  • AvailabilityFilteringRule

    • 可用过滤策略
    • 过滤掉始终失败并被标记为 circuit tripped 的 server，过滤掉那些高并发链接的 server（active connections 超过配置的阈值）

  • ResponseTimeWeightedRule

    • 响应工夫加权重策略
    • 依据 server 的响应工夫调配权重，响应工夫越长，权重越低，被抉择到的概率也就越低。响应工夫越短，权重越高，被选中的概率越高，这个策略很贴切，综合了各种因素，比方：网络，磁盘，io 等，都间接影响响应工夫

  • ZoneAvoidanceRule

    • 区域权重策略
    • 综合判断 server 所在区域的性能，和 server 的可用性，轮询抉择 server 并且判断一个 AWS Zone 的运行性能是否可用，剔除不可用的 Zone 中的所有 server

Ribbon 默认的负载平衡策略是 ZoneAvoidanceRule，如果没有查看到 Zone，那么理论应用的是 RoundRobinRule。

如何能更换负载平衡策略呢？

注入一个实现 IRule 的 bean 即可

@Configuration
public class NacosRule {

    @Bean
    public IRule iRule(){return new NacosWeightRandomRule();
    }
}

下面的 NacosWeightRandomRule 是本人实现 Nacos 权重负载平衡的策略，通过下面的配置能够批改 Ribbon 的负载平衡策略。

如果把下面的类放在 @SpringBootApplication 所在的包或子包下，那么所有的微服务近程拜访都是用此负载平衡策略。

如果只想把此负载平衡策略应用在某个微服务的申请上如何做呢？

把下面的类放在放在 @SpringBootApplication 所在的包或子包外；

而后在启动类上增加以下注解：

@RibbonClient(name = "nacos-discovery-provider", configuration = NacosRule.class)
  • name，须要应用负载平衡策略的微服务名
  • configuration，负载平衡策略类
退出移动版