Spring Cloud 之 GateWay

ops/2024/10/18 8:27:28/

前言

请添加图片描述

前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家：https://www.captainbed.cn/z
请添加图片描述

ChatGPT体验地址

请添加图片描述

文章目录

  • 前言
  • 前言
  • 1、通过API网关访问服务
  • 2、Spring Cloud GateWay 最主要的功能就是路由转发
  • 3、Gateway的工作流程
  • 4、Predicate 断言
  • 5、示例
    • 5.1、pom.xml配置
    • 5.2、application.xml配置
    • 5.3、启动类
  • 6、动态路由
    • 6.1、修改application.xml配置
  • 7、过滤器Filter
    • 7.1、Filter 分类
      • 7.1.1、GatewayFilter
      • 7.1.2、实例
      • 7.1.2、GlobalFilter

前言

API 网关是一个搭建在客户端和微服务之间的服务，我们可以在 API 网关中处理一些非业务功能的逻辑，例如权限验证、监控、缓存、请求路由等。
image.png

1、通过API网关访问服务

  • 客户端通过 API 网关与微服务交互时，客户端只需要知道 API 网关地址即可，而不需要维护大量的服务地址，简化了客户端的开发。
  • 客户端直接与 API 网关通信，能够减少客户端与各个服务的交互次数。
  • 客户端与后端的服务耦合度降低。
  • 节省流量，提高性能，提升用户体验。
  • API 网关还提供了安全、流控、过滤、缓存、计费以及监控等 API 管理功能。

2、Spring Cloud GateWay 最主要的功能就是路由转发

而在定义转发规则时主要涉及了以下三个核心概念，如下表。

核心概念描述
Route（路由）网关最基本的模块。它由一个 ID、一个目标 URI、一组断言（Predicate）和一组过滤器（Filter）组成。
Predicate（断言）路由转发的判断条件，我们可以通过 Predicate 对 HTTP 请求进行匹配，例如请求方式、请求路径、请求头、参数等，如果请求与断言匹配成功，则将请求转发到相应的服务。
Filter（过滤器）过滤器，我们可以使用它对请求进行拦截和修改，还可以使用它对上文的响应进行再处理。

3、Gateway的工作流程

image.png

  • 客户端将请求发送到 Spring Cloud Gateway 上。
  • Spring Cloud Gateway 通过 Gateway Handler Mapping 找到与请求相匹配的路由，将其发送给 Gateway Web Handler。
  • Gateway Web Handler 通过指定的过滤器链（Filter Chain），将请求转发到实际的服务节点中，执行业务逻辑返回响应结果。
  • 过滤器之间用虚线分开是因为过滤器可能会在转发请求之前（pre）或之后（post）执行业务逻辑。
  • 过滤器（Filter）可以在请求被转发到服务端前，对请求进行拦截和修改，例如参数校验、权限校验、流量监控、日志输出以及协议转换等。
  • 过滤器可以在响应返回客户端之前，对响应进行拦截和再处理，例如修改响应内容或响应头、日志输出、流量监控等。
  • 响应原路返回给客户端。

4、Predicate 断言

pring Cloud Gateway 通过 Predicate 断言来实现 Route 路由的匹配规则。简单点说，Predicate 是路由转发的判断条件，请求只有满足了 Predicate 的条件，才会被转发到指定的服务上进行处理。
image.png
常见的 Predicate 断言如下表（假设转发的 URI 为 http://localhost:8001）。

