三、搭建springCloudAlibaba2021.1版本分布式微服务-springcloud loadbalancer负载均衡

什么是负责均衡

Spring Cloud LoadBalancer是一个客户端负载均衡器，类似于Ribbon，但是由于Ribbon已经进入维护模式，并且Ribbon 2并不与Ribbon 1相互兼容，所以Spring Cloud全家桶在Spring Cloud Commons项目中，添加了Spring cloud Loadbalancer作为新的负载均衡器，并且做了向前兼容，就算你的项目中继续用 Spring Cloud Netflix 套装（包括Ribbon，Eureka，Zuul，Hystrix等等）让你的项目中有这些依赖，你也可以通过简单的配置，把ribbon替换成Spring Cloud LoadBalancer。

ribbon与LoadBalance区别

SpringCloud原有的客户端负载均衡方案Ribbon已经被废弃，取而代之的是SpringCloud LoadBalancer。本文介绍SpringCloud LoadBalancer的搭建和测试验证过程。

1. ribbon和loadbalancer都是springcloud的负载均衡组件
2. ribbon是Netflix开源的基于HTTP和TCP等协议负载均衡组件，loadBalancer是SpringCloud自己写的，根据服务id获取负载均衡器rpc地址。
3. Ribbon的使用需要代码里手动调用目标服务，loadBalancer底层原理是默认调用ribbon的实现客户端负载均衡
4. Ribbon从2019年5月份后就不维护了，后期loadbalancer会成为主流，目前还是ribbon用的多。Loadbalancer支持ribbon。
5. ribbon 提供7中默认的负载均衡策略，常见的常见都有覆盖，一般我们都是使用 ZoneAvoidanceRule 复合判断server所在区域的性能和server的可用性选择server
6. ribbon 支持超时、懒加载处理、重试及其和 hystrix整合高级属性等
7. 目前spring-cloud-loadbalancer 仅支持 重试操作的配置

2021.x 注意事项

Spring cloud alibaba 的Nacos最新版中，有以下几个问题

1. nacos 2021 版本已经没有自带ribbon的整合，所以需要引入另一个支持的jar包 loadbalancer
2. nacos 2021 版本已经取消了对ribbon的支持，所以无法通过修改Ribbon负载均衡的模式来实现nacos提供的负载均衡模式

开始搭建

1、创建工程

首下创建一个名为 spring-cloud-alibaba-2021-loadbalancer 的工程，继承spring-cloud-alibaba-2021父项目

2、pom.xml 文件内容

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>spring-cloud-alibaba-2021</artifactId><groupId>org.example</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>spring-cloud-alibaba-2021-loadbalancer</artifactId><dependencies><!-- springweb 启动依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- nacos 服务注册发现（客户端）依赖 --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><!-- nacos-config 配置中心依赖 --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency><!--spring-cloud-dependencies 2020.0.0 版本不在默认加载bootstrap.yml 文件，如果需要加载bootstrap 文件需要手动添加依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bootstrap</artifactId></dependency><!--loadbalancer ，负载均衡，用来替代ribbon的组件 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency></dependencies>
</project>

3、application.yml

server:port: 7001
spring:# 后面的bean会覆盖前面相同名称的beanmain:allow-bean-definition-overriding: true

4、bootstrap.yml

spring:application:name: ribbon-demoprofiles:active: yexindong_activecloud:nacos:discovery:server-addr: chn520.cn:8848 # 服务注册中心地址namespace: public # 注册到nacos的名称空间，默认为publicconfig:prefix: yexindong_nacos_prefixfile-extension: yaml  # 指定yaml格式的配置, 必须要放到bootstrao.yml 才会生效，放到application下不会生效server-addr: chn520.cn:8848 #配置中心地址group: DEFAULT_GROUP

5、启动类 RibbonApp.java

package com.alibaba.cloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication
@EnableDiscoveryClient
public class RibbonApp {public static void main(String[] args) {SpringApplication.run(RibbonApp.class, args);}
}

6、控制层 RibbonController.java

