文档章节

SpringCloud 基础教程(六)-负载均衡Ribbon

程序员笑笑生
 程序员笑笑生
发布于 01/29 22:10
字数 1746
阅读 92
收藏 1

 我的博客:程序员笑笑生,欢迎浏览博客!

 上一章 SpringCloud基础教程(五)-配置中心热生效和高可用当中,我们对配置中心进行进行了深入的了解,本章将继续微服务架构的深入学习,了解在微服务中是如何做到负载均衡的。

前言

 简单来讲,Ribbon是Netflix发布的开源项目,主要的功能是提供客户端的软件负载均衡算法。它可以在客户端配置服务端类别,然后轮询请求以实现负载均衡。

 当项目引入Eureka依赖后,会自动的引入ribbon的依赖,当然我们可以显示的引入ribbon依赖。在集成Eureka时,DiscoveryEnabledNIWSServerList重写了Ribbon的服务列表,在com.netflix.ribbon:ribbon-eureka:2.3.0模块我们可以看到,同时使用 NIWSDiscoveryPing取代IPing:

file

一、Ribbo快速使用

 当前的实例我们会涉及到Eureka注册中心,两个服务提供者(server-provider),一个服务消费者(server-consumer),首先,我们启动两个服务提供者,并注册到Eureka,服务提供接口如下:

@RestController
public class RibbonController {

    @RequestMapping("/sayHello")
    public String sayHello(String name) {
        return "hello!,"+name;
    }
}

 接下来,对之前文章的Eureka客户端,即服务消费者进行相关改造,首先引入ribbon依赖(其实在引入eureka-client时就已经默认引入了Ribbon):

        <dependency>
			<groupId>org.springframework.cloud</groupId>
			<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
		</dependency>

 并对服务消费者代码进行改造,将DiscoveryClient改为LoadBalancerClient,顾名思义,改成支持负载均衡的客户端,同时在消费者的主类上添加@EnableDiscoveryClient注解,开启发现服务功能:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class RibbonController {

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @Autowired
    private LoadBalancerClient client;

    @Autowired
    RestTemplate restTemplate;

    @GetMapping("/sayHello")
    public String sayHello(String name) {
        ServiceInstance instance = client.choose("server-provider");
        String res =  restTemplate.
            getForObject(instance.getUri().toString() 
                         + "sayHello?name=" + name, String.class);
        return res + " from :" + instance.getPort();
    }
}

 先后启动Eureka注册中心,启动两个服务提供者和一个服务消费者,在Eureka的监控页面我们可以看到如下的内容:

file

接下来用浏览器请求服务调用者的接口得到的结果是:

 hello!,test from :9001 

 hello!,test from :9002

 响应为9001和9002交替的出现,这表明Ribbon客户端正在用轮询的方式实现了负载均衡。

 当然我们还可以使用一种更为简单的方法,修改客户端的调用代码,给RestTemplate添加 @LoadBalanced注解,通过restTemplate直接使用URL :http://server-provider/sayHello?name=test的方式调用,这里的server-provider是服务提供者的注册在Eureka的服务名称, @LoadBalanced的默认算法是轮询:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class RibbonController {

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @Autowired
    RestTemplate restTemplate;

    @GetMapping("/sayHello")
    public String sayHello(String name) {
        String res = restTemplate
            .getForObject("http://server-provider/sayHello?name=" + name, String.class);
        return res;
    }

 通过这样简洁的方式同样可以实现负载均衡的调用。

二 、Ribbon进阶配置

 上文简单的展示了Ribbon的基本功能,但是Ribbon还可以有更多自定义的配置,比如我们想修改默认的负载均衡算法、自定义HTTP线程池等,我们该如何实现呢?

2.1 Ribbon的核心组件

 在ribbon-loadbalancer项目中,定义和很多的接口,其中就有

  • IRule:轮询的策略的接口。

  • ServerList:定义用于获取服务器列表的额方法的接口。

  • IPing:定义了以什么方式去检查服务之间是否通讯良好的接口。

  • file

2.2 实现自定义算法

 Spring Cloud提供了为Ribbon的默认实现,当然我们也可以自定义的去修改轮询策略等配置,首选我们在客户端你的启动类上添加@RibbonClient注解,

import com.microservice.RibbonConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.ribbon.RibbonClient;

@SpringBootApplication
@EnableEurekaClient
@EnableDiscoveryClient
@RibbonClient(name = "server-provider",configuration = RibbonConfig.class)
public class ServerConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServerConsumerApplication.class, args);
    }
}

 @RibbonClient(name = "server-provider",= RibbonConfig.class)

  • name:是服务提供者注册在Eureka的名称;
  • configuration :是我们即将自定义的配置类;

接下来,我们新建RibbonConfig配置类,

import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 配置Ribbon
 */
@Configuration
public class RibbonConfig {

    /**
     * 使用随机的轮询方法
     *
     * @return
     */
    @Bean
    public IRule iRule() {
        return new RandomRule();
    }

}

