SpringCloud 微服务全栈体系（二）

第三章 Eureka 注册中心

  • 假如我们的服务提供者 user-service 部署了多个实例，如图：

在这里插入图片描述

  • 思考几个问题：

    • order-service 在发起远程调用的时候，该如何得知 user-service 实例的 ip 地址和端口？
    • 有多个 user-service 实例地址，order-service 调用时该如何选择？
    • order-service 如何得知某个 user-service 实例是否依然健康，是不是已经宕机？

一、Eureka 的结构和作用

  • 这些问题都需要利用 SpringCloud 中的注册中心来解决，其中最广为人知的注册中心就是 Eureka，其结构如下：

在这里插入图片描述

  • 回答之前的各个问题：

  • 问题 1：order-service 如何得知 user-service 实例地址？

    • 获取地址信息的流程如下：

      • user-service 服务实例启动后，将自己的信息注册到 eureka-server（Eureka 服务端）。这个叫服务注册
      • eureka-server 保存服务名称到服务实例地址列表的映射关系
      • order-service 根据服务名称，拉取实例地址列表。这个叫服务发现或服务拉取

  • 问题 2：order-service 如何从多个 user-service 实例中选择具体的实例？

    • order-service 从实例列表中利用负载均衡算法选中一个实例地址
    • 向该实例地址发起远程调用

  • 问题 3：order-service 如何得知某个 user-service 实例是否依然健康，是不是已经宕机？

    • user-service 会每隔一段时间（默认 30 秒）向 eureka-server 发起请求，报告自己状态，称为心跳
    • 当超过一定时间没有发送心跳时，eureka-server 会认为微服务实例故障，将该实例从服务列表中剔除
    • order-service 拉取服务时，就能将故障实例排除了

注意：一个微服务，既可以是服务提供者，又可以是服务消费者，因此 eureka 将服务注册、服务发现等功能统一封装到了 eureka-client 端

因此，接下来我们动手实践的步骤包括：

在这里插入图片描述

二、搭建 eureka-server

  • 首先注册中心服务端：eureka-server，这必须是一个独立的微服务

1. 创建 eureka-server 服务

  • 在 cloud-demo 父工程下，创建一个子模块：

在这里插入图片描述

  • 填写模块信息：

在这里插入图片描述

  • 然后填写服务信息：

在这里插入图片描述

2. 引入 eureka 依赖

  • 引入 SpringCloud 为 eureka 提供的 starter 依赖：
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

3. 编写启动类

  • 给 eureka-server 服务编写一个启动类，一定要添加一个@EnableEurekaServer 注解，开启 eureka 的注册中心功能：
package com.alex.eureka;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {public static void main(String[] args) {SpringApplication.run(EurekaApplication.class, args);}
}

4. 编写配置文件

  • 编写一个 application.yml 文件，内容如下：
server:port: 10086
spring:application:name: eureka-server
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka

5. 启动服务

  • 启动微服务，然后在浏览器访问：http://127.0.0.1:10086

  • 看到下面结果应该是成功了：

在这里插入图片描述

三、服务注册

  • 下面，我们将 user-service 注册到 eureka-server 中去。

1. 引入依赖

  • 在 user-service 的 pom 文件中，引入下面的 eureka-client 依赖：
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

2. 配置文件

  • 在 user-service 中，修改 application.yml 文件，添加服务名称、eureka 地址：
spring:application:name: userservice
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka

3. 启动多个 user-service 实例

  • 为了演示一个服务有多个实例的场景，我们添加一个 SpringBoot 的启动配置，再启动一个 user-service。

  • 首先，复制原来的 user-service 启动配置：

在这里插入图片描述

  • 然后，在弹出的窗口中，填写信息：

在这里插入图片描述

  • 现在，SpringBoot 窗口会出现两个 user-service 启动配置：

在这里插入图片描述

  • 不过，第一个是 8081 端口，第二个是 8082 端口。

  • 启动两个 user-service 实例：

在这里插入图片描述

  • 查看 eureka-server 管理页面：

在这里插入图片描述

四、服务发现

  • 下面，我们将 order-service 的逻辑修改：向 eureka-server 拉取 user-service 的信息，实现服务发现。

