用系统的吞吐能力并且可以消除系统中的单点故障提升应用系统的可用性。

负载均衡一般分服务端负载均衡

传统的方式前端发送请求会到我们的的nginx上去nginx作为反向代理然后路由给后端的

服务器由于负载均衡算法是nginx提供的而nginx是部署到服务器端的所以这种方式又

2.2、客户端负载均衡

假如现在有三个用户中心实例订单中心可以通过discoveryClient

息如果我们在订单中心写一个负载均衡

请求这样也可以实现负载均衡这个算法里面负载均衡是由订单中心提供的而订单中

心相对于用户中心是一个客户端所以这种方式又称为客户端负负载均衡。

如下图所示

在订单中心服务调用方编写负载均衡方法如下

提供的类通过该类可以获取Nacos注册中心的服务列表*/Autowiredprivate

DiscoveryClient

discoveryClient;GetMapping(/order/create)public

String

discoveryClient.getInstances(shop-stock);//获取目标服务地址ListString

targetUrl

instances.stream().map(instance

instance.getUri().toString()/stock/reduce/).collect(Collectors.toList());//随机获取服务int

index

ThreadLocalRandom.current().nextInt(targetUrl.size());String

target

targetUrl.get(index);//调用目标服务String

result2

restTemplate.getForObject(target

productId,

Ribbon是Netflix开源的客户端侧负载均衡器更加直观说就是ribbon就是简化上边方法createOrder中的这段代码的小组件不过他比我们的代码要强大一些他给他们提供了丰富

2、Ribbon

接口作用默认值IClientConfig读取配置DefaultclientConfigImplIRule负载均衡规则选择实例ZoneAvoidanceRuleIPing筛选掉ping不通的实例默认采用DummyPing实现该检查策略是一个特殊的实现br

/实际上它并不会检查实例是否可用而是始终返回true默认认为所br

/有服务实例都是可用的.ServerListServer交给Ribbon的实例列表Ribbon:

Spring

NacosServerListServerListFilter过滤掉不符合条件的实例ZonePreferenceServerListFilterILoadBalancerRibbon的入口ZoneAwareLoadBalancerServerListUpdater更新交给Ribbon的List的策略PollingServerListUpdater

规则名称特点RandomRule随机选择一个ServerRetryRule对选定的负责均衡策略机上充值机制在一个配置时间段内当选择Server不成功则一直尝试使用subRule的方式选择一个可用的ServerRoundRobinRule轮询选择轮询index选择index对应位置ServerWeightedResponseTimeRule根据相应时间加权相应时间越长权重越小被选中的可能性越低ZoneAvoidanceRule默认是这个该策略能够在多区域环境下选出最佳区域的实例进行访问。

在没有Zone的环境下类似于轮询RoundRobinRule

3、Ribbon

!--spring-cloud-starter-netflix-ribbon

dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-netflix-ribbon/artifactIdversion2.2.10.RELEASE/version

/dependency

注意这一步不是必须项若没有配置Ribbon的负载均衡策略Ribbon

java

/*****************************************************

Ribbon

Configuration该类中的负载均衡策略就变成了全局的负载均衡策略*

shop-order调用任何模块都会使用该类中的负载均衡策略。

*

注意这种方式配置全局的负载均衡策略有bug不支持使用推荐使用注解RibbonClients

author

9:15****************************************************/

public

负载均衡实例哪个Ribbon负载均衡策略被实例化了RPC远程调用时就用*

哪个负载均衡策略即通过配置类手动指定Ribbon的负载均衡策略**/Beanpublic

IRule

ribbonRule(){//指定Ribbon的负载均衡策略为随机return

new

可以用来为某个服务指定Ribbon的负载均衡策略如shop-stock

粒度比较细RibbonClients

/*****************************************************

配置类不编写什么内容用于指定调用目标服务如shop-stack时所采用的负载均衡策略**

author

9:55****************************************************//***

RibbonClient

用于指定当前服务如shop-order以哪个负载均衡策略调用目标服务如shop-stack*/

//RibbonClient(name

RibbonClients(defaultConfiguration

RibbonConfig.class)

GetMapping(/order/create)public

String

LoadBalanced即整合Ribbon使用Ribbon的负载均衡来实现*

远程调用*//**//方式1ListServiceInstance

instances

discoveryClient.getInstances(shop-stock);//获取目标服务地址ListString

targetUrl

instances.stream().map(instance

instance.getUri().toString()/stock/reduce/).collect(Collectors.toList());//随机获取服务int

index

ThreadLocalRandom.current().nextInt(targetUrl.size());String

target

targetUrl.get(index);//调用目标服务String

result2

restTemplate.getForObject(target

productId,

restTemplate.getForObject(http://shop-stock/stock/reduce/

productId,

ZoneAvoidanceRuleFeign或openfeign、RestTemplateSpring

Cloud

轮询默认Feign或openfeign、RestTemplate、WebClientWebFlux

3、整合

因为如果是Hoxton之前的版本默认负载均衡器为Ribbon需要移除Ribbon引用和

增加配置spring.cloud.loadbalancer.ribbon.enabled:

false不启用ribbon

/*****************************************************

配置类注入

15:30****************************************************//***

配置使用

局部的负载均衡器使用name指定目标服务configuration

LoadBalancerClientConfiguration.class)

/***

配置全局的负载均衡器表示在当前服务中远程调用任何目标服务所使用的*

CustomRandomLoadBalancerClient*/

//LoadBalancerClients(defaultConfiguration

LoadBalancerClientConfiguration.class)

Configuration

开启远程调用的负载均衡*/LoadBalancedBeanpublic

RestTemplate

/*****************************************************

自定义负载均衡器用法*

ReactorServiceInstanceLoadBalancer

自定义负载均衡器*

15:49****************************************************/

public

ReactorServiceInstanceLoadBalancer

{//

ObjectProviderServiceInstanceListSupplier

serviceInstanceListSupplierProvider;public

CustomRandomLoadBalancerClient(ObjectProviderServiceInstanceListSupplier

serviceInstanceListSupplierProvider)

{this.serviceInstanceListSupplierProvider

serviceInstanceListSupplierProvider;}Overridepublic

choose(Request

serviceInstanceListSupplierProvider.getIfAvailable();return

supplier.get().next().map(this::getInstanceResponse);}/***

使用随机数获取服务**

getInstanceResponse(ListServiceInstance

instances)

EmptyResponse();}System.out.println(进行随机选取服务);//

随机算法int

instances.get(random.nextInt(size));return

new

}/*****************************************************

配置类注入

15:30****************************************************//***

配置使用

局部的负载均衡器使用name指定目标服务configuration

CustomRandomLoadBalancerClient.class)

/***

配置全局的负载均衡器表示在当前服务中远程调用任何目标服务所使用的*

CustomRandomLoadBalancerClient*/

//LoadBalancerClients(defaultConfiguration

CustomRandomLoadBalancerClient.class)

/***

CustomRandomLoadBalancerClient*

LoadBalancerClientConfiguration*/

/**

CustomRandomLoadBalancerClient.class)},defaultConfiguration

LoadBalancerClientConfiguration.class)*/

Configuration

开启远程调用的负载均衡*/LoadBalancedBeanpublic

RestTemplate

spring:cloud:loadbalancer:#以下配置为LoadBalancerProperties

配置类clients:#default

表示去全局配置如要针对某个服务则填写毒地应的服务名称即可default:retry:enbled:

true#是否所有的的请求都重试false表示只有GET请求才重试retryOnAllOperation:

实际会调用4次maxRetriesOnSameServiceInstance:

3#其他实例的重试次数多节点情况下使用maxRetriesOnNextServiceInstance: