【Spring Cloud】Gateway 服务网关核心架构的执行流程和断言

文章目录

  • 基本概念
  • 执行流程
  • 断言
    • 内置路由断言工厂
    • 自定义路由断言工厂
  • 总结

基本概念

路由(Route)是gateway中最基本的组件之一,表示一个具体的路由信息载体。主要定义了下面的几个信息:

  • id:路由标识符,区别于其他Route。
  • uri:路由指向的目的地uri,即客户端请求最终被转发到的微服务。
  • order:用于多个Route之间的排序,数值越小排序越靠前,匹配优先级越高。
  • predicate:断言的作用是进行条件判断,只有断言都返回真,才会真正的执行路由。
  • filter:过滤器用于修改请求和响应信息。

执行流程

在这里插入图片描述
执行流程大体如下:

  1. Gateway ClientGateway Server 发送请求;
  2. 请求首先会被 HttpWebHandlerAdapter 进行提取组装成网关上下文;
  3. 然后网关的上下文会传递到 DispatcherHandler,它负责将请求分发给RoutePredicateHandlerMapping
  4. RoutePredicateHandlerMapping 负责路由查找,并根据路由断言判断路由是否可用;
  5. 如果断言成功,由FilteringWebHandler创建过滤器链并调用;
  6. 请求会依次经过PreFilter->微服务->PostFiter的方法,最终返回响应;

断言

Predicate(断言,谓词)用于进行条件判断,只有断言都返回真,才会真正的执行路由。断言就是说: 在什么条件下才能进行路由转发。

内置路由断言工厂

Spring Cloud Gateway 包括许多内置的断言工厂,所有这些断言都与HTTP请求的不同属性匹配。具体如下:

(1)基于Datetime类型的断言工厂,此类型的断言根据时间做判断,主要有三个:

  • AfterRoutePredicateFactory:接收一个日期参数,判断请求日期是否晚于指定日期;
  • BeforeRoutePredicateFactory:接收一个日期参数,判断请求日期是否早于指定日期;
  • BetweenRoutePredicateFactory:接收两个日期参数,判断请求日期是否在指定时间段内;

- After=2019-12-31T23:59:59.789+08:00[Asia/Shanghai]

(2)基于远程地址的断言工厂 RemoteAddrRoutePredicateFactory:接收一个IP地址段,判断请求主机地址是否在地址段中

- RemoteAddr=192.168.1.1/24

(3)基于Cookie的断言工厂 CookieRoutePredicateFactory ,接收两个参数:cookie名字和一个正则表达式。判断请求cookie是否具有给定名称且值与正则表达式匹配。

- Cookie=chocolate, ch.

(4)基于Header的断言工厂 HeaderRoutePredicateFactory,接收两个参数:标题名称和正则表达式。判断请求Header是否具有给定名称且值与正则表达式匹配。

- Header=X-Request-ld, \d+

(5)基于Host的断言工厂 HostRoutePredicateFactory,接收一个参数:主机名模式。判断请求的Host是否满足匹配规则。

- Host=**.testhost.org

(6)基于Method请求方法的断言工厂 MethodRoutePredicateFactory,接收一个参数:判断请求类型是否跟指定的类型匹配。

- Method=GET

(7)基于Path请求路径的断言工厂 PathRoutePredicateFactory,接收一个参数:判断请求的URI部分是否满足路径规则。

- Path=/foo/{segment}

(8)基于Query请求参数的断言工厂 QueryRoutePredicateFactory,接收两个参数:请求param和正则表达式,判断请求参数是否具有给定名称且值与正则表达式匹配。

- Query=baz, ba.

(9)基于路由权重的断言工厂 WeightRoutePredicateFactory,接收一个[组名,权重],然后对于同一个组内的路由按照权重转发

