Spring Cloud Ribbon
是一个基于Http
和TCP
的客户端负载均衡工具,基于Netflix Ribbon
实现的。它不像服务注册中心、配置中心、API网关那样独立部署,但是它几乎存在于每个微服务的基础设施中。
Ribbon架构图
Ribbon负载均衡策略
Ribbon
默认的策略是轮询,我们可以自定义负载策略来覆盖默认的,当然也可以通过配置指定使用哪些策略。
负载均衡概念
负载均衡技术在现有网络结构之上提供了一种廉价、有效、透明的方法,来扩展网络设备和服务器的带宽、增加吞吐量、加强网络数据处理能力、提高网络的灵活性和可用性。它有两方面的含义:首先,大量的并发访问或数据流量分担到多台节点设备上分别处理,减少用户等待响应的时间;其次,单个重负载的运算分担到多台节点设备上做并行处理,每个节点设备处理结束后,将结果汇总,返回给用户,系统处理能力得到大幅度提高。
负载均衡是对系统的高可用,网络压力的缓解和处理能力扩容的重要手段之一。
硬件负载均衡:
主要通过在服务节点之间安装专门的负载均衡设备,比如F5
详细参照百度百科:https://baike.baidu.com/item/F5%E6%96%B9%E6%A1%88/1121377?fr=aladdin
软件负载均衡
实现方式有两种,分别是服务端的负载均衡和客户端的负载均衡
服务端负载均衡:在服务端安装一些具有均衡负载功能或者模块的软件来完成请求的分发工作,比如Nginx
。
当浏览器向后台发出请求的时候,会首先向反向代理服务器发送请求,反向代理服务器会根据客户端部署的ip:port
映射表以及负载均衡策略,来决定向哪台服务器发送请求,一般会使用到nginx
反向代理技术。
客户端负载均衡:当浏览器向后台发出请求的时候,客户端会向服务注册器(例如Eureka Server
),拉取注册到服务器的可用服务信息,然后根据负载均衡策略,直接命中哪台服务器发送请求。这整个过程都是在客户端完成的,并不需要反向代理服务器的参与。
在微服务中最基本的两个角色是服务提供者与服务消费者。
服务提供者:服务的被调用方(为其他服务提供服务的服务)
服务消费者:服务的调用方(依赖其他服务的服务)
之前我们已经尝试了好几种服务注册方式,注册了服务,肯定需要被调用的,也就是消费。
服务调用方式实现方式RestTemplate+Ribbon
使用RestTemplate
消费SpringBoot
的Restful
服务
前提
需要一个服务注册中心,两个服务提供者和一个消费者
因为只有两个以上的服务提供者提供相同的服务才可以体现出负载均衡
服务注册中心和服务提供者都使用Spring Cloud Eureka
实现服务提供者的Restful接口
之前已经实现过服务注册中心和服务提供者
不过之前的服务提供者并没有提供接口给消费者使用
@RestController
public class DiscoveryController {
@Autowired
private DiscoveryClient discoveryClient;
@Value("${server.port}")
private String ip;
@GetMapping("/client")
public String client() {
String services = "调用的服务是: " + discoveryClient.getServices()+" 对应的端口号 :"+ip;
System.out.println("调用的服务是: " + discoveryClient.getServices()+" 对应的端口号 :"+ip);
return services;
}
}
实现服务消费者Ribbon
一开始肯定打算是引入Spring Cloud Ribbon
依赖,不过Spring Cloud Eureka
依赖中已经有Ribbon
的依赖了。单独引入Ribbon
依赖可能注册不了服务
在项目的外部
Jar
包目录中可以发现Spring Cloud Eureka
依赖中已经有Ribbon
的依赖了
所以,主要引入的依赖和Eureka客户端的一样
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
在项目启动类上添加@EnableEurekaClient
注解,消费者和服务提供者一样,都需要到注册中心中注册
并且使用@bean
像Spring
容器中注入一个restTemplate
对象,@LoadBalanced
注解表明这个restRemplate
开启负载均衡的功能。
@SpringBootApplication
@EnableEurekaClient
public class SpringcloudConsumerRibbonApplication {
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
return new RestTemplate();
}
public static void main(String[] args) {
SpringApplication.run(SpringcloudConsumerRibbonApplication.class, args);
}
}
下面来写一个简单的服务消费类
@RestController
public class RibbonController {
@Autowired
RestTemplate restTemplate;
@GetMapping("/consumer")
public String getMsg() {
return restTemplate.getForObject("http://springcloud-eureka-client/client", String.class);
}
}
restTemplate
可以发送Get
,Post
,Put
,Delete
等请求Get
调用getForEntity()
方法Post
调用postForObject()
方法Put
调用put()
方法Delete
调用delete()
方法
getForEntity
的第一个参数为我要调用的服务的地址,这里我调用了服务提供者提供的/client
接口(Eureka
客户端中已写好),getForEntity
第二个参数String.class
表示我希望返回的body
类型是String
注意这里是通过服务名调用而不是服务地址,如果写成服务地址就没法实现客户端负载均衡了。
调用spring boot
服务的时候,需要将服务的URL
写死或者是写在配置文件中,一旦ip
地址发生了变化,都需要改动程序,并重新部署服务,使用Ribbon
的时候,可以有效的避免这个问题。
restTemplate
的所有用法可以参考
官方说明文档:https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/web/client/RestTemplate.html
在配置文件中加入相关配置
spring:
application:
name: eureka-consumer-ribbon
server:
port: 9999
eureka:
client:
service-url:
defaultZone: http://localhost:9090/eureka
整体项目结构
Eureka服务端 端口号是9090
两个Eureka客户端 端口号分别是8081
和8082
相同的服务名springcloud-eureka-client
Ribbon消费者客户端 端口号是9999
启动服务进行测试
先启动服务端再启动客户端,客户端启动顺序没要求
访问http://localhost:9090服务注册中心
在服务注册中心可以看到,服务提供者和消费者都注册好了
对服务提供者的Restful
服务进行消费
访问http://localhost:9999/consumer可以看到消费的服务名和端口
刷新下页面
继续刷新就调用另一个端口的服务了
我试着刷新了11次页面,在控制台可以看到调用情况
说明已经消费了Eureka
客户端提供的服务,而且Ribbon
已经默认实现了负载均衡
在整个程序中,最关键的就是在RestTemplate上标记的@LoadBalanced
注解,Spring Cloud Ribbon
通过注解@LoadBalanced
来实现负载均衡
深入了解@LoadBalanced
注解可以参考:
https://blog.csdn.net/qq_26562641/article/details/53332269