SpringCloud学习笔记(三)

SpringCloud学习笔记(一)

1.Ribbon 概述

Spring Cloud Ribbon 是一个基于 HTTP 和 TCP 的客户端负载均衡工具，它基于 NetflixRibbon 实现。通过 Spring Cloud 的封装，可以让我们轻松地将面向服务的 REST 模版请求自动转换成客户端负载均衡的服务调用。 轮询 hash 权重 …简单的说 Ribbon 就是 netfix 公司的一个开源项目，主要功能是提供客户端负载均衡算法和服务调用。Ribbon 客户端组件提供了一套完善的配置项，比如连接超时，重试等。

在 Spring Cloud 构建的微服务系统中， Ribbon 作为服务消费者的负载均衡器，有两种使用方式，一种是和 RestTemplate 相结合，另一种是和 OpenFeign 相结合。OpenFeign 已经默认集成了 Ribbon,关于 OpenFeign 的内容将会在下一章进行详细讲解。Ribbon 有很多子模块，但很多模块没有用于生产环境!

2.负载均衡

负载均衡，英文名称为 Load Balance（LB）http:// lb://（负载均衡协议） ，其含义就是指将负载（工作任务）进行平衡、分摊到多个操作单元上进行运行，例如 Web 服务器、企业核心应用服务器和其它主要任务服务器等，从而协同完成工作任务。负载均衡构建在原有网络结构之上，它提供了一种透明且廉价有效的方法扩展服务器和网络设备的带宽、加强网络数据处理能力、增加吞吐量、提高网络的可用性和灵活性。

3.Ribbon 快速入门

3.1 本次调用设计图

3.2 项目搭建

consumer 和 provider-1 和 provider-2 都是 eureka-client
注意这三个依赖是 eureka-client
注意 provider-1 和 provider-2 的 spring.application.name=provider
注意启动类的注解和配置文件的端口以及服务名称

3.3 创建 provider-1和provider-2

创建时候添加eureka Client的依赖和Web依赖。
修改端口号，不能相同。

3.4 编写 provider-1 和 provider-2

同理provider-B也一样

3.5 创建 consumer

额外添加依赖：

<dependency>
        <groupId>org.springframework.cloudgroupId>
        <artifactId>spring-cloud-starter-netflix-ribbonartifactId>
        <version>2.2.9.RELEASEversion>
dependency>
1
2
3
4
5

3.6 编写 consumer 的启动类

@SpringBootApplication
@EnableEurekaClient
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14

3.7 编写 consumer 的 ConsumerController

@RestController
public class ConsumerController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("testRibbon")
    public String consumerA(String providerName){
        String url="http://"+providerName+"/test";
        String result = restTemplate.getForObject(url, String.class);
        return result;
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14

3.8 启动测试

先启动注册中心服务。

访问页面
刷新页面

可以看得出是通过轮询的方式实现负载均衡。

4.Ribbon 分析

4.1 Ribbon 要做什么事情？

先通过 “http://” + serviceId + “/info” 我们思考 ribbon 在真正调用之前需要做什么？
restTemplate.getForObject(“http://provider/info”, String.class);
想要把上面这个请求执行成功，我们需要以下几步

1. 拦截该请求；
2. 获取该请求的 URL 地址:http://provider/info
3. 截取 URL 地址中的 provider
4. 从服务列表中找到 key 为 provider 的服务实例的集合(服务发现)
5. 根据负载均衡算法选出一个符合的实例
6. 拿到该实例的 host 和 port，重构原来 URL 中的 provider
7. 真正的发送 restTemplate.getForObject(“http://ip:port/info”，String.class)

5.如何修改默认的负载均衡算法

5.1 修改 yml 配置文件（指定某一个服务使用什么算法）

provider: # 提供者的服务名称 , 那么访问该服务的时候就会按照自定义的负载均衡算法
ribbon:
NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
# 几种算法的全限定类名
1
2
3
4

5.2 测试调用该服务（这里使用随机规则）

5.3 配置此消费者调用任何服务都用某种算法

@Bean
public IRule myRule() {
// 指定调用所有的服务都用此算法
return new RandomRule();
}
1
2
3
4
5

6.Ribbon 的配置文件和常用配置

Ribbon 有很多默认的配置，查看 DefaultClientConfigImpl

ribbon: # 全局的设置
	eager-load:
		enabled: false # ribbon 一启动不会主动去拉取服务列表，当实际使用时才
去拉取 是否立即加载
http:
	client:
		enabled: false # 在 ribbon 最后要发起 Http 的调用调用，我们认为是
RestTemplate 完成的，其实最后是 HttpURLConnection 来完成的，这里面设置为 true ，
可以把 HttpUrlConnection->HttpClient
okhttp:
	enabled: false #HttpUrlConnection 来完成的，这里面设置为 true ，可以
把 HttpUrlConnection->OkHttpClient( 也是发 http 请求的，它在移动端的开发用的多 )
provider: # 提供者的服务名称 , 那么访问该服务的时候就会按照自定义的负载均衡算法
	ribbon:
		NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
# 修改默认负载均衡算法，几种算法的全限定类名
# NFLoadBalancerClassName: #loadBalance 策略
# NFLoadBalancerPingClassName: #ping 机制策略
# NIWSServerListClassName: # 服务列表策略
# NIWSServerListFilterClassName: # 服务列表过滤策略
ZonePreferenceServerListFilter 默认是优先过滤非一个区的服务列表
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

7.Ribbon 总结（后面的代码中 不会出现 ribbon）

Ribbon 是客户端实现负载均衡的远程调用组件，用法简单
Ribbon 源码核心：
ILoadBalancer 接口：起到承上启下的作用

1. 承上：从 eureka 拉取服务列表
2. 启下：使用 IRule 算法实现客户端调用的负载均衡

设计思想：每一个服务提供者都有自己的 ILoadBalanceruserService—》客户端有自己的 ILoadBalancer
TeacherService—》客户端有自己的 ILoadBalancer在客户端里面就是 Map iLoadBalancersMap iLoadBalancers 消费者端服务提供者的名称 value （服务列表 算法规则 ）
如何实现负载均衡的呢？
iloadBalancer loadbalance = iloadBalancers.get(“user-service”)List servers = Loadbalance.getReachableServers();//缓存起来
Server server = loadbalance .chooseServer(key) //key 是区 id，–》IRule 算法chooseServer 下面有一个 IRule 算法
IRule 下面有很多实现的负载均衡算法
你就可以使用 eureka+ribbon 做分布式项目