Springboot整合 Spring Cloud Gateway

1.Gateway介绍

1.是spring cloud官方推出的响应式的API网关框架，旨在为微服务架构提供一种简单有效的API路由的管理方式，并基于Filter的方式提供网关的基本功能，例如：安全认证，监控，限流等等。
2.功能特征：动态路由：能够匹配任何请求属性。支持路径重写可集成Naocs,Sentinel。可以对路由指定易于编写的predicate（断言）和Filter（过滤器）。
3.核心概念：路由（route）:路由是网关中最基础的部分，路由信息包括一个ID，一个目的URL，一组断言工厂，一组Filter组成。如果断言为真，则说明请求的url和配置的路由匹配。断言（predicates）:断言函数允许开发者去定义匹配Http request中的任何信息，比如请求头和参数等。过滤器（Filter）:分为Gateway filter和Global filter。filter可以对请求和响应进行处理。

2.整合Gateway

1.引入依赖

<!--查看是否引入SpringCloud 版本依赖-->
<dependencyManagement><dependencies><!-- SpringCloud 版本依赖 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency></dependencies>
</dependencyManagement><dependencies><!--spring cloud gateway--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency>
</dependencies>

2.yml配置
路由规则：id：路由唯一标识,不要使用  -uri：需要转发的地址predicates：断言规则，用于路由规则的匹配filters：过滤器

# 开发环境配置
server:# 服务器的HTTP端口，默认为8080port: 9005##注册到nacos的服务名
spring:application:name: @artifactId@profiles:active: ${profiles.active}cloud:#gateway配置gateway:#路由规则routes:- id: auth_route #路由唯一标识,不要使用  -uri: http://localhost:9000 #需要转发的地址predicates: #断言规则，用于路由规则的匹配- Path=/initialAuth/** #如果请求路径中存在initialAuth 则自动匹配到auth服务filters:- StripPrefix=1 #转发之前去除第一层路径，将断言规则中的initialAuth去除
验证测试结果：
通过访问路由端口拼接断言规则，访问auth服务的testUser接口
由此可见通过以上路由配置：成功转发到:http://localhost:9000/testUser

在这里插入图片描述

3.Gateway集成Naocs

1.引入Nacos依赖(nacos版本以及SpringCloud Alibaba 微服务 版本管理)这里不多赘述，之前的文档里都有。
2.springcloud在Hoxton.M2 RELEASED版本之后舍弃Ribbon。需手动引入spring-cloud-loadbalancer
如果不引入spring-cloud-loadbalancer 。则uri: lb://initial-auth 请求时使用负载均衡策略会报 503。

在这里插入图片描述

<!-- SpringCloud Alibaba Nacos -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency><!-- SpringCloud Alibaba Nacos Config -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

2.yml修改(加入nacos配置)

# 开发环境配置
server:# 服务器的HTTP端口，默认为8080port: 9005##注册到nacos的服务名
spring:application:name: @artifactId@profiles:active: ${profiles.active}cloud:nacos:discovery:server-addr: 127.0.0.1:8848config:server-addr: ${spring.cloud.nacos.discovery.server-addr}#gateway配置gateway:#路由规则routes:- id: auth_route #路由唯一标识,不要使用  -uri: lb://initial-auth #需要转发的已注册到nacos的服务名 lb：使用nacos的负载均衡策略predicates: #断言规则，用于路由规则的匹配- Path=/initialAuth/** #如果请求路径中存在initialAuth 则自动匹配到auth服务filters:- StripPrefix=1 #转发之前去除第一层路径，将断言规则中的initialAuth去除config:import:- optional:nacos:initial-stage-common.yml- optional:nacos:initial-stage-openFeign-${profiles.active}.yml- optional:nacos:initial-stage-${profiles.active}.yml
验证测试结果：

在这里插入图片描述

3.路由断言工厂配置

作用：当请求gateway的时候，使用断言对请求进行匹配，如果匹配成功就路由转发，如果匹配失败就返回404。
类型：内置。自定义。
3.1）内置路由断言工厂
官网地址：https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.1.0.RELEASE/single/spring-cloud-gateway.html#gateway-request-predicates-factories
3.1.1)时间断言：
	AfterRouterPredicateFactory:接收一个日期参数，判断请求日期是否晚于指定日期。BeforeRouterPredicateFactory:接收一个日期参数，判断请求日期是否早于指定日期。BetweenRouterPredicateFactory:接收两个日期参数，判断请求日期是否在指定时间断内。

