服务路由：解密 Spring Cloud LoadBalancer 实例缓存与选择器原理

在 Spring Cloud 2020.0.0 版本之后，经典的 Netflix Ribbon 负载均衡组件被彻底从官方生态中移除，取而代之的是全新的、基于响应式编程设计的 **Spring Cloud LoadBalancer**。

为了避免每一次 RPC 声明式调用（如 OpenFeign）都向注册中心（如 Nacos/Consul）发起昂贵的 HTTP 网络拉取以获取实例列表，Spring Cloud LoadBalancer 内部实现了一套高效的**动态服务实例本地缓存机制**。

本文将系统拆解 Spring Cloud LoadBalancer 本地实例缓存的刷新时机、基于 Reactor 响应式的 ServiceInstanceListSupplier 数据管道流转、以及内置选择器（如轮询/随机）的并发安全选择算法。

一、 二代对比：Ribbon 与 Spring Cloud LoadBalancer 架构演进

相较于 Ribbon 的阻塞模型，Spring Cloud LoadBalancer 在响应式编程与缓存管理上做出了显著升级：

二、 负载均衡执行管线与本地缓存刷新拓扑

当一个声明式 Feign 客户端向“订单服务”发起请求时，其内部负载均衡过滤与选择拓扑如下：

      [ 业务发起 Feign RPC 请求 (如 /api/v1/orders) ]
                            │
                            ▼ 1. 拦截并包装为响应式 Request
        [ ReactorLoadBalancerExchangeFilterFunction ]
                            │
                            ▼ 2. 调度执行 choose() 决策方法
           [ 核心实现: RoundRobinLoadBalancer ]
                            │
                            ▼ 3. 向数据供应器请求实例列表
       [ CachingServiceInstanceListSupplier (缓存装饰器) ]
                            │
            ┌───────────────┴───────────────┐
         (命中)                             (失效/未命中)
            ▼                               ▼
     [ Caffeine 本地内存缓存 ]        [ DiscoveryClientServiceInstanceListSupplier ]
            │                               │
            │                               ▼ 4. 发起网络调用拉取最新实例
            │                        [ Nacos / Consul 注册中心 ]
            │                               │
            │ ◄────── 5. 同步回写缓存 ───────┘
            ▼
     [ 6. 获得存活实例集合 (Flux<List<ServiceInstance>>) ]
            │
            ▼ 7. 执行原子 CAS (Compare And Swap) 轮询计数选择器
     [ 8. 返回选定的单一 ServiceInstance ] ──> 9. 拼装 IP/Port 发起真实网络 HTTP 调用

三、 代码实战：声明式注入自定义负载均衡配置

以下代码展示了如何通过显式配置类，在 Spring Cloud 项目中为特定的微服务配置指定为**随机选择负载均衡器**以替代默认的轮询器：

1. 编写自定义 LoadBalancer 配置类

package com.company.infra.loadbalancer.config;

import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.loadbalancer.core.*;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.annotation.*;
import org.springframework.core.env.Environment;

@Configuration
public class CustomLoadBalancerConfiguration {

    /**
     * 替换默认的轮询算法，注入随机负载均衡器（RandomLoadBalancer）
     */
    @Bean
    public ReactorLoadBalancer<ServiceInstance> randomLoadBalancer(
            Environment environment,
            LoadBalancerClientFactory loadBalancerClientFactory) {
        
        String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
        
        // 获得对应的服务实例数据提供器
        return new RandomLoadBalancer(
            loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class),
            name
        );
    }
}

2. 绑定在特定 Feign 客户端

package com.company.infra.feign.client;

import com.company.infra.loadbalancer.config.CustomLoadBalancerConfiguration;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClient;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.*;

@FeignClient(name = "inventory-service")
// 将随机算法强绑定到“库存微服务”的负载调用链中
@LoadBalancerClient(name = "inventory-service", configuration = CustomLoadBalancerConfiguration.class)
public interface InventoryApiClient {

    @GetMapping("/api/v1/stock/{sku}")
    int getStockLevel(@PathVariable("sku") String sku);
}

四、 总结

Spring Cloud LoadBalancer 的 Caffeine 本地缓存与 Reactor 响应式过滤管道，是高并发客户端负载均衡的“算力底座”。

它通过**基于 CachingServiceInstanceListSupplier 的物理缓存装饰，有效规避了高频服务请求直查注册中心造成的 IO 拥堵；并采用并发安全的 CAS 计数器保障了多线程选择算法的零阻塞锁争抢**。掌握这套 LoadBalancer 数据管道控制与自定义选择器装配，是进行分布式系统吞吐率调优、设计异地多活和路由灰度控制的基本功！