Spring Cloud 之 Gateway

本篇主要介绍有关Gateway网关的相关内容。

目录

一、什么是网关

二、Gateway的使用

Gateway服务的搭建

Route Predicate Factories

Gateway Filter Factories 

Filter

GlobalFilter

Filter的执行顺序


一、什么是网关

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

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

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

常见的网关组件有,zuul,Gateway。zull是由Netflix开源的一个网关组件,但在2018年后,zuul就进入维护阶段了,不再进行一些新特性的开发。Gateway为了替代zuul而研发的一个全新的网关组件,目前市面上大多数都是使用Gateway来作为微服务的网关。

二、Gateway的使用

Gateway服务的搭建

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

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

<!--⽹关--> 
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!--基于nacos实现服务发现依赖--> 
<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

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

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

Route Predicate Factories

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

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

然后重写其中的test方法

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

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

因为Predicate是一个函数式接口,因此我们还可以以Lamada表达式的形式来使用 

在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:10030/order/1(网关通常使用10030端口)

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

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

如果我们的请求不符合定义的匹配规则,则不会访问到目标服务,例如我们访问下面这个 路径http://127.0.0.1:10030/1

结果返回404了。

我们也可以配置多个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一样,也是需要在配置文件中进行配置,具体如下:

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

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

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

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

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

GatewayFilter Factories :: Spring Cloud Gateway 

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

spring:cloud:gateway:default-filters:- AddResponseHeader=X-Response-Default-Red, Default-Blue

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

GlobalFilter

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

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

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

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

其它的还有很多,大家可以去下面的网站去查询:

Global Filters :: Spring Cloud Gateway

使用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.rhkb.cn/news/330880.html

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

相关文章

CAN笔记第二篇,车载测试继续学起来!

在CAN协议中&#xff0c;“帧”是一个包含完整信息的独立单元&#xff0c;它具有特定的格式和结构&#xff0c;以确保数据在CAN总线上的可靠传输。这里的“帧”字可以理解为&#xff1a; 完整性&#xff1a;一个帧包含了所有必要的信息&#xff0c;从起始到结束&#xff0c;都遵…

【LeetCode】【1】两数之和(1141字)

文章目录 [toc]题目描述样例输入输出与解释样例1样例2样例3 提示进阶Python实现哈希表 个人主页&#xff1a;丷从心 系列专栏&#xff1a;LeetCode 刷题指南&#xff1a;LeetCode刷题指南 题目描述 给定一个整数数组nums和一个整数目标值target&#xff0c;请在该数组中找出…

视觉检测实战项目——九点标定

