Ribbon 使用入门

Ribbon 是 Netflix 下的负载均衡项目,在集群中为各个客户端的通信提供支持,主要实现中间层应用程序的负载均衡,提供以下特性:

  • 负载均衡器,可支持插拔式的负载均衡规则
  • 对多种协议提供支持,例如HTTP、TCP
  • 集成了负载均衡功能的客户端

Ribbon 可以与 Eureka 服务注册中心整合使用,并且被整合到 Spring Cloud Netflix 子项目中。Ribbon 主要有三大模块,模块说明如下:

  • ribbon-core:该模块为Ribbon项目的核心,主要包括负载均衡器接口定义、客户端接口定义、内置的负载均衡实现等API
  • ribbon-eureka:为 Eureka 客户端提供的负载君均衡实现类
  • ribbon-httpclient:对 Apache 的 HttpClient 进行封装,该模块提供了含有负载均衡功能的 REST 客户端

Ribbon 的负载均衡器主要是与集群中的各个服务器进行通信,因此负载均衡器需要提供维护服务器IP、DNS名称等信息、根据特定逻辑在服务器列表中循环的功能,为了实现这些功能 Ribbon 的负载均衡器提供了以下三大模块:

  • Rule:该组件用于处理从服务器列表中选择那个服务器实例
  • Ping:该组件主要用定时器来确保服务器网络可以连接
  • ServerList:服务器列表,可以通过静态的配置确定负载的服务器,也可以动态指定服务器列表,如果动态指定服务器列表,则会有后台线程来刷新该列表

在使用 Ribbon 时,可以使用配置也可以使用代码设置配置项,需要使用代码来设置配置项,示例代码如下:

ConfigurationManager.getConfigInstance()

.setProperty("MyRibbonClient.ribbon.listOfServers","localhost:8080,localhost:8002");

如果希望使用配置文件来设置项,在 src/main/resources 目录创建 properties 文件,并在文件中增加配置项,格式如下:

<client>.<namespace>.<property>=<value>

其中,<client> 表示为客户的名称,声明配置属于那个客户端,在使用 ClientFactory 时可传入客户端的名称来获取对应的实例;<namespace>为该配置的命名空间,默认为 ribbon;<property>为属性名;<value>为属性值;如果希望对全部客户端生效,则配置格式如下:

<namespace>.<property>=<value>

Ribbon使用示例

  • 创建项目

    创建 maven 项目,命名为 ribbon-client,并增加 ribbon 依赖,POM.xml 内容如下:

    <?xmlversion="1.0"encoding="UTF-8"?>

    <projectxmlns="http://maven.apache.org/POM/4.0.0"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <groupId>org.lixue</groupId>

    <artifactId>ribbon-client</artifactId>

    <version>1.0-SNAPSHOT</version>

    <dependencies>

    <dependency>

    <groupId>com.netflix.ribbon</groupId>

    <artifactId>ribbon</artifactId>

    <version>2.2.2</version>

    </dependency>

    <dependency>

    <groupId>com.netflix.archaius</groupId>

    <artifactId>archaius-core</artifactId>

    <version>0.7.4</version>

    </dependency>

    <dependency>

    <groupId>com.netflix.ribbon</groupId>

    <artifactId>ribbon-loadbalancer</artifactId>

    <version>2.2.2</version>

    </dependency>

    <dependency>

    <groupId>com.netflix.ribbon</groupId>

    <artifactId>ribbon-core</artifactId>

    <version>2.2.2</version>

    </dependency>

    </dependencies>

    </project>

  • 增加配置文件

    在 src/main/resources 目录创建 ribbon-client.properties 文件,并增加配置项,配置如下:

    MyRibbonClient.ribbon.listOfServers=localhost:8080,localhost:8002

  • 增加测试类

    package org.lixue.ribbon.client;

    import com.netflix.client.ClientFactory;

    import com.netflix.config.ConfigurationManager;

    import com.netflix.loadbalancer.ILoadBalancer;

    import com.netflix.loadbalancer.IRule;

    import com.netflix.loadbalancer.RoundRobinRule;

    import com.netflix.loadbalancer.Server;

    public class RibbonClient{

    public static void main(String[]args)throwsException{

    ConfigurationManager.loadCascadedPropertiesFromResources("ribbon-client");

    ILoadBalancerloadBalancer=ClientFactory.getNamedLoadBalancer("MyRibbonClient");

    Irule chooseRule=new RoundRobinRule();

    chooseRule.setLoadBalancer(loadBalancer);

    for(inti=0;i<10;i++){

    Server server=chooseRule.choose(null);

    System.out.println("request"+server.getHostPort());

    }

    }

    }

  • 测试验证

    启动项目,我们代码获取了10次的服务器,地址分别为 localhost:8080 和 localhost:8002 ,通过输出结果可以发现,使用了轮询调度算法来选择服务器,输出结果如下:

    request localhost:8002

    request localhost:8080

    request localhost:8002

    request localhost:8080

    request localhost:8002

    request localhost:8080

    request localhost:8002

    request localhost:8080

    request localhost:8002

    request localhost:8080

上一篇:计算机网络大纲_day01


下一篇:R语言——基本绘图函数