#AfterRouterPredicateFactory
spring:cloud:gateway:routes:- id: after_routeuri: http://example.orgpredicates:- After=2017-01-20T17:42:47.789-07:00[America/Denver]
#BeforeRouterPredicateFactory
spring:cloud:gateway:routes:- id: before_routeuri: http://example.orgpredicates:- Before=2017-01-20T17:42:47.789-07:00[America/Denver]
#BetweenRouterPredicateFactory
spring:cloud:gateway:routes:- id: between_routeuri: http://example.orgpredicates:- Between=2017-01-20T17:42:47.789-07:00[America/Denver], 2017-01-21T17:42:47.789-07:00[America/Denver]
3.1.2)Cookie断言：
CookieRouterPredicateFactory:两个参数 第一个代表Cookie中的一个key，第二个代表这个key的值（可以是正则表达式）。

spring:cloud:gateway:routes:- id: cookie_routeuri: http://example.orgpredicates:- Cookie=chocolate, ch.p
3.1.3)请求头断言：
HeaderRouterPredicateFactory：根据请求头里的某个参数进行匹配，第一个代表请求头里的某个参数，第二个代表这个参数的值（可以是正则表达式）。

spring:cloud:gateway:routes:- id: header_routeuri: http://example.orgpredicates:- Header=X-Request-Id, \d+
3.1.4)域名断言：
HostRouterPredicateFactory：根据域名进行匹配

spring:cloud:gateway:routes:- id: host_routeuri: http://example.orgpredicates:- Host=**.somehost.org,**.anotherhost.org
3.1.5)请求方式断言：
MethodRouterPredicateFactory：根据请求方式进行匹配,多个用逗号分开

spring:cloud:gateway:routes:- id: method_routeuri: http://example.orgpredicates:- Method=GET
3.1.6)请求路径断言：
PathRouterPredicateFactory：根据请求路径进行匹配，{segment}占位符

spring:cloud:gateway:routes:- id: host_routeuri: http://example.orgpredicates:- Path=/foo/{segment},/bar/{segment}
3.1.7)查询参数断言：
QueryRouterPredicateFactory：根据查询参数进行断言
请求地址的参数中要包含baz这个参数。
请求地址的参数中要包含foo这个参数，并且值等于ba。

spring:cloud:gateway:routes:- id: query_routeuri: http://example.orgpredicates:- Query=bazspring:cloud:gateway:routes:- id: query_routeuri: http://example.orgpredicates:- Query=foo, ba.
3.1.8)客户端ip断言：
RemoteAddrRouterPredicateFactory：根据客户端ip进行断言。

spring:cloud:gateway:routes:- id: remoteaddr_routeuri: http://example.orgpredicates:- RemoteAddr=192.168.1.1
3.2）自定义路由断言工厂
可以模仿内置路由断言工厂

在这里插入图片描述

1.必须是Spring组件bean (类上面添加@Component)
2.类名必须加上RoutePredicateFactory作为结尾
3.必须继承AbstractRoutePredicateFactory
4.在类中必须声明静态内部类(Config)，声明属性来接收yml配置文件中对应的断言信息(yml几个参数，Config就声明几个属性)
5.需要结合shortcutFieldOrder方法进行绑定
6.通过apply进行逻辑判断， true匹配成功，false匹配失败。

package com.initial.gateway.predicate;import jakarta.validation.constraints.NotEmpty;
import org.springframework.cloud.gateway.handler.predicate.AbstractRoutePredicateFactory;
import org.springframework.cloud.gateway.handler.predicate.GatewayPredicate;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.server.ServerWebExchange;import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import java.util.function.Predicate;@Component
public class CheckSignRoutePredicateFactory extends AbstractRoutePredicateFactory<CheckSignRoutePredicateFactory.Config> {public CheckSignRoutePredicateFactory() {super(Config.class);}@Overridepublic List<String> shortcutFieldOrder() {return Arrays.asList("param");}@Overridepublic Predicate<ServerWebExchange> apply(final Config config) {return new GatewayPredicate() {public boolean test(ServerWebExchange exchange) {if (config.getParam().equals("sign")) {return true;}return false;}public Object getConfig() {return config;}};}@Validatedpublic static class Config {private @NotEmpty String param;public Config() {}public String getParam() {return this.param;}public void setParam(String param) {this.param = param;}}
}
测试结果：
正常加入CheckSign断言：CheckSign=sign

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

