Spring Cloud 系列之负载均衡(四)
通过前几篇章节,初步认识了通过 RestTemplate
调用微服务拆分的服务的 rest
请求,进一步引入了通过 Eureka
来实现服务注册于发现(此部分的拓展内容其实还有很多,牵扯到自定义元数据及 Eureka
的自我保护等)。
那么问题来了,在实际的场景中我们会遇到很多服务端其实是存在多个副本以实现高可用,那么客户端的请求是如何做分发控制的呢?当然,朋友你肯定第一个想到的是老毛子搞的 nginx
。Nice!!nginx 确实很强大,基于 nginx 我们能做很多事情【后续我也会对 nginx 做进一步的分享:)】。在 Spring Cloud
生态圈,其实大佬们早已准备好了开箱即用的组件,就是今天的主角:**Riboon
**。
Eureka
与 Ribbon
配合的架构图
服务消费者
microservice-consumer-movie-ribbon
将之前的 microservice-consumedr-movie
整合 Ribbon
改造下。
pom
文件
由于此微服务还是Eureka
的Client
端,所以依赖中还是会存在eureka client
的依赖,同时加入新的依赖netflix-ribbon
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="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.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.5.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.kirago.sc</groupId>
<artifactId>microserver-consumer-movie-ribbon</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>microserver-consumer-movie-ribbon</name>
<description>microserver-consumer-movie-ribbon project for Spring cloud</description>
<properties>
<java.version>1.8</java.version>
<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--<dependency>-->
<!--<groupId>org.springframework.boot</groupId>-->
<!--<artifactId>spring-boot-starter-logging</artifactId>-->
<!--</dependency>-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>- 为
RestTemplate
添加@LoadBalanced
的注解进行声明。
此部分我是通过@Configuration
注解 后加入@Bean
注解,来告知应用生成这个Bean
。
此处有个知识点,可以拓展下@Configuration
的具体作用:
- 在实际的项目开发中,我引用的类可能不在当前包中那么如何处理?
- 还有我们很多时候会发现一个类被 @Configuration 注解了实际上类的内部为空,那么这个 @Configuration 存在的意思是啥,为啥需要它?
以上都是需要掌握的。
1 | package com.kirago.sc.microserverconsumermovieribbon.config; |
服务生产者
microservice-priovider-user-ribbon
在完善此 demo
的时候由于是单机本地环境,所以我们需要通过对同一个应用启动应用多个端口来来实现生成多个实例来模拟多节点多副本的场景,我是通过 IDEA
中采用配置去实现的。
具体的实现方式参考 csdn 上的一篇文章,亲测有效。
此篇 服务消费者没啥改动,所以我就不贴示例代码了。
服务注册与发现
microservice-discovery-eureka
此服务也未作任何变动,所以此部分就不重复了。:)
验证
启动 microservice-discovery-eureka
、microservice-consumer-movie-ribbon
、microservice-discovery-eureka
(我设置的副本数为2),成功运行的情况下去浏览 Eureka
服务的监控页面,会看到如下内容:
我们会发现服务生产者副本数为2,说明多副本服务创建成功了。
各位老铁应该注意到我特意标注了 A 点,这里就卖个关子,作为自己拓展思考,此处为啥会有红色字体的 Warnninng,以及这种展示是否是可控的,如果是可控的要做什么配置修改?:)
下面我们可以发送请求进一步验证下
- 对服务生产者直接请求:
此处我故意请求的是我创建的服务生产者多副本实例2,验证下服务确实可用。 - 对服务消费者发送请求:
由此验证最终结果是保持一致的。 - 通过后台日志我们其实可以发现最终的请求最终落在那个服务生产者示例上:
此次通过服务消费者消费的服务是落在服务生产者多副本的实例1上。
多啰嗦几句
此偏章节为 Eureka 结合 Ribbon 实现负载均衡,在实际的生产项目中,我们的服务器会处理性能不一致,遵循“能者多劳”的原则,我们可能要适当的对负载分发有一定的可控机制,或者由于目前容器技术 docker 的新起,一台服务器我们会尽量的压榨资源,那么在部署架构上我们已经有了规划,那么对负载分发也要有一定的可控机制去实现,这些在实际的生产过程中我认为都是需要考虑的。
示例代码链接