Spring Cloud ------ Gateway

一、什么是网关

经常面试的人肯定知道,在去公司面试时,通常不会直接去面试官那里面试,而是先去前台进行询问面试官的所在地,并进行一些相关登记。而网关对于一个微服务项目来说,就类似于一个前台,打到微服务中的请求通常都需要先到网关,由网关进行一些处理后,再打到相关服务上。

网关的处理具体包括以下几个方面:

  • 权限控制:对请求进行权限校验,校验失败则直接将请求进行拦截。
  • 动态路由:根据请求信息将请求转发到对应的微服务上。
  • 负载均衡:当请求的目标服务有多个时,根据情况进行负载均衡
  • 限流:将请求按照设定的最大流量进行限流,以免各服务压力过大 

目前市面上大多数都是使用Gateway来作为微服务的网关。

二、Gateway的使用
Gateway服务的搭建

1.在微服务中使用Gateway网关,首先我们得在微服务项目中创建一个新的模块。

2.然后我们需要引入依赖,具体如下:

 <dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency></dependencies>

3.然后我们需要创建一个启动类

此时,一个网关模块就创建好了,但当前网关还没有设置任何处理请求的功能,下面我们来看一下如何设置网关的功能。

Route Predicate Factories

在Java8中提供了一个函数式接口Predicate,这个接口能够校验请求中的参数,具体为通过接受一个字符串,根据字符串的特点返回一个布尔值,用来进行条件过滤。下面我们来具体使用一下这个接口。

1.首先我们来创建一个该接口的实现类

2.然后重写其中的test方法

在test中我们可以定义一些逻辑来进行条件判断,例如我们这里定义成字符串为空返回false,不为空返回true。

然后我们就可以使用这个类来进行一些参数判断了

在Predicate中还包含了许多其它方法,例如and方法,它的参数为Predicate类型 ,返回值为一个新的Predicate,这个新的Predicate的test方法返回的则是前两个Predicate的test返回值取”&&“的结果。其它方法可以参考下面的内容:

  • isEqual(Object targetRef):⽐较两个对象是否相等,参数可以为Null
  • and(Predicate other):短路与操作,返回⼀个组成Predicate
  • or(Predicate other):短路或操作,返回⼀个组成Predicate
  • test(T t):传⼊⼀个Predicate参数,⽤来做判断 
  • negate():返回表⽰此Predicate逻辑否定的Predicate

Gateway给我们提供了一个 Route Predicate Factories(路由断言工厂),里面包含了很多的Predicate来对路由进行一些规则匹配,例如Path,它能匹配指定规则的路径,Methond能够匹配指定的请求方法,还有其它的一些Predicate,大家可以去下面这个链接进行查询:

https://docs.spring.io/spring-cloud-gateway/reference/spring-cloudgateway/request-predicates-factories.html

我们可以在我们创建的Gateway模块的配置文件中来使用这些Predicate,具体使用的配置如下:

gateway:routes: # ⽹关路由配置- id: product-service #路由ID, ⾃定义, 唯⼀即可uri: lb://product-service #⽬标服务地址predicates: #路由条件- Path=/product/**- id: order-serviceuri: lb://order-servicepredicates:- Path=/order/**

配置好之后,当请求的url与predicates中对于的路由规则path匹配时,就会依据id中的服务名称,去注册中心获取对应的服务地址,然后负载均衡出一个地址并构建对应的请求去访问目标服务。

例如我们去访问下面这个地址:

http://127.0.0.1:8080/order/1

此时请求就会来到网关,在网关中进行predicate的条件判断,判断通过后去Nacos获取服务信息并负载均衡吗,然后去访问目标服务。上面地址的访问结果如下:

可以发现成功返回了数据,由此可以推断,请求成功通过网关访问到了目标服务。

如果我们的请求不符合定义的匹配规则,则不会访问到目标服务,例如我们访问下面这个 路径http://127.0.0.1:8080/feign/1(也是order-service里面的)

我们也可以配置多个predicate,例如我们再配置 一个Method,用来匹配请求的方法

