Spring Cloud Alibaba 网关 Gateway 集成（7）

项目的源码地址
Spring Cloud Alibaba 工程搭建（1）
Spring Cloud Alibaba 工程搭建连接数据库（2）
Spring Cloud Alibaba 集成 nacos 以及整合 Ribbon 与 Feign 实现负载调用（3）
Spring Cloud Alibaba Ribbon 负载调用说明（4）
Spring Cloud Alibaba 核心理论 CAP与BASE理论简单理解（5）
Spring Cloud Alibaba Sentinel 集成与限流实战（6）
Spring Cloud Alibaba 网关 Gateway 集成（7）
目录

什么是网关

我们从下面几个点来说明吧：

  1. API Gateway，是系统的唯⼀对外的⼊⼝，介于客户端和服务器端之间的中间层，处理⾮业务功能，提供路由请求、鉴权、监控、缓存、限流等功能。
  2. 统一接入，可以做智能路由，负载均衡，容灾处理，日志埋点等等
  3. 流量监控，限流处理与服务降级
  4. 安全防护，统一的鉴权处理，监控，机器网络隔离
    Api Gateway
    主流的网关有哪些呢？
  • zuul： 是Netflix开源的微服务网关，和 Eureka,Ribbon,Hystrix 等组件配合使用，依赖组件比较多，性能教差（这个是我百度之后搬过来的，我还没有用过这个 zuul）。
  • nginx+lua：是⼀个⾼性能的HTTP和反向代理服务器,lua 是脚本语⾔，让Nginx执⾏Lua脚本，并且⾼并发、⾮阻塞的处理各种请求
  • SpringCloud Gateway: Spring公司专⻔开发的⽹关，替代 zuul。

AlibabaCloud 全家桶还没对应的⽹关，我们就⽤ SpringCloud官⽅推荐的 Gateway。

Spring Cloud Gateway

spring 官方的说明文档，点击这里看看，官网上面有一句话，是说 Spring Cloud Gateway 是基于 Spring Boot 2.x，Spring WebFlux 和 Project Reactor 构建。

这里引用官方上面的两段文字，是需要我们引起注意的地方

Spring Cloud Gateway 是建立在 Spring Boot 2.x、 Spring WebFlux 和 Project Reactor之上。因此，你所熟悉的许多同步库（例如Spring Data和Spring Security）和模式在你使用Spring Cloud Gateway时可能不适用。如果你不熟悉这些项目，我们建议你在使用Spring Cloud Gateway之前，先阅读它们的文档，熟悉一些新概念。

Spring Cloud Gateway 需要 Spring Boot 和 Spring Webflux 提供的 Netty 运行时。它不能在传统的Servlet容器中工作，也不能以WAR的形式构建。

三个核心的术语

  • Route（路由）: 网关的基本构件。它由一个ID、一个目的地URI、一个谓词（Predicate）集合和一个过滤器（Filter）集合定义。如果集合谓词为真，则路由被匹配。

  • Predicate（谓词）: 这是一个 Java 8 Function Predicate。输入类型是 Spring Framework ServerWebExchange。这让你可以在HTTP请求中的任何内容上进行匹配，比如header或查询参数。

  • Filter（过滤器）: 这些是 GatewayFilter 的实例，已经用特定工厂构建。在这里，你可以在发送下游请求之前或之后修改请求和响应。

这里我们先有一个眼熟，后面我们再具体操作。

工程搭建

新增 api-gateway 模块

这里我们按照之前搭建工程的方式创建一个 demo-api-gateway 的模块出来，具体的搭建方式看这里，搭建的方式是一样的，其实就是新建一个 module，这里就不赘述了。最后搭建完了之后，是这样子的结构：
增加 api-gateway

增加模块内容

pom 文件依赖引入

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>

启动类

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

配置文件
这个 routes 节点是一个数组，是可以写多个的

