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.mzph.cn/news/876432.shtml

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

相关文章

Redisson中的RScoredSortedSet的常见使用场景及排行榜例子

Redisson中的RScoredSortedSet的常见使用场景及排行榜例子

Redisson 中的 RScoredSortedSet 类是对 Redis 内置的 Sorted Set 数据结构的一个封装&#xff0c;它支持对集合中的元素进行排序&#xff0c;每个元素都有一个与之关联的分数(score)。 RScoredSortedSet 可以用于多种场景&#xff0c;以下是一些常见的使用案例&#xff1a; 排…
阅读更多...
【初阶数据结构篇】时间（空间）复杂度

【初阶数据结构篇】时间（空间）复杂度

文章目录 算法复杂度时间复杂度1. 定义2. 表示方法3. 常见时间复杂度4.案例计算分析冒泡排序二分查找斐波那契数列&#xff08;递归法&#xff09;斐波那契数列&#xff08;迭代法&#xff09; 空间复杂度案例分析冒泡排序斐波那契数列&#xff08;递归法&#xff09;斐波那契数…
阅读更多...
欧鹏 数据库 第五次作业

欧鹏 数据库 第五次作业

文章目录 第五次作业题目一,触发器1)建立两个表:good(商品表),orders(订单表) 二,在商品表中导入记录三,储存过程 1)建立触发器,订单中增加订单数量后,商品表数量同步减少对应的商品订单出单数量,并测试2)建立触发器,实现功能:客户取消订单,恢复商品表对应商品的数量3)建立触发…
阅读更多...
QT 5 同时使用Q_DECLARE_METATYPE(pointdata) 和继承 QObjectUserData

QT 5 同时使用Q_DECLARE_METATYPE(pointdata) 和继承 QObjectUserData

在Qt框架中&#xff0c;QObjectUserData 和 Q_DECLARE_METATYPE() 宏都与Qt的元对象系统有关&#xff0c;但它们的使用方式有一些特别的限制和兼容性问题。 关于QObjectUserData&#xff1a; QObjectUserData 是一个用来存储用户数据的类。在Qt中&#xff0c;每个 QObject 可以…
阅读更多...
CI/CD学习之路

CI/CD学习之路

CI/CD之路 https://mp.weixin.qq.com/mp/appmsgalbum?__bizMzg4NDg0MjQ0MQ&actiongetalbum&album_id3433192036428447744&scene173&subscene&sessionidsvr_0b1e7fe1d6b&enterid1721879847&from_msgid2247485821&from_itemidx1&count3&am…
阅读更多...
【漏洞复现】ServiceNow UI Jelly模板注入(CVE-2024-4879)

【漏洞复现】ServiceNow UI Jelly模板注入(CVE-2024-4879)

声明&#xff1a;本文档或演示材料仅用于教育和教学目的。如果任何个人或组织利用本文档中的信息进行非法活动&#xff0c;将与本文档的作者或发布者无关。 一、漏洞描述 ServiceNow是一家专注于提供企业级云计算服务的企业&#xff0c;其旗舰产品是基于云的服务管理解决方案&…
阅读更多...
视觉巡线小车（STM32+OpenMV）——总结

视觉巡线小车（STM32+OpenMV）——总结

文章目录 目录 文章目录 前言 一、效果展示 二、完整流程 1、STM32CubeMX配置 2、Keil编辑 3、硬件接线 4、参数调试 5、图像处理调试 三、总结 前言 基于前面的系列文章&#xff0c;已基本介绍完了基于STM32OpenMV的视觉巡线小车&#xff0c;本文将以小编自己的小车…
阅读更多...
SeaCMS海洋影视管理系统远程代码执行漏洞复现

SeaCMS海洋影视管理系统远程代码执行漏洞复现

SeaCMS海洋影视管理系统远程代码执行漏洞复现 Ⅰ、环境搭建Ⅱ、漏洞复现Ⅲ、漏洞分析 免责声明&#xff1a;请勿利用文章内的相关技术从事非法测试&#xff0c;由于传播、利用此文所提供的信息或者工具而造成的任何直接或者间接的后果及损失&#xff0c;均由使用者本人负责&…
阅读更多...
Greenplum数据库中常用的聚合函数及其对应的分析函数

Greenplum数据库中常用的聚合函数及其对应的分析函数

一、SUM()函数及其对应的分析函数&#xff08;SUM() OVER&#xff09; SUM()函数是一种常用的聚合函数&#xff0c;用于计算某一列的总和。在Greenplum数据库中&#xff0c;SUM()函数可以与分析函数SUM() OVER结合使用&#xff0c;实现对某一列的累计求和操作。 语法示例&…
阅读更多...
全栈嵌入式C++、STM32、Modbus、FreeRTOS和MQTT协议：工业物联网（IIoT）可视化系统设计思路（附部分代码解析）

全栈嵌入式C++、STM32、Modbus、FreeRTOS和MQTT协议：工业物联网（IIoT）可视化系统设计思路（附部分代码解析）

