Ribbon实现负载均衡和服务调用

Ribbon的工作原理

Ribbon是Netfix公司的开源项目,是基于HTTP和TCP的客户端负载均衡组件,她是不可以独立部署的。Spring Cloud Ribbon基于Ribbon实现,基于轮训、随机等规则自动调用服务,也可以自定义负载均衡算法。

Ribbon支持的负载均衡策略

负载均衡策略主要有几种:

    1. 线性轮训策略
      通过一个计数器实现。
    1. 重试策略
      • 如果选到的服务实例正常,则返回数据。
      • 如果选到的服务实例为null或失效,则choose方法会在失效时间前不断进行重试。
      • 如果超过了实效时间还是没取到,则返回一个null。
    1. 加权响应时间策略
      每30s计算一次各个服务实例的响应时间,以响应时间来计算权重。平均响应时间越短则权重越高,权重越高被选中的概率越高,反之被选中的概率越低。
    1. 随机策略
      (1)负载均衡通过upList()和allList()方法获得可用服务实例列表,然后初始化一个Random对象以生成一个不大于服务实例总数的随机数。
      (2)choose()方法将该随机数作为下标获取一个服务实例。轮训“index”,选择“index”对应位置的服务实例。
    1. 客户端配置启用线性轮训策略
    1. 最空闲策略
      (1)根据loadBalanceStats()方法中保存的服务实例的状态信息来过滤实效服务实例。
      (2)判断loadBalanceStats是否为空。
    1. 过滤性轮训策略PredicateBasedRule
      PredicateBasedRule类是ClientConfigEnabledRoundRobinRule类的子类,通过定义一个过滤器过滤出一部分服务实例清单,然后用线性轮询的方式从过滤出来的服务实例清单中选取一个服务实例。
    1. 区域感知轮训策略ZoneAvoidanceRule
      以区域、可用服务器为基础,选择服务实例并对服务实例进行分类。
    1. 可用性过滤策略
      该策略根据服务状态(宕机或繁忙)来分配权重,过滤掉那些因为一直连接失败或高并发的服务实例。

自定义负载均衡策略

1.添加依赖和配置

添加Web和Ribbon的依赖

  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <!--Ribbon 依赖-->
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
  </dependency>

添加配置项

spring.application.name=RibbonRule
server.port=9003
logging.level.root=DEBUG
provider.ribbon.listOfServers=localhost:8504,localhost:8505

2.开启负载均衡支持

在启动类中添加注解#@LoadBalnced以开启客户端负载均衡,然后实例化RestTemplate见以下代码:

    /**
     * 表示开启客户端负载均衡
     */
    @LoadBalanced
    @Bean
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

3.编写配置类,配置规则

配置类注解@Configuration,并用注解@RibbonClient配置服务名,然后实例了Ribbon规则

@Configuration
@RibbonClient(name = "provider", configuration = RibbonClientConfiguration.class)
public class RibbonConfig {
    @Bean
    public IRule iRule() {
        return new RandomRule();
    }
}

除配置方式以外,还可以用配置文件的方式进行配置

ServiceA.ribbon.NFLoadBalancerRuleClassName:com.netflix.loadbalance.RandomRule

其中“ServiceA”代表对服务A进行配置。

4.编写控制器

在控制器中编写测试代码,用于测试自定义的负载均衡策略。

@RestController
public class TestController {
    @Autowired
    private LoadBalancerClient loadBalancerClient;
    private static final SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    @GetMapping("/test")
    public String test() {
        ServiceInstance serviceInstance = loadBalancerClient.choose("provider");
        String result = serviceInstance.getHost() + serviceInstance.getPort() + " " + SDF.format(new Date());
        System.out.println(result);
        return result;
    }
}

5.测试策略

多次访问http://localhost:9003/test,可以查看轮训结果。

Feign