断言示例说明
Path- Path=/user/listUserInfo/**当请求路径与 /user/listUserInfo/** 匹配时，该请求才能被转发到 http://localhost:8001上。
Before- Before=2022-12-07T11:47:34.255+08:00[Asia/Shanghai]在 2022 年 12 月 07 日 11 时 47 分 34.255 秒之前的请求，才会被转发到 http://localhost:8001上。
After- After=2022-12-07T11:47:34.255+08:00[Asia/Shanghai]在 2022 年 12 月 07 日 11 时 47 分 34.255 秒之后的请求，才会被转发到 http://localhost:8001上。
Between- Between=2022-12-07T15:18:33.226+08:00[Asia/Shanghai],2022-12-07T15:23:33.226+08:00[Asia/Shanghai]在 2022 年 12 月 07 日 15 时 18 分 33.226 秒 到 2022 年 12 月 07 日 15 时 23 分 33.226 秒之间的请求，才会被转发到 http://localhost:8001服务器上。
Cookie- Cookie=name,hqyj.com携带 Cookie 且 Cookie 的内容为 name=hqyj.com 的请求，才会被转发到 http://localhost:8001上。
Header- Header=X-Request-Id,\d+请求头上携带属性 X-Request-Id 且属性值为整数的请求，才会被转发到 http://localhost:8001上。
Method- Method=GET只有 GET 请求才会被转发到 http://localhost:8001上。

5、示例

建立子模块：gateway-service

5.1、pom.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>com.hqyj</groupId><artifactId>SpringCloud</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>gateway-service</artifactId><properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><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><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency></dependencies></project>

5.2、application.xml配置

server:port: 80
spring:application:name: gateway-servicecloud:gateway: #网关路由配置routes:#将 drp-user-service 提供的服务隐藏起来，不暴露给客户端，只给客户端暴露 API 网关的地址 80- id: drp-user-service_routh   #路由 id,没有固定规则，但唯一，建议与服务名对应uri: http://localhost:8001          #匹配后提供服务的路由地址predicates:#以下是断言条件，必选全部符合条件- Path=/user/userInfoList/**               #断言，路径匹配 注意：Path 中 P 为大写- Method=GET #只能时 GET 请求时，才能访问eureka:instance:instance-id: gateway-servicehostname: localhostclient:fetch-registry: trueregister-with-eureka: trueservice-url:defaultZone: http://localhost:7001/eureka

5.3、启动类

@SpringBootApplication
@EnableEurekaClient
public class GatewayApplication {public static void main(String[] args) {SpringApplication.run(GatewayApplication.class,args);}
}

访问：http://localhost/user/userInfoList

6、动态路由

以服务名（spring.application.name）作为路径创建动态路由进行转发，从而实现动态路由功能
Route 的 uri 地址修改为以下形式。

lb://service-name

6.1、修改application.xml配置

server:port: 80
spring:application:name: gateway-servicecloud:gateway: #网关路由配置routes:#将 user-service 提供的服务隐藏起来，不暴露给客户端，只给客户端暴露 API 网关的地址 80- id: user-service_routh   #路由 id,没有固定规则，但唯一，建议与服务名对应,必须是*_routh格式，否则报错uri: lb://USER-SERVICE          #匹配后提供服务的路由地址 , 必须引入依赖：spring-cloud-starter-loadbalancerpredicates:#以下是断言条件，必选全部符合条件- Path=/user/userInfoList/**               #断言，路径匹配 注意：Path 中 P 为大写- Method=GET #只能时 GET 请求时，才能访问metadata:connect-timeout: 10#单位毫秒response-timeout: 10000- id: admin-service_routh   #路由 id,没有固定规则，但唯一，建议与服务名对应,必须是*_routh格式，否则报错uri: lb://ADMIN-SERVICE          #匹配后提供服务的路由地址 , 必须引入依赖：spring-cloud-starter-loadbalancerpredicates:#以下是断言条件，必选全部符合条件- Path=/api/admin/**               #断言，路径匹配 注意：Path 中 P 为大写- Method=GET #只能时 GET 请求时，才能访问metadata:connect-timeout: 10#单位毫秒response-timeout: 10000eureka:instance:instance-id: gateway-servicehostname: localhostclient:fetch-registry: trueregister-with-eureka: trueservice-url:defaultZone: http://localhost:7001/eureka

7、过滤器Filter

用户登陆状态校验、签名校验。
Spring Cloud Gateway 提供了以下两种类型的过滤器

过滤器类型说明
Pre 类型这种过滤器在请求被转发到微服务之前可以对请求进行拦截和修改，例如参数校验、权限校验、流量监控、日志输出以及协议转换等操作。
Post 类型这种过滤器在微服务对请求做出响应后可以对响应进行拦截和再处理，例如修改响应内容或响应头、日志输出、流量监控等。

7.1、Filter 分类

按照作用范围划分，Spring Cloud gateway 的 Filter 可以分为 2 类：GatewayFilter、GlobalFilter

7.1.1、GatewayFilter

应用在单个路由或者一组路由上的过滤器。
常用的GatewayFilter过滤器

路由过滤器描述参数使用示例
AddRequestHeader拦截传入的请求，并在请求上添加一个指定的请求头参数。name：需要添加的请求头参数的 key
value：需要添加的请求头参数的 value。- AddRequestHeader=my-request-header,1024
AddRequestParameter拦截传入的请求，并在请求上添加一个指定的请求参数。name：需要添加的请求参数的 key；
value：需要添加的请求参数的 value。- AddRequestParameter=my-request-param,c.biancheng.net
AddResponseHeader拦截响应，并在响应上添加一个指定的响应头参数。name：需要添加的响应头的 key；
value：需要添加的响应头的 value。- AddResponseHeader=my-response-header,c.biancheng.net
PrefixPath拦截传入的请求，并在请求路径增加一个指定的前缀。prefix：需要增加的路径前缀。-PrefixPath=/consumer
PreserveHostHeader转发请求时，保持客户端的 Host 信息不变，然后将它传递到提供具体服务的微服务中。无-PreserveHostHeader
RemoveRequestHeader移除请求头中指定的参数。name：需要移除的请求头的 key。- RemoveRequestHeader=my-request-header
RemoveResponseHeader移除响应头中指定的参数。name：需要移除的响应头。- RemoveResponseHeader=my-response-header
RemoveRequestParameter移除指定的请求参数。name：需要移除的请求参数。- RemoveRequestParameter=my-request-param
RequestSize配置请求体的大小，当请求体过大时，将会返回 413 Payload Too Large。maxSize：请求体的大小。- name:RequestSize
args:
  maxSize: 5000000 |

7.1.2、实例

spring:application:name: gateway-servicecloud:gateway: #网关路由配置routes:#将 user-service 提供的服务隐藏起来，不暴露给客户端，只给客户端暴露 API 网关的地址 80- id: user-service_routh   #路由 id,没有固定规则，但唯一，建议与服务名对应, 必须是*_routh格式，否则报错uri: lb://USER-SERVICE          #匹配后提供服务的路由地址,#匹配后提供服务的路由地址 , 必须引入依赖：spring-cloud-starter-loadbalancerpredicates:#以下是断言条件，必选全部符合条件- Path=/userInfoList/**               #断言，路径匹配 注意：Path 中 P 为大写- Method=GET #只能时 GET 请求时，才能访问filters:- AddRequestHeader=token,tigergege- PrefixPath=/user

7.1.2、GlobalFilter

应用在所有的路由上的过滤器，可用于统一异常处理

import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.RequestPath;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
import java.util.List;/**** @title DrfGlobalFilter* @desctption 登录验证* @author Administrator* @create 2023/5/15 14:17**/
@Component
public class DrfGlobalFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {ServerHttpRequest request = exchange.getRequest();//获取URI地址RequestPath path = request.getPath();HttpHeaders headers = request.getHeaders();List<String> stringList = headers.get("token");//是否登录验证if(CollectionUtils.isEmpty(stringList)){ServerHttpResponse response = exchange.getResponse();response.setStatusCode(HttpStatus.UNAUTHORIZED);return response.setComplete();}return chain.filter(exchange);}@Overridepublic int getOrder() {//过滤器优先级，0为最高return 0;}
}