1. 引入依赖

  • 之前说过，服务发现、服务注册统一都封装在 eureka-client 依赖，因此这一步与服务注册时一致。

  • 在 order-service 的 pom 文件中，引入下面的 eureka-client 依赖：

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

2. 配置文件

  • 服务发现也需要知道 eureka 地址，因此第二步与服务注册一致，都是配置 eureka 信息：

  • 在 order-service 中，修改 application.yml 文件，添加服务名称、eureka 地址：

spring:application:name: orderservice
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka

3. 服务拉取和负载均衡

  • 最后，我们要去 eureka-server 中拉取 user-service 服务的实例列表，并且实现负载均衡。

  • 不过这些动作不用我们去做，只需要添加一些注解即可。

  • 在 order-service 的 OrderApplication 中，给 RestTemplate 这个 Bean 添加一个@LoadBalanced 注解：

在这里插入图片描述

  • 修改 order-service 服务中的 com.alex.order.service 包下的 OrderService 类中的 queryOrderById 方法。修改访问的 url 路径，用服务名代替 ip、端口：

在这里插入图片描述

  • spring 会自动帮助我们从 eureka-server 端，根据 userservice 这个服务名称，获取实例列表，而后完成负载均衡。

第四章 Ribbon 负载均衡

  • 上一章中，我们添加了@LoadBalanced 注解，即可实现负载均衡功能，这是什么原理呢？

一、负载均衡原理

  • SpringCloud 底层其实是利用了一个名为 Ribbon 的组件，来实现负载均衡功能的。

在这里插入图片描述

  • 那么我们发出的请求明明是 http://userservice/user/1，怎么变成了 http://localhost:8081 的呢？

二、源码跟踪

  • 为什么我们只输入了 service 名称就可以访问了呢？之前还要获取 ip 和端口。

  • 显然有人帮我们根据 service 名称，获取到了服务实例的 ip 和端口。它就是LoadBalancerInterceptor，这个类会在对 RestTemplate 的请求进行拦截，然后从 Eureka 根据服务 id 获取服务列表，随后利用负载均衡算法得到真实的服务地址信息，替换服务 id。

  • 我们进行源码跟踪：

1. LoadBalancerInterceptor

在这里插入图片描述

  • 可以看到这里的 intercept 方法，拦截了用户的 HttpRequest 请求，然后做了几件事：

    • request.getURI()：获取请求 uri，本例中就是 http://user-service/user/8
    • originalUri.getHost()：获取 uri 路径的主机名，其实就是服务 id，user-service
    • this.loadBalancer.execute()：处理服务 id，和用户请求。

  • 这里的this.loadBalancer是LoadBalancerClient类型，我们继续跟入。

2. LoadBalancerClient

  • 继续跟入 execute 方法：

在这里插入图片描述

  • 代码是这样的：

    • getLoadBalancer(serviceId)：根据服务 id 获取 ILoadBalancer，而 ILoadBalancer 会拿着服务 id 去 eureka 中获取服务列表并保存起来。
    • getServer(loadBalancer)：利用内置的负载均衡算法，从服务列表中选择一个。本例中，可以看到获取了 8082 端口的服务

  • 放行后，再次访问并跟踪，发现获取的是 8081：

在这里插入图片描述

  • 果然实现了负载均衡。

3. 负载均衡策略 IRule

  • 在刚才的代码中，可以看到获取服务使通过一个getServer方法来做负载均衡:

在这里插入图片描述

  • 我们继续跟入：

在这里插入图片描述

  • 继续跟踪源码 chooseServer 方法，发现这么一段代码：

在这里插入图片描述

  • 我们看看这个 rule 是谁：

在这里插入图片描述

  • 这里的 rule 默认值是一个RoundRobinRule，看类的介绍：

在这里插入图片描述

  • 这不就是轮询的意思嘛。

  • 到这里，整个负载均衡的流程我们就清楚了。

4. 总结

  • SpringCloudRibbon 的底层采用了一个拦截器，拦截了 RestTemplate 发出的请求，对地址做了修改。用一幅图来总结一下：