SpringCloud的“服务发现”除可以用RestTemplate客户端实现外,还可以用Feign客户端实现。Feign是一个声明式Web Service客户端,它使得编写Web Service客户端变得容易。
Feign客户端过程:
(1)建立与“服务提供者”的网络连接
(2)构造请求
(3)发送请求到“服务提供者”
(4)处理“服务提供者”返回的响应结果。
在项目中,在接口中使用了注解@FeignClient,则Feign客户端会针对这个接口创建一个动态代理。调用该接口,实质就是调用Feign客户端创建的动态代理:Feign客户端的动态代理会根据接口上的@RequestMapping等注解动态构造要请求的服务地址和方法,并针对这个地址发起请求并解析响应。

添加依赖和配置

  • 添加依赖
  <!--Consul 依赖-->
  <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-consul-discovery</artifactId>
 </dependency>

   <!--Openfeign 依赖-->
        <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
        <version>2.1.2.RELEASE</version>
  </dependency>
  • 添加配置文件
spring.application.name=Feign Configuration
server.port=8701
spring.cloud.consul.host=127.0.0.1
spring.cloud.consul.port=8500
#因为不提供,所以设置不需要将其注册到Consul
spring.cloud.consul.discovery.register=false
logging.level.com.ping.feign=DEBUG

添加支持

在启动类中添加注解@EnableDiscoveryClient(用于支持“服务中心”)和@EnableFeignClients(用于支持Feign)。

自定义Feign的配置

@Configuration
public class FeignConfig {
    @Bean
    Logger.Level feignLoggerLevel() {
        // 记录请求响应的标题,正文和元数据
        return Logger.Level.FULL;
    }
}

用feign.Contract.Default将契约改为Feign原生的契约,然后即可使用Feign自带的注解了。

自定义的Feign的接口

因为上面配置了"feign.Contract.Default",所以在接口中可以使用Feign原生的注解@RequestLine了。

@FeignClient(contextId = "feignClient", name = "service-provider", configuration = FeignConfiguration.class)
public interface MyFeignClient {
    /**
     * Spring MVC注解修改为Feign自带的注解;
     * 使用feign自带的注解@RequestLine;
     */
    @RequestLine("GET /hello")
    public String hello();
}

用post方式构建多参数请求

如果“服务提供者”是通过注解@RequestBody获取数据的,则可以通过以下代码来发送请求:

@FeignClient(name="service-provider")
public interface MyFeignClient {
      @PostMapping(value="/post")
      public User post(@RequestBody User user);
}

Ribbon和Feign的区别

    1. 启动类所使用的注解
      Ribbon用的是注解@RibbonClient,而Feign用的注解@EnableFeignCliens。
    1. 服务的指定位置
      Ribbon的服务是在注解@RibbonClient中声明的,而Feign的服务则是在注解@FeignClient中声明的。
    1. 调用方式
      Ribbon需要自己构建HTTP请求模拟HTTP请求,然后使用RestTemplate将该请求发送给其他服务。即, Ribbon使用@RibbonClient(value="服务名称")和RestTemplate调用远程对应的方法。
      Feign则是在Ribbon的基础上封装,采用的接口方式,不需要自己构建HTTP请求,只需将“其他服务的方法”定义成抽象方法即可。即, Feign在接口上使用“@FeignClient("指定服务名")”方式来调用服务。注意,注解@FeignClient的属性值应与远程服务中的方法名完全一致。
    1. Maven依赖
      Ribbon的Maven依赖是spring-starter-ribbon。
      Feign的Maven依赖是spring-starter-openfeign。
      综上所述,Ribbon使用了RestTemplate,所以其代码的可读性、可维护性和开发体验一般;而Feign则相对好多。Ribbon性能强,灵活性强。
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,132评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,802评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,566评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,858评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,867评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,695评论 1 282
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,064评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,705评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,915评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,677评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,796评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,432评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,041评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,992评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,223评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,185评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,535评论 2 343

推荐阅读更多精彩内容