server:port: 8888spring:application:name: api-gatewaycloud:gateway:routes: #数组形式- id: demo-order  #路由唯一标识uri: http://127.0.0.1:9000  #想要转发到的地址order: 1 #优先级，数字越小优先级越高predicates: #断言 配置哪个路径才转发- Path=/demo-order/**filters: #过滤器，请求在传递过程中通过过滤器修改- StripPrefix=1  #去掉第一层前缀

这里先初步说明下配置的意思：

  • 我们请求的地址如果是： http://localhost:8888/demo-order/api/v1/video_order/list ，这个是我们网关的地址，
  • 访问网关之后，会转发到 这个地址上面去 http://localhost:9000/demo-order/api/v1/video_order/list 访问我们订单服务。
    请求的过程

测试下

访问下：http://localhost:8888/demo-order/api/v1/video_order/list
请求
然后我们再访问下：http://localhost:9000/api/v1/video_order/list
请求
OK了，我们初步的测试就算通过了，那么我们就接着向下看把，

连接Nacos

在 pom 文件中增加 nacos 依赖

 <!--添加 nacos 客户端--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>

增加启动类开启支持

@EnableDiscoveryClient

修改配置文件

注意看下下面增加的部分

  • nacos.discovery.server-addr
  • gateway.routes.id.uri：这里使用了 lb://demo-order 负载的调用方式
  • gateway.locator.enabled： 开启网关拉取 nacos 服务
server:port: 8888spring:application:name: api-gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848gateway:routes: #数组形式- id: order-service  #路由唯一标识#uri: http://127.0.0.1:8000  #想要转发到的地址uri: lb://demo-order  #从nocas进行转发order: 1 #优先级，数字越小优先级越高predicates: #断言 配置哪个路径才转发- Path=/order-server/**filters: #过滤器，请求在传递过程中通过过滤器修改- StripPrefix=1  #去掉第一层前缀discovery:locator:enabled: true  #开启网关拉取nacos的服务logging:level:org.springframework.cloud.gateway: DEBUG

我们去订单服务里面增加一个接口，方便于测试

@RequestMapping("gateway")
private Map gateway(HttpServletRequest httpRequest) {String serverInfo = httpRequest.getServerName() + ":"+ httpRequest.getServerPort();return Map.of("title", "测试返回数据", "name", "返回名称", "serverInfo", serverInfo);
}

增加接口
测试下

首先我们启动两个订单服务
启动服务列表
然后我们看下 nacos 的面板，可以看到相关的服务都在上面了
在这里插入图片描述
开始请求：http://localhost:8888/order-server/api/v1/video_order/gateway
请求
再次请求下：http://localhost:8888/order-server/api/v1/video_order/gateway
请求

断言、过滤器实战

网关的配置项回顾

路由：是网关的基本单元，由ID、URI、一组Predicate、一组Filter组成，根据Predicate进行匹配转发

route组成部分

id：路由的ID
uri：匹配路由的转发地址
predicates：配置该路由的断言，通过 PredicateDefinition 类进行接收配置。
order：路由的优先级，数字越小，优先级越高。

交互流程

  • 客户端向Spring Cloud Gateway发出请求
  • 如果网关处理程序映射确定请求与路由匹配
  • 则将其发送到网关Web处理程序
  • 通过特定过滤器链运行，前置处理-后置处理
    请求流程

断言

什么是Gateway路由断言 ？

  • Predicate 来源于Java8，接受输入参数，返回一个布尔值结果
  • Spring Cloud Gateway 中 Spring 利用 Predicate 的特性实现了各种路由匹配规则
  • 转发的判断条件，SpringCloud Gateway支持多种方式，常见如：Path、Query、Method、Header等
  • 支持多个Predicate请求的转发是必须满足所有的Predicate后才可以进行路由转发

内置路由断言都是 RoutePredicateFactory 接口实现类，我们一起看下：
具体的实现类
我们可以去访问下这里，具体的说明这里也有Route Predicate（路由谓词）工厂，我们这里就选几个出来看看

Before

比如，我们现在有一个需求接口需要在指定时间进行下线，过后不可以在被访问。那么我们可以使用 Before Gateway 内置的路由接口定时下线实战。

