Spring-Cloud-Netflix-Ribbon&Feigen

2023-11-27 13:21:08 浏览数 (1)

Spring-Cloud-Netflix-Ribbon&Feigen

负载均衡Ribbon

负载均衡概述

  1. 实际环境中,我们往往会开启很多个goods-service的集群。此时我们获取的服务列表中就会有多个,到底该访问哪一个呢
  2. 如何从多台服务器当中, 均衡的调用
Spring Cloud Ribbon

  1. Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。
  2. Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起。
  3. Ribbon是Netflix发布的负载均衡器,Ribbon默认为我们提供了很多负载均衡算法,
  4. 例如轮询、随机等。当然,我们也可为Ribbon实现自定义的负载均衡算法。 在Spring
  5. Cloud中,当Ribbon与Eureka配合使用时,Ribbon可自动从Eureka Server获取服务提供者地址列表,
  6. 并基于负载均衡算法,请求其中一个服务提供者实例。展示了Ribbon与Eureka配合使用时的架构。

Ribbon负载均衡配置

  1. 在Eureka当中已经包换了Ribbon,所以我们不需要单独添加依赖
  1. 在RestTemplatet的Bean上再添加一个注解@LoadBalanced
  1. 在控制器当中定义要调用服务的实例名称

默认是轮询

负载均衡算法

  1. 随机
  2. 轮询
  3. hash:根据ip地址进行hash,通过ip值模于服务的数量,从而确定访问认证
  4. 最少访问

这些算法, 都不需要要我们去写, 直接使用一个Robbin进行操作

核心组件IRule

IRule是是Ribbon对于负载均衡策略实现的接口

默认实现IRule接口的类:

  1. RoundRobinRule:轮询
  2. RandomRule:随机
  3. AvailabilityFilteringRule:会先过滤由于多次访问故障处于断路器跳闸状态 的服务,还有并发的连接数据超过阈值的服务,然后对剩余的服务列表按照轮询策略进行选取
  4. WeightedResponseTimeRule:根据平均响应时间计算所有服务的权重,响应时间越快权重越大,刚启动时如果统计信息不足,则使用RoundRobinRule策略,等统计信息足够时后,会切换到WeightedResponseTieRule
  5. RetryRule:先按照RoundRobinRule的策略获取服务,如果获取服务失败,则在制定时间内会重试,再获取不到, 则放弃
  6. BestAvailableRule:会先过滤掉由于多次访问故障,而处于断路器跳闸的服务,然后选择一个并发量最小的服务
  7. ZoneAvoidanceRule:默认规则,符合判断Server所在区域的性能和server的可用性选择服务器

IRule配置:在启动类添加

代码语言:javascript复制
	@Bean
    public IRule Irule(){
        return new RandomRule();//随机
    }
不同服务设置不同的策略

步骤:

  1. 新建两个order和order1的子模块
  1. 添加依赖
代码语言:javascript复制
	<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>
  1. 复制goods的文件到order,order1并修改名称
  1. 修改配置文件
  1. 创建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();
    }
}
  1. 启动类添加

删除:

Feigen

概述:

直接使用RestTemplate存在问题:在请求接口时, 路径仍存在问题,只解决了服务名称,没有解决服务后,功能路径问题,因为有可能是别人开发的, 你不知道后面功能路径是什么

  1. 什么是Feign?

  1. Feign是一个声明式WebService客户端。 Feign旨在使编写Java Http客户端变得更容易。
  2. Feign在RestTemplate基础上做了进一步封装,由他来帮助我们定义和实现依赖服务接口的定义
  3. Feign可以把请求进行隐藏,你不用再自己拼接url,拼接参数等等操作,一切都交给Feign去做。
  4. 调用时,使用的负载均衡,是当前客户端配置的负载均衡规则

使用步骤:

  1. 在客户端引入依赖:
代码语言:javascript复制
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
  1. 在启动类上面加上注解:@EnableFeignClients
  1. 创建服务FeignClient,创建一个service文件夹,在该文件下创建一个接口,在接口加上添加@FeignClient()注解 参数就是你的微服务名字
代码语言:javascript复制
@FeignClient(name= "client-goods")
public interface goodsFeignClient {
    @RequestMapping("/getGoods.do")
    public Object getGoods();
}
  1. 在控制器当中进行调用
代码语言:javascript复制
 	@Autowired
    goodsFeignClient goodsFeignClient;
 	@RequestMapping("/getGoods.do")
    public ResponseResult getGoods(){
        return ResponseResult.success("操作成功",
                goodsFeignClient.getGoods());
    }
  1. 启动访问localhost:5000/getGoods.do

0 人点赞