Spring Cloud Gateway详解

文章目录

    • Gateway搭建
    • 路由(route)
    • 断言(Predicate )
      • 自定义断言
    • 过滤器(filter)
      • 自定义全局过滤器

引言

  在传统的单体项目中,前端和后端的交互相对简单,只需通过一个调用地址即可实现。然而,随着微服务架构的兴起,后端服务被拆分成多个微服务,这给前端带来了新的挑战:需要记住每个微服务的地址才能进行交互。显然,这种做法不仅繁琐,还容易导致前端代码的不可维护性和耦合度的增加。为了解决这一问题,网关应运而生!

  在微服务中,比较常见的网关有Spring Cloud GatewayNetflix Zuul等等,由于Zuul已经停止维护了,并且Spring Cloud Gateway 在性能、灵活性、易用性和社区支持等方面都具有优势,所以现目前常用Gateway作为微服务的网关。

Gateway搭建

版本说明:

<spring-cloud.version>Greenwich.SR5</spring-cloud.version>
<spring-cloud-alibaba.version>2.1.2.RELEASE</spring-cloud-alibaba.version>

创建一个Gateway微服务项目,引入依赖

<dependencies><!--Gateway--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency>
</dependencies>

再写个启动类,启动即可

下面介绍Gateway的配置三要素,路由(route)断言(Predicate )过滤器(filter)

路由(route)

  在网关中,路由决定了请求应该被转发到哪个后端服务处理,路由功能使得网关能够将请求动态地转发到不同的后端服务,从而实现请求的分发和负载均衡。

从代码中不难看出,路由的配置主要有下面几个属性
在这里插入图片描述

spring:cloud:gateway:## 路由routes:## id名称任意,唯一即可- id: gateway-service-01## 路由转发的uriuri: http://localhost:8011- id: gateway-service-02uri: http://localhost:8012

  routes下面是可以配置多个路由的,如上图所示,那到底什么时候走8011,什么时候走8012呢,这就需要用到Gateway中非常重要的组件,Predicate断言!

断言(Predicate )

  简单来说,Gateway的断言就是一种条件判断,用来控制请求向那个路由转发,可以根据需要灵活地定制路由规则。

  在Gateway中,内置的断言有很多,可以根据不同的属性进行配置,提供的路由断言工厂有如下几个:
在这里插入图片描述

  比如有根据请求路径的PathRoutePredicateFactory,有根据请求方法的MethodRoutePredicateFactory,有根据请求头的HeaderRoutePredicateFactory,等等,因为这些断言的命名都是有规范的,都是xxxRoutePredicateFactory的格式,所以在配置的时候只需要写前面部分的名称就行了,比如Path,Method。

好,现在我们就来配置一个根据Path的断言

spring:cloud:gateway:## 路由routes:## id名称任意,唯一即可- id: gateway-service-01## 路由转发的uriuri: http://localhost:8011## 配置断言predicates:## 满足/api/orderService/** 这个请求路径的,都会被路由到http://localhost:8011- Path=/api/orderService/**- id: gateway-service-02uri: http://localhost:8012## 配置断言predicates:## 满足/api/userService/** 这个请求路径的,都会被路由到http://localhost:8012- Path=/api/userService/**

当然,断言可以配置多个,之间是and的关系,比如我们可以配置权重比例

spring:cloud:gateway:## 路由routes:## id名称任意,唯一即可- id: gateway-service-01## 路由转发的uriuri: http://localhost:8011## 配置断言predicates:## 满足/api/orderService/** 这个请求路径的,都会被路由到http://localhost:8011- Path=/api/orderService/**- id: gateway-service-02uri: http://localhost:8012## 配置断言predicates:## 满足/api/userService/** 这个请求路径的,都会被路由到http://localhost:8012- Path=/api/userService/**## 同一分组按照权重进行分配流量,这里分配了60%## 第一个userGroup是分组名,第二个参数是权重- Weight=userGroup, 6- id: gateway-service-03uri: http://localhost:8013predicates:- Path=/api/userService/**- Weight=userGroup, 4    

  这里路由gateway-service-02和gateway-service-03断言的Path都是一样的,但是加了Weight权重,当大量请求过来时,路由到8012的流量大约有60%,路由到8013的流量大约有40%,做到负载均衡的作用。

下面建立OrderService和UserService服务进行验证

// userService
@RestController
@RequestMapping("/api/userService")
@Slf4j
public class UserController {@GetMapping("/test")public ResponseEntity<String> testOrder() {log.info("进入userService...");return ResponseEntity.ok().body("进入userService");}
}// orderService
@RestController
@RequestMapping("/api/orderService")
@Slf4j
public class OrderController {@GetMapping("/test")public ResponseEntity<String> testOrder(){log.info("进入orderService...");return ResponseEntity.ok().body("进入orderService");}
}