此时只要请求同时匹配这两个规则才能够去访问对应的服务。 

Gateway Filter Factories 
Filter

Predicate能够设置一些请求的匹配规则,而Filter则能在请求被目标服务处理前后,添加一些逻辑。例如,我们可以在请求发送到目标服务之前,让请求新增一个参数。Filter在生效时机上可以分为Post类型和Pre类型,

Pre类型的Filter中定义的逻辑在请求处理前执行,而Post类型的则是在请求处理完成之后,数据返回给用户之前执行。在生效范围上,又可以把Filter分为GatewayFilter(作用于单个路由或者同一个分组的路由上,也就是匹配到的id是一样的)、GlobalFilter(对于每一个路由都生效,也就是每一个请求都生效)。

Gateway Filter Factories(路由过滤工厂)中为我们提供了很多的Filter,例如AddRequestParameter,它能在请求被处理之前在请求中添加一个参数,下面我们来具体使用以下。

Filter和Predicate一样,也是需要在配置文件中进行配置,具体如下:

server:port: 10030
gateway:routes: # ⽹关路由配置- id: product-service #路由ID, ⾃定义, 唯⼀即可uri: lb://product-service #⽬标服务地址predicates: #路由条件- Path=/product/**- id: order-serviceuri: lb://order-servicepredicates:- Path=/order/**filters:- AddRequestParameter=userName, bite

这里我们配置了AddRequestParameter,他在请求中添加了一个username字段,值为bite。

下面我们通过一个接口来测试一下是否真的添加了该参数

我们启动对应的服务来访问一下这个接口,打印的日志如下:

可以发现成功获取到Filter添加的参数了。在路由过滤工厂中还有许多其他的Filter,如果大家想了解更多,可以访问如下地址:

GatewayFilter Factories :: Spring Cloud Gateway

前面我们配置的Filter只能对当前的单一路由生效,如果我们想对所有路由都生效,就需要配置default-Filter,具体配置项如下:

server:port: 10030
spring:application:name: gatewaycloud:nacos:discovery:server-addr: 182.92.242.181:8848gateway:metrics:enabled: trueroutes:- id: order-service   #路由规则id, 随便起, 不重复即可uri: lb://order-service/ #目标服务地址predicates:   #路由条件- Path=/order/**- After=2024-03-20T00:00:22.370856700+08:00[Asia/Shanghai]filters:- AddRequestParameter=userName, bite- name: Custom    #过滤器名称args:name: test_custom- id: product-serviceuri: lb://product-service/predicates:- Path=/product/**default-filters:- name: Retryargs:retries: 3statuses: BAD_GATEWAY

 此时配置的Filter就对对所有路径都生效了。

GlobalFilter

在Gateway中提供了很多全局过滤器(GlobalFilter),用来实现安全监控,日志记录等功能。常见的有

 • Gateway Metrics Filter: ⽹关指标,提供监控指标

 • Forward Routing Filter:⽤于本地forword,请求不转发到下游服务器

 • LoadBalancer Client Filter: 针对下游服务, 实现负载均衡.

使用GlobalFilter 进行监控等功能需要引入下面这个依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

然后在配置文件中进行配置,具体配置项如下:

spring:cloud:gateway:metrics:enabled: true #开启监控相关的全局过滤器
management:endpoints:web:exposure:include: "*"endpoint:health:show-details: alwaysshutdown:enabled: true

此时我们访问下面这个链接就能得到请求的监控信息:

网关地址/actuator

Filter的执行顺序

在一个路由下,可能会有多个Filter,他们的执行顺序如何呢?我们来看一下。

在请求发送到对应的服务之前,网关会去获取当前请求需要使用到的所有Filter,并将其按照Order值排序(每个Filter都必须指定一个Order值,Order值越大,执行的顺序则越靠前,反之则越靠后,路由过滤工厂给我们提供的Filter都是已经设置好Order值了),根据顺序执行Filter。如果Order值一样,则按照,defaultFilter>GatewayFilter>GlobalFilter的顺序执行。

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

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

相关文章

Go初级之九:Select 与并发控制

