关于java:Ribbon负载均衡

37次阅读

共计 2451 个字符,预计需要花费 7 分钟才能阅读完成。

上一段代码中应用了简略的消费者 - 服务者模式提供了最简略的微服务,应用 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,负载平衡策略类

正文完
 0