SpringCloud之LoadBalancer负载均衡服务调用过程
前言
LoadBalancer是Ribbon的未来替换方案
一、LoadBalancer是什么?
LB负载均衡(Load Balance)是什么
- 简单的说就是将用户的请求平摊的分配到多个服务上,从而达到系统的HA(高可用)
- 常见的负载均衡有软件Nginx,LVS,硬件 F5等
spring-cloud-starter-loadbalancer组件是什么
- Spring Cloud LoadBalancer是由SpringCloud官方提供的一个开源的、简单易用的客户端负载均衡器,它包含在SpringCloud-commons中用它来替换了以前的Ribbon组件。
- 相比较于Ribbon,SpringCloud LoadBalancer不仅能够支持RestTemplate,还支持WebClient(WeClient是Spring Web Flux中提供的功能,可以实现响应式异步请求)
官网:http://docs.spring.io/spring-cloud-commons/reference/spring-cloud-commons/loadbalancer.html
客户端负载和服务端负载区别:
- Nginx是服务器负载均衡,客户端所有请求都会交给nginx,然后由nginx实现转发请求,即负载均衡是由服务端实现的。
- loadbalancer本地负载均衡,在调用微服务接口时候,会在注册中心上获取注册信息服务列表之后缓存到JVM本地,从而在本地实现RPC远程服务调用技术。
二、使用步骤
1、启动consul
详见:SpringCloud--consul服务注册与发现、配置管理、配置持久化
2、客户端加入依赖
<!--loadbalancer-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>3、以服务名称调用
public static final String PaymentSrv_URL = "http://cloud-payment-service";//服务注册中心上的微服务名称
@GetMapping(value = "/consumer/pay/get/info")
private String getInfoByConsul(){
return restTemplate.getForObject(PaymentSrv_URL + "/pay/get/info", String.class);
}用restTemplate调用服务时,使用服务名称调用后,在consul中注册相同服务名称的的服务会通过loadbalancer实现负载均衡,使得每个相同服务名称的服务被访问的次数平均。
三、负载均衡算法替换
1、 默认算法轮询(相同服务名下的所有服务枚举调用)
- restTemplate配置:
@Configuration
public class RestTemplateConfig {
@Bean
@LoadBalanced //按服务名称调用时默认负载均衡 要加上该注解支持负载均衡
public RestTemplate restTemplate(){
return new RestTemplate();
}
}2、替换随机算法(相同服务名下的所有服务随机调用)
- restTemplate配置:
@Configuration
@LoadBalancerClient(
//下面的value值大小写一定要和consul里面的名字一样,必须一样
value = "cloud-payment-service",configuration = RestTemplateConfig.class)
public class RestTemplateConfig
{
@Bean
@LoadBalanced //使用@LoadBalanced注解赋予RestTemplate负载均衡的能力
public RestTemplate restTemplate(){
return new RestTemplate();
}
@Bean
ReactorLoadBalancer<ServiceInstance> randomLoadBalancer(Environment environment,
LoadBalancerClientFactory loadBalancerClientFactory) {
String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
return new RandomLoadBalancer(loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class), name);
}
}总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
相关文章
SpringBoot整合Spring Data Elasticsearch的过程详解
这篇文章主要介绍了SpringBoot整合Spring Data Elasticsearch的过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-09-09
Java Stream 流中 Collectors.toMap 的用法详解
这篇文章主要介绍了Stream 流中 Collectors.toMap 的用法,Collectors.toMap()方法是把List转Map的操作,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2024-01-01
SpringBoot+Mybatis-plus实现分页查询的示例代码
本文主要介绍了SpringBoot+Mybatis-plus实现分页查询的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2025-02-02
knife4j3.0.3整合gateway和注册中心的详细过程
这篇文章主要介绍了knife4j3.0.3整合gateway和注册中心的详细过程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2023-03-03


最新评论