加入任意CheckSign断言的值：CheckSign=sign1111

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

4.过滤器工厂配置

作用：当请求gateway的时候，使用过滤器工厂可以进行一些业务逻辑处理，比如去除请求某几层路径。
官网地址：https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.1.0.RELEASE/single/spring-cloud-gateway.html#_gatewayfilter_factories
因为有很多，这里就不全做整理了，	可以在官网中查看用法。
4.1）内置过滤器工厂
4.1.1)AddRequestHeader:在请求头中添加X-Request-Foo属性，值为Bar
spring:cloud:gateway:routes:- id: add_request_header_routeuri: http://example.orgfilters:- AddRequestHeader=X-Request-Foo, Bar
4.1.2)PrefixPath:为匹配的路由添加前缀，对应服务需要配置context-path
相对应的服务yml中配置
server:servlet:context-path: /mypath 

spring:cloud:gateway:routes:- id: prefixpath_routeuri: http://example.orgfilters:- PrefixPath=/mypath
4.1.3)AddRequestParameter:为匹配的路由添加foo参数，值为bar
spring:cloud:gateway:routes:- id: add_request_parameter_routeuri: http://example.orgfilters:- AddRequestParameter=foo, bar
4.2）自定义过滤器工厂
可以模仿 AddRequestHeaderGatewayFilterFactory 继承了AbstractNameValueGatewayFilterFactory 继承了AbstractGatewayFilterFactory

在这里插入图片描述

可以模仿 PrefixPathGatewayFilterFactory

在这里插入图片描述

1.必须是Spring组件bean (类上面添加@Component)
2.类名必须加上GatewayFilterFactory作为结尾
3.必须继承AbstractGatewayFilterFactory
4.在类中必须声明静态内部类(Config)，声明属性来接收yml配置文件中对应的断言信息(yml几个参数，Config就声明几个属性)
5.需要结合shortcutFieldOrder方法进行绑定
6.通过apply进行逻辑判断。

5.全局过滤器配置

对所有配置的路由进行过滤。
在全局过滤器中，过滤的类需要去实现GlobalFilter接口。

package com.initial.gateway.filter;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;@Component
public class LogFilter implements GlobalFilter {Logger logger = LoggerFactory.getLogger(LogFilter.class);@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {logger.info(exchange.getRequest().toString());return chain.filter(exchange);}
}
测试结果：请求进入过滤器断点。

在这里插入图片描述

6.Gateway跨域处理

spring:application:name: @artifactId@profiles:active: ${profiles.active}cloud:#gateway配置gateway:#路由规则routes:- id: auth_route #路由唯一标识,不要使用  -uri: lb://initial-auth #需要转发的已注册到nacos的服务名 lb：使用nacos的负载均衡策略predicates: #断言规则，用于路由规则的匹配- Path=/initialAuth/** #如果请求路径中存在initialAuth 则自动匹配到auth服务- CheckSign=signfilters:- StripPrefix=1 #转发之前去除第一层路径，将断言规则中的initialAuth去除#跨域配置globalcors: # 全局的跨域处理add-to-simple-url-handler-mapping: true # 解决浏览器向服务器发options请求被拦截问题，这样网关就不拦截这个请求了corsConfigurations:'[/**]': # 拦截一切请求
#            allowedOrigins: # 允许哪些网站的跨域请求
#              - "http://localhost:8090"allowedOrigins: '*'allowedMethods: # 允许的跨域ajax的请求方式- "GET"- "POST"- "DELETE"- "PUT"- "OPTIONS"allowedHeaders: "*" # 允许在请求中携带的头信息，这里是允许所有的请求头maxAge: 360000 # 这次跨域检测的有效期

7.Gateway整合sentinel流控降级