在Go语言中&#xff0c;select语句是处理并发编程的核心工具之一。它让我们能够优雅地管理多个通道操作&#xff0c;实现高效的并发控制。 1. Select 语句基础 1.1 Select 的基本语法 package mainimport ("fmt""time" )func main() {ch1 : make(chan stri…

使用 Acme.sh 获取和管理免费 SSL 证书

Acme.sh 是一个开源的 Shell 脚本工具&#xff0c;支持从 Let’s Encrypt 等证书颁发机构获取免费的 SSL/TLS 证书。它支持多种验证方式&#xff0c;并能自动续期证书&#xff0c;适合个人网站或企业使用。 目标 同时支持&#xff0c;主域名和泛域名 安装 Acme.sh获取源码 git …

docker-compose跨节点部署Elasticsearch 9.X集群

系列文章目录 提示:这里可以添加系列文章的所有文章的目录,目录需要自己手动添加 例如:第一章 Python 机器学习入门之pandas的使用 提示:写完文章后,目录可以自动生成,如何生成可参考右边的帮助文档 文章目录 系列文章目录 前言 一、环境准备 二、遇到的问题与分析 三、配…

【面试场景题】spring应用启动时出现内存溢出怎么排查

文章目录一、定位 OOM 类型二、基础排查&#xff1a;调整 JVM 参数与日志三、堆内存溢出&#xff08;Heap Space&#xff09;排查1. 分析堆转储文件2. 典型场景与解决四、元空间溢出&#xff08;Metaspace&#xff09;排查1. 分析类加载情况2. 典型场景与解决五、直接内存溢出&…

2025年经济学专业女生必考证书指南:打造差异化竞争力

在数字经济快速发展的2025年&#xff0c;经济学专业女生面临着诸多机遇与挑战。单纯的理论知识已经难以满足职场需求&#xff0c;企业更看重解决实际问题的能力&#xff0c;特别是将数据转化为商业洞察的专业技能。各类专业资质认证可以成为系统提升能力的途径之一&#xff0c;…

【CAN通信】AUTOSAR架构下TC3xx芯片是如何将一帧CAN报文接收上来的

目录 前言 正文 1.背景介绍 2.CAN报文硬件原理 3.CAN接收软件实现 3.1. vCan_30_Mcan_Interrupt 3.2. vCan_30_Mcan_RxInterrupt 3.3. vCan_30_Mcan_RxBasicCanHandling 4.总结 前言 在《【CAN通信】AUTOSAR架构下TC3xx芯片是如何将一帧CAN报文发送出去的》一文中我们…

STM32H750 RTC介绍及应用

第十一章 RTC介绍及应用 1. RTC 简介 RTC&#xff08;Real-Time Clock&#xff0c;实时时钟&#xff09;是 STM32H750VBT6 中用于提供日历和时钟功能的低功耗外设&#xff0c;即使主电源关闭&#xff0c;只要 VBAT&#xff08;备份电源&#xff09;供电&#xff0c;RTC 仍能持续…

飞网自适应通信:IPv4 与 IPv6 环境下的高效互联

一、网络连接的难题与飞网的解决方案 在日常生活中&#xff0c;我们常常会碰到这样的场景&#xff1a;在家用手机访问公司电脑里的重要文件&#xff0c;或者远程连接家里的NAS设备查看照片和视频。这些操作都需要设备之间建立起安全又稳定的连接。然而&#xff0c;现实中的网络…

拉格朗日多项式

最近打的几个比赛没意思&#xff0c;不是不会就是不会。不过比赛完后看到别人的WP&#xff0c;感觉受益匪浅。先看一个多项式&#xff1a;当输入Xi时会得到一个Si,要求输入一定数量的xi 来求[c] 当可以输入的x个数与c的个数相同时&#xff0c;可以用矩阵直接求解。&#xff08;…

Vue3 + TypeScript 实现文件拖拽上传

应用效果&#xff1a;实例代码&#xff1a;CommonApplyBasicInfoForm.vue<script setup lang"ts" name"CommonApplyBasicInfoForm"> ...... // 选择文件列表 const selectedFiles ref<FileList | null>(null); // 通过 FormData 对象实现文件…