Before 路由谓词工厂只需要一个参数，即 datetime（这是一个java ZonedDateTime）。这个谓词匹配发生在指定 datetime 之前的请求。

predicates:- Before=2024-05-11T01:01:01.000+08:00

那么修改下把：
修改

测试访问下，现在是可以访问的：
测试访问
然后我们再修改下：

Before=2024-05-09T01:01:01.000+08:00

访问不了

Query

query 参数表示再请求的时候一定要带上的字段，如果没有这个字段就是非法请求
query参数

访问请求
http://localhost:8888/order-server/api/v1/video_order/gateway
请求报错
http://localhost:8888/order-server/api/v1/video_order/gateway?source=alipay
带上参数

Filter 过滤器

这里我们再看下这个图，可以看到我们的 Filter，是一层层的过滤然后访问到 proxied service ，然后再一层层的经过 filter 返回
请求流程

过滤器生命周期

PRE： 这种过滤器在请求被路由之前调用,一般用于鉴权、限流等
POST：这种过滤器在路由到微服务以后执行，一般用于修改响应结果，比如增加header信息、打点结果日志

网关过滤器分类

  • 局部过滤器GatewayFilter：应用在某个路由上,每个过滤器工厂都对应一个实现类，并且这些类的名称必须以GatewayFilterFactory 结尾

  • 全局过滤器：作用全部路由上

局部过滤器

内置很多局部过滤器，顶级接口 GatewayFilterFactory
GatewayFilterFactory
全局过滤器

内置很多全局过滤器，顶级接⼝ GlobalFilter
全局过滤器

自定义网关过滤器

第一步：先增加一个自定义的过滤器
新增代码

import org.apache.commons.lang3.StringUtils;
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.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;@Component
public class UserGlobalFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {//写业务逻辑String token = exchange.getRequest().getHeaders().getFirst("token");//TODO 根据业务开发对应的鉴权规则, JWTif(StringUtils.isBlank(token)){exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);return exchange.getResponse().setComplete();}//继续往下执行return chain.filter(exchange);}//数字越小，优先级越高@Overridepublic int getOrder() {return 0;}
}

第二步： 接着重启服务

访问测试下：http://localhost:8888/order-server/api/v1/video_order/gateway?source=alipay
报错访问通过 postMan 访问，可以请求到数据
PostMan访问
好了，我们总算是搞定了这个 Gateway 了，其实这个更多的就是配置，没有啥其他代码部分的东西。先理解配置部分东西，方便与工作中使用。

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

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

相关文章

网络 | 应用层-websocket协议概述与握手过程解析

网络 | 应用层-websocket协议概述与握手过程解析

背景&#xff1a;这里为了实现消息实时传输决定引入websocket协议。 不管是发送消息还是接收消息&#xff0c;都需要实时传输&#xff0c;张三发给李四&#xff0c;李四立马就能收到&#xff0c;基于HTTP实现是有些困难的。 但轮询方式也带来了一些问题 1、消耗更多系统资源&…
阅读更多...
【Shell脚本】Shell编程之数组

【Shell脚本】Shell编程之数组

目录 一.数组 1.基本概念 2.定义数组的方法 2.1.方法一 2.2.方法二 2.3.方法三 2.4.方法四 2.5.查看数组长度 2.6.查看数组元素下标 3.数组分片 4.数组字符替换 4.1.临时替换 4.2.永久替换 5.数组删除 5.1.删除某个下标 5.2.删除整组 6.数组遍历和重新定义 7…
阅读更多...
每日Attention学习4——Spatial Attention Module

每日Attention学习4——Spatial Attention Module

模块出处 [link] [code] [MM 21] Complementary Trilateral Decoder for Fast and Accurate Salient Object Detection 模块名称 Spatial Attention Module (SAM) 模块作用 空间注意力 模块结构 模块代码 import torch import torch.nn as nn import torch.nn.functional a…
阅读更多...
ubuntu下不生成core dumped

ubuntu下不生成core dumped

