Spring Cloud Ribbon(服务消费者)

本文涉及的产品
网络型负载均衡 NLB,每月750个小时 15LCU
传统型负载均衡 CLB,每月750个小时 15LCU
应用型负载均衡 ALB,每月750个小时 15LCU
简介: Spring Cloud Ribbon 是一个基于Http和TCP的客户端负载均衡工具,基于Netflix Ribbon实现的。它不像服务注册中心、配置中心、API网关那样独立部署,但是它几乎存在于每个微服务的基础设施中。

Spring Cloud Ribbon 是一个基于HttpTCP的客户端负载均衡工具,基于Netflix Ribbon实现的。它不像服务注册中心、配置中心、API网关那样独立部署,但是它几乎存在于每个微服务的基础设施中。

Ribbon架构图

1258b858-c697-32e3-8f9e-b2623f7c6862.png

Ribbon负载均衡策略

6944619-0355d316f5df9b3f.png

Ribbon默认的策略是轮询,我们可以自定义负载策略来覆盖默认的,当然也可以通过配置指定使用哪些策略。

负载均衡概念

负载均衡技术在现有网络结构之上提供了一种廉价、有效、透明的方法,来扩展网络设备和服务器的带宽、增加吞吐量、加强网络数据处理能力、提高网络的灵活性和可用性。它有两方面的含义:首先,大量的并发访问或数据流量分担到多台节点设备上分别处理,减少用户等待响应的时间;其次,单个重负载的运算分担到多台节点设备上做并行处理,每个节点设备处理结束后,将结果汇总,返回给用户,系统处理能力得到大幅度提高。

负载均衡是对系统的高可用,网络压力的缓解和处理能力扩容的重要手段之一。

硬件负载均衡:

主要通过在服务节点之间安装专门的负载均衡设备,比如F5
详细参照百度百科:https://baike.baidu.com/item/F5%E6%96%B9%E6%A1%88/1121377?fr=aladdin

软件负载均衡

实现方式有两种,分别是服务端的负载均衡和客户端的负载均衡
服务端负载均衡:在服务端安装一些具有均衡负载功能或者模块的软件来完成请求的分发工作,比如Nginx

当浏览器向后台发出请求的时候,会首先向反向代理服务器发送请求,反向代理服务器会根据客户端部署的ip:port映射表以及负载均衡策略,来决定向哪台服务器发送请求,一般会使用到nginx反向代理技术。

QQ截图20180626191547.png

客户端负载均衡:当浏览器向后台发出请求的时候,客户端会向服务注册器(例如Eureka Server),拉取注册到服务器的可用服务信息,然后根据负载均衡策略,直接命中哪台服务器发送请求。这整个过程都是在客户端完成的,并不需要反向代理服务器的参与。

在微服务中最基本的两个角色是服务提供者与服务消费者。
服务提供者:服务的被调用方(为其他服务提供服务的服务)
服务消费者:服务的调用方(依赖其他服务的服务)

之前我们已经尝试了好几种服务注册方式,注册了服务,肯定需要被调用的,也就是消费。
服务调用方式实现方式RestTemplate+Ribbon
使用RestTemplate消费SpringBootRestful服务

前提

需要一个服务注册中心,两个服务提供者和一个消费者
因为只有两个以上的服务提供者提供相同的服务才可以体现出负载均衡
服务注册中心和服务提供者都使用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依赖可能注册不了服务

QQ截图20180626163952.png

在项目的外部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注解,消费者和服务提供者一样,都需要到注册中心中注册
并且使用@beanSpring容器中注入一个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可以发送GetPostPutDelete等请求
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客户端 端口号分别是80818082 相同的服务名springcloud-eureka-client
Ribbon消费者客户端 端口号是9999

启动服务进行测试

先启动服务端再启动客户端,客户端启动顺序没要求
访问http://localhost:9090服务注册中心

QQ截图20180626171326.png

在服务注册中心可以看到,服务提供者和消费者都注册好了

对服务提供者的Restful服务进行消费

访问http://localhost:9999/consumer可以看到消费的服务名和端口

QQ截图20180626171745.png

刷新下页面
QQ截图20180626171834.png

继续刷新就调用另一个端口的服务了
我试着刷新了11次页面,在控制台可以看到调用情况
QQ截图20180626172315.png