项目概述 随着工业4.0时代的到来&#xff0c;工业物联网&#xff08;IIoT&#xff09;在提高生产效率、降低运营成本和实现智能制造方面得到了广泛应用。本项目旨在开发一个全面的工业物联网监控系统&#xff0c;能够实时监测设备的温度、压力、振动和电流等参数&#xff0c;并…
阅读更多...
【Python实战因果推断】60_随机实验与统计知识2

【Python实战因果推断】60_随机实验与统计知识2

目录 An A/B Testing Example An A/B Testing Example 在许多公司中&#xff0c;一种常见的策略是提供廉价甚至免费的产品&#xff0c;这种产品本身可能并不盈利&#xff0c;但其目的是吸引新客户。一旦公司获得了这些客户&#xff0c;就可以向他们推销其他更盈利的产品&#x…
阅读更多...
ThinkPHP一对一关联模型的运用（ORM）

ThinkPHP一对一关联模型的运用（ORM）

一、序言 最近在写ThinkPHP关联模型的时候一些用法总忘&#xff0c;我就想通过写博客的方式复习和整理下一些用法。 具体版本&#xff1a; topthink/framework&#xff1a;6.1.4topthink/think-orm&#xff1a;2.0.61 二、实例应用 1、一对一关联 1.1、我先设计了两张表&#x…
阅读更多...
Makefile 如何将生成的 .o 文件放到指定文件夹

Makefile 如何将生成的 .o 文件放到指定文件夹

研究了不少文章&#xff0c;我行通了一个&#xff0c;但是也不全&#xff0c;目前只能适用当前文件夹&#xff0c;如果源文件有子文件夹处理不了&#xff0c;还得继续研究。很多人说编译完把O文件移动走或者直接删掉。我想说的是不符合我的要求&#xff0c;移走或者删除O文件&a…
阅读更多...
git使用报错 无法切换到master，因存在未提交的更改。 在切换分支之前提交或撤消更改。 有关详细信息，请查看“输出”窗口

git使用报错 无法切换到master，因存在未提交的更改。 在切换分支之前提交或撤消更改。 有关详细信息，请查看“输出”窗口

"git使用报错 无法切换到master&#xff0c;因存在未提交的更改。 在切换分支之前提交或撤消更改。 有关详细信息&#xff0c;请查看“输出”窗口" 这个错误消息通常出现在你尝试切换Git分支时&#xff0c;当前工作目录中有未提交的更改。Git会阻止你切换分支&#…
阅读更多...
Linux下的网络通讯

Linux下的网络通讯

UDP&#xff1a;用户数据报协议 传输层 特点: 1.无连接 2.不安全、不可靠 3.面向报文 4.占用资源开销小 TCP : 传输控制协议 传输层 1. TCP特点: 1.面向连接 2.安全、可靠 3.面向字节流 4.占用资源开销大 三次握手: 指建立tc…
阅读更多...
[SWPU2019]Web1

[SWPU2019]Web1

上来看到两个功能&#xff0c;登录和注册&#xff0c;看到登录框直接sqlmap嗦一下 失败 注册admin显示被注册&#xff0c;那就注册一个账密都为aaa 登录进来发现两个功能点 发了一个广告却显示代管理确认&#xff0c;这里肯定没有管理员&#xff0c;所以我们得想办法自己上去a…
阅读更多...
lxml.etree模式使用(一)

lxml.etree模式使用(一)

from lxml import etree from copy import deepcopydef prettyprint(element, **kwargs):print("/")xml etree.tostring(element, pretty_printTrue, **kwargs)print(xml.decode(), end)# 1. 创建元素 root etree.Element("root")# 2. 添加子元素 root.a…
阅读更多...
【Python】基础学习技能提升代码样例3：JSON文本处理

【Python】基础学习技能提升代码样例3：JSON文本处理

对json的处理&#xff0c;无非是编码和解码两部分 编码&#xff1a;将python数据结构转换为json字符串解码: 将json字符串转换为python数据结构 另外&#xff0c;还有.json文件的读写 一、编码 json.dumps(obj, *, skipkeysFalse, ensure_asciiTrue, check_circularTrue, a…
阅读更多...
React特点

React特点

React 是一个用于构建用户界面的 JavaScript 库&#xff0c;由 Facebook 开发并维护。React 的特点主要体现在以下几个方面&#xff1a; 声明式&#xff08;Declarative&#xff09;&#xff1a;React 使你能够以一种声明的方式来描述你的 UI&#xff0c;这使得代码更加容易理解…
阅读更多...
铲屎官的必备好物——希喂、352、米家养宠空气净化器分享

铲屎官的必备好物——希喂、352、米家养宠空气净化器分享

对于每一位深爱着家中萌宠的铲屎官而言&#xff0c;无尽的温情往往也伴随着日常生活中的小烦恼。那些不经意间飘散在空气中的毛发&#xff0c;偶尔缠绕在鼻腔或口腔中的细微触感&#xff0c;以及偶尔袭来的不明异味&#xff0c;都是与宠物共度的日子里不可或缺的一部分。幸好随…
阅读更多...
最新文章

Copyright @ 2022~2023