http://www.ppmy.cn/ops/48484.html

相关文章

联想电脑 调节屏幕亮度不起使用，按F5，F6，屏幕上的hotkeys进度条是在改变，但是屏幕没有一些作用的处理方法

联想电脑 调节屏幕亮度不起使用，按F5，F6，屏幕上的hotkeys进度条是在改变，但是屏幕没有一些作用的处理方法

1、查看驱动是否正常 Win键X &#xff0c;设备管理器 发现似乎挺正常的。 查看原厂驱动&#xff1a;联想电脑管家 这样看来&#xff0c;驱动是没有问题了。 2、看看设置电池模式 其实还是这个电池模式的问题导致。 如果处于养护模式的话&#xff0c;充电只在75%~80%&#x…
阅读更多...
最小二乘法-拟合平面方程

最小二乘法-拟合平面方程

背景 通常有这样的需求 给你一些点&#xff0c;拟合出最佳直线或者拟合出最佳平面。本文介绍的是最小二乘法 最小二乘法 最小二乘法&#xff08;又称最小平方法&#xff09;是一种数学优化技术。它通过最小化误差的平方和寻找数据的最佳函数匹配。利用最小二乘法可以简便地求…
阅读更多...
算法02 递归算法及其相关问题

算法02 递归算法及其相关问题