1、先用ulimit -c&#xff0c;如果看到0&#xff0c;说明没有开core dump。 所以我们输入ulimit -c unlimited&#xff0c;打开core dump。 再次用ulimit -c&#xff0c;看到unlimited了&#xff0c;说明core dump打开了。 注意这句ulimit -c unlimited只对当前会话有效。要永…
阅读更多...
【操作系统期末速成】​内存管理|内存的装入模块在装入内存的方式|分配管理方式|页面置换算法|页面置换

【操作系统期末速成】​内存管理|内存的装入模块在装入内存的方式|分配管理方式|页面置换算法|页面置换

&#x1f3a5; 个人主页&#xff1a;深鱼~&#x1f525;收录专栏&#xff1a;操作系统&#x1f304;欢迎 &#x1f44d;点赞✍评论⭐收藏 推荐 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到…
阅读更多...
常见加解密算法02 - RC4算法分析

常见加解密算法02 - RC4算法分析

RC4是一种广泛使用的流密码&#xff0c;它以其简洁和速度而闻名。区别于块密码&#xff0c;流密码特点在于按位或按字节来进行加密。 RC4由Ron Rivest在1987年设计&#xff0c;尽管它的命名看起来是第四版&#xff0c;实际上它是第一个对外发布的版本。 RC4算法的实施过程简洁…
阅读更多...
uniapp高性能图片裁剪插件，可添加水印

uniapp高性能图片裁剪插件，可添加水印

效果图&#xff1a; 插件地址&#xff1a;高性能图片裁剪&#xff0c;裁剪图片后自动添加水印 - DCloud 插件市场 示例&#xff1a; <template> <view><button click"select">选择图片</button><image mode"widthFix" :src&qu…
阅读更多...
Java—如何判断两个浮点数相等

Java—如何判断两个浮点数相等

结论 一旦有浮点型数据参与运算的结果&#xff0c;一定不要使用 “ ” 与其比较。 提出问题 我们知道在Java中浮点数float 和 double 的值不能很精准的表示一个小数&#xff0c;因为会有精度损失。 下面来看一个例子&#xff1a; public class FloatTest {public static …
阅读更多...
在Linux系统上使用nmcli命令配置各种网络（有线、无线、vlan、vxlan、路由、网桥等）

在Linux系统上使用nmcli命令配置各种网络（有线、无线、vlan、vxlan、路由、网桥等）

前言&#xff1a;原文在我的博客网站中&#xff0c;持续更新数通、系统方面的知识&#xff0c;欢迎来访&#xff01; 在Linux系统上使用nmcli命令配置各种网络&#xff08;有线、无线、vlan、vxlan等&#xff09;https://myweb.myskillstree.cn/123.html 更新于2024/5/13&…
阅读更多...
基于SpringBoot的竹宣非遗宣传网站

基于SpringBoot的竹宣非遗宣传网站

摘要 随着互联网的普及和数字化时代的到来&#xff0c;竹编等非物质文化遗产的保护与传承面临新的机遇和挑战。该研究旨在使用SpringBoot后端框架与Vue前端框架&#xff0c;构建一个竹编非遗宣传网站&#xff0c;通过丰富的展示形式和交互体验&#xff0c;提升公众对竹编这一非…
阅读更多...
[牛客网]——C语言刷题day2

[牛客网]——C语言刷题day2

答案&#xff1a;B 解析&#xff1a; char *p[10] 是指针数组,数组里存放了10个指针,在64位系统下指针占8个字节,所以sizeof(p) 10 * 8 80. char (*p1)[10]是数组指针,p1是一个指向存放10个char类型的数组的指针,所以sizeof(p1) 8. 答案&#xff1a;B 解析&#xff1a…
阅读更多...
asp.net 齿轮加工车间生产管理系统-计算机毕业设计源码56014

asp.net 齿轮加工车间生产管理系统-计算机毕业设计源码56014

