简介

说明

本文介绍Spring Cloud LoadBalancer负载均衡的原理。

SpringCloud从2020版本开始移除了对Ribbon的依赖，官方使用Spring Cloud Loadbalancer正式替换Ribbon，而且Spring Cloud Loadbalancer成为了Spring Cloud负载均衡器的唯一实现。

本例使用的SpringCloud版本为：2020.0.1，SpringBoot版本为：2.4.13。

Loadbalancer提供的的负载均衡策略

RandomLoadBalancer - 随机策略
RoundRobinLoadBalancer - 轮询策略（默认）

粉丝福利：有很多粉丝私信问我有没有面试及PDF书籍等资料，我把它们进行了整理，包含：真实面试题汇总、简历模板、PDF书籍、PPT模板等。这些是我自己也在用的资料，面试题是面试官问到我的问题的整理，其他资料也是我自用的，真正实用、靠谱。资料可以从这里免费获取：资料地址

实例代码

本处的场景是：order（订单微服务）调用storage（库存微服务）扣减库存。

本处只列出核心代码：依赖和feign定义，其他略。

依赖

pom.xml


4.0.0org.springframework.bootspring-boot-starter-parent2.4.13 com.knifegateway0.0.1-SNAPSHOTgatewayDemo project for Spring Boot1.8org.springframework.cloudspring-cloud-dependencies2020.0.1pomimportcom.alibaba.cloudspring-cloud-alibaba-dependencies2021.1pomimportorg.springframework.bootspring-boot-starterorg.springframework.cloudspring-cloud-starter-gatewaycom.alibaba.cloudspring-cloud-starter-alibaba-nacos-discovery springframework.cloudspring-cloud-starter-netflix-ribbonorg.springframework.cloudspring-cloud-loadbalancerorg.projectlomboklombok1.18.24providedorg.springframework.bootspring-boot-maven-plugin2.4.13

feign接口

package com.knife.storage.api;import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;@FeignClient("storage")
public interface StorageFeignClient {@PostMapping("/feign/storage/decreaseStorage")void decreaseStorage(@RequestParam("productId") Long productId, @RequestParam("count") Integer count);
}

原理分析

打断点

在Feign接口上打断点

到达断点，多次点击“Step Into”（跳到方法内）（我点击了15次才进去）

FeignInvocationHandler#invoke

到达feign-core包里边的：feign.ReflectiveFeign.FeignInvocationHandler#invoke

执行到最后一行（点下图红色箭头所指按钮“Step Over”（跳过），一直到最后一行）

进入到invoke方法（如下图：先点击绿色箭头按钮，再点击红色箭头所指invoke方法）

SynchronousMethodHandler#invoke

上边点击之后，进入feign.SynchronousMethodHandler#invoke（feign-core包）。

进入到executeAndDecode方法：

SynchronousMethodHandler#executeAndDecode

上边点击之后，进入到feign.SynchronousMethodHandler#executeAndDecode（feign-core包）。

进入到client.execute方法内：

FeignBlockingLoadBalancerClient#execute

上一步点击完之后，进入org.springframework.cloud.openfeign.loadbalancer.FeignBlockingLoadBalancerClient#execute（spring-cloud-openfeign-core包）。

其中，loadBalancerClient.choose是核心，它里边会去找一个storage实例去调用。

同样的方法，也是跳到方法内部去。

BlockingLoadBalancerClient#choose（重点）

本方法是核心，先找到负载均衡策略，再按负载均衡策略挑选实例。

执行到此方法（spring-cloud-loadbalancer包）：

org.springframework.cloud.loadbalancer.blocking.client.BlockingLoadBalancerClient#choose(java.lang.String, org.springframework.cloud.client.loadbalancer.Request)