Spring Cloud 负载均衡实战：LoadBalancer 原理与策略

启动多个 product-service 实例后，观察日志即可发现请求被自动分发到了不同端口上，实现了流量的均衡。

策略配置

负载均衡策略决定了请求分发的逻辑。Spring Cloud LoadBalancer 默认提供两种策略：轮询（Round Robin）和随机（Random）。

自定义随机策略

虽然默认是轮询，但有时我们需要随机选择。可以通过定义一个 ReactorLoadBalancer Bean 来实现。

public class LoadBalancerConfig {
    @Bean
    ReactorLoadBalancer<ServiceInstance> randomLoadBalancer(
            Environment environment,
            LoadBalancerClientFactory loadBalancerClientFactory) {
        String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
        System.out.println("==============" + name);
        return new RandomLoadBalancer(
                loadBalancerClientFactory.getLazyProvider(name, ServiceInstanceListSupplier.class), 
                name);
    }
}

注意：该类不需要 @Configuration 注解，但必须在组件扫描范围内。

接着，在配置类上使用 @LoadBalancerClient 指定该策略生效的服务：

@LoadBalancerClient(name = "product-service", configuration = LoadBalancerConfig.class)
@Configuration
public class BeanConfig {
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

这里 name 指定服务提供方，configuration 指定具体的策略实现类。

原理分析

LoadBalancer 的核心拦截器是 LoadBalancerInterceptor。它会拦截 RestTemplate 发出的 HTTP 请求，提取主机名（即服务 ID），查询注册中心获取实例列表，并根据算法选出真实地址替换原 URI。

关键流程如下：

public class LoadBalancerInterceptor implements ClientHttpRequestInterceptor {
    public ClientHttpResponse intercept(final HttpRequest request, final byte[] body, 
                                        final ClientHttpRequestExecution execution) throws IOException {
        URI originalUri = request.getURI();
        String serviceName = originalUri.getHost();
        Assert.state(serviceName != null, "Request URI does not contain a valid hostname");
        // 执行负载均衡逻辑
        return (ClientHttpResponse) this.loadBalancer.execute(serviceName, 
                this.requestFactory.createRequest(request, body, execution));
    }
}

在 BlockingLoadBalancerClient 中，会进一步调用 choose 方法，根据当前配置的负载均衡器从实例列表中选择一个可用的 ServiceInstance。如果找不到可用实例，则会抛出异常。

结语

通过上述实践，我们掌握了 Spring Cloud LoadBalancer 的基本用法及策略定制方法。理解其背后的拦截器机制，有助于在遇到连接超时或路由问题时进行更深入的排查。在实际生产环境中，结合健康检查和权重配置，能进一步提升系统的稳定性。