在这里插入图片描述

  • 基本流程如下：

    • 拦截我们的 RestTemplate 请求 http://userservice/user/1
    • RibbonLoadBalancerClient 会从请求 url 中获取服务名称，也就是 user-service
    • DynamicServerListLoadBalancer 根据 user-service 到 eureka 拉取服务列表
    • eureka 返回列表，localhost:8081、localhost:8082
    • IRule 利用内置负载均衡规则，从列表中选择一个，例如 localhost:8081
    • RibbonLoadBalancerClient 修改请求地址，用 localhost:8081 替代 userservice，得到 http://localhost:8081/user/1，发起真实请求

三、负载均衡策略

1. 负载均衡策略

  • 负载均衡的规则都定义在 IRule 接口中，而 IRule 有很多不同的实现类：

在这里插入图片描述

  • 不同规则的含义如下：
内置负载均衡规则类规则描述
RoundRobinRule简单轮询服务列表来选择服务器。它是 Ribbon 默认的负载均衡规则。
AvailabilityFilteringRule对以下两种服务器进行忽略： （1）在默认情况下，这台服务器如果 3 次连接失败，这台服务器就会被设置为“短路”状态。短路状态将持续 30 秒，如果再次连接失败，短路的持续时间就会几何级地增加。 （2）并发数过高的服务器。如果一个服务器的并发连接数过高，配置了 AvailabilityFilteringRule 规则的客户端也会将其忽略。并发连接数的上限，可以由客户端的..ActiveConnectionsLimit 属性进行配置。
WeightedResponseTimeRule为每一个服务器赋予一个权重值。服务器响应时间越长，这个服务器的权重就越小。这个规则会随机选择服务器，这个权重值会影响服务器的选择。
ZoneAvoidanceRule以区域可用的服务器为基础进行服务器的选择。使用 Zone 对服务器进行分类，这个 Zone 可以理解为一个机房、一个机架等。而后再对 Zone 内的多个服务做轮询。
BestAvailableRule忽略那些短路的服务器，并选择并发数较低的服务器。
RandomRule随机选择一个可用的服务器。
RetryRule重试机制的选择逻辑
  • 默认的实现就是 ZoneAvoidanceRule，是一种轮询方案

2. 自定义负载均衡策略

  • 通过定义 IRule 实现可以修改负载均衡规则，有两种方式：
2.1 代码方式
  • 在 order-service 中的 OrderApplication 类中，定义一个新的 IRule：
@Bean
public IRule randomRule(){return new RandomRule();
}
2.2 配置文件方式
  • 在 order-service 的 application.yml 文件中，添加新的配置也可以修改规则：
userservice: # 给某个微服务配置负载均衡规则，这里是userservice服务ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # 负载均衡规则

注意，一般用默认的负载均衡规则，不做修改。

四、饥饿加载

  • Ribbon 默认是采用懒加载，即第一次访问时才会去创建 LoadBalanceClient，请求时间会很长。

  • 而饥饿加载则会在项目启动时创建，降低第一次访问的耗时，通过下面配置开启饥饿加载：

ribbon:eager-load:enabled: trueclients: userservice

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/112541.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

学生学徒作品分享——金融大模型-房屋租金价格影响因素分析与预测

学生学徒作品分享——金融大模型-房屋租金价格影响因素分析与预测

金融大模型-房屋租金价格影响因素分析与预测项目背景 广州作为中国最发达的城市之一&#xff0c;每年都吸引大量务工人员前来就业&#xff0c;而租房是他们需要解决的最大问题之一&#xff0c;各地区租房需求日益增长。在租房过程&#xff0c;价格、交通是重要的考虑因素&a…
阅读更多...
使用 Rust 开发：以太坊与 Layer2 生态建设新趋势

使用 Rust 开发：以太坊与 Layer2 生态建设新趋势

Rust 是一种系统编程语言&#xff0c;以其出色的性能、内存安全和并发性而闻名&#xff0c;在区块链和 Web3 中广泛应用&#xff0c;大多数编程语言和开发框架都以 Rust 为核心&#xff0c;如 Polkadot、Solana、NEAR、Elrond&#xff08;现名 MultiversX&#xff09;、Hyperle…
阅读更多...
android 指针动画转动

android 指针动画转动

记录一种简单动画 效果图&#xff1a; 都是直接使用图片资源FrameLayout布局实现&#xff0c;布局如下&#xff1a; <LinearLayout xmlns:android"http://schemas.android.com/apk/res/android"xmlns:app"http://schemas.android.com/apk/res-auto"…
阅读更多...
【JavaEE】Java多线程编程案例 -- 多线程篇(3)