注意:确保RibbonConfig所在的包不能被@ComponentScan扫描到,如果主类使用@SpringBootApplication,也需要避免会被自动扫描,具体的配置如下:

file

 服务调用的代码不变化:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class RibbonController {


    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @Autowired
    RestTemplate restTemplate;


    @GetMapping("/sayHello")
    public String sayHello(String name) {
        String res = restTemplate.getForObject("http://server-provider/sayHello?name=" + name, String.class);
        return res;
    }

 我们使用浏览器调用接口 http://192.168.1.103:5168/sayHello?name=test,返回的结果是以随机的方式返回的;

2.3 @RibbonClient注解

 我们通过指定@RibbonClient中configuration的配置可以修改默认的实现,针对IRule的实现,SpringCloud有以下的实现:

  • RoundRobinRule:轮询,默认的每一次的请求都是轮流分配给服务提供者;

  • AvailabilityFilteringRule:更具可用性进行过滤的策略。默认情况下,如果RestClient最后三次连接失败,则实例会电路跳闸,一旦实例跳闸,它将保持这个状态30s,之后会被再次启用;如果在连续连接失败,则再会变成电路跳闸,等待的时间会指数级增长;

  • WeightedResponseTimeRule:每个服务器根据响应的时间给予权重,响应时间越长,权重越少;

  • RandomRule:随机策略

 当然还有其他的权重策略,有兴趣的同学可以自行的研究源代码。

Spring Cloud提供了@RibbonClients这样的一个注解,我们的客户端不可能只会调用一个提供者,这样的注解我们可以配置多个提供者。

三、总结

 本章介绍了Ribbon组件作为一个客户端的负载均衡器对微服务架构方面起到了非常大的作用,我们对Ribbon有了一个深入的理解,同时我们也可以自定义一些配置,我相信微服务的学习并不是一件很难的事。

file

.以就是本期的分享,你还可以关注公众号: 程序员笑笑生,关注更多精彩内容!

file

file

SpringCloud基础教程(一)-微服务与SpringCloud

SpringCloud基础教程(二)-服务发现 Eureka

SpringCloud基础教程(三)-Eureka进阶

SpringCloud 基础教程(四)-配置中心入门

SpringCloud基础教程(五)-配置中心热生效和高可用

SpringCloud 基础教程(六)-负载均衡Ribbon

更多精彩内容,请期待...

本文由博客一文多发平台 OpenWrite 发布!

我的博客地址兰陵笑笑生,欢迎浏览!

© 著作权归作者所有

程序员笑笑生
粉丝 7
博文 27
码字总数 38186
作品 0
合肥
高级程序员
私信 提问
加载中

评论(0)

springcloud eureka 服务注册中心

------------------------------------------------------------------------------------------------------------ springcloud (零) springboot 基础 下载 springcloud (一)服务注册中心 ......

curiousby
2017/02/08
0
0
springcloud 服务网关 gateway zuul

------------------------------------------------------------------------------------------------------------ springcloud (零) springboot 基础 下载 springcloud (一)服务注册中心 ......

curiousby
2017/02/17
0
0
springcloud 客户端负载均衡 ribbon

------------------------------------------------------------------------------------------------------------ springcloud (零) springboot 基础 下载 springcloud (一)服务注册中心 ......

curiousby
2017/02/09
0
0
springcloud 断路由hystrix

------------------------------------------------------------------------------------------------------------ springcloud (零) springboot 基础 下载 springcloud (一)服务注册中心 ......

curiousby
2017/02/10
0
0
springcloud 消费者 Feign (类似 webservice)

------------------------------------------------------------------------------------------------------------ springcloud (零) springboot 基础 下载 springcloud (一)服务注册中心 ......

curiousby
2017/02/09
0
0

没有更多内容

加载失败,请刷新页面

加载更多

入门实战: ELK

ELK

BeanHo
19分钟前
14
0
PHP一致性hash代码

[TOC] PHP实现一致性hash bash命令 因为下面PHP代码的模拟用户用的是随机数,所以统计结果达不到绝对的均衡. php ./hash.php | sort | uniq -c | sort PHP代码 这是之前学的时候留下来的测试...

我爱吃炒鸡
今天
78
0
OSChina 周六乱弹 —— 现在看动弹的人都是什么状态

Osc乱弹歌单(2020)请戳(这里) 【今日歌曲】 @薛定谔的兄弟 :分享洛神有语创建的歌单「我喜欢的音乐」: 《夏日、教室与望着窗外的我》- Candy_Wind 手机党少年们想听歌,请使劲儿戳(这里...

小小编辑
今天
704
8
wamp环境安装redis扩展

1.查看phpinfo信息根据配置信息下载对应的扩展 关键信息:VC14,TS,x86 2.下载php_redis和php_igbinary扩展 php_redis扩展下载地址: https://windows.php.net/downloads/pecl/snaps/redis...

点滴课程
今天
36
0
开源商城开发笔记1-创建MyBatis示例

一、修改pom.xml,引入MyBatis,JUnit,Log4j <dependencies><dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.5.4</version>......

土龙
今天
56
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部