2025全国大学生数学建模C题保姆级思路模型(持续更新):NIPT 的时点选择与胎儿的异常判定

2025全国大学生数学建模C题保姆级思路模型&#xff08;持续更新&#xff09;&#xff1a;NIPT 的时点选择与胎儿的异常判定&#xff0c;完整持续更新内容见文末名片 胎儿遗传信息检测与临床决策数学建模分析讲义 问题一&#xff1a;Y染色体浓度的影响因素探索——线性回归的“侦…

【笔记】Software Engineering at Google

聚焦核心原则&#xff0c;挑取最让我眼前一亮的实践点&#xff0c;特别是那些能直接启发或解决我当前工作中痛点的部分。0. 序言 最近集中精力速读了关于 ​Google 软件工程实践​ 的诸多资料&#xff08;包括官方出版物、工程博客、技术演讲以及社区讨论&#xff09;。面对 G…

无人机防风技术难点解析

防风防御模块的技术难点主要体现在以下几个方面风场感知与精准建模1.复杂风场的实时感知&#xff1a;风&#xff0c;尤其是近地面的风&#xff0c;常常是无规则、瞬息万变的阵风、湍流或风切变。无人机需要通过各种传感器&#xff08;如空速计、惯性测量单元&#xff08;IMU&am…

HarmonyOS 应用开发深度解析:ArkTS 声明式 UI 与精细化状态管理

好的&#xff0c;请看这篇关于 HarmonyOS 应用开发中声明式 UI 状态管理的技术文章。 HarmonyOS 应用开发深度解析&#xff1a;ArkTS 声明式 UI 与精细化状态管理 引言 随着 HarmonyOS 4、5 的广泛应用和 HarmonyOS NEXT 的发布&#xff0c;基于 API 12 及以上的应用开发已成为…

机器学习入门,第一个MCP示例

前面我们已经搭建了属于自己的AI大模型&#xff1a;详情见 https://blog.csdn.net/hl_java/article/details/150591424?spm1001.2014.3001.5501 近期MCP概念这么火&#xff0c;那么它到底是什么呢&#xff0c;借一个例子为你讲解 第一步&#xff1a;理解MCP的核心价值 MCP (Mo…

flutter 中间组件自适应宽度

使用Flexible IntrinsicWidth Row(children: [Text(第一个text),IntrinsicWidth(child: ConstrainedBox(constraints: BoxConstraints(maxWidth: 200), // 最大宽度限制child: Text(中间的text可能很长也可能很短,overflow: TextOverflow.ellipsis,maxLines: 1,),),),Text(第三…

TDengine 时间函数 DAYOFWEEK 用户手册

DAYOFWEEK 函数使用手册 函数描述 DAYOFWEEK 函数用于返回指定日期是一周中的第几天。该函数遵循标准的星期编号约定&#xff0c;返回值范围为 1-7&#xff0c;其中&#xff1a; 1 星期日 (Sunday)2 星期一 (Monday)3 星期二 (Tuesday)4 星期三 (Wednesday)5 星期四 (T…

【STM32】贪吃蛇 [阶段 3] 增强模块结构(架构优化)

这篇博客是 承接&#xff1a;【项目思维】贪吃蛇&#xff08;嵌入式进阶方向&#xff09;中 聚焦于 &#x1f9f1; 阶段 3&#xff1a;增强模块结构&#xff08;架构优化&#xff09; 中的 菜单系统&#xff08;Menu System&#xff09;&#xff0c;这部分的结构优化可以学到的…

江协科技STM32学习笔记补充之004

STM32 ISP 一键下载电路&#xff08;按功能、逻辑与时序拆解&#xff09;

数据库小册(1)

1. 关系型数据库主要考点关系型数据库&#xff1a;架构索引锁语法理论规范2. 如何设计一个关系型数据库设计即模块划分。数据库最主要的功能是存储我们的数据&#xff0c;所以需要一个存储的文件系统。我们要把涉及到的物流数据提供逻辑的形式给组织和表示出来&#xff0c;这是…