package com.alibaba.cloud.controller;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;@RestController
@RequestMapping("/ribbon")
public class RibbonController {@Autowiredprivate RestTemplate restTemplate;/*** 远程调用订单服务的接口* @return*/@RequestMapping("/getRibbon")public String getRibbon(){// 以下2种方式都都可以调用远程服务String url  = "http://order-demo/order/getOrderById";
//        String url  = "http://localhost:8088/order/getOrderById";String res = restTemplate.getForObject(url, String.class);return "restTemplate 响应："+res;}
}

7、自定义负载均衡配置

SpringBeanConfiguration.java 内容如下

package com.alibaba.cloud.config;import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClients;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;/*** @program: my-town* @author: 洛天* @create: 2021-12-13 16:27**/
@Configuration
// 在这里配置我们自定义的LoadBalancer策略，注：这里的类为注入Bean的类，而非负载均衡的实现类
@LoadBalancerClients(defaultConfiguration = {NacosSameClusterConfiguration.class})
public class SpringBeanConfiguration {@Bean@LoadBalanced // 开启负载均衡，必须的public RestTemplate restTemplate(RestTemplateBuilder restTemplateBuilder){return restTemplateBuilder.build();}
}

NacosSameClusterConfiguration.java 调用负载均衡算法，选取其中的一个节点

package com.alibaba.cloud.config;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.Environment;//这里不用写Configuration
public class NacosSameClusterConfiguration{@BeanReactorLoadBalancer<ServiceInstance> randomLoadBalancer(Environment environment,LoadBalancerClientFactory loadBalancerClientFactory) {// 获取远程调用的服务名称String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);// 返回内容为自定义负载均衡的配置类return new NacosSameClusterWeightedRule(loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class),name);}
}

NacosSameClusterWeightedRule.java 自定义负载均衡的实现类

package com.alibaba.cloud.config;import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.DefaultResponse;
import org.springframework.cloud.client.loadbalancer.EmptyResponse;
import org.springframework.cloud.client.loadbalancer.Request;
import org.springframework.cloud.client.loadbalancer.Response;
import org.springframework.cloud.loadbalancer.core.NoopServiceInstanceListSupplier;
import org.springframework.cloud.loadbalancer.core.ReactorServiceInstanceLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
import reactor.core.publisher.Mono;import javax.annotation.Resource;
import java.util.List;
import java.util.Random;// 自定义负载均衡实现需要实现 ReactorServiceInstanceLoadBalancer 接口 以及重写choose方法
public class NacosSameClusterWeightedRule implements ReactorServiceInstanceLoadBalancer {// 注入当前服务的nacos的配置信息@Resourceprivate NacosDiscoveryProperties nacosDiscoveryProperties;// loadbalancer 提供的访问当前服务的名称final String serviceId;// loadbalancer 提供的访问的服务列表ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider;public NacosSameClusterWeightedRule(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider, String serviceId) {this.serviceId = serviceId;this.serviceInstanceListSupplierProvider = serviceInstanceListSupplierProvider;}/*** 服务器调用负载均衡时调的放啊* 此处代码内容与 RandomLoadBalancer 一致*/@Overridepublic Mono<Response<ServiceInstance>> choose(Request request) {ServiceInstanceListSupplier supplier = this.serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new);Mono<Response<ServiceInstance>> map1 = supplier.get(request).next().map((list) -> {Response<ServiceInstance> serviceInstanceResponse = this.getInstanceResponse(list);;return serviceInstanceResponse;});return map1;}/*** 对负载均衡的服务进行筛选的方法* 自定义* 此处的 instances 实例列表  只会提供健康的实例  所以不需要担心如果实例无法访问的情况*/private Response<ServiceInstance> getInstanceResponse(List<ServiceInstance> instances) {if (instances.isEmpty()) {return new EmptyResponse();}// 获取当前服务所在的集群名称
//        String currentClusterName = nacosDiscoveryProperties.getClusterName();// 过滤在同一集群下注册的服务 根据集群名称筛选的集合
//        List<ServiceInstance> sameClusterNameInstList  = instances.stream().filter(i-> StringUtils.equals(i.getMetadata().get("nacos.cluster"),currentClusterName)).collect(Collectors.toList());
//        ServiceInstance sameClusterNameInst;
//        if (sameClusterNameInstList.isEmpty()) {
//            // 如果为空，则根据权重直接过滤所有服务列表
//            sameClusterNameInst = getHostByRandomWeight(instances);
//        } else {
//            // 如果不为空，则根据权重直接过滤所在集群下的服务列表
//            sameClusterNameInst = getHostByRandomWeight(sameClusterNameInstList);
//        }// 随机选择一个节点int size = instances.size();int index = new Random().nextInt(size);  // 如果size为2，生成 0-1之间的随机数；如果为10，生成0-9之间的随机数System.out.println("生成的随机数为：" + index);ServiceInstance serviceInstance = instances.get(index);return new DefaultResponse(serviceInstance);}
}

8、父工程加入 module

在 父项目（spring-cloud-alibaba-2021）加入以下内容

    <modules><module>spring-cloud-alibaba-2021-loadbalancer</module></modules>

9、搭建完成

此时工程目录如下图

测试

在浏览器输入http://127.0.0.1:7001/ribbon/getRibbon后回车，显示以下内容，表示测试成功