网关层的限流可以简单的针对不同路由进行限流，也可针对业务的接口进行限流，或者根据接口的特征分组限流。1.gateway项目pom.xml添加依赖：

<!--sentinel整合gateway--><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>

2.gateway项目yml文件添加:

spring:application:name: @artifactId@profiles:active: ${profiles.active}cloud:sentinel:transport:#添加sentinel控制台地址dashboard: 127.0.0.1:8088

3.通过网关访问接口：
sentinel会将访问的路由注册进去：auth_routeRoute ID:根据选择的路由id进行流控。

在这里插入图片描述

 API 分组 ：在api管理中维护api分组，然后选择api分组进行流控。

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

间隔： QPS按每秒请求量，比如1秒请求2次。这里的间隔设置为 当前QPS 1秒钟请求2次，当间隔为2秒则为当前QPS 2秒中请求2次。
Burst size:宽容次数。如果设置为1，则QPS阈值+1。
针对请求属性:参数属性:Client IP：根据id进行限流Remote Host：域名Header：请求头。Header 名称 ：对请求头中含有某个key-value的进行限流。比如Header 名称：sign，匹配模式：精确 匹配串：1当一个请求头中含有sign并且这个值等1的进行流控。URL 参数：请求地址参数。URL 参数名称：对请求地址中含有某个参数的进行限流。比如URL 参数名称：name，匹配模式：精确 匹配串：1当一个请求连接的参数中含有name并且这个值等1的进行流控。Cookie：Cookie。Cookie 名称：对Coolie中含有某个key-value的进行限流。属性值匹配：匹配模式：精确: 一个具体的值。 比如设置为127.0.0.1 则对127.0.0.1这个ip访问进行限流子串:模糊匹配正则: 正则表达式4.测试流控：根据路由id进行流控。

在这里插入图片描述

5.gateway项目中自定义全局限流信息。

package com.initial.gateway.config;import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.BlockRequestHandler;
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.GatewayCallbackManager;
import jakarta.annotation.PostConstruct;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.ServerResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;@Configuration
public class GatewaySentinelConfig {@PostConstructpublic void init(){BlockRequestHandler blockRequestHandler = new BlockRequestHandler() {@Overridepublic Mono<ServerResponse> handleRequest(ServerWebExchange serverWebExchange, Throwable throwable) {Map<String,String> map = new HashMap<>();map.put("code",HttpStatus.TOO_MANY_REQUESTS.toString());map.put("msg","服务器繁忙，请稍后再试");return ServerResponse.status(HttpStatus.OK).contentType(MediaType.APPLICATION_JSON).body(BodyInserters.fromValue(map));}};GatewayCallbackManager.setBlockHandler(blockRequestHandler);}}

在这里插入图片描述

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

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

相关文章

为什么很多计算机专业的同学毕业即失业❓

为什么很多计算机专业的同学毕业即失业❓

✅大部分计算机专业毕业生在就业时遇到困难&#xff0c;原因往往是多方面的&#xff0c;并非普遍情况&#xff0c;主要包括以下几点&#xff1a; 1.技能不匹配&#xff1a;学校所学知识可能与实际工作需求有一定差距&#xff0c;比如缺乏特定编程语言的深入掌握或实际项目经验。…
阅读更多...
基于MetaGPT的LLM Agent学习实战(一)

基于MetaGPT的LLM Agent学习实战(一)

前言 我最近一直在做基于AI Agent 的个人项目&#xff0c; 因为工作加班较多&#xff0c;设计思考时间不足&#xff0c;这里借着Datawhale的开源学习课程《MetaGPT智能体理论与实战》课程&#xff0c;来完善自己的思路&#xff0c;抛砖引玉&#xff0c;和各位开发者一起学习&am…
阅读更多...
MySQL 8.4参考手册

MySQL 8.4参考手册

5.1 连接到服务器和断开服务器连接 host 和 user 表示主机名&#xff0c;其中 MySQL服务器正在运行&#xff0c;并且您的MySQL帐户的用户名。 为您的设置替换适当的值。代表您的密码;输入它 当 MySQL 显示提示时。********Enter password: 5.2 输入查询 mysql> SELECT VERSI…
阅读更多...
美国分析人工智能技术对网络格局的影响（中）

美国分析人工智能技术对网络格局的影响（中）

