共计 7539 个字符，预计需要花费 19 分钟才能阅读完成。
这篇文章主要介绍了 Spring Cloud 如何使用 Ribbon，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让丸趣 TV 小编带着大家一起了解一下。
8 Spring Cloud 与 RibbonRibbon8.1 准备工作
为了本小节的测试做准备，按顺序进行以下工作：
新建 Eureka 服务器端项目，命名为“cloud-server”，端口 8761，
代码目录 codes\04\4.4\cloud-server。
新建 Eureka 服务提供者项目，命名为“cloud-provider”，
代码目录 codes\04\4.4\cloud-provider，该项目主要进行以下工作：
1. 在控制器里面，发布一个 REST 服务，地址为“/person/{personId}”，
请求后返回 Person 实例，其中 Person 的 message 为 HTTP 请求的 URL。
2. 服务提供者需要启动两次，因此在控制台中需要输入启动端口。
新建 Eureka 服务调用者项目，命名为“cloud-invoker”，对外端口为 9000，
代码目录 codes\04\4.4\cloud-invoker。本例的负载均衡配置主要针对服务调用者。
以上项目准备完成并启动后，结构如图 4 - 2 所示。
图 4 -2 准备的项目结构图
注意：Eureka 相关项目的建立，可参见前面章节。
8.2 使用代码配置 Ribbon
在前面章节讲述了负载规则以及 Ping，在 Spring Cloud 中，可将自定义的负载规则以及 Ping 类，放到服务调用者中，查看效果。新建自定义的 IRule 与 IPing，两个实现类请见代码清单 4 -11。
代码清单 4 -11：
codes\04\4.4\cloud-invoker\src\main\java\org\crazyit\cloud\MyRule.java
codes\04\4.4\cloud-invoker\src\main\java\org\crazyit\cloud\MyPing.java
package org.crazyit.cloud;
import java.util.List;
import com.netflix.loadbalancer.ILoadBalancer;
import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.Server;
public class MyRule implements IRule {
private ILoadBalancer lb;
public Server choose(Object key) {List Server servers = lb.getAllServers();
System.out.println( 这是自定义服务器定规则类，输出服务器信息：for(Server s : servers) {System.out.println( + s.getHostPort());
return servers.get(0);
public void setLoadBalancer(ILoadBalancer lb) {
this.lb = lb;
public ILoadBalancer getLoadBalancer() {return this.lb;}package org.crazyit.cloud;
import com.netflix.loadbalancer.IPing;
import com.netflix.loadbalancer.Server;
public class MyPing implements IPing {public boolean isAlive(Server server) {System.out.println( 自定义 Ping 类，服务器信息： + server.getHostPort());
return true;
}根据两个自定义的 IRule 和 IPing 类可知，实际上跟 4.3 章节中的自定义实现类似，服务器选择规则中只返回集合中的第一个实例，IPing 实现仅仅是控制输入服务器信息。接下来，新建配置类，返回规则与 Ping 的 Bean，请见代码清单 4 -12。
代码清单 4 -12：
codes\04\4.4\cloud-invoker\src\main\java\org\crazyit\cloud\config\MyConfig.java
codes\04\4.4\cloud-invoker\src\main\java\org\crazyit\cloud\config\CloudProviderConfig.java
package org.crazyit.cloud.config;
import org.crazyit.cloud.MyPing;
import org.crazyit.cloud.MyRule;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.netflix.loadbalancer.IPing;
import com.netflix.loadbalancer.IRule;
public class MyConfig {
@Bean
public IRule getRule() {return new MyRule();
@Bean
public IPing getPing() {return new MyPing();
}package org.crazyit.cloud.config;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.cloud.netflix.ribbon.RibbonClient;
import org.springframework.context.annotation.Configuration;
@RibbonClient(name= cloud-provider , configuration=MyConfig.class)
public class CloudProviderConfig {}代码清单 4 -12 中，CloudProviderConfig 配置类，使用了 @RibbonClient 注解，配置了 RibbonClient 的名称为“cloud-provider”，对应的配置类为“MyConfig”，也就是名称为“cloud-provider”的客户端，将使用 MyRule 与 MyPing 两个类。在服务调用者的控制器中，加入对外服务，服务中调用 RestTemplate，如代码清单 4 -13。
代码清单 4 -13：
codes\04\4.4\cloud-invoker\src\main\java\org\crazyit\cloud\InvokerController.java
@RestController
@Configuration
public class InvokerController {
@LoadBalanced
@Bean
public RestTemplate getRestTemplate() {return new RestTemplate();
@RequestMapping(value = /router , method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
public String router() {RestTemplate restTpl = getRestTemplate();
// 根据名称调用服务
String json = restTpl.getForObject( http://cloud-provider/person/1 ,
String.class);
return json;
}以上的控制器中，为 RestTemplate 加入了 @LoadBalanced 修饰，与前面章节类似，在此不再赘述，关于 RestTemplate 的原理，将在本章后面章节讲述。进行以下操作，查看本例效果：
启动一个 Eureka 服务器（cloud-server）。
启动两次 Eureka 服务提供者（cloud-provider），分别输入 8080 与 8081 端口。
启动一个 Eureka 服务调用者（cloud-invoker）。
打开浏览器访问 http://localhost:9000/router，可以看到调用服务后返回的 JSON 字符串，不管刷新多少次，最终都只会访问其中一个端口。
8.3 使用配置文件设置 Ribbon
在前面使用 Ribbon 时，可以通过配置来定义各个属性，在使用 Spring Cloud 时，这些属性同样可以配置到 application.yml 中，以下的配置同样生效：
cloud-provider:
ribbon:
NFLoadBalancerRuleClassName: org.crazyit.cloud.MyRule
NFLoadBalancerPingClassName: org.crazyit.cloud.MyPing
listOfServers: http://localhost:8080/,http://localhost:8081/为 cloud-provider 这个客户端，配置了规则处理类、Ping 类以及服务器列表，以同样的方式运行本小节例子，可看到同样的效果，在此不再赘述。
代码与配置文件的方式进行配置，两种方式的效果一致，但对比起来，明显是配置文件的方式更加简便。
注意：本案例的 cloud-invoker 模块中，默认使用了代码的方式来配置 Ribbon，配置文件中的配置已被注释。
8.4 Spring 使用 Ribbon 的 API
Spring Cloud 对 Ribbon 进行封装，例如像负载客户端、负载均衡器等，我们可以直接使用 Spring 的 LoadBalancerClient 来处理请求以及服务选择。代码清单 4 -14，在服务器调用者的控制器中使用 LoadBalancerClient。
代码清单 4 -14：
codes\04\4.4\cloud-invoker\src\main\java\org\crazyit\cloud\InvokerController.java
@Autowired
private LoadBalancerClient loadBalancer;
@RequestMapping(value = /uselb , method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
public ServiceInstance uselb() {
// 查找服务器实例
ServiceInstance si = loadBalancer.choose( cloud-provider
return si;
}除了使用 Spring 封装的负载客户端外，还可以直接使用 Ribbon 的 API，代码 4 -15，直接获取 Spring Cloud 默认环境中，各个 Ribbon 的实现类。
代码清单 4 -15：
codes\04\4.4\cloud-invoker\src\main\java\org\crazyit\cloud\InvokerController.java
@Autowired
private SpringClientFactory factory;
@RequestMapping(value = /defaultValue , method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
public String defaultValue() {
System.out.println( ==== 输出默认配置：// 获取默认的配置
ZoneAwareLoadBalancer alb = (ZoneAwareLoadBalancer) factory
.getLoadBalancer( default
System.out.println( IClientConfig:
+ factory.getLoadBalancer(default).getClass().getName());
System.out.println( IRule: + alb.getRule().getClass().getName());
System.out.println( IPing: + alb.getPing().getClass().getName());
System.out.println( ServerList:
+ alb.getServerListImpl().getClass().getName());
System.out.println( ServerListFilter:
+ alb.getFilter().getClass().getName());
System.out.println( ILoadBalancer: + alb.getClass().getName());
System.out.println( PingInterval: + alb.getPingInterval());
System.out.println( ==== 输出 cloud-provider 配置：// 获取 cloud-provider 的配置
ZoneAwareLoadBalancer alb2 = (ZoneAwareLoadBalancer) factory
.getLoadBalancer( cloud-provider
System.out.println( IClientConfig:
+ factory.getLoadBalancer(cloud-provider).getClass()
.getName());
System.out.println( IRule: + alb2.getRule().getClass().getName());
System.out.println( IPing: + alb2.getPing().getClass().getName());
System.out.println( ServerList:
+ alb2.getServerListImpl().getClass().getName());
System.out.println( ServerListFilter:
+ alb2.getFilter().getClass().getName());
System.out.println( ILoadBalancer: + alb2.getClass().getName());
System.out.println( PingInterval: + alb2.getPingInterval());
return
}代码中使用了 SpringClientFactory，通过该实例，可获取各个默认的实现类以及配置，分别输出了默认配置以及“cloud-provider”配置。运行代码清单 4 -15，浏览器中访问地址 http://localhost:8080/defaultValue，可看到控制台输出如下：
==== 输出默认配置： IClientConfig: com.netflix.loadbalancer.ZoneAwareLoadBalancer
IRule: com.netflix.loadbalancer.ZoneAvoidanceRule
IPing: com.netflix.niws.loadbalancer.NIWSDiscoveryPing
ServerList: org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList
ServerListFilter: org.springframework.cloud.netflix.ribbon.ZonePreferenceServerListFilter
ILoadBalancer: com.netflix.loadbalancer.ZoneAwareLoadBalancer
PingInterval: 30
==== 输出 cloud-provider 配置： IClientConfig: com.netflix.loadbalancer.ZoneAwareLoadBalancer
IRule: org.crazyit.cloud.MyRule
IPing: org.crazyit.cloud.MyPing
ServerList: org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList
ServerListFilter: org.springframework.cloud.netflix.ribbon.ZonePreferenceServerListFilter
ILoadBalancer: com.netflix.loadbalancer.ZoneAwareLoadBalancer
PingInterval: 30根据输出可知，cloud-provider 客户端使用的负载规则类以及 Ping 类，是我们自定义的实现类。
一般情况下，Spring 已经帮我们封装好了 Ribbon，我们只需要直接调用 RestTemplate 等 API 来访问服务即可。
感谢你能够认真阅读完这篇文章，希望丸趣 TV 小编分享的“Spring Cloud 如何使用 Ribbon”这篇文章对大家有帮助，同时也希望大家多多支持丸趣 TV，关注丸趣 TV 行业资讯频道，更多相关知识等着你来学习!
