Ribbon 使用入门

Posted 2020-10-31 追寻自由的路途

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