SpringCloud（10）：LoadBalance：负载均衡介绍

以你之姓@ 2023-01-10 13:29 139阅读 0赞

### 一、什么是负载均衡？ ###

互联网早期，业务流量比较小并且业务逻辑比较简单，单台服务器便可以满足基本的需求；但随着互联网的发展，业务流量越来越大并且业务逻辑也越来越复杂，单台机器的性能问题以及单点问题凸显了出来，因此需要多台机器来进行性能的水平扩展以及避免单点故障。但是要如何将不同的用户的流量分发到不同的服务器上面呢？  
![58dac417dd38a601b319525047a21da4.png][]

早期的方法是使用DNS做负载，通过给客户端解析不同的IP地址，让客户端的流量直接到达各个服务器。但是这种方法有一个很大的缺点就是延时性问题，在做出调度策略改变以后，由于DNS各级节点的缓存并不会及时的在客户端生效，而且DNS负载的调度策略比较简单，无法满足业务需求，因此就出现了负载均衡。

![load\_balancer][load_balancer]

### 二、Ribbon是什么？ ###

Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将NetFlix的中间层服务连接在一起。Ribbon的客户端组件提供一系列完整的配置项如：连接超时、重试等等。就是在配置文件中列出LoadBalancer（简称LB：负载均衡）后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等等）去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。

SpringCloud在2020.0.0版本中移除了Ribbon。提供了自己的客户端负载平衡器抽象和实现。对于负载平衡机制，已经添加了reactiveladbalancer接口，并为其提供了基于轮询和随机的实现。为了从响应式ServiceInstanceListSupplier中选择实例，我们使用了ServiceInstanceListSupplier。目前，我们支持基于服务发现的ServiceInstanceListSupplier实现，该实现使用类路径中可用的发现客户端从服务发现中检索可用实例。

官方说明文档：[https://docs.spring.io/spring-cloud-commons/docs/current/reference/html/\#custom-loadbalancer-configuration][https_docs.spring.io_spring-cloud-commons_docs_current_reference_html_custom-loadbalancer-configuration]

### 三、负载均衡方式 ###

*  LB，即负载均衡（Load Balance），在微服务或分布式集群中经常用的一种应用。
 *  负载均衡就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA（高可用）。
 *  常见的负载均衡软件有Nginx，Lvs等等。
 *  dubbo、SpringCloud中均给我们提供了负载均衡，SpringCloud的负载均衡算法可以自定义。

负载均衡简单分类：

*  集中式LB：即在服务的消费方和提供方之间使用独立的LB设施，如Nginx（反向代理服务器），由该设施负责把访问请求通过某种策略转发至服务的提供方。
 *  进程式LB：将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选出一个合适的服务器。

Ribbon属于进程式LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址。

### 四、在项目中添加负载均衡 ###

（1）在客户端模块中添加依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
                <version>3.0.0</version>
            </dependency>

（2）编写Eureka配置

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70][]

package com.buba.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient // Eureka客户端启动类
    public class DeptConsumer_80 {
        public static void main(String[] args) {
            SpringApplication.run(DeptConsumer_80.class, args);
        }
    }

（3）配置负载均衡到RestTemplate

package com.buba.springcloud.config;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    /**
     * @Configuration 相当于applicationContext.xml
     */
    @Configuration
    public class ConfigBean {
    
        /**
         * @LoadBalanced 配置负载均衡到RestTemplate
         * 把RestTemplate对象交给Spring管理
         * @return
         */
        @Bean
        @LoadBalanced
        public RestTemplate getRestTemplate(){
            return new RestTemplate();
        }
    }

（4）修改DeptConsumerController类

package com.buba.springcloud.controller;
    
    import com.buba.springcloud.pojo.Dept;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import java.util.List;
    
    @RestController
    public class DeptConsumerController {
    
        // 消费者不应该有Service层，使用RestTemplate调用Service。RestTemplate封装了多种访问Http请求的类。
        private RestTemplate restTemplate;
    
        // Ribbon,这里的地址应该是个变量。我们应该通过Eureka中的服务名访问
        // private static final String REST_URL_PREFIX = "http://localhost:8001";
        private static final String REST_URL_PREFIX = "http://SPRINGCLOUD-PROVIDER-DEPT";
    
        /** 以下省略 **/
    }

（5）启动测试

开启3个Eureka集群、服务提供者和消费者。访问[http://localhost/consumer/dept/list][http_localhost_consumer_dept_list]

![20210125163433844.png][]

可以看到直接使用服务名访问服务。

[58dac417dd38a601b319525047a21da4.png]: /images/20221119/27bd8e222eb84710adb9edf9beed3fa7.png
[load_balancer]: /images/20221119/6b09b94338f74cc089dae0ca92b6bc91.png
[https_docs.spring.io_spring-cloud-commons_docs_current_reference_html_custom-loadbalancer-configuration]: https://docs.spring.io/spring-cloud-commons/docs/current/reference/html/#custom-loadbalancer-configuration
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70]: /images/20221119/d0e81ada7da844f08e432c7e483bbe26.png
[http_localhost_consumer_dept_list]: http://localhost/consumer/dept/list
[20210125163433844.png]: /images/20221119/ff261dff9b0f4df4b52e44ee4847dbb4.png