Ribbon详解与实例
Ribbon是⼀个为客户端提供负载均衡功能的服务，它内部提供了⼀个叫做ILoadBalance的接⼝代表负载均衡器的操作，⽐如有添加服务器操作、选择服务器操作、获取所有的服务器列表、获取可⽤的服务器列表等等。
需要解决的问题：
①如何在配置Eureka Client注册中⼼时不去硬编码Eureka Server的地址？
②在微服务不同模块间进⾏通信时，如何不去硬编码服务提供者的地址？
③当部署多个相同微服务时，如何实现请求时的负载均衡？
Ribbon是什么？
Ribbon是Netflix发布的云中间层服务开源项⽬，其主要功能是提供客户端实现负载均衡算法。Ribbon客户端组件提供⼀系列完善的配置项如连接超时，重试等。简单的
说，Ribbon是⼀个客户端负载均衡器，我们可以在配置⽂件中Load Balancer后⾯的所有机器，Ribbon会
⾃动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器，我们也很容易使⽤Ribbon实现⾃定义的负载均衡算法。
下图展⽰了Eureka使⽤Ribbon时的⼤致架构：
SpringCloud之Ribbon⼊门案例
①⾸先引⼊Ribbon依赖，Ribbon的使⽤依赖Eureka：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>
②如何使⽤Ribbon
使⽤RestTemplate进⾏Eureka Client(包括服务提供者以及服务消费者，在这⾥其实是服务消费者使⽤RestTemplate)之间的通信，为RestTemplate配置类添加
@LoadBalanced注解即可，如下所⽰：
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
return new RestTemplate();
}
主程序：
@SpringBootApplication
@EnableEurekaClient
//在启动该微服务的时候就能去加载我们的⾃定义Ribbon配置类，从⽽使配置⽣效
@RibbonClient(name="MICROSERVICECLOUD-DEPT")
public class DeptConsumer80_App{
public static void main(String[] args){
SpringApplication.run(DeptConsumer80_App.class, args);
}
}
③如何解决硬编码
使⽤添加@LoadBalanced注解后的RestTemplate调⽤服务提供者的接⼝时，可以使⽤虚拟IP替代真实IP地址。所谓的虚拟IP就是服务提供者在application.properties或yml⽂件中配置的spring.application.name属性的值。⽰例如下：
以前：
@RestController
public class DeptController_Consumer
{
private static final String REST_URL_PREFIX = "localhost:8001"; //需要ip+端⼝
@Autowired
private RestTemplate restTemplate;
@RequestMapping(value = "/consumer/dept/add")
public boolean add(Dept dept)
{
return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
}
}
使⽤Ribbon后：
@RestController
public class DeptController_Consumer
{
private static final String REST_URL_PREFIX = "MICROSERVICECLOUD-DEPT"; //微服务的虚拟id
@Autowired
private RestTemplate restTemplate;
@RequestMapping(value = "/consumer/dept/add")
reactorloadbalancerpublic boolean add(Dept dept)
{
return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
}
}
⼩总结：Ribbon和Eureka整合后Consumer可以直接调⽤服务⽽不⽤再关⼼ip地址和端⼝号
微服务（服务提供者）集搭建：
机器1
server:
port: 8001
spring:
application:
name: microservicecloud-dept
datasource:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: sql.Driver
url: jdbc:mysql://localhost:3306/cloudDB01
username: root
password: 123456
机器2
server:
port: 8002
spring:
application:
name: microservicecloud-dept
datasource:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: sql.Driver
url: jdbc:mysql://localhost:3306/cloudDB02
username: root
password: 123456
机器3
server:
port: 8003
spring:
application:
name: microservicecloud-dept
datasource:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: sql.Driver
url: jdbc:mysql://localhost:3306/cloudDB03
username: root
password: 123456
其中{Spring.application.name}都是⼀样的，不可以变。
Ribbon组件IRule
默认的是RoundBobinRule（轮询）
RetryRule
1、先按照RoundRobinRule(轮询)的策略获取服务，如果获取的服务失败侧在指定的时间会进⾏重试，进⾏获取可⽤的服务
2、如多次获取某个服务失败，这不会再再次获取该服务如(⾼德地图上某条道路堵车，司机不会⾛那条道路)=
使⽤：
@Configuration
public class ConfigBean //boot -->spring  l --- @Configuration配置  ConfigBean = l
{
@Bean
@LoadBalanced
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
@Bean
public IRule myRule(){
//return new RoundRobinRule();
//return new RandomRule();//达到的⽬的，⽤我们重新选择的随机算法替代默认的轮询。
return new RetryRule();  //在这⾥选择负载均衡算法
}
}
⾃定义负载均衡算法：
所谓的⾃定义Ribbon Client的主要作⽤就是使⽤⾃定义配置替代Ribbon默认的负载均衡策略，注意：⾃定义的Ribbon Client是有针对性的，⼀般⼀个⾃定义的Ribbon Client 是对⼀个服务提供者(包括服务名相同的⼀系列副本)⽽⾔的。⾃定义了⼀个Ribbon Client 它所设定的负载均衡策略只对某⼀特定服务名的服务提供者有效，但不能影响服务消费者与别的服务提供者通信所使⽤的策略。根据官⽅⽂档的意思，
推荐在 springboot 主程序扫描的包范围之外进⾏⾃定义配置类。其实纯代码⾃定义RibbonClient的话有两种⽅式：
⽅式⼀：在springboot主程序扫描的包外定义配置类，然后为springboot主程序添加 @RibbonClient 注解引⼊配置类。
配置类不应该在SpringBoot的包路径下，通过@RibbonClient 注解加载：
@Configuration
public class MySelfRule
{
@Bean
public IRule myRule()
{
return new RandomRule_ZY();  // 我⾃定义为每台机器5次，5次之后在轮询到下⼀个
}
}
springboot主程序：
@SpringBootApplication
@EnableEurekaClient
//在启动该微服务的时候就能去加载我们的⾃定义Ribbon配置类，从⽽使配置⽣效
@RibbonClient(name="MICROSERVICECLOUD-DEPT",configuration=MySelfRule.class)
public class DeptConsumer80_App
{
public static void main(String[] args)
{
SpringApplication.run(DeptConsumer80_App.class, args);
}
}
⾃定义LoadBalance：
public class RandomRule_ZY extends AbstractLoadBalancerRule{
// total = 0 // 当total==5以后，我们指针才能往下⾛，
// index = 0 // 当前对外提供服务的服务器地址，
// total需要重新置为零，但是已经达到过⼀个5次，我们的index = 1
// 分析：我们5次，但是微服务只有8001 8002 8003 三台，OK？
private int total = 0;        // 总共被调⽤的次数，⽬前要求每台被调⽤5次
private int currentIndex = 0;        // 当前提供服务的机器号
public Server choose(ILoadBalancer lb, Object key){
if (lb == null) {
return null;
}
Server server = null;
while (server == null) {
if (Thread.interrupted()) {
return null;
}
List<Server> upList = lb.getReachableServers();  //激活可⽤的服务
List<Server> allList = lb.getAllServers();  //所有的服务
int serverCount = allList.size();
if (serverCount == 0) {
return null;
}
if(total < 5){
server = (currentIndex);
total++;
}else {
total = 0;
currentIndex++;
if(currentIndex >= upList.size()){
currentIndex = 0;
}
}
if (server == null) {
Thread.yield();
continue;
}
if (server.isAlive()) {
return (server);
}
// Shouldn't actually happen.. but must be transient or a bug.
server = null;
Thread.yield();
}
return server;
}
@Override
public Server choose(Object key){
return choose(getLoadBalancer(), key);
}
@Override
public void initWithNiwsConfig(IClientConfig clientConfig){
}
}

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。