服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

这篇具有很好参考价值的文章主要介绍了服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1、Ribbon背景介绍

Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等。简单来说,就是在配置文件中列出Load Balancer(简称LB)后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随即连接等)去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。

现在的很多RPC框架,向Duobbo、JSF都是采用类似思想进行实现的。

2、常见负载均衡方案

目前主流的负载均衡方案可分成两类。

2.1 集中式负载均衡

一种是集中式LB, 即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件,如F5, 也可以是软件,如nginx, 由该设施负责把访问请求通过某种策略转发至服务的提供方。

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

2.2 进程式负载均衡

另一种是进程内LB,将LB逻辑集成到消费方,消费方从服务注册中心获知有哪些地址可用,然后自己再从这些地址中选择出一个合适的服务器。Ribbon就属于后者,它只是一个类库,集成于消费方进程,消费方通过它来获取到服务提供方的地址。

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

3、Ribbon的核心组件

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

Ribbon 主要有6大功能组件:LoadBalance、ServerList、Rule、Ping、ServerListFilter、ServerListUpdater。

3.1 负载均衡器 LoadBalancer

用于管理负载均衡的组件。初始化的时候通过加载 YMAL 配置文件创建出来的。

3.2 服务列表 ServerList

ServerList 主要用来获取所有服务的地址信息,并保存到本地。根据获取服务信息的方式不同,又分为静态存储和动态存储。

※静态存储

 从配置文件中获取服务节点列表并存储到本地。

※动态存储

从注册中心获取服务节点列表并存储到本地。

3.3 服务列表过滤 ServerListFilter

将获取到的服务列表按照过滤规则过滤。通过 Eureka 的分区规则对服务实例进行过滤。

比较服务实例的通信失败数和并发连接数来剔除不够健康的实例,根据所属区域过滤出同区域的服务实例。

3.4 服务列表更新 ServerListUpdater

服务列表更新就是 Ribbon 会从注册中心获取最新的注册表信息。是由这个接口 ServerListUpdater 定义的更新操作。而它有两个实现类,也就是有两种更新方式:

1) 通过定时任务进行更新。由这个实现类 PollingServerListUpdater 做到的。

2)利用 Eureka 的事件监听器来更新。由这个实现类 EurekaNotificationServerListUpdater 做到的。

3.5 心跳检测 Ping

IPing 接口类用来检测哪些服务可用。如果不可用了,就剔除这些服务。实现类主要有这几个:PingUrl、PingConstant、NoOpPing、DummyPing、NIWSDiscoveryPing。心跳检测策略对象 IPingStrategy,默认实现是轮询检测。

3.6 负载均衡策略 Rule

Ribbon 的负载均衡策略和之前讲过的负载均衡策略有部分相同,见第4节,看下Ribbon有哪些负载均衡策略。

4、Ribbon提供的主要负载均衡策略介绍

 

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

4.1 简单轮询负载均衡(RoundRobin)

以轮询的方式依次将请求调度不同的服务器,即每次调度执行i = (i + 1) mod n,并选出第i台服务器。轮流依次请求不同的服务器。优点是无需记录当前所有连接的状态,无状态调度;

4.2 随机负载均衡 (Random)

随机选择状态为UP的Server。随机选择服务器。适合并发比较大的场景。

4.3 加权响应时间负载均衡 (WeightedResponseTime)

每个服务按响应时长自动分配权重,响应时间越长,权重越低,被选中的概率越低;

4.4 区域感知轮询负载均衡(ZoneAvoidanceRule)

更倾向于选择发出调用的服务所在的托管区域内的服务,降低延迟,节省成本。Spring Cloud Ribbon 中默认的策略;区域感知负载均衡(ZoneAvoidanceRule):更倾向于选择发出调用的服务所在的托管区域内的服务,降低延迟,节省成本。Spring Cloud Ribbon 中默认的策略;

4.5 重试负载均衡(RetryRule)

通过轮询均衡策略选择一个服务器,如果请求失败或响应超时,可以选择重试当前服务节点,也可以选择其他节点;

4.6 高可用均衡(BestAvailableRule)

忽略请求失败的服务器,尽量找并发比较低的服务器。注意:这种会给服务器集群带来成倍的压力;

5、Spring Cloud Ribbon是什么

既然有了Ribbon, 怎么又出来一个Spring Cloud Ribbon呢?

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

通过Spring Cloud的封装,可以让我们轻松地将面向服务的REST模版请求自动转换成客户端负载均衡的服务调用。Spring Cloud Ribbon虽然只是一个工具类框架,它不像服务注册中心、配置中心、API网关那样需要独立部署,但是它几乎存在于每一个Spring Cloud构建的微服务和基础设施中。因为微服务间的调用,API网关的请求转发等内容,实际上都是通过Ribbon来实现的,无需单独部署。

6、准备工作

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

6.1 创建3个服务

本次项目示例,改造第一篇文章中的项目,使用spring-cloud-eureka-service作为服务注册中心,spring-cloud-eureka-client,复制3分,项目名称依次修改:

