springboot使用Gateway做网关并且配置全局拦截器

一、为什么要用网关

统一入口:

  • 作用:作为所有客户端请求的统一入口。
  • 说明:所有客户端请求都通过网关进行路由,网关负责将请求转发到后端的微服务

路由转发:

  • 作用:根据请求的URL、方法等信息将请求路由到不同的微服务。
  • 说明:网关可以根据配置的路由规则,将请求转发到正确的微服务,实现请求的路由和负载均衡。

负载均衡:

  • 作用:实现请求的负载均衡。
  • 说明:网关可以集成负载均衡组件(如Ribbon),根据负载均衡策略将请求分发到不同的服务实例,提高系统的可用性和扩展性。

服务发现:

  • 作用:与服务注册中心集成,实现服务的自动发现。
  • 说明:网关可以与Eureka等服务注册中心集成,动态获取服务实例的信息,实现服务的自动发现和路由。

认证与授权:

  • 作用:提供统一的安全认证和授权机制。
  • 说明:网关可以集成认证和授权组件(如OAuth2、JWT),对所有进入的请求进行安全检查,确保只有合法的请求才能访问后端服务。

跨域资源共享(CORS):

  • 作用:处理跨域请求。
  • 说明:网关可以处理跨域请求,允许来自不同域的客户端访问后端服务,解决了浏览器的同源策略限制。

二、Gateway简单使用

第一步:引入Gateway的maven依赖到pom.xml文件

        <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-gateway</artifactId></dependency>

第二步:编写配置文件application.yml文件,如下所示:

server:port: 10086   # 网关端口
spring:application:name: gateway # 服务名称cloud:nacos:server-addr: localhost:8848    # nacos 地址gateway:routes:         # 网关路由配置- id: provider      # 路由id,自定义,只要唯一即可# uri: http://127.0.0.1:8081   # 路由的目标地址 (直接写死地址的方式,不推荐)uri: lb://provider    # 路由的目标地址 lb是负载均衡,后面跟服务名称(推荐)predicates:       # 路由断言,判断请求是否符合路由规则的条件- Path=/provider/**      # 按照路径匹配,以/user/开头的请求就符合要求

第三步:启动测试

当然要注意的是我们需要开启另一个服务provider服务,并且这个服务需要配置方法前缀/provider,当我们通过网关访问的时候就可以直接的访问到provider服务了。

三、Gateway断言工厂

路由断言主要用来判断路由的规则。

配置文件中写的断言规则只是字符串,这些字符串会被Predicate Factory读取并处理。