递归 在编程中&#xff0c;我们把函数直接或者间接调用自身的过程叫做递归。 递归处理问题的过程是&#xff1a;通常把一个大型的复杂问题&#xff0c;转变成一个与原问题类似的&#xff0c;规模更小的问题来进行求解。 递归的三大要素 函数的参数。在用递归解决问题时&…
阅读更多...
关于数据备份

关于数据备份

关于数据备份 数据备份背景技术人or非技术人备份方式云上数据写在最后 数据备份背景 关于数据备份的问题&#xff0c;这个真的是遇到的太多了。在当前信息时代下&#xff0c;数据充斥着工作或者生活的方方面面&#xff0c;不管你是技术人员还是非技术人员&#xff0c;或者说你…
阅读更多...
TCP是什么、UDP是什么，它们有什么区别

TCP是什么、UDP是什么，它们有什么区别

目录 TCP 1.面向连接 2.可靠性 3.流量控制 4.拥塞控制 5.全双工通信 6.面向字节流 7.总结 UDP 1.无连接 2.不可靠 3.头部开销小 4.支持一对多、多对一和多对多通信 5.传输效率高 6.适合传输少量数据 7.总结 TCP和UDP的主要区别 1.连接性 2.可靠性 3.头部开…
阅读更多...
基于Pytorch实现AI写藏头诗

基于Pytorch实现AI写藏头诗

网上你找了一圈发现开源的代码不是付费订阅就是代码有问题，基于Pytorch实现AI写藏头诗看我这篇就够了。 用到的工具：华为云ModelArts平台的notebook/Pycharm/Vscode都行。 镜像：pytorch1.8-cuda10.2-cudnn7-ubuntu18.04，有GPU优先使用GPU资源。 实验背景 在短时测试使用场…
阅读更多...
kunpeng的aarch64架构cpu、openeuler系统、昇腾服务器适配文档转换功能（doc转docx、ppt转pptx）

kunpeng的aarch64架构cpu、openeuler系统、昇腾服务器适配文档转换功能（doc转docx、ppt转pptx）

一、安装flatpak sudo yum install flatpak flatpak remote-add --if-not-exists flathub https://flathub.org/repo/flathub.flatpakrepo二、安装libreoffice flatpak install flathub org.libreoffice.LibreOffice三、使用 对于使用 flatpak 安装的 LibreOffice,不需要手…
阅读更多...
nc网络收发测试-tcp客户端\TCP服务器\UDP\UDP广播

nc网络收发测试-tcp客户端\TCP服务器\UDP\UDP广播

netcat&#xff08;nc&#xff09;&#xff1a; 作用&#xff1a;一个功能强大的网络工具&#xff0c;提供了简单的网络测试和网络编程功能。工作原理&#xff1a;可以用于建立TCP或UDP连接&#xff0c;并发送和接收数据。示例用法&#xff1a; 监听TCP端口&#xff1a;nc -l 1…
阅读更多...
最新文章

Copyright @ 2022~2023