一、Spring Cloud Ribbon简介
Spring Cloud Ribbon是Spring Cloud生态系统中的一部分,是一套基于 Netflix Ribbon 实现的客户端负载均衡工具,由于Spring Cloud对其进行二次封装,可以将面向服务的Rest模板(RestTemplate)请求转换成客户端负载均衡的服务调用。且无需单独部署,只需要在项目中引入相关依赖,并在项目配置文件中进行相关配置后,便可以在客户端进行请求的负载均衡调用了。
二、Ribbon和Nginx负载均衡区别
Ribbon和Nginx都是常用的负载均衡解决方案,但它们各自有不同的特点和适用场景:
- 位置不同:
- Ribbon是客户端负载均衡器,它运行在客户端应用程序中。
- Nginx是服务器负载均衡器,它运行在服务端,作为反向代理服务器。
- 工作原理:
- Ribbon通过编程方式在客户端应用中实现负载均衡,客户端直接与后端服务实例进行通信,并根据配置的规则选择目标服务。
- Nginx作为反向代理,接收客户端请求后,根据配置的负载均衡策略将请求转发到后端服务的某个实例。
- 配置方式:
- Ribbon的负载均衡配置通常通过配置文件或编程方式完成,更灵活,可以针对不同服务定制不同的负载均衡策略。
- Nginx的负载均衡配置通过编辑Nginx的配置文件完成,配置较为集中,适合统一管理多个服务的负载均衡。
- 扩展性:
- Ribbon适用于微服务架构中的服务间调用,每个客户端服务独立管理负载均衡,易于扩展和维护。
- Nginx作为中心化的负载均衡器,适合处理大量并发连接和高流量的场景,但当服务数量增多时,配置和管理可能变得更加复杂。
- 性能:
- Ribbon由于运行在客户端,可能会增加客户端的计算负担。
- Nginx作为专业的代理服务器,在处理静态资源、缓存和反向代理方面具有很好的性能。
- 功能:
- Ribbon提供了丰富的负载均衡策略和服务降级功能。
- Nginx除了基本的负载均衡功能外,还提供了HTTP缓存、GZIP压缩、SSL终端化等多种高级功能。
- 故障转移和健康检查:
- Ribbon可以通过Ribbon Isolation和Ping机制来隔离故障实例和执行健康检查。
- Nginx也支持健康检查,可以定期检测后端服务器的状态,并在必要时从负载均衡池中移除故障实例。
三、常见的Ribbon配置项
在使用Ribbon时,通常不需要手动配置太多的选项,因为Spring Cloud会提供一些默认的配置。如果需要对特定服务进行特殊配置,可以在该服务对应的bootstrap.yml或application.yml文件中覆盖默认配置。在YAML格式的配置文件中,配置项如下所示:
ribbon:
eureka:
enabled: true
listOfServers: myservice:8080
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
MaxTotalHttpConnectionsPerHost: 500
MaxHttpConnectionsPerServer: 200
ConnectTimeout: 5000
ReadTimeout: 10000
- ribbon.eureka.enabled: 是否启用Eureka集成,默认值为true。
- ribbon.eureka.fetchInterval: 从Eureka中获取服务列表的时间间隔,单位为毫秒,默认为60000。
- ribbon.eureka.preferIpAddress: 在Eureka中注册的服务实例是以IP还是主机名的形式返回,默认为false(返回主机名)。
- ribbon.listOfServers: 手动指定服务列表,格式为"host1:port1,host2:port2"。
- ribbon.ServerListFilter: 用于过滤服务列表的策略,如ZonePreferenceServerListFilter、RandomRule等。
- ribbon.MaxTotalHttpConnectionsPerHost: 每个服务实例最大HTTP连接数,默认值为200。
- ribbon.MaxHttpConnectionsPerServer: 每个服务实例最大HTTP连接数,默认值为200。
- ribbon.OkToRetryOnAllOperations: 是否对所有操作尝试重试,默认为true。
- ribbon.MaxAutoRetries: 自动重试次数,不包括首次调用,默认为2。
- ribbon.MaxAutoRetriesNextServer: 在当前服务实例失败后,自动重试的次数,默认为1。
- ribbon.Interceptor: 可以添加自定义拦截器,用于修改请求或响应。
- ribbon.ConnectTimeout: 连接超时时间,单位为毫秒,默认为1000。
- ribbon.ReadTimeout: 读取超时时间,单位为毫秒,默认为5000。
四、Ribbon负载均衡策略
Spring Cloud Ribbon 提供了多种内置的负载均衡策略,以及支持自定义策略。以下是一些常用的内置负载均衡策略及其描述:
- 轮询策略(RoundRobinRule): 这是默认的负载均衡策略,它按照顺序轮流将请求分配给服务列表中的各个实例。
- 随机策略(RandomRule): 该策略会随机地从服务列表中选择一个实例来处理请求。
- 权重响应时间策略(WeightedResponseTimeRule): 该策略会考虑到每个服务实例的平均响应时间,响应时间越短的实例获得的权重越大,从而被选中的概率越高。
- 重试策略(BestAvailableRule): 这种策略会首先排除掉最近一次调用失败过的实例,然后从剩余的实例中选择一个响应时间最短的实例进行调用。如果所有实例最近都失败过,它会随机选择一个。
- 可用性过滤策略(AvailabilityFilteringRule): 该策略会排除掉最近一段时间内一直不健康的实例,然后从剩余的健康实例中按照权重来进行选择。
这些策略可以通过设置ribbon.NFLoadBalancerRuleClassName属性来指定,例如在application.yml文件中配置如下:
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.WeightedResponseTimeRule
五、Ribbon自定义负载均衡策略
Ribbon也允许开发者通过实现IRule接口来自定义负载均衡规则。自定义的策略可以通过实现自己的规则类,并在配置文件中指定该类的全路径来使用。下面是一个简单的自定义负载均衡规则的例子,这个规则会总是选择列表中第一个可用的服务实例:
public class MyCustomRule implements IRule {
@Override
public Server choose(Object key) {
// 获取可用的服务实例列表
Server server = null;
List<Server> servers = getServerList();
if (!servers.isEmpty()) {
// 选择列表中的第一个实例
server = servers.get(0);
}
return server;
}
private List<Server> getServerList() {
// 这里可以添加获取服务列表的逻辑,例如从Eureka获取
// 为了示例简单,这里直接返回空列表
return null;
}
}
接下来,你需要在Spring Boot的配置文件中指定这个自定义规则类。在application.yml中添加以下配置:
ribbon:
NFLoadBalancerRuleClassName: com.yourpackage.MyCustomRule
六、Ribbon的Ping机制
Ribbon的Ping机制是用来检测后端服务实例是否健康的一种机制。Ribbon通过定期发送Ping请求到服务实例上,来判断服务实例是否存活并且能够处理请求。如果Ping请求成功,则认为该服务实例是健康的;如果失败,则认为该实例是不健康的,并且在负载均衡时不会被选中。默认情况下,Ribbon 使用简单的 HTTP 请求(通常是 GET 请求到 / 路径)来检测服务实例。但是,这种方法可能不适用于所有的服务。在一些场景下,你可能需要执行更复杂的检查,这时开发者可以自定义Ping操作,通过继承DummyPing或实现IPing接口,并重写isAlive方法来实现,以确定服务实例是否能够接受请求。以下是一个自定义Ping操作的简单示例:文章来源:https://www.toymoban.com/news/detail-829136.html
public class CustomPing implements IPing {
@Override
public boolean isAlive(Server server) {
String url = "http://" + server.getId() + "/healthCheck";
boolean isAlive;
HttpClient httpClient = new DefaultHttpClient();
HttpUriRequest request = new HttpGet(url);
try {
HttpResponse response = httpClient.execute(request);
isAlive = response.getStatusLine().getStatusCode() == 200;
} catch (Exception e) {
isAlive = false;
} finally {
request.abort();
}
return isAlive;
}
}
然后,需要在Spring Boot的配置文件中指定这个自定义的Ping实现类。在application.yml中添加以下配置:文章来源地址https://www.toymoban.com/news/detail-829136.html
ribbon:
NFLoadBalancerPingClassName: com.yourpackage.CustomPing
七、Ribbon结合Eureka实现客户端负载均衡调用
1.添加依赖
<!--Spring Cloud Ribbon 依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
<version>2.2.9.RELEASE</version>
</dependency>
<!--Spring Cloud Eureka 客户端依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
2.注入RestTemplate,通过@LoadBalanced注解开启负载均衡
@Configuration
public class RestTemplateConfiguration {
@Bean
@LoadBalanced //在客户端使用 RestTemplate 请求服务端时,开启负载均衡(Ribbon)
public RestTemplate restTemplate(){
return new RestTemplate();
}
}
3.设置配置文件application.properties
server:
port: 80
# eureka配置
eureka:
client:
register-with-eureka: false # 本微服务为服务消费者,不需要将自己注册到服务注册中心
fetch-registry: true # 本微服务为服务消费者,需要到服务注册中心搜索服务
service-url:
defaultZone: http://eureka.com:8001/eureka/,http://eureka.com:8002/eureka/ #服务注册中心集群
4.接口调用
@GetMapping
public String getMessage(){
String url="http://test-service/message";
String message=restTemplate.getForObject(url,String.class);
return message;
}
到了这里,关于SpringCloud--Ribbon解析的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!