QQ截图20180626172322.png

说明已经消费了Eureka客户端提供的服务,而且Ribbon已经默认实现了负载均衡

在整个程序中,最关键的就是在RestTemplate上标记的@LoadBalanced注解,Spring Cloud Ribbon通过注解@LoadBalanced 来实现负载均衡

深入了解@LoadBalanced注解可以参考:
https://blog.csdn.net/qq_26562641/article/details/53332269

相关实践学习
SLB负载均衡实践
本场景通过使用阿里云负载均衡 SLB 以及对负载均衡 SLB 后端服务器 ECS 的权重进行修改,快速解决服务器响应速度慢的问题
负载均衡入门与产品使用指南
负载均衡(Server Load Balancer)是对多台云服务器进行流量分发的负载均衡服务,可以通过流量分发扩展应用系统对外的服务能力,通过消除单点故障提升应用系统的可用性。 本课程主要介绍负载均衡的相关技术以及阿里云负载均衡产品的使用方法。
目录
相关文章
|
2月前
|
存储 数据可视化 Java
基于MicrometerTracing门面和Zipkin实现集成springcloud2023的服务追踪
Sleuth将会停止维护,Sleuth最新版本也只支持springboot2。作为替代可以使用MicrometerTracing在微服务中作为服务追踪的工具。
133 1
|
16天前
|
消息中间件 监控 Java
如何将Spring Boot + RabbitMQ应用程序部署到Pivotal Cloud Foundry (PCF)
如何将Spring Boot + RabbitMQ应用程序部署到Pivotal Cloud Foundry (PCF)
31 6
|
16天前
|
Java 关系型数据库 MySQL
如何将Spring Boot + MySQL应用程序部署到Pivotal Cloud Foundry (PCF)
如何将Spring Boot + MySQL应用程序部署到Pivotal Cloud Foundry (PCF)
36 5
|
16天前
|
缓存 监控 Java
如何将Spring Boot应用程序部署到Pivotal Cloud Foundry (PCF)
如何将Spring Boot应用程序部署到Pivotal Cloud Foundry (PCF)
27 5
|
4月前
|
缓存 NoSQL Java
【Azure Redis 缓存】示例使用 redisson-spring-boot-starter 连接/使用 Azure Redis 服务
【Azure Redis 缓存】示例使用 redisson-spring-boot-starter 连接/使用 Azure Redis 服务
|
1月前
|
JSON Java 测试技术
SpringCloud2023实战之接口服务测试工具SpringBootTest
SpringBootTest同时集成了JUnit Jupiter、AssertJ、Hamcrest测试辅助库,使得更容易编写但愿测试代码。
58 3
|
1月前
|
负载均衡 算法 Java
除了 Ribbon,Spring Cloud 中还有哪些负载均衡组件?
这些负载均衡组件各有特点,在不同的场景和需求下,可以根据项目的具体情况选择合适的负载均衡组件来实现高效、稳定的服务调用。
67 5
|
13天前
|
负载均衡 Java Nacos
常见的Ribbon/Spring LoadBalancer的负载均衡策略
自SpringCloud 2020版起,Ribbon被弃用,转而使用Spring Cloud LoadBalancer。Ribbon支持轮询、随机、加权响应时间和重试等负载均衡策略;而Spring Cloud LoadBalancer则提供轮询、随机及Nacos负载均衡策略,基于Reactor实现,更高效灵活。
34 0
|
3月前
|
消息中间件 存储 Java
SpringCloud基础9——服务异步通信-高级篇
消息可靠性、死信交换机、惰性队列、MQ集群
SpringCloud基础9——服务异步通信-高级篇
|
3月前
|
Java API 对象存储
微服务魔法启动!Spring Cloud与Netflix OSS联手,零基础也能创造服务奇迹!
这段内容介绍了如何使用Spring Cloud和Netflix OSS构建微服务架构。首先,基于Spring Boot创建项目并添加Spring Cloud依赖项。接着配置Eureka服务器实现服务发现,然后创建REST控制器作为API入口。为提高服务稳定性,利用Hystrix实现断路器模式。最后,在启动类中启用Eureka客户端功能。此外,还可集成其他Netflix OSS组件以增强系统功能。通过这些步骤,开发者可以更高效地构建稳定且可扩展的微服务系统。
60 1