跳到主要内容

微服务中的LoadBalancer策略增强

本章节是讲解如何对原有的微服务中负载均衡的逻辑进行定制化增强，这里的逻辑有点难度，涉及到了对源码的修改，但本人会以最容易理解的方式来讲解，请放心食用。

负载均衡的功能简单介绍下，比如请求中的逻辑要A服务 调用 B服务，由于此业务并发比较高。为了缓解B服务的压力，B服务就会有多台服务实例，来缓解单个实例的压力，比如有B1、B2、B3。

而A服务调用B服务时，就会将压力分担到这三个实例上，最常见的调用方式就是轮询策略，比如 此业务有3个请求，那么A服务来调用B服务时，被调用的实例依次就是B1、B2、B3。除了除轮询策略，还有随机策略、权重策略等。而这些策略就是所谓的负载均衡了。

而在 SpringBoot 2.6之后，负载均衡的实现从 Ribbon 变成 LoadBalancer，link-flow 的SpringBoot版本为3.3.0，所以就是 LoadBalancer。

关于 LoadBalancer 负载均衡的详细原理分析，并不要求掌握，因为真的有难度，能把 link-flow 能掌握就已经可以了，但如果确实想了解的话，请跳转到 Spirng-Cloud-LoadBlancer源码分析 系列章节。

而 link-flow 要做的就是将满足路由条件的服务实例留下，剩下的服务实例再负载均衡。

比如说请求调用规则 路由参数 version=2，意思是只能调用版本是2的服务实例。假设B1版本是1、B2版本是2、B3版本是2。那么link-flow就会将B1过滤掉，留下B2和B3，接着再从B2和B3中执行负载均衡。 所以我们要在原有的 SpringCloud 逻辑中，添加 link-flow 的功能。

LoadBalancer负载均衡配置​

原有的负载均衡配置

@Configuration(proxyBeanMethods = false)
@ConditionalOnDiscoveryEnabled
public class LoadBalancerClientConfiguration {

	private static final int REACTIVE_SERVICE_INSTANCE_SUPPLIER_ORDER = 193827465;

	@Bean
	@ConditionalOnMissingBean
	public ReactorLoadBalancer<ServiceInstance> reactorServiceInstanceLoadBalancer(Environment environment,
			LoadBalancerClientFactory loadBalancerClientFactory) {
		String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
		return new RoundRobinLoadBalancer(
				loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class), name);
	}

	@Configuration(proxyBeanMethods = false)
	@ConditionalOnReactiveDiscoveryEnabled
	@Order(REACTIVE_SERVICE_INSTANCE_SUPPLIER_ORDER)
	public static class ReactiveSupportConfiguration {

		@Bean
		@ConditionalOnBean(ReactiveDiscoveryClient.class)
		@ConditionalOnMissingBean
		@Conditional(DefaultConfigurationCondition.class)
		public ServiceInstanceListSupplier discoveryClientServiceInstanceListSupplier(
				ConfigurableApplicationContext context) {
			return ServiceInstanceListSupplier.builder().withDiscoveryClient().withCaching().build(context);
		}

		@Bean
		@ConditionalOnBean(ReactiveDiscoveryClient.class)
		@ConditionalOnMissingBean
		@Conditional(ZonePreferenceConfigurationCondition.class)
		public ServiceInstanceListSupplier zonePreferenceDiscoveryClientServiceInstanceListSupplier(
				ConfigurableApplicationContext context) {
			return ServiceInstanceListSupplier.builder().withDiscoveryClient().withCaching().withZonePreference()
					.build(context);
		}

		@Bean
		@ConditionalOnBean(LoadBalancerClientFactory.class)
		@ConditionalOnMissingBean
		public XForwardedHeadersTransformer xForwarderHeadersTransformer(LoadBalancerClientFactory clientFactory) {
			return new XForwardedHeadersTransformer(clientFactory);
		}

    }
    //省略... ...
}

别担心，并不要求清楚这里都是干嘛的，只是让你知道一下 LoadBalancer 的配置是在这里的，而要做的功能就是把这里的配置替换掉，换成 link-flow 的

那么应该怎样能替换成功呢？仔细看每个bean上面都有个这个注解 @ConditionalOnMissingBean

关于此注解的详细讲解，请跳转到 技术精华精讲-@ConditionalOnMissingBean的作用 章节

依然这些bean的生成都有 @ConditionalOnMissingBean 注解，那就说明是可以被替换的，那就替换成 link-flow 的呗，替换也简单，就是要保证 link-flow中的bean加载时机要比这些原有bean的加载时机要早！

这里要用到 @AutoConfigureBefore 注解，关于此注解的详细讲解，请跳转到 技术精华精讲-@AutoConfigureBefore的作用 章节。

付费内容提示

该文档的全部内容仅对「码力全开」项目实战&技术讲解 知识星球用户开放

加入星球，一次获得完整项目资料、全栈技术知识库和长期答疑服务。

100万+字全栈技术知识库深入讲解技术核心、数据库、中间件和分布式等内容
8套热门的实战项目持续更新的企业级项目覆盖高并发、微服务、数据中台 和 AI Agent 等方向
AI 技术知识大模型面试详解覆盖 AI 模型原理、Agent、RAG、MCP、Skills、Harness 等核心知识点
文档 + 视频两种讲解形式既能系统阅读，也能跟随视频理解核心业务

完整项目实战资料

每套项目均包含从 0 到 1 讲解文档核心业务讲解视频

从基础项目到复杂业务场景，项目资料会持续更新。

8 套项目
  • 01Nexus Agent AI 智能体
  • 02Nexus Agent Pro 完全版
  • 03黑马点评Plus
  • 04大麦
  • 05大麦Pro
  • 06大麦AI
  • 07流量切换
  • 08数据中台

加入后还能获得

进入星球后，即可享受上述所有服务，保证不会再有其他隐藏费用。

从学习、面试到项目启动，都可以继续获得支持。

  • 1 对 1 解答项目和技术问题都可以提问
  • 针对性补充没有讲清楚的内容会继续补充
  • 面试与简历指导梳理回答技巧和项目亮点
  • 中间件云环境项目依赖可以直接接入使用
  • 面试后复盘被问住的问题可以继续交流
  • 远程问题解决项目启动问题可协助排查
知识星球二维码

扫码进入知识星球

  1. 打开微信，扫描左侧二维码，加入「码力全开」项目实战&技术讲解 知识星球
  2. 查看星球使用指导，获取完整项目讲解资料索引
解锁全部付费内容
🎁优惠