【JavaEE】Java多线程编程案例 -- 多线程篇(3)

Java多线程编程案例 1. 单例模式1.1 代码的简单实现1.2 懒汉模式的线程安全代码 2. 阻塞队列2.1 阻塞队列的概念2.2 使用库中的BlockingDeque2.3 模拟实现阻塞队列2.4 生产者消费者模型 3. 定时器3.1 概念3.2 使用库的定时器 - Timer类3.3 模拟实现定时器 4. 线程池4.1 概念4.2…
阅读更多...
面向对象设计原则之依赖倒置原则

面向对象设计原则之依赖倒置原则

目录 定义原始定义进一步的理解 作用实现方法代码示例 面向对象设计原则之开-闭原则 面向对象设计原则之里式替换原则 面向对象设计原则之依赖倒置原则 面向对象设计原则之单一职责原则 定义 依赖倒置原则&#xff08;Dependence Inversion Principle&#xff09;&#xff0c…
阅读更多...
互联网Java工程师面试题·Java 总结篇·第十一弹

互联网Java工程师面试题·Java 总结篇·第十一弹

目录 90、简述一下你了解的设计模式。 91、用 Java 写一个单例类。 92、什么是 UML&#xff1f; 93、UML 中有哪些常用的图&#xff1f; 94、用 Java 写一个冒泡排序。 95、用 Java 写一个折半查找。 90、简述一下你了解的设计模式。 所谓设计模式&#xff0c;就是一套被…
阅读更多...
最新Ai写作创作系统源码+Ai绘画系统源码+搭建部署教程+支持GPT4.0+支持Prompt预设应用+思维导图生成

最新Ai写作创作系统源码+Ai绘画系统源码+搭建部署教程+支持GPT4.0+支持Prompt预设应用+思维导图生成

一、AI创作系统 SparkAi创作系统是基于OpenAI很火的ChatGPT进行开发的Ai智能问答系统AI绘画系统&#xff0c;支持OpenAI GPT全模型国内AI全模型。本期针对源码系统整体测试下来非常完美&#xff0c;可以说SparkAi是目前国内一款的ChatGPT对接OpenAI软件系统。那么如何搭建部署…
阅读更多...
2、Kafka 生产者

2、Kafka 生产者

3.1 生产者消息发送流程 3.1.1 发送原理 在消息发送的过程中&#xff0c;涉及到了两个线程——main 线程和 Sender 线程。在 main 线程 中创建了一个双端队列 RecordAccumulator。main 线程将消息发送给 RecordAccumulator&#xff0c; Sender 线程不断从 RecordAccumulator 中…
阅读更多...
OpenCV 笔记(2)：图像的属性以及像素相关的操作

OpenCV 笔记(2)：图像的属性以及像素相关的操作

Part11. 图像的属性 11.1 Mat 的主要属性 在前文中&#xff0c;我们大致了解了 Mat 的基本结构以及它的创建与赋值。接下来我们通过一个例子&#xff0c;来看看 Mat 所包含的常用属性。 先创建一个 3*4 的四通道的矩阵&#xff0c;并打印出其相关的属性&#xff0c;稍后会详细…
阅读更多...
安装Sentinel

安装Sentinel

大家好今天来安装Sentinel . 安装Sentinel 下载 : 大家可以选择相应版本(最新版本1.8.6) 官网下载地址 : Release v1.8.6 alibaba/Sentinel GitHub 链接&#xff1a;Sentinel_免费高速下载|百度网盘-分享无限制 (baidu.com) 提取码&#xff1a;8eh9 运行 : 将jar包放到任…
阅读更多...
Youtrack Linux 安装

Youtrack Linux 安装

我们考虑最后应该使用的是 ZIP 方式的安装。 按照官方的说法如何设置运行 YouTrack 应该是非常简单的。 准备环境 根据官方的说法&#xff0c;我们需要做的就是下载 Zip 包&#xff0c;然后把 Zip 包解压到指定的目录中就可以了。 下载 当前官方的下载地址为&#xff1a;Ge…
阅读更多...
基于nodejs+vue中学信息技术线上学习系统

基于nodejs+vue中学信息技术线上学习系统