摘 要 随着我国经济迅速发展&#xff0c;人们对手机的需求越来越大&#xff0c;各种手机软件也都在被广泛应用&#xff0c;但是对于手机进行数据信息管理&#xff0c;对于手机的各种软件也是备受用户的喜爱&#xff0c;在现实运用中&#xff0c;为方便用户能够可以随时进行在线…
阅读更多...
Altium Designer封装库和元器件符号库下载与导入教程（SnapEDA 、Ultra Librarian、Alldatasheetcn）

Altium Designer封装库和元器件符号库下载与导入教程（SnapEDA 、Ultra Librarian、Alldatasheetcn）

1.AD封装库和元器件符号库下载网址 以下是一些全球热门的Altium Designer封装库和元器件符号库下载网址推荐&#xff1a; Altium Content Vault (现称为Altium Manufacturer Part Search)&#xff1a;这是Altium官方提供的元器件库&#xff0c;可以直接在Altium Designer中使用…
阅读更多...
第 397 场 LeetCode 周赛题解

第 397 场 LeetCode 周赛题解

A 两个字符串的排列差 模拟&#xff1a;遍历 s s s 记录各字符出现的位置&#xff0c;然后遍历 t t t 计算排列差 class Solution {public:int findPermutationDifference(string s, string t) {int n s.size();vector<int> loc(26);for (int i 0; i < n; i)loc[s…
阅读更多...
【2024华为HCIP831 | 高级网络工程师之路】刷题日记（18）

【2024华为HCIP831 | 高级网络工程师之路】刷题日记（18）

个人名片&#xff1a;&#x1faaa; &#x1f43c;作者简介&#xff1a;一名大三在校生&#xff0c;喜欢AI编程&#x1f38b; &#x1f43b;‍❄️个人主页&#x1f947;&#xff1a;落798. &#x1f43c;个人WeChat&#xff1a;hmmwx53 &#x1f54a;️系列专栏&#xff1a;&a…
阅读更多...
libsndfile读取wav文件基本属性

libsndfile读取wav文件基本属性

本文的目的是提供一种方法读取wav文件的基本属性&#xff1a;音频帧数&#xff0c;格式、通道数和采样率信息。 代码如下所示&#xff1a; #include <iostream> #include <QDebug> #include "sndfile.h"using namespace std;int main() {// 初始化 ALS…
阅读更多...
如何安全高效地进行分公司文件下发？

如何安全高效地进行分公司文件下发？

确保分公司文件下发过程中的保密性和安全性&#xff0c;是企业信息安全管理的重要组成部分。以下是一些关键步骤和最佳实践&#xff1a; 权限管理&#xff1a;确保只有授权的人员可以访问文件。使用权限管理系统来控制谁可以查看、编辑或下载文件。 加密传输&#xff1a;在文…
阅读更多...
国际化日期（inti）

国际化日期（inti）

我们可以使用国际化API自动的格式化数字或者日期&#xff0c;并且格式化日期或数字的时候是按照各个国家的习惯来进行格式化的&#xff0c;非常的简单&#xff1b; const now new Date(); labelDate.textContent new Intl.DateTimeFormat(zh-CN).format(now);比如说这是按照…
阅读更多...
Isaac Sim 4 键盘控制小车前进方向（学习笔记5.8.2）

Isaac Sim 4 键盘控制小车前进方向（学习笔记5.8.2）

写的乱糟糟&#xff0c;主要是这两周忘了记录了...吭哧吭哧往下搞&#xff0c;突然想起来要留档&#xff0c;先大致写一个&#xff0c;后面再往里添加和修改吧&#xff0c;再不写就全忘了 有一个一直没解决的问题&#xff1a; 在保存文件时出现问题&#xff1a;isaac sim mism…
阅读更多...
LabVIEW MEMS电容式压力传感器测试系统

LabVIEW MEMS电容式压力传感器测试系统

LabVIEW MEMS电容式压力传感器测试系统 随着微电子技术的发展&#xff0c;MEMS&#xff08;微电机系统&#xff09;技术在各个领域得到了广泛应用。MEMS电容式压力传感器以其高灵敏度、小尺寸、低功耗等优点&#xff0c;在微传感器领域占据了重要的地位。然而&#xff0c;这些…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023