Spring-Cloud-Netflix-Ribbon&Feigen
负载均衡Ribbon
负载均衡概述
- 实际环境中,我们往往会开启很多个goods-service的集群。此时我们获取的服务列表中就会有多个,到底该访问哪一个呢
- 如何从多台服务器当中, 均衡的调用
Spring Cloud Ribbon
- Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。
- Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起。
- Ribbon是Netflix发布的负载均衡器,Ribbon默认为我们提供了很多负载均衡算法,
- 例如轮询、随机等。当然,我们也可为Ribbon实现自定义的负载均衡算法。 在Spring
- Cloud中,当Ribbon与Eureka配合使用时,Ribbon可自动从Eureka Server获取服务提供者地址列表,
- 并基于负载均衡算法,请求其中一个服务提供者实例。展示了Ribbon与Eureka配合使用时的架构。
Ribbon负载均衡配置
- 在Eureka当中已经包换了Ribbon,所以我们不需要单独添加依赖
- 在RestTemplatet的Bean上再添加一个注解@LoadBalanced
- 在控制器当中定义要调用服务的实例名称
默认是轮询
负载均衡算法
- 随机
- 轮询
- hash:根据ip地址进行hash,通过ip值模于服务的数量,从而确定访问认证
- 最少访问
这些算法, 都不需要要我们去写, 直接使用一个Robbin进行操作
核心组件IRule
IRule是是Ribbon对于负载均衡策略实现的接口
默认实现IRule接口的类:
- RoundRobinRule:轮询
- RandomRule:随机
- AvailabilityFilteringRule:会先过滤由于多次访问故障处于断路器跳闸状态 的服务,还有并发的连接数据超过阈值的服务,然后对剩余的服务列表按照轮询策略进行选取
- WeightedResponseTimeRule:根据平均响应时间计算所有服务的权重,响应时间越快权重越大,刚启动时如果统计信息不足,则使用RoundRobinRule策略,等统计信息足够时后,会切换到WeightedResponseTieRule
- RetryRule:先按照RoundRobinRule的策略获取服务,如果获取服务失败,则在制定时间内会重试,再获取不到, 则放弃
- BestAvailableRule:会先过滤掉由于多次访问故障,而处于断路器跳闸的服务,然后选择一个并发量最小的服务
- ZoneAvoidanceRule:默认规则,符合判断Server所在区域的性能和server的可用性选择服务器
IRule配置:在启动类添加
代码语言:javascript复制 @Bean
public IRule Irule(){
return new RandomRule();//随机
}
不同服务设置不同的策略
步骤:
- 新建两个order和order1的子模块
- 添加依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--Eureka的客户端-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
</dependencies>
- 复制goods的文件到order,order1并修改名称
- 修改配置文件
- 创建config包,写goods和order的负载均衡配置
goodsconfig:
代码语言:javascript复制@Configuration
public class goodsConfig {
@Bean
public IRule goods(){
return new RoundRobinRule();
}
}
orderconfig:
代码语言:javascript复制@Configuration
public class OrderConfig {
@Bean
public IRule order(){
return new RandomRule();
}
}
- 启动类添加
删除:
Feigen
概述:
直接使用RestTemplate存在问题:在请求接口时, 路径仍存在问题,只解决了服务名称,没有解决服务后,功能路径问题,因为有可能是别人开发的, 你不知道后面功能路径是什么
- 什么是Feign?
- Feign是一个声明式WebService客户端。 Feign旨在使编写Java Http客户端变得更容易。
- Feign在RestTemplate基础上做了进一步封装,由他来帮助我们定义和实现依赖服务接口的定义
- Feign可以把请求进行隐藏,你不用再自己拼接url,拼接参数等等操作,一切都交给Feign去做。
- 调用时,使用的负载均衡,是当前客户端配置的负载均衡规则
使用步骤:
- 在客户端引入依赖:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
- 在启动类上面加上注解:@EnableFeignClients
- 创建服务FeignClient,创建一个service文件夹,在该文件下创建一个接口,在接口加上添加@FeignClient()注解 参数就是你的微服务名字
@FeignClient(name= "client-goods")
public interface goodsFeignClient {
@RequestMapping("/getGoods.do")
public Object getGoods();
}
- 在控制器当中进行调用
@Autowired
goodsFeignClient goodsFeignClient;
@RequestMapping("/getGoods.do")
public ResponseResult getGoods(){
return ResponseResult.success("操作成功",
goodsFeignClient.getGoods());
}
- 启动访问localhost:5000/getGoods.do