- id: weight_route1uri: host1predicates:- Path=/product/**- Weight=group3, 1
- id: weight_route2uri: host2predicates:- Path=/product/**- Weight=group3, 9

接下来我们验证几个内置断言的使用:

server:port: 7000spring:application:name: api-gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848gateway:discovery:locator:enabled: true  # 让gateway可以发现nacos中的微服务lowerCaseServiceId: true # 将请求路径上的服务名配置为小写routes:- id: shop-product #当前路由标识,要求唯一uri: lb://shop-product #lb代表从nacos中获取微服务,shop-product是微服务的名称order: 1 #路由的优先级,数字越小级别越高predicates: #断言(就是路由转发要满足的条件)- Path=/product/** #当请求路径满足Path指定的规则时,才进行路由转发- Before=2019-08-30T15:46:00.000+08:00 #限制请求时间在2019-11-28之前- Method=POST #限制请求方式为postfilters: #过滤器,请求在传递过程中可以通过过滤器对其进行一定的修改- StripPrefix=1 #去掉请求路径的第一层

自定义路由断言工厂

我们来设定一个场景:假设我们的应用仅仅让age在(min,max)之间的人来访问。

1、在配置文件中,添加一个Age的断言配置

spring:application:name: api-gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848gateway:discovery:locator:enabled: true  # 让gateway可以发现nacos中的微服务lowerCaseServiceId: true # 将请求路径上的服务名配置为小写routes:- id: shop-product #当前路由标识,要求唯一uri: lb://shop-product #lb代表从nacos中获取微服务,shop-product是微服务的名称order: 1 #路由的优先级,数字越小级别越高predicates: #断言(就是路由转发要满足的条件)- Path=/product/** #当请求路径满足Path指定的规则时,才进行路由转发- Age=18,60 #限制年龄只有在18到60岁之间的人能访问filters: #过滤器,请求在传递过程中可以通过过滤器对其进行一定的修改- StripPrefix=1 #去掉请求路径的第一层

2、自定义一个断言工厂,实现断言方法

@Component
//泛型用于接收一个配置类,配置类用于接收配置文件中的配置。
public class AgeRoutePredicateFactory extends AbstractRoutePredicateFactory<AgeRoutePredicateFactory.Config> {public AgeRoutePredicateFactory() {super(AgeRoutePredicateFactory.Config.class);}/*** 用于从配置文件中获取参数值赋值到配置类中的属性上**/@Overridepublic List<String> shortcutFieldOrder() {//这里的顺序要跟配置文件中的参数顺序一致return Arrays.asList("minAge","maxAge");}/*** 断言**/@Overridepublic Predicate<ServerWebExchange> apply(AgeRoutePredicateFactory.Config config) {return new Predicate<ServerWebExchange>() {@Overridepublic boolean test(ServerWebExchange serverWebExchange) {//从 serverWebExchange 获取传入的参数String ageStr = serverWebExchange.getRequest().getQueryParams().getFirst("age");if(StringUtils.isNotEmpty(ageStr)) {int age = Integer.parseInt(ageStr);return age > config.getMinAge() && age < config.getMaxAge();}return true;}} ;}/*** 自定义一个配置类,用于接收配置文件中的参数**/@Datapublic static class Config {private int minAge;private int maxAge;}}

3、启动测试
在这里插入图片描述

测试发现当age在(18,60)之间可以访问,其它范围不能访问。

总结

到这儿,Gateway 服务网关核心架构的执行流程和断言就已经介绍完了。下一篇将为大家带来Gateway 服务网关核心架构的过滤器相关的文章,敬请期待吧!

后续的文章,我们将继续完善我们的微服务系统,集成更多的Alibaba组件。想要了解更多JAVA后端知识,请点击文末名片与我交流吧。留下您的一键三连,让我们在这个寒冷的东西互相温暖吧!

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

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

相关文章

论文合集整理推荐2024.6.4

论文合集整理推荐2024.6.4 原创 小王搬运工 时序课堂 2024-06-04 20:12 四川 ‍2012年论文合集&#xff1a;论文入口 ‍2019年论文合集&#xff1a;论文入口 2021年论文合集&#xff1a;论文入口 2022年论文合集&#xff1a;论文入口 2023年论文合集&#xff1a;论文入口…

carbondata入库数据查询异常排查

1&#xff0c;背景&#xff1a;carbondata的入库segments对应的状态都是success&#xff0c;但是查询的时候报错&#xff0c; 2&#xff0c;排查内容 1&#xff0c;segments的状态 success 2&#xff0c;任务执行记录日志 正常 3&#xff0c;找到对应查询的天&#xff0c;指定对…

8255A-LED

DATA SEGMENTPORTA EQU 280H ;A端口地址PORTB EQU 281H ;B端口地址PORTD EQU 283H ;命令口地址 DATA ENDSCODE SEGMENTASSUME CS:CODE,DS:DATA START:MOV AX, DATAMOV DS, AXMOV DX, PORTDMOV AL, 10010000BOUT DX,ALMOV DX, 281H MOV AL, 00HOUT DX, ALWAIT1:MOV DX, POR…

【JavaEE精炼宝库】多线程(4)深度理解死锁、内存可见性、volatile关键字、wait、notify

目录 一、死锁 1.1 出现死锁的常见场景&#xff1a; 1.2 产生死锁的后果&#xff1a; 1.3 如何避免死锁&#xff1a; 二、内存可见性 2.1 由内存可见性产生的经典案例&#xff1a; 2.2 volatile 关键字&#xff1a; 2.2.1 volatile 用法&#xff1a; 2.2.2 volatile 不…

C/C++ 检测文件是否存在的方法

在C和C中&#xff0c;检测文件是否存在的方法通常涉及到平台特定的API或者使用标准库的功能&#xff08;在C17及以后版本中&#xff09;。以下是几种常见的方法&#xff1a; C 在C中&#xff0c;通常使用POSIX标准&#xff08;在Unix-like系统上&#xff09;或Windows API&am…

PostgreSQL的视图pg_stat_user_tables

PostgreSQL的视图pg_stat_user_tables pg_stat_user_tables 是 PostgreSQL 中的一个系统视图&#xff0c;用于显示用户定义的表的统计信息。这些统计信息包括表的访问情况、修改情况以及很多其他的性能指标。这个视图为数据库管理员提供了丰富的数据&#xff0c;可以帮助他们进…

使用 Scapy 库编写 ICMP 时间戳攻击脚本

一、介绍 ICMP时间戳攻击&#xff08;ICMP Timestamp Attack&#xff09;是一种利用ICMP协议中的Timestamp请求和响应消息来实施的攻击。攻击者发送大量的ICMP Timestamp请求消息到目标主机&#xff0c;以触发目标主机对每个请求进行响应&#xff0c;从而消耗目标系统的网络资…

Codeforces Round 950 (Div. 3)

好久没写题解了&#xff0c;今天来写个题解。 A - 问题 Generator #include "bits/stdc.h" using namespace std;#define int long long #define endl \n #define IOS ios::sync_with_stdio(0),cin.tie(0); #define all(x) x.begin(),x.end() #define pi pair<in…

【Linux】(一)——Linux基础和Linux命令基础语法

目录 Linux基础Linux发行版本Linux终端Linux命令 Linux基础 Linux&#xff0c;通常指的是GNU/Linux操作系统&#xff0c;这是一个开源且免费使用的类UNIX操作系统。它的核心组件——Linux内核&#xff0c;由林纳斯托瓦兹&#xff08;Linus Torvalds&#xff09;在1991年10月5日…

Arthas使用教程——JVM常用命令

JVM相关命令 dashboard——当前系统的实时数据面板 显示当前 tomcat 的实时信息。 使用方式&#xff1a;dashboard 数据说明 ID: Java 级别的线程 ID&#xff0c;注意这个 ID 不能跟 jstack 中的 nativeID 一一对应。 NAME: 线程名 GROUP: 线程组名 PRIORITY: 线程优先级…

Rocky Linux安装与基础配置

目录 背景与起源 主要特点 目标用户 发展前景 下载 安装 常用配置命令&#xff1a; 更换镜像源 Rocky Linux 是一个开源的、由社区驱动的操作系统&#xff0c;旨在使用 Red Hat Enterprise Linux&#xff08;RHEL&#xff09;源码构建的下游二进制兼容发行版。以下是关于…

优思学院|一文看懂新版FMEA与FMEA的七大步骤

FMEA的起源 FMEA最早起源于20世纪40年代的美国军工行业。当时&#xff0c;美国军方为了提高武器系统的可靠性和安全性&#xff0c;开始使用FMEA来识别和评估潜在的故障模式及其影响。1949年&#xff0c;美国军方发布了《军用程序手册》&#xff08;Military Procedures Handbo…

【Android面试八股文】在Java中重载和重写是什么意思,区别是什么?

文章目录 在Java中重载和重写是什么意思,区别是什么?这道题想考察什么 ?考察的知识点考生应该如何回答重载(Overloading)重写(Overriding)重载和重写的区别在Java中重载和重写是什么意思,区别是什么? 这道题想考察什么 ? Java基础 考察的知识点 面向对象多态的基…

五种网络IO模型

目录 前言 文件描述符 为什么要多种io模型 同步IO 1.阻塞IO 2.非阻塞IO 3.多路复用IO&#xff08;事件驱动IO&#xff09; select: poll&#xff1a; epoll&#xff1a; 4.信号驱动IO 异步IO 区别 前言 文件描述符 首先我们了解一下文件描述符是什么&#xff1a;…

【Python报错】已解决AttributeError: ‘method‘ object has no attribute ‘xxx‘

解决Python报错&#xff1a;AttributeError: ‘method’ object has no attribute ‘xxx’ 在Python中&#xff0c;AttributeError通常表明你试图访问的对象没有你请求的属性或方法。如果你遇到了AttributeError: method object has no attribute xxx的错误&#xff0c;这通常意…

批量处理脚本,用于删除指定目录下3天前的备份文件和日志。

echo off echo 删除3天前的备份文件和日志 set SrcDirD:\home set DaysAgo3 echo 准备删除3天前的备份文件和日志 forfiles /p %SrcDir% /d -%DaysAgo% /c "cmd /c del /f /q /a path && rd /s /q path" echo 正在执行删除&#xff0c;请稍等…… set SrcDi…

奇迹MU最强法师介绍

1、黑龙波 释放出深渊中的黑龙之魂&#xff0c;对一定范围内的目标造成中等程度伤害。 奥义&#xff1a; 怒哮——法师释放出深渊龙魂的怨怒之力&#xff0c;在电闪雷鸣中中咆哮的龙魂将对敌人额外造成少量伤害。 魂阵——法师利用法阵控制黑龙之魂进行更大范围的攻击&…

如何使用SeaFile文件共享服务器结合内网穿透将家中电脑变成个人云盘

文章目录 1. 前言2. SeaFile云盘设置2.1 Owncould的安装环境设置2.2 SeaFile下载安装2.3 SeaFile的配置 3. cpolar内网穿透3.1 Cpolar下载安装3.2 Cpolar的注册3.3 Cpolar云端设置3.4 Cpolar本地设置 4.公网访问测试5.结语 1. 前言 本文主要为大家介绍&#xff0c;如何使用两个…

opt 优化

【整理】深入理解拉格朗日乘子法&#xff08;Lagrange Multiplier) 和KKT条件 【amos注】&#xff1a;通俗易懂&#xff0c;让人易于理解。

【Oracle篇】rman全库异机恢复:从RAC环境到单机测试环境的转移(第四篇,总共八篇)

&#x1f4ab;《博主介绍》&#xff1a;✨又是一天没白过&#xff0c;我是奈斯&#xff0c;DBA一名✨ &#x1f4ab;《擅长领域》&#xff1a;✌️擅长Oracle、MySQL、SQLserver、阿里云AnalyticDB for MySQL(分布式数据仓库)、Linux&#xff0c;也在扩展大数据方向的知识面✌️…