本文介绍九点标定方法 已知 9 个点的图像坐标和对应的机械坐标,直接计算转换矩阵,核心原理即最小二乘拟合 {𝑥′=𝑎𝑥+𝑏𝑦+𝑐𝑦′=𝑎′𝑥+𝑏′𝑦+𝑐′ [𝑥1𝑦11𝑥2𝑦21⋮⋮⋮𝑥9𝑦91][𝑎𝑎′𝑏𝑏′𝑐𝑐′]=[𝑥1′𝑦…

AI爆文写作:根据别人的爆款标题,如何通过名词替换改成自己的爆款标题?

在日常刷到爆文的时候&#xff0c;就可以培养自己的网感&#xff0c;为啥这篇文章会爆&#xff1f; 这篇爆文的标题有啥诀窍呢&#xff1f; 比如下面这一篇&#xff1a;《极简生活&#xff1a;变富就是每天循环5个动作》 我们可以发现&#xff0c;每天循环5个动作 这几个词语…

C#基础一

使用Visual Studio 2022&#xff08;VS2022&#xff09;编写C#控制台程序 1. 安装Visual Studio 2022 确保已安装Visual Studio 2022。如果未安装&#xff0c;请从Visual Studio官网下载并安装。 另一篇文章中已经有详细描述&#xff0c;这里就不在细说了。 VisualStudio2022…

【JavaEE 初阶(十)】JVM

❣博主主页: 33的博客❣ ▶️文章专栏分类:JavaEE◀️ &#x1f69a;我的代码仓库: 33的代码仓库&#x1f69a; &#x1faf5;&#x1faf5;&#x1faf5;关注我带你了解更多进阶知识 目录 1.前言2.JVM内存区域划分3.类加载3.1双亲委派模型 4.垃圾回收&#xff08;GC&#xff0…

1098: 堆的判断

解法&#xff1a; 堆是完全二叉树 用数组来存储 然后用定义判定 #include<iostream> #include<vector> using namespace std; int main() {int n;cin >> n;vector<int> vec(n);for (int i 0; i < n; i) cin >> vec[i];for (int i 0; i &…

LabVIEW超高温高压流变仪测试系统

LabVIEW超高温高压流变仪测试系统 超高温高压流变仪广泛应用于石油、天然气、化工等行业&#xff0c;用于测量材料在极端条件下的流变特性。随着计算机技术、测试技术和电子仪器技术的快速发展&#xff0c;传统的流变仪测试方式已无法满足现代工业的需求。因此&#xff0c;开发…

【全开源】沃德商协会管理系统源码(FastAdmin+ThinkPHP+Uniapp)

一款基于FastAdminThinkPHPUniapp开发的商协会系统&#xff0c;新一代数字化商协会运营管理系统&#xff0c;以“智慧化会员体系、智敏化内容运营、智能化活动构建”三大板块为基点&#xff0c;实施功能全场景覆盖&#xff0c;一站式解决商协会需求壁垒&#xff0c;有效快速建立…

就业班 第三阶段(CICD) 2401--5.15 day2 自动化构建打包、部署(Jenkins + maven+ gitlab+tomcat)

一、平滑发布与灰度发布 **什么叫平滑&#xff1a;**在发布的过程中不影响用户的使用&#xff0c;系统不会因发布而暂停对外服务&#xff0c;不会造成用户短暂性无法访问&#xff1b; **什么叫灰度&#xff1a;**发布后让部分用户使用新版本&#xff0c;其它用户使用旧版本&am…

vector的底层实现与模拟

嗨喽大家好&#xff0c;时隔许久阿鑫又给大家带来了新的博客&#xff0c;关于vector的模拟实现&#xff0c;下面让我们开始今天的学习吧&#xff01; vector的底层实现与模拟 1.关于vector中的插入和删除 2. vector中的拷贝构造和赋值 3.vector的构造函数 4.关于vector中浅…

微信小程序报错:notifyBLECharacteristicValueChange:fail:nodescriptor的解决办法

文章目录 一、发现问题二、分析问题二、解决问题 一、发现问题 微信小程序报错&#xff1a;notifyBLECharacteristicValueChange:fail:nodescriptor 二、分析问题 这个提示有点问题&#xff0c;应该是该Characteristic的Descriptor有问题&#xff0c;而不能说nodescriptor。 …

windows docker desktop 更换镜像存储目录

windows docker desktop 更换镜像存储目录 方法&#xff1a;如图&#xff0c;Browse浏览一个新的目录并选中&#xff0c;确定后&#xff0c;程序会开始stop&#xff0c;在stop完成前&#xff0c;会持续迁移原有镜像到新的位置&#xff0c;你会发现目标位置的磁盘占用空间越来越…

DNS服务的部署与配置(1)

一、DNS的定义 1、域名系统&#xff08;英文&#xff1a;Domain Name System&#xff0c;缩写&#xff1a;DNS&#xff09;是互联网的一项服务。 它作为将域名和IP地址相互映射的一个分布式数据库&#xff0c;能够使人更方便地访问互联网。 DNS使用UDP端口53。 当前&#xff0…

使用pygame绘制图形

参考链接&#xff1a;https://www.geeksforgeeks.org/pygame-tutorial/?reflbp 在窗口中绘制单个图形 import pygame from pygame.locals import * import sys pygame.init()window pygame.display.set_mode((600,600)) window.fill((255,255,255))# pygame.draw.rect(wind…

WSL调用docker

WSL&#xff08;windows subsystem linux&#xff09;是window系统的原生linux子系统&#xff0c;用于代码开发很方便。 希望在wsl里面运行docker&#xff0c;首先要安装docker在WSL中使用&#xff0c;大部分人的第一想法肯定是用以下命令行安装&#xff08;个人不推荐&#x…

【C语言】指针运算

前言 前面在“走进指针世界”中我已经讲解过指针相关的很多前置知识&#xff0c;其实还有一个很重要的部分就是指针的运算。这篇博客&#xff0c;就让我们一起了解一下指针的运算吧&#xff01; 指针作为变量&#xff0c;是可以进行算术运算的&#xff0c;只不过情况会和整型…

Behind the Code:Polkadot 如何重塑 Web3 未来

2024 年 5 月 17 日 Polkadot 生态 Behind the Code 第二季第一集 《创造 Web3 的未来》正式上线。第一集深入探讨了 Polkadot 和 Web3 技术在解决数字身份、数据所有权和去中心化治理方面的巨大潜力。 &#x1f50d; 查看完整视频&#xff1a; https://youtu.be/_gP-M5nUidc?…

aws glue配置读取本地kafka数据源

创建连接时填写本地私有ip地址&#xff0c;选择网络配置 配置任务选择kafka作为数据源 但是执行任务时日志显示连接失败 文档提到只能用加密通信 如果您希望与 Kafka 数据源建立安全连接&#xff0c;请选择 Require SSL connection (需要 SSL 连接)&#xff0c;并在 Kafka priv…