目 录 摘 要 I ABSTRACT II 目 录 II 第1章 绪论 1 1.1背景及意义 1 1.2 国内外研究概况 1 1.3 研究的内容 1 第2章 相关技术 3 2.1 nodejs简介 4 2.2 express框架介绍 6 2.4 MySQL数据库 4 第3章 系统分析 5 3.1 需求分析 5 3.2 系统可行性分析 5 3.2.1技术可行性&#xff1a;…
阅读更多...
单片机郭天祥（02）

单片机郭天祥（02）

1&#xff1a;解决keil5软件的乱码问题&#xff0c;修改编码为UTF-8 2&#xff1a;打开keil5使用debug对编写好的程序进行调试 给程序打上断点 使用仿真芯片 更改设备管理器相关设置 接通电源后点击debug连接到51单片机 使用stc-isp获取延时函数 将延时函数添加进入创建好的…
阅读更多...
17-spring aop调用过程概述

17-spring aop调用过程概述

文章目录 1.源码2. debug过程 1.源码 public class TestAop {public static void main(String[] args) throws Exception {saveGeneratedCGlibProxyFiles(System.getProperty("user.dir") "/proxy");ApplicationContext ac new ClassPathXmlApplication…
阅读更多...
在JavaScript中，如何创建一个数组或对象？

在JavaScript中，如何创建一个数组或对象？

在JavaScript中，可以使用以下方式创建数组和对象： 一：创建数组（Array）： 1：使用数组字面量（Array Literal）语法，使用方括号 [] 包裹元素，并用逗号分隔： let array1 = []; // 空数组 let array2 = [1, 2, 3]; // 包含三个数字的数组 let array3 = [apple, banana,…
阅读更多...
Nautilus Chain 与 Coin98 生态达成合作，加速 Zebec 生态亚洲战略进程

Nautilus Chain 与 Coin98 生态达成合作，加速 Zebec 生态亚洲战略进程

目前&#xff0c;行业内首个模块化 Layer3 架构公链 Nautilus Chain 已经上线主网&#xff0c;揭示了模块化区块链领域迎来了全新的进程。在主网上线后&#xff0c;Nautilus Chain 将扮演 Zebec 生态中最重要的底层设施角色&#xff0c;并将为 Zebec APP 以及 Zebec Payroll 规…
阅读更多...
ESP32C3 LuatOS TM1650②动态显示累加整数

ESP32C3 LuatOS TM1650②动态显示累加整数

--注意:因使用了sys.wait()所有api需要在协程中使用 -- 用法实例 PROJECT "ESP32C3_TM1650" VERSION "1.0.0" _G.sys require("sys") local tm1650 require "tm1650"-- 拆分整数&#xff0c;并把最低位数存放在数组最大索引处 loc…
阅读更多...
用Nginx搭建一个具备缓存功能的反向代理服务

用Nginx搭建一个具备缓存功能的反向代理服务

在同一台服务器上&#xff0c;使用nginx提供服务&#xff0c;然后使用openresty提供反向代理服务。 参考《Ubuntu 20.04使用源码安装nginx 1.14.0》安装nginx。 参考《用Nginx搭建一个可用的静态资源Web服务器》搭建静态资源Web服务器&#xff0c;但是/nginx/conf/nginx.conf里…
阅读更多...
Uniapp软件库源码 全新带勋章功能(包含前后端源码)

Uniapp软件库源码 全新带勋章功能(包含前后端源码)

Uniapp软件库全新带勋章功能&#xff0c;搭建好后台 在前端找到 util 这个文件 把两个js文件上面的填上自己的域名&#xff0c; 电脑需要下载&#xff1a;HBuilderX 登录账号 没有账号就注册账号&#xff0c;然后上传文件&#xff0c;打包选择 “发行” 可以打包app h5等等。…
阅读更多...
异常数据检测 | Python基于Hampel的离群点检测

异常数据检测 | Python基于Hampel的离群点检测

文章目录 文章概述模型描述源码分享文章概述 在时间序列数据分析领域，识别和处理异常点是至关重要的任务。异常点或离群点是明显偏离预期模式的数据点，可能表明存在错误、欺诈或有价值的见解。 应对这一挑战的一种有效技术是汉普尔过滤器（Hampel Filter）。 模型描述 汉…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023