一、LoadBalancer

spring-cloud-starter-loadbalancer

依赖.

注解之后会启用拦截器对我们发起的服务调用请求进行拦截注意这里是针对我们发起的请求进行拦截叫做

FunctionalInterface

originalUri.getHost();Assert.state(serviceName

null,

(ClientHttpResponse)this.loadBalancer.execute(serviceName,

this.requestFactory.createRequest(request,

body,

b这个拦截器具体做了什么事情呢我们知道被拦截的请求地址并不是一个有效的主机地址而是服务名称因此需要通过

public

this.getHint(serviceId);LoadBalancerRequestAdapterT,

lbRequest

LoadBalancerRequestAdapter(request,

new

hint));SetLoadBalancerLifecycle

this.getSupportedLifecycleProcessors(serviceId);supportedLifecycleProcessors.forEach((lifecycle)

{lifecycle.onStart(lbRequest);});//可以看到在这里会调用choose方法自动获取对应的服务实例信息ServiceInstance

serviceInstance

{supportedLifecycleProcessors.forEach((lifecycle)

CompletionContext(Status.DISCARD,

lbRequest,

EmptyResponse()));});//没有发现任何此服务的实例就抛异常之前的测试中可能已经遇到了throw

new

{//成功获取到对应服务的实例这时就可以发起HTTP请求获取信息了return

serviceInstance,

}c因此实际上在进行负载均衡的时候会向服务的注册中心Nacos发起一个请求选择一个可用的服务如果有多个然后返回此服务的主机地址等信息.

二、整合

dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-openfeign/artifactId/dependencydependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-loadbalancer/artifactId/dependency2.2、具体实现

a启动类中添加

{SpringApplication.run(UserApplication.class,

args);}}b例如在

{GetMapping(/article/start)String

userStart();}服务提供者

articleClient;GetMapping(/start)public

String

articleClient.userStart();return

user

中添加断点就可以看到我们指定的策略默认是轮询RoundRobin

2.3、自定义负载均衡策略

现在希望修改默认的负载均衡策略为随机分配策略就需要创建随机分配策略的配置类不用加

Configuration

ReactorLoadBalancerServiceInstance

environment,

loadBalancerClientFactory){String

name

environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);return

new

RandomLoadBalancer(loadBalancerClientFactory.getLazyProvider(name,

ServiceInstanceListSupplier.class),

name);}

LoadBalanced(可以写也可以不用写默认所有方法都自动加

LoadBalanced)GetMapping(/article/start)String

userStart();}