spring-cloud-eureka-client-1;

spring-cloud-eureka-client-2;

spring-cloud-eureka-client-3;

分别添加各自依赖,

 <dependency>

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

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

</dependency>

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

6.2 添加启动类和Controller

在3个项目中:分别添加各自启动类和Controller类,并使用ribbon做均衡需要测试需要使用到。

代码示例(spring-cloud-eureka-client-1 为例),

//启动类

package com.xintu.springcloud;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.EnableEurekaClient;



@SpringBootApplication

@EnableEurekaClient//代表自己是一个服务提供方

public class SpringCloudEurekaClient1App { //其他两个类名为:SpringCloudEurekaClient2App 、SpringCloudEurekaClient3App



public static void main(String[] args) {

SpringApplication.run(SpringCloudEurekaClient1App.class, args);

}



}
// controller

package com.xintu.springcloud.controller;



import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;



@RestController

@RequestMapping("/xintu")

public class HelloWorldController {

@RequestMapping("/hello")

public String helloWorld(String s){

System.out.println("传入的值为:"+s);

return "传入的值为-1:"+s; //其他两个改为传入的值为-2,传入的值为-3

}

}

6.3 修改YML配置文件

在3个项目中,分别添加yml并修改server: port:端口依次为8711,8712,8713

#指定应用名称

spring:

application:

name: eureka-service



server:

port: 8711 # 服务提供方



# 指定当前eureka客户端的注册地址,

eureka:

instance:

hostname: localhost

client:

service-url:

defaultZone: http://${eureka.instance.hostname}:8700/eureka

7、添加Ribbon消费者

7.1 添加依赖

新建 module, 命名为springcloud-ribbon-consumer,

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

在pom文件中,添加如下依赖,

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

<dependency>
	<groupId>com.xintu.springcloud</groupId>
	<artifactId>springcloud-common</artifactId> //这个为7.2节的module
	<version>0.0.1-SNAPSHOT</version>
</dependency>

7.2 添加公共负载平衡module(提高模块的代理复用性)

新建module, 命名为springcloud-common。

package com.xintu.springcloud.configuration;

import com.netflix.loadbalancer.BestAvailableRule;

import com.netflix.loadbalancer.IRule;

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;



/**

* 配置负载均衡模板

*/

@Configuration

public class RestTemplateConfiguration {



/**

* 公共负载均衡

* @return

*/

@LoadBalanced //b表示开启负载均衡

@Bean

public RestTemplate restTemplate(){

return new RestTemplate(simpleClientHttpRequestFactory());

}



/**

* 自定义配置ribbon负载均衡算法

* @return

*/

@Bean

public IRule myRule(){

//return new RoundRobinRule();//轮询

//return new RetryRule();//重试

return new BestAvailableRule();

}



@Bean

public ClientHttpRequestFactory simpleClientHttpRequestFactory() {

SimpleClientHttpRequestFactory factory

= new SimpleClientHttpRequestFactory();

//设置超时时间

factory.setReadTimeout(5000);//ms

factory.setConnectTimeout(15000);//ms

return factory;

}

}

7.3 创建启动类和controller类

// 启动类

package com.xintu.springcloud;



import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;



/**

* @author XinTu

* @classname SpringCloudRibbonConsumerApp

* @description TODO

* @date 2023年03月25日 14:30

*/



@SpringBootApplication

@EnableDiscoveryClient //向服务注册中心注册

public class SpringCloudRibbonConsumerApp {

public static void main(String[] args) {

SpringApplication.run(SpringCloudRibbonConsumerApp.class, args);

}



}
// controller类

package com.xintu.springcloud.controller;



import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.client.RestTemplate;



@RestController

@RequestMapping("/xintu")

public class RibbonConsumerController {

@Autowired

private RestTemplate restTemplate;

@RequestMapping("/hello")

public String helloWorld(){

return restTemplate.getForEntity("http://eureka-service/xintu/hello?s=123", String.class).getBody(); //eureka-service 这个为前面三个服务名,无需加ip和端口

}

}

7.4 添加YML配置完整配置 application.yml如下,

#指定应用名称

spring:

application:

name: ribbon-consumer



server:

port: 8866 # 消费方端口



# 指定当前eureka客户端的注册地址,

eureka:

instance:

hostname: localhost

client:

service-url:

defaultZone: http://${eureka.instance.hostname}:8700/eureka

7.5 测试服务

项目启动顺序:

1、springcloud-config-server

2、spring-cloud-eureka-client-1

3、spring-cloud-eureka-client-2

4、spring-cloud-eureka-client-3

5、springcloud-ribbon-consumer

启动该工程后,先访问服务注册中心,查看服务是否都已注册成功:

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

确认没问题后,开始验证,http://localhost:8866/xintu/hello。可以在浏览器频繁刷新这个地址,会发先返回内容有所不同。说明负载均衡是生效的。

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战

 

8、各种负载均衡对比

Nginx与Ribbon负载均衡的区别

8.1 服务器端负载均衡Nginx