我这里启动网关服务,一个订单服务,两个用户服务
在这里插入图片描述

启动两个userService是为了测试权重的配置

输入地址,注意这里是网关的IP+端口

http://localhost:8010/api/orderService/test
在这里插入图片描述

http://localhost:8010/api/userService/test
在这里插入图片描述

网关配置的Path起到了效果

再测试下权重的配置

连续访问http://localhost:8010/api/userService/test 10次
在这里插入图片描述
在这里插入图片描述

可以看出和我们在网关配置的比例大致相等,做到了按权重分发请求流量

自定义断言

接下来,我们自己定义一个断言来试试

/*** 自定义一个指定时间访问的断言* 1.类名称必须是配置+RoutePredicateFactory* 2.必须继承AbstractRoutePredicateFactory<自定义的内部类>*/
@Component
public class MyHourRoutePredicateFactory extends AbstractRoutePredicateFactory<MyHourRoutePredicateFactory.MyConfig> {/*** 必须用无参构造*/public MyHourRoutePredicateFactory() {super(MyHourRoutePredicateFactory.MyConfig.class);}/*** 通过apply进行逻辑判断 true就是匹配成功 false匹配失败** @param config* @return*/@Overridepublic Predicate<ServerWebExchange> apply(MyHourRoutePredicateFactory.MyConfig config) {return new Predicate<ServerWebExchange>() {@Overridepublic boolean test(ServerWebExchange serverWebExchange) {// 获取当前时间LocalDateTime now = LocalDateTime.now();int hour = now.getHour();// 判断时间是否大于配置的时间if (hour >= config.getMyHour()) {return true;}return false;}};}/*** 读取配置文件的参数值,赋值到配置类中的属性上** @return*/@Overridepublic List<String> shortcutFieldOrder() {// 顺序必须必须和yml文件中的配置顺序一致return Arrays.asList("myHour");}/*** 接收配置参数*/@Data@NoArgsConstructorpublic static class MyConfig {private int myHour;}}

我们直接在OrderService增加这个配置

spring:cloud:gateway:## 路由routes:## id名称任意,唯一即可- id: gateway-service-01## 路由转发的uriuri: http://localhost:8011## 配置断言predicates:## 满足/api/orderService/** 这个请求路径的,都会被路由到http://localhost:8011- Path=/api/orderService/**## 自定义的断言 当前时间在16点后才允许访问- MyHour=16  

在这里插入图片描述

如上图所示,当前时间是15点,未到16点,不能访问,我再把时间配置为15点试试
在这里插入图片描述

顺利进入!

过滤器(filter)

  接下来,介绍下另外一个重要组件,过滤器,路由过滤器会对请求或响应做相应的处理,Gateway目前有30多种内置的过滤器,具体可参考 https://docs.spring.io/spring-cloud-gateway/docs/current/reference/html/#gatewayfilter-factories

其中分为局部过滤器和全局过滤器。

常见的局部过滤器:

名称说明
AddRequestHeaderGatewayFilterFactory添加一个请求头
RemoveRequestHeaderGatewayFilterFactory移除一个请求头
RemoveResponseHeaderGatewayFilterFactory移除一个响应头
RequestRateLimiterGatewayFilterFactory请求限流设置
AddResponseHeaderGatewayFilterFactory添加一个响应头

我们简单举个例子,使用AddResponseHeaderGatewayFilterFactory,为请求添加响应头

配置的时候还是和断言一样的,只需要写前面的AddResponseHeader即可

spring:cloud:gateway:## 路由routes:## id名称任意,唯一即可- id: gateway-service-01## 路由转发的uriuri: http://localhost:8011## 配置断言predicates:## 满足/api/orderService/** 这个请求路径的,都会被路由到http://localhost:8011- Path=/api/orderService/**- MyHour=15# 过滤器配置(局部)filters:- AddResponseHeader=myKey,myVal

访问下就可以看到设置的值已经在响应头了
在这里插入图片描述

但是对于其他的请求是没有的,下面将配置一个默认过滤器配置 ,也是个全局过滤器,默认过滤器default-filters的配置和routes是平级的。

server:port: 8010spring:cloud:gateway:## 路由routes:## id名称任意,唯一即可- id: gateway-service-01## 路由转发的uriuri: http://localhost:8011## 配置断言predicates:## 满足/api/orderService/** 这个请求路径的,都会被路由到http://localhost:8011- Path=/api/orderService/**- MyHour=15- id: gateway-service-02uri: http://localhost:8012## 配置断言predicates:## 满足/api/userService/** 这个请求路径的,都会被路由到http://localhost:8012- Path=/api/userService/**## 同一分组按照权重进行分配流量,这里分配了60%## 第一个userGroup是分组名,第二个参数是权重- Weight=userGroup, 6- id: gateway-service-03uri: http://localhost:8013predicates:- Path=/api/userService/**- Weight=userGroup, 4# 默认过滤器,对所有路由生效default-filters:- AddResponseHeader=myKey,myVal

在这里插入图片描述
在这里插入图片描述

配置一个,全局生效

自定义全局过滤器

