转载

Ribbon（客户端负载均衡）

Ribbon - 客户端负载均衡

简介

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。它是一个基于HTTP和TCP的客户端负载均衡器。它可以通过在客户端中配置ribbonServerList来设置服务端列表去轮询访问以达到均衡负载的作用。

使用（消费端）

导入依赖

<groupId>org.springframework.cloud </groupId>

<artifactId>spring-cloud-starter-netflix-eureka-client </artifactId>

</dependency>

<groupId>org.springframework.cloud </groupId>

<artifactId>spring-cloud-starter-netflix-ribbon </artifactId>

</dependency>

在消费端添加如下配置，用来从eureka集群中轮询请求可访问的微服务，不用注册到eureka中，配置如下：

server:

port: 8003

servlet:

context-path: /dept-consumer

eureka: # 配置eureka客户端，不用注册到eureka中

client:

serviceUrl:

defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/,http://eureka7001.com:7001/eureka/ # eureka的暴露地址，指向集群中每一个eureka，多个用都好分隔

在restTemplate的配置类中添加一个注解@LoadBalanced，配置如下：

import org.springframework.cloud.client.loadbalancer.LoadBalanced;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.http.client.ClientHttpRequestFactory;

import org.springframework.http.client.SimpleClientHttpRequestFactory;

import org.springframework.web.client.RestTemplate;

/**

* RestTemplate的配置类

* @author 陈加兵

* @since 2018年12月6日下午6:10:58

@Configuration

public class RestConfig

@Bean

@LoadBalanced //ribbon实现客户端的负载均衡，默认使用的是轮询的算法

public RestTemplate restTemplate(ClientHttpRequestFactory factory)

return new RestTemplate(factory);

@Bean

public ClientHttpRequestFactory simpleClientHttpRequestFactory()

SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();

factory.setReadTimeout( 5000); //单位为ms

factory.setConnectTimeout( 5000); //单位为ms

return factory;

在主启动类上添加@EnableEurekaClient注解

@SpringBootApplication

@EnableEurekaClient

public class EurekaClientApplication

public static void main(String[] args)

SpringApplication.run(EurekaClientApplication.class, args);

消费者的controller端直接使用微服务的名称访问即可，ribbon会自动根据名称在eureka中查询指定的微服务，不需要写明微服务的ip了，如下：

@RestController

public class DeptController

@Resource

private RestTemplate restTemplate;

//请求路径直接使用微服务的名称即可EUREKA-PROVIDER，eureka-provider是微服务的项目名称(servlet.context-path)

private final static String URI_PREFIX= "http://EUREKA-PROVIDER/eureka-provider";

/**

* 使用RestTemplate发出get请求

@GetMapping( "/dept/ id ")

public Dept getDept(@PathVariable("id")Integer id) throws RestClientException, URISyntaxException

Map<String, Object> params= new HashMap<String, Object>();

params.put( "id", id);

Dept dept = restTemplate.getForObject(URI_PREFIX+ "/dept/ id ", Dept.class, params);

return dept;

创建两个提供者，提供相同的服务，使用同一个微服务的名称（EUREKA-PROVIDER），这个就相当于是一个集群了，需要改变的就是端口和instance-id，配置如下：

第一个服务提供者

server:

port: 8001

servlet:

context-path: /eureka-provider # 访问的项目名称在配置“集群”的时候也是必须一样的，否则不好调用

eureka:

client:

serviceUrl:

defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/,http://eureka7001.com:7001/eureka/ # eureka的暴露地址，直接注册，使用的是eureka的集群

instance:

instance-id: eureka-provider:8001 ## instance-id区别服务

prefer-ip-address: true ## 访问路径可以显示服务主机的IP地址

spring:

application:

name: eureka-provider #微服务的名称，配置集群的时候必须相同

第二个服务提供者

server:

port: 8002

servlet:

context-path: /eureka-provider # 访问的项目名称在配置“集群”的时候也是必须一样的，否则不好调用

eureka:

client:

serviceUrl:

defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/,http://eureka7001.com:7001/eureka/ # eureka的暴露地址，直接注册，使用的是eureka的集群

instance:

instance-id: eureka-provider:8002 ## instance-id区别服务

prefer-ip-address: true ## 访问路径可以显示服务主机的IP地址

spring:

application:

name: eureka-provider #微服务的名称，配置集群的时候必须相同

微服务启动，如下图：

此时访问http://localhost:8003/dept/-consumer/dept/1可以发现此时的负载均衡的策略默认使用的是轮询算法

注意

负载均衡是在同一个功能的微服务中根据不同的策略选择不同的微服务，因此这些微服务对外暴露的实例名称要相同（spring.application.name）
ribbon是一个客户端的负载均衡，必须要连接eureka，才能在指定的微服务实例中按照策略选择

负载均衡算法

RoundRobinRule：轮询，默认的算法
RandomRule ：随机算法
AvailabilityFilteringRule：会先过滤掉由于多次访问故障而处于断路器跳闸状态的服务，还有并发的连接数量超过阈值的服务，然后对剩余的服务列表按照轮询策略进行访问
WeightedResponseTimeRule：根据平均响应时间计算所有的权重，响应时间越快服务权重越大被选中的概率越高，刚启动时统计信息不足，则使用轮询策略，等统计信息足够，会自动切换到WeightedResponseTimeRule
RetryRule：先按照轮询策略获取服务，如果服务获取失败则在指定时间内会进行重试，获取可用的服务
BestAvailableRule：会先过滤掉由于多次访问故障而处于断路器跳闸状态的服务，然后选择一个并发量最小的服务
ZoneAvoidanceRule：复合判断server所在区域的性能和server的可用性选择服务器