nginx是客户端所有请求统一交给nginx,由nginx进行实现负载均衡请求转发,属于服务器端负载均衡。

既请求有nginx服务器端进行转发。

8.3 客户端负载均衡Ribbon

Ribbon是从eureka注册中心服务器端上获取服务注册信息列表,缓存到本地,让后在本地实现轮训负载均衡策略。

既在客户端实现负载均衡。

应用场景的区别:

Nginx适合于服务器端实现负载均衡 比如Tomcat ,Ribbon适合与在微服务中RPC远程调用实现本地服务负载均衡,比如Dubbo、SpringCloud中都是采用本地负载均衡。

以上! 文章来源地址https://www.toymoban.com/news/detail-441604.html

到了这里,关于服务提供者 Eureka + 服务消费者(Rest + Ribbon)实战的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Rest学习环境搭建:服务提供者

        创建一个普通的Maven项目       Controller  

    2024年02月12日
    浏览(43)
  • RpcProvider(rpc服务提供者)实现思路

    上一节说到,如何将一个本地服务发布成远程服务,但没有说明一个rpc框架怎么进行调用的,看看上节代码 现在实现的发布服务方,那么显然Login方法是rpc框架帮我们调用的,什么时候调用?当rpc客户端通过网络发送rpc调用请求之后,这边接收到rpc请求,解析请求然后调用发

    2024年02月14日
    浏览(39)
  • Eureka(F版本)教程二 服务消费者,深度好文

    service-ribbon 0.0.1-SNAPSHOT service-ribbon jar Demo project for Spring Boot java.version1.8/java.version spring-cloud.versionGreenwich.SR2/spring-cloud.version org.springframework.cloud spring-cloud-starter-netflix-eureka-client org.springframework.boot spring-boot-starter-web org.springframework.cloud spring-cloud-starter-netflix-ribbon org.springframewor

    2024年04月10日
    浏览(36)
  • 【spring cloud学习】4、创建服务提供者

    注册中心Eureka Server创建并启动之后,接下来介绍如何创建一个Provider并且注册到Eureka Server中,再提供一个REST接口给其他服务调用。 首先一个Provider至少需要两个组件包依赖:Spring Boot Web服务组件和Eureka Client组件。如下所示: Spring Boot Web服务组件用于提供REST接口服务,Eure

    2024年02月11日
    浏览(39)
  • SpringCloud学习笔记(三)_服务提供者集群与服务发现Discovery

    既然SpringCloud的是微服务结构,那么对于同一种服务,当然不可能只有一个节点,需要部署多个节点 架构图如下: 由上可以看出存在多个同一种服务提供者(Service Provider) 搭建服务提供者集群 1、参考:SpringCloud 快速入门搭建单机版的:Eureka Server、Service Provider、Service Con

    2024年02月11日
    浏览(40)
  • Java安全——安全提供者

    安全提供者 在Java中,安全提供者(Security Provider)是一种实现了特定安全服务的软件模块。它提供了一系列的加密、解密、签名、验证和随机数生成等安全功能。安全提供者基础设施在Java中的作用是为开发人员提供一种扩展和替换标准安全功能的方式,以满足特定的安全需

    2024年02月12日
    浏览(41)
  • 探索安卓内容提供者:构建、访问和管理数据【复习】

    内容提供者(ContentProvider)是Android系统四大组件之一,它是不同应用程序之间进行数据共享的标准API ,通过ContentResolver类可以访问ContentProvider中共享的数据。 ContentProvider的工作原理如下: A程序使用ContetntProvider暴露数据,才能被其他程序操作。B程序通过ContetnResolver操作A程序

    2024年02月10日
    浏览(37)
  • 移动应用开发实验-内容提供者-ContentResolver的使用

    本人将所学和前人的成果和经验结合,仅供学习和参考!!! 本文大部分源码内容有清晰的注释,请认真阅读! 通过线性布局和相对布局来搭建通讯录界面,界面效果如下图所示。创建布局文件contact_item.xml、导入界面图片、放置界面控件、创建条目界面的背景文件。创建

    2024年02月08日
    浏览(52)
  • 【云计算学习教程】用户如何使用云服务产品?_云服务消费者从云服务提供商或者云服务代理商那里租赁云服务产品在合同期内和

    先自我介绍一下,小编浙江大学毕业,去过华为、字节跳动等大厂,目前阿里P7 深知大多数程序员,想要提升技能,往往是自己摸索成长,但自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前! 因此收集整理了一份《2024年最新大数据全套学习资料》,

    2024年04月25日
    浏览(48)
  • 简单步骤:Android studio 内容提供者 - 实现建立手机通讯录界面,读取系统联系人

    提示:本篇文章将会尽量保持精简,同时请诸位敲写代码时保持耐心,三连是最大的支持! 文章目录 前言 一、项目介绍 二、使用步骤 1.创建程序 2.添加 recyclerview-v7 库 3.放置界面控件 4.搭建界面布局 5.封装实体类 6.编写数据适配器 7.实现显示界面数据功能 8.去掉默认标题栏

    2024年02月08日
    浏览(57)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包