文章目录 前言三、剑更锋利，盾更坚固四、各国对于储存与披露已发现的漏洞有不同的国家级法规五、人工智能将如何改变网络安全的问题既是一个技术问题，也是一个政策问题前言 美国政府正在探索如何使用人工智能来增强其网络能力，如何使用人工智能来加强网络防御，以及如何最好…
阅读更多...
照明灯具十大排名都有哪些？市面上比较流行的十大护眼台灯品牌推荐

照明灯具十大排名都有哪些？市面上比较流行的十大护眼台灯品牌推荐

照明灯具十大排名都有哪些&#xff1f;护眼台灯排名当中靠前的主要有书客、飞利浦、松下等品牌。照明灯具作为家居与办公环境中不可或缺的元素&#xff0c;其品质与选择直接关系到人们的视觉健康与舒适度。本文将为大家揭示照明灯具的十大排名&#xff0c;让大家了解市场上最受…
阅读更多...
[QNX] BSP 网络性能优化：调优io-pkt和ClockPeriod提升网速

[QNX] BSP 网络性能优化：调优io-pkt和ClockPeriod提升网速

0 概要 本文介绍如何在QNX系统上优化网络性能&#xff0c;主要通过调整io-pkt和ClockPeriod参数来实现。通过优化&#xff0c;网络吞吐量可以得到显著提升。 1 优化方法 1.1 调整io-pkt的mclbytes参数: io-pkt是QNX系统中常用的网络协议栈&#xff0c;其mclbytes参数指定了…
阅读更多...
HTML的使用（上）

HTML的使用（上）

文章目录 前言一、HTML是什么&#xff1f;二、使用内容 &#xff08;1&#xff09;换行标记<br>&#xff08;2&#xff09;加粗标记<b> </b>&#xff08;3&#xff09;段落标记<p> </p>&#xff08;4&#xff09;标题标记<h1>~<h6> …
阅读更多...
韵搜坊（全栈）-- 前后端初始化

韵搜坊（全栈）-- 前后端初始化

文章目录 前端初始化后端初始化 前端初始化 使用ant design of vue 组件库 官网快速上手&#xff1a;https://www.antdv.com/docs/vue/getting-started-cn 安装脚手架工具 进入cmd $ npm install -g vue/cli # OR $ yarn global add vue/cli创建一个项目 $ vue create ant…
阅读更多...
运维基础（二）- 钉钉的使用

运维基础（二）- 钉钉的使用

一、钉钉的介绍&#xff08;来自百度百科&#xff09; 免费沟通和协同的多端平台 帮助中国企业通过系统化的解决方案&#xff08;微应用&#xff09;&#xff0c;全方位提升中国企业沟通和协同效率。 钉钉&#xff08;Ding Talk&#xff09; 是阿里巴巴打造的企业级智能移动…
阅读更多...
安利一个轻量级流程引擎compileflow

安利一个轻量级流程引擎compileflow

写在文章开头 今日推荐一个比较轻量级的工作流引擎——即阿里的compileflow&#xff0c;这款流程引擎算是笔者接触过流程引擎中相对轻量级、且性能和集成扩展表现都比较良好的框架&#xff0c;本文就会从几种常见的使用场景以及源码分析的角度介绍这款工具。 Hi&#xff0c;我…
阅读更多...
邓闲小——生存、生活、生命｜真北写作

邓闲小——生存、生活、生命｜真北写作

人生有三个层次∶生存、生活、生命。 生存就是做必须做的事。生存的模式是邓&#xff0c;是交易&#xff0c;是买卖。别人需要的东西&#xff0c;你生产出来&#xff0c;卖给他。哪怕这个东西没啥用&#xff0c;也可以卖&#xff0c;情绪也可以卖。你需要的东西&#xff0c;你花…
阅读更多...
社交媒体数据恢复：派派

社交媒体数据恢复：派派

派派是一款非常流行的社交软件&#xff0c;但是如果你在使用派派的过程中&#xff0c;不小心删除了一些重要的聊天记录或者其他数据&#xff0c;那么该怎么办呢&#xff1f;下面是一些简单的步骤&#xff0c;可以帮助你进行数据恢复。 1. 首先打开派派&#xff0c;并进入需要恢…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023