例如Path=/user/**是按照路径匹配,这个规则是由org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory类来处理。

像这样的断言工厂在SpringCloudGateway还有十几个:

当然这个地方可能给的不是很全所以我贴出官网地址:大家需要的可以去看官网:Spring Cloud Gatewayicon-default.png?t=N7T8https://docs.spring.io/spring-cloud-gateway/docs/3.1.4-SNAPSHOT/reference/html/#gateway-request-predicates-factories

简单示例,下面我配置一个在访问之前需要到一定的时间才可以访问,并且看一下效果

server:port: 10086   # 网关端口
spring:application:name: gateway # 服务名称cloud:nacos:server-addr: localhost:8848    # nacos 地址gateway:routes:         # 网关路由配置- id: provider      # 路由id,自定义,只要唯一即可# uri: http://127.0.0.1:8081   # 路由的目标地址 (直接写死地址的方式,不推荐)uri: lb://provider    # 路由的目标地址 lb是负载均衡,后面跟服务名称(推荐)predicates:       # 路由断言,判断请求是否符合路由规则的条件- Path=/provider/**      # 按照路径匹配,以/user/开头的请求就符合要求- After=2031-01-20T17:42:47.789-07:00[America/Denver]

因为我配置了需要在2031年1月20号后才可以访问明显现在是2024年不可以访问到,所以会报错404。

四、Gateway路由过滤器

客户端请求先找到路由,路由匹配时经过过滤器层层筛选,最终访问到微服务。

当然微服务的请求反悔时,也会经过过滤器的筛选,只不过我们一般只对请求过滤,而不会对响应过滤。

SpringCloudGateWay目前已经提供了34种不同的过滤器工厂。感兴趣的大家也可以去上面给出的官网地址查看。

下面我在路由过滤器中添加一个请求头,并且需要在provider请求中加入一个参数去拿到请求头中的参数

server:port: 10086   # 网关端口
spring:application:name: gateway # 服务名称cloud:nacos:server-addr: localhost:8848    # nacos 地址gateway:routes:         # 网关路由配置- id: provider      # 路由id,自定义,只要唯一即可# uri: http://127.0.0.1:8081   # 路由的目标地址 (直接写死地址的方式,不推荐)uri: lb://provider    # 路由的目标地址 lb是负载均衡,后面跟服务名称(推荐)predicates:       # 路由断言,判断请求是否符合路由规则的条件- Path=/provider/**      # 按照路径匹配,以/user/开头的请求就符合要求filters: # 过滤器配置- AddRequestHeader=token, test # 添加请求头

provider请求变为,需要拿到请求头中的信息

    @GetMapping("/provider/t")public String t(@RequestHeader(value = "token",required = false)String token){return "恭喜您测试成功啦!"+token;}

测试

当然这是局部配置我们也可以针对所有的路由进行全局配置(但是这个配置是需要和路由s是同级的),如下所示:

server:port: 10086   # 网关端口
spring:application:name: gateway # 服务名称cloud:nacos:server-addr: localhost:8848    # nacos 地址gateway:routes:         # 网关路由配置- id: provider      # 路由id,自定义,只要唯一即可# uri: http://127.0.0.1:8081   # 路由的目标地址 (直接写死地址的方式,不推荐)uri: lb://provider    # 路由的目标地址 lb是负载均衡,后面跟服务名称(推荐)predicates:       # 路由断言,判断请求是否符合路由规则的条件- Path=/provider/**      # 按照路径匹配,以/user/开头的请求就符合要求default-filters: # 默认过滤器配置- AddRequestHeader=token, test  # 添加请求头

五、Gateway全局过滤器

上面的gateway路由器可以配置全局的,为什么还需要有一个全局过滤器呢,因为上面的过滤器都是只可以针对与一些逻辑的拦截,但是不可以涉及到一些业务的处理,所以就有这个全局过滤器可以通过编写代码的方式来编写业务逻辑进行对用户访问的鉴权放行等等。

package com.example.demo.filter;import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.util.MultiValueMap;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;@Component
public class GateWayFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 1.获取请求参数//1.这里的request并不是servlet中的request//2.返回值是一个多键的map集合、也就是说这个map集合的键可以重复MultiValueMap<String, String> params = exchange.getRequest().getQueryParams();// 2.获取userName参数String userName = params.getFirst("userName");// 3.校验if ("root".equals(userName)) {// 放行return chain.filter(exchange);}// 4.拦截// 4.1.禁止访问,设置状态码exchange.getResponse().setStatusCode(HttpStatus.valueOf(500));// 4.2.结束处理return exchange.getResponse().setComplete();}//过滤器优先级,数字越小优先级越高@Overridepublic int getOrder() {return -1;}
}

测试:

我们先正常的访问之前的请求,会发现无法使用此页面也就是被拒绝访问了

当我们加上一个参数后把userName=root加上之后就可以正确的访问到请求了

过滤器链执行顺序

SpringCloudGateWay中,有三种过滤器:

  • 默认过滤器default-filters

  • 只对具体某个路由生效的局部过滤器filters

  • 使用java代码编写的全局过滤器GlobalFilter

过滤器最终都会转化成GlobalFilter(使用的是适配器模式)所以我们就可以把这三种过滤器看成一个整体而顺序也入下图显示的一致。

由上图知过滤器的执行顺序为:默认过滤器 → 当前路由过滤器 → 全局过滤器。

六、Gateway跨域请求配置

1.跨域请求定义

跨域:请求位置和被请求位置不同源就会发生跨域。

这里的不同源包括两个点:

  • 域名不同:www.baidu.com 和 www.taobao.com。(IP不同也是相同道理)

  • 端口不同:127.0.0.1:8080和127.0.0.1:8081。

而浏览器又会禁止请求的发起者与服务端发生跨域AJAX请求。

如果发生了跨域请求,服务器端是能够正常响应的,但是响应的结果会被浏览器拦截。

2.跨域常见解决方案

使用CORS方式。

CORS是一个W3C标准,全称是"跨域资源共享"(Cross-origin resource sharing)。

它允许浏览器向跨源服务器,发出XMLHttpRequest请求,从而克服了AJAX只能同源使用的限制。

3.跨域请求解决方案

方式一:配置application.yml文件:

spring:cloud:gateway:globalcors: # 全局的跨域配置add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题# options请求 就是一种询问服务器是否浏览器可以跨域的请求# 如果每次跨域都有询问服务器是否浏览器可以跨域对性能也是损耗# 可以配置本次跨域检测的有效期maxAge# 在maxAge设置的时间范围内,不去询问,统统允许跨域corsConfigurations:'[/**]':allowedOrigins:   # 允许哪些网站的跨域请求 - "http://localhost:8090"allowedMethods:   # 允许的跨域ajax的请求方式- "GET"- "POST"- "DELETE"- "PUT"- "OPTIONS"allowedHeaders: "*"  # 允许在请求中携带的头信息allowCredentials: true # 允许在请求中携带cookiemaxAge: 360000    # 本次跨域检测的有效期(单位毫秒)# 有效期内,跨域请求不会一直发option请求去增大服务器压力

方式二:使用编码方式定义配置类:

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.cors.reactive.CorsUtils;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono;@Configuration
public class CorsConfig {private static final String MAX_AGE = "18000L";@Beanpublic WebFilter corsFilter() {return (ServerWebExchange ctx, WebFilterChain chain) -> {ServerHttpRequest request = ctx.getRequest();// 使用SpringMvc自带的跨域检测工具类判断当前请求是否跨域if (!CorsUtils.isCorsRequest(request)) {return chain.filter(ctx);}HttpHeaders requestHeaders = request.getHeaders();                                  // 获取请求头ServerHttpResponse response = ctx.getResponse();                                    // 获取响应对象HttpMethod requestMethod = requestHeaders.getAccessControlRequestMethod();          // 获取请求方式对象HttpHeaders headers = response.getHeaders();                                        // 获取响应头headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, requestHeaders.getOrigin());   // 把请求头中的请求源(协议+ip+端口)添加到响应头中(相当于yml中的allowedOrigins)headers.addAll(HttpHeaders.ACCESS_CONTROL_ALLOW_HEADERS, requestHeaders.getAccessControlRequestHeaders());if (requestMethod != null) {headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_METHODS, requestMethod.name());    // 允许被响应的方法(GET/POST等,相当于yml中的allowedMethods)}headers.add(HttpHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS, "true");          // 允许在请求中携带cookie(相当于yml中的allowCredentials)headers.add(HttpHeaders.ACCESS_CONTROL_EXPOSE_HEADERS, "*");                // 允许在请求中携带的头信息(相当于yml中的allowedHeaders)headers.add(HttpHeaders.ACCESS_CONTROL_MAX_AGE, MAX_AGE);                           // 本次跨域检测的有效期(单位毫秒,相当于yml中的maxAge)if (request.getMethod() == HttpMethod.OPTIONS) {                                    // 直接给option请求反回结果response.setStatusCode(HttpStatus.OK);return Mono.empty();}return chain.filter(ctx);                                                           // 不是option请求则放行};}}

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

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

相关文章

Hive之扩展函数(UDF)

Hive之扩展函数(UDF) 1、概念讲解 当所提供的函数无法解决遇到的问题时&#xff0c;我们通常会进行自定义函数&#xff0c;即&#xff1a;扩展函数。Hive的扩展函数可分为三种&#xff1a;UDF,UDTF,UDAF。 UDF&#xff1a;一进一出 UDTF&#xff1a;一进多出 UDAF&#xff1a…

作业帮6-19笔试-选填题

可以看到10在第一位&#xff0c;说明用的是挖坑法快速排序&#xff0c;过程如下&#xff1a; 右指针从最右边开始&#xff0c;找到第一个比30小的数10&#xff0c;与30交换。 10、15、40、28、50、30、70 左指针从位置1开始&#xff0c;找到40&#xff0c;与30互换。 10、15、3…

C语言 ——— 函数指针的定义 函数指针的使用

目录 何为函数指针 打印 函数名的地址 及 &函数名的地址 函数指针的代码&#xff08;如何正确存储函数地址&#xff09; 函数指针的使用 何为函数指针 类比&#xff1a; 整型指针 - 指向整型数据的指针&#xff0c;整型指针存放的是整型数据的地址 字符指针 - 指向字…

Lc63---1859将句子排序(排序)---Java版(未写完)

1.题目描述 2.思路 &#xff08;1&#xff09;首先将句子按空格分割成若干单词。 &#xff08;2&#xff09;每个单词的最后一个字符是它的位置索引。我们可以通过这个索引将单词恢复到正确的位置。 &#xff08;3&#xff09;按照单词的索引顺序排序这些单词。 &#xff08;4…

分布式搜索引擎ES--Elasticsearch集群

1.Elasticsearch集群的概念 分片机制&#xff1a;每个索引都可以被分片 索引my_doc只有一个主分片&#xff1b;索引shop有三个主分片&#xff1b;索引shop2有5个主分片;(参考前面案例) 每个主分片都包含索引的数据&#xff0c;由于目前是单机&#xff0c;所以副分片是没有的&a…

shardingsphere的学习(二):sharingjdbc操作读写分离

简介 mysql配置读写分离以及使用shardingjdbc配置操作读写分离 读写分离 主数据库负责增删改操作&#xff08;写&#xff09;&#xff0c;从数据库负责查询操作&#xff08;读&#xff09;&#xff0c;主数据库和从数据库之间会数据同步&#xff08;主从复制&#xff09;。 …

【前端】一文带你了解 CSS

文章目录 1. CSS 是什么2. CSS 引入方式2.1 内部样式2.2 外部样式2.3 内联样式 3. CSS 常见选择器3.1 基础选择器3.1.1 标签选择器3.1.2 类选择器3.1.3 id 选择器3.1.4 通配符选择器 3.2 复合选择器3.2.1 后代选择器 4. CSS 常用属性4.1 字体相关4.2 文本相关4.3 背景相关4.4 设…

敢不敢跟我一起搭建一个Agent!不写一行代码,10分钟搞出你的智能体!纯配置也能真正掌握AI最有潜力的技术?AI圈内人必备技能

说一千道一万&#xff0c;不如实地转一转。学了那么久的AI Agent的概念了&#xff0c;是时候该落地一个Agent看看自己的掌握程度了对不对&#xff0c;我们都理解大脑是自动节能的&#xff0c;但是知识的确需要倒逼自己一把才能真的掌握&#xff0c;不瞒大家说&#xff0c;笔者对…

论文阅读:面向自动驾驶场景的多目标点云检测算法

论文地址:面向自动驾驶场景的多目标点云检测算法 概要 点云在自动驾驶系统中的三维目标检测是关键技术之一。目前主流的基于体素的无锚框检测算法通常采用复杂的二阶段修正模块,虽然在算法性能上有所提升,但往往伴随着较大的延迟。单阶段无锚框点云检测算法简化了检测流程,…

日程管理多源归一,服务场景一键直达

时间对于每个人来说都是非常宝贵的&#xff0c;曾经我们使用台历、挂历来标记和查看重要日程&#xff0c;通过翻页来见证时光的流逝&#xff0c;随着信息化时代的不断发展&#xff0c;更加灵活简洁的电子日历成为主流&#xff0c;日历也从一个最简单的日期看板&#xff0c;慢慢…

正余弦算法作者又提出新算法!徒步优化算法(HOA)-2024年一区顶刊新算法-公式原理详解与性能测评 Matlab代码免费获取

声明&#xff1a;文章是从本人公众号中复制而来&#xff0c;因此&#xff0c;想最新最快了解各类智能优化算法及其改进的朋友&#xff0c;可关注我的公众号&#xff1a;强盛机器学习&#xff0c;不定期会有很多免费代码分享~ 目录 原理简介 算法伪代码 性能测评 参考文献 …

ruoyi vue3版本web端隐藏侧边栏及其顶部导航栏

做项目时有个需求是在web端里面嵌入一个页面全屏的大屏&#xff0c;但若依web自带的侧边栏导航和顶部导航一时还不知道怎么隐藏起来&#xff0c;于是在网上到处查找资料&#xff0c;终于&#xff0c;还是在若依的gitee文档中发现了线索 怎么隐藏侧边栏和顶部导航栏实现完全的全…

从数据时代到智能时代,星环科技信雅达联合发布金融全栈解决方案

近年来&#xff0c;星环科技与信雅达在金融行业的多个关键领域展开了广泛而深入的合作&#xff0c;推出了一系列面向金融科技领域的联合解决方案。此次合作基于星环科技在大数据、人工智能和云计算领域的先进技术&#xff0c;以及信雅达在金融领域的深厚积累&#xff0c;围绕数…

C语言程序设计(二)

四.找素数 素数&#xff1a;除了1和它本身不再有其他因数的自然数。换句话说&#xff1a;一个大于1的自然数 &#xff0c;如果只能被1和它本身整除&#xff0c;那就是素数&#xff08;质数&#xff09;。 在打印中遇到的问题就是&#xff0c;知道怎么写却总是运行不起来。主要…

Python missingno和Vaex库:高性能的大数据分析

在数据分析和处理过程中&#xff0c;数据缺失是常见的问题。处理和理解数据缺失情况是确保数据质量和分析准确性的关键步骤。Python的missingno库提供了一种便捷且直观的方式来可视化数据缺失情况&#xff0c;从而帮助我们更好地理解和处理缺失值。本文将详细介绍missingno库的…

一文看懂:数据产品的3种输出形式和4大服务层次

企业要想提升数据资产的价值&#xff0c;就必须了解数据产品。那么&#xff0c;什么是数据产品&#xff0c;我们该如何认识它&#xff1f; 在由WakeData惟客数据联合星光数智推出的直播栏目《星光对话》第5期中&#xff0c;星光数智首席数据架构师魏战松&#xff0c;分享了对于…

分布式事务解决方案(一) 2PC、3PC、TCC、Sega

目录 1.绪论 2.2PC 2.1 基本原理 2.1.1 组成 2.1.2 步骤 1.prepare阶段 2.commit阶段 2.2 2PC 存在的问题 2.2.1 阻塞问题 2.2.2 单点故障问题 1. 事务协调器宕机 2.部分数据不一致问题 2.资源管理器宕机 3. 事务协调器和资源管理管理器同时宕机 2.2 实现 2.2.1…

JCR一区级 | Matlab实现SO-Transformer-LSTM多变量回归预测(蛇群算法优化)

JCR一区级 | Matlab实现SO-Transformer-LSTM多变量回归预测&#xff08;蛇群算法优化&#xff09; 目录 JCR一区级 | Matlab实现SO-Transformer-LSTM多变量回归预测&#xff08;蛇群算法优化&#xff09;效果一览基本介绍程序设计参考资料 效果一览 基本介绍 1.【JCR一区级】M…

跨网段 IP 地址通信故障分析

现如今计算机网络的规模和复杂性不断增加&#xff0c;跨网段通信成为网络运行中的常见需求。但如果设备处于不同网段且路由设置出现偏差时就会导致通信故障&#xff0c;严重影响网络的正常运行和数据传输。 1.跨网段通信的基本原理 跨网段通信依赖于路由器的路由功能。路由器根…