  和断言一样,也可以自定义过滤器,自定义局部过滤器需要extends AbstractGatewayFilterFactory,自定义全局过滤器需要实现GlobalFilter ,我们这里定义一个全局的过滤器吧。

/*** 全局过滤器 认证*/
@Component
@Order(-1)
public class MyGatewayFilter implements GlobalFilter {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 1.获取请求参数MultiValueMap<String, String> params = exchange.getRequest().getQueryParams();// 2.获取user参数String userName = params.getFirst("name");if ("root".equals(userName)) {return chain.filter(exchange);// 继续执行后续的过滤器}// 3.拦截exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);// 禁止访问return exchange.getResponse().setComplete();}
}

在这里插入图片描述
在这里插入图片描述

我们可以定义多个过滤器,那么Order的值就决定了执行的先后顺序

Order的值越大,优先级越低,值越小,优先级越高

定义Order的值有两种方式

  • 实现Ordered接口,重写getOrder方法
  • 实用@Order注解

过滤器的执行顺序:默认过滤器(default-filters) ----> 局部过滤器------> 全局过滤器

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

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

相关文章

【C语言题解】用函数来模拟实现strlen()、strcpy()、strcmp()、strcat()

&#x1f970;欢迎关注 轻松拿捏C语言系列&#xff0c;来和 小哇 一起进步&#xff01;✊ 学习了函数后&#xff0c;老师让我们用函数来实现上面这四个字符串函数。 我们首先来了解一下这四个字符串函数&#xff1a; 1.strlen函数 用于获取字符串长度&#xff08;不包括末尾…

每日OJ题_贪心算法四②_力扣435. 无重叠区间

目录 力扣435. 无重叠区间 解析代码 力扣435. 无重叠区间 435. 无重叠区间 难度 中等 给定一个区间的集合 intervals &#xff0c;其中 intervals[i] [starti, endi] 。返回 需要移除区间的最小数量&#xff0c;使剩余区间互不重叠 。 示例 1: 输入: intervals [[1,2]…

IDEA安装使用Git

IDEA安装使用Git 1 Git下载与安装 2 在IDEA中使用Git 2.1 IDEA中配置Git 在IDEA中使用Git&#xff0c;本质上还是使用本地安装的Git软件&#xff0c;所以需要在IDEA中配置Git。 2.2 在IDEA中使用Git 2.2.1 获取Git仓库 在IDEA中使用Git获取仓库有两种方式: 本地初始化仓库从…

CentOS7 安装 Kamailio

https://www.kamailio.org/wiki/packages/rpms 官方文档说 yum -y install yum-utils yum-config-manager --add-repo https://rpm.kamailio.org/centos/kamailio.repo 但目前这样其实行不通 需要这样做&#xff1a; yum install --disablerepokamailio --enablerepokamai…

数据库出现死锁的解决方法参考

死锁引起的原因一般是多个用户并发访问数据库导致的问题&#xff0c;或是因为某个进程挂死以后资源未释放导致的。通过onstat –p可查看deadlks项大于0即表示历史总计死锁次数。对于被锁的表进行操作的时候会出现-143 ISAM error: deadlock detected的错误。当其他会话访问此表…

从JSON数据到Pandas DataFrame:如何解析出所需字段

目录 一、引言 二、JSON数据的基本结构 三、使用Pandas从JSON数据中读取数据 四、从DataFrame中解析出所需字段 解析对象字段 解析嵌套对象字段 解析数组字段 五、案例与代码示例 六、总结 一、引言 在数据分析和处理的日常工作中&#xff0c;我们经常需要从各种…

UBoat:一款功能强大的HTTP Botnet学习与研究工具

关于UBoat UBoat是一款功能强大的HTTP Botnet概念验证工具&#xff0c;该工具支持复刻一个现实场景中完整功能的Botnet测试环境&#xff0c;广大研究人员可以利用UBoat深入学习和研究Botnet的工作机制&#xff0c;以此来提升安全检测和保护策略。 功能介绍 1、基于C开发&…

luceda ipkiss教程 70:合并GDS版图

通过代码拼版&#xff1a; 所有代码如下&#xff1a; from si_fab import all as pdk from ipkiss3 import all as i3class Design1(i3.GDSCell):def _default_filename(self):return "Ring_Test.gds"def _default_name(self):return "Design1"class Des…

VTK官方例子

VTK官方例子 vtkMutableDirectedGraph #!/usr/bin/env python# noinspection PyUnresolvedReferences import vtkmodules.vtkInteractionStyle # noinspection PyUnresolvedReferences import vtkmodules.vtkRenderingOpenGL2 from vtkmodules.vtkCommonColor import vtkName…

Apache Flume事务

Apache Flume 中的事务处理是指 Flume Agent 在处理事件流时的一种机制&#xff0c;用于确保数据的可靠传输和处理。 1. 事务概述&#xff1a; Flume 中的事务是指一组事件的传输和处理&#xff0c;这些事件在传输过程中要么全部成功完成&#xff0c;要么全部失败&#xff0…

Jsp+Servlet实现图片上传和点击放大预览功能(提供Gitee源码)

前言&#xff1a;在最近老项目的开发中&#xff0c;需要做一个图片上传和点击放大的功能&#xff0c;在Vue和SpringBoot框架都有现成封装好的组件和工具类&#xff0c;对于一些上世纪的项目就没这么方便了&#xff0c;所以需要自己用原生的代码去编写&#xff0c;这里分享一下我…

01.Net基础知识

.Net的用途 Web、移动、云、桌面、游戏开发、物联网 &#xff08;IDE&#xff1a;集成开发环境&#xff09; .Net学习资源 Microsoft Learn、GitHub、G码云&#xff08;Gitee&#xff09; Visual Studio初步使用 1&#xff09;可创建的项目种类&#xff08;主要学习以下四…

Maven 的仓库、周期和插件

优质博文&#xff1a;IT-BLOG-CN 一、Maven 仓库 在Maven的世界中&#xff0c;任何一个依赖、插件或者项目构建的输出&#xff0c;都可以称为构建。Maven在某个统一的位置存储所有项目的共享的构建&#xff0c;这个统一的位置&#xff0c;我们就称之为仓库。任何的构建都有唯一…

经典权限五张表功能实现

文章目录 用户模块(未使用框架)查询功能实现步骤代码 新增功能实现步骤代码 修改功能实现步骤代码实现 删除功能实现步骤代码实现 用户模块会了&#xff0c;其他两个模块与其类似 用户模块(未使用框架) 查询功能 这里将模糊查询和分页查询写在一起 实现步骤 前端&#xff1…

翻译/润色找哪里比较专业,机构怎么选?

英文专业术语多&#xff0c;润色是很有必要的&#xff0c;大家可以选择专业的文章翻译润色服务&#xff0c;一定要挑选好正规的机构&#xff0c;这样的机构在出版过程中会为作者提供多项支持&#xff0c;对顺利发表是有帮助的。 科研领域英文论文专业润色包含这些内容&#xff…

基于Huffman编码的字符串统计及WPL计算

一、问题描述 问题概括&#xff1a; 给定一个字符串或文件&#xff0c;基于Huffman编码方法&#xff0c;实现以下功能&#xff1a; 1.统计每个字符的频率。 2.输出每个字符的Huffman编码。 3.计算并输出WPL&#xff08;加权路径长度&#xff09;。 这个问题要求对Huffman编码算…

德国Dürr杜尔机器人维修技巧分析

在工业生产中&#xff0c;杜尔工业机器人因其高效、精准和稳定性而备受青睐。然而&#xff0c;即便是最精良的设备&#xff0c;也难免会出现Drr机械手故障。 一、传感器故障 1. 视觉传感器故障&#xff1a;可能导致机器人无法正确识别目标物&#xff0c;影响工作效率。解决方法…

【页面】3D六边形

<!DOCTYPE html> <html> <head><title>3D正六边形</title><style>body {display: flex;justify-content: center;align-items: center;height: 100vh;margin: 0;}.container {perspective: 1000px;}.hexagon {width: 200px;height: 200px;…

Java并发处理

Java并发处理 问题描述:项目中业务编号出现重复编号 生成编号规则&#xff1a;获取数据库表最大值&#xff0c;然后再做1处理&#xff0c;即为新编号&#xff08;因为起始值是不固定的&#xff0c;还存在‘字符数据’格式&#xff0c;做了字典项可配置&#xff0c;所以不能直…

俄罗斯方块的代码实现

文章目录 首先是头文件的引入部分接下来是一些预处理指令接下来定义了两个结构体&#xff1a;接下来是全局变量g_hConsoleOutput&#xff0c;用于存储控制台输出句柄。之后是一系列函数的声明最后是main函数源码 首先是头文件的引入部分 包括stdio.h、string.h、stdlib.h、tim…