Spring Cloud Gateway教程

1 微服务网关概述

Spring Cloud Gateway是在 Spring 生态系统之上构建的API网关服务，旨在为微服务架构应用提供一种简单有效的统一的API路由管理方式。

Spring Cloud Gateway主要功能：

  • 反向代理
  • 认证鉴权
  • 流量控制
  • 熔断
  • 日志监控

2 Spring Cloud Gateway三大核心概念

  • 路由（Route）：它由一个 ID、一个目标 URI、断言集合和过滤器集合。如果断言为真，则路由匹配。
  • 断言（Predicate）：参考的是 Java8 的 java.util.function.Predicate，开发人员可以匹配 HTTP 请求中的所有内容（例如请求头或请求参数），如果与断言相匹配则进行路由。
  • 过滤器（Filter）：指的是 GatewayFilter 实例，可以在请求被路由之前或之后修改请求和响应。

3 Spring Cloud Gateway工作流程

客户端向 Spring Cloud Gateway 发出请求。然后在 Gateway Handler Mapping 中找到与请求相匹配的路由，将其发送到 Gateway Web Handler。Handler 再通过指定的过滤器链来将请求发送到我们实际的服务执行业务逻辑，然后返回。

过滤器被虚线分开的原因是过滤器可以在发送代理请求之前（pre）和之后（post）运行逻辑。执行所有“pre”过滤器逻辑。然后发出代理请求。在发出代理请求之后，运行“post”过滤器逻辑。

总结：断言判断–>路由转发–>执行过滤器链

4 Spring Cloud Gateway网关微服务开发

  1. 新建网关微服务模块
  2. 修改pom文件，引入依赖
  3. 修改yml文件和主启动类，在Consul中进行服务注册

4.1 引入依赖

<dependencies><!--Spring Cloud Gateway--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><!--Consul服务注册--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-consul-discovery</artifactId></dependency><!--指标监控健康检查的actuator--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency>
</dependencies>

4.2 网关微服务注册

server:port: 9527 # 网关服务端口spring:application:name: gateway-service # 网关服务名称cloud:consul:host: 47.120.52.144 # Consul服务地址port: 8500 # Consul服务端口discovery:prefer-ip-address: true # 服务注册时优先使用IP地址而不是主机名service-name: ${spring.application.name} # 在Consul中注册的服务名称heartbeat:enabled: true # 启用心跳检测，定期检查服务健康状态

@SpringBootApplication
@EnableDiscoveryClient // 服务注册
public class Gateway9527 {public static void main(String[] args) {SpringApplication.run(Gateway9527.class, args);}
}

服务注册使用了 Consul，如果要使用 Nacos 进行服务注册，修改 pom 文件中的依赖和 yml 文件中的配置！

image-20240308150657584

4.3 路由配置

假设场景，商城系统用户下单支付。

Consul注册中心8500
订单微服务8001
网关微服务9527
支付微服务8002
用户

网关微服务yml配置：

spring:gateway:routes:- id: order-route # 路由ID，没有固定规则但要求唯一，建议配合服务名uri: http://localhost:8001 # 路由转发地址predicates:- Path=/gateway/order/**/** # 断言，匹配请求路径- id: pay-routeuri: http://localhost:8002predicates:- Path=/gateway/pay/**/**

如果要使用OpenFeign，订单微服务8001调用支付微服务8002，

Consul注册中心8500
OpenFeign
订单微服务8001
网关微服务9527
支付微服务8002
用户

服务调用链：

  1. 用户调用网关微服务9527
  2. 网关微服务9527根据配置的路由匹配到订单微服务8001
  3. 订单微服务8001根据业务需要使用OpenFeign远程调用支付微服务8002
    1. 因为支付微服务8002也需要通过网关访问，因此也要通过网关微服务9527
    2. 网关微服务9527根据配置的路由匹配到支付微服务8002，到此完成服务调用

此时，网关微服务yml配置：

spring:gateway:routes:- id: order-route # 路由ID，没有固定规则但要求唯一，建议配合服务名uri: lb://order-service # 路由转发地址，负载均衡predicates:- Path=/order/**/** # 断言，匹配请求路径- id: pay-routeuri: lb://pay-servicepredicates:- Path=/pay/**/**
  • @FeignClient(value = “gateway-service”)注解不再使用微服务名，而是使用网关服务名称！
  • 动态获取服务URI：根据微服务名称而不是固定IP+port的方式获取URI！

Spring Cloud Gateway支持丰富的路由匹配逻辑，以应对各种类型的业务诉求：

断言示例说明
Path- Path=/httpbin/**路径与/httpbin/**匹配的请求会被转发
Cookie- Cookie=chocolate, ch.p携带Cookie且内容为chocolate=ch.p的请求会被转发
Header- Header=X-Request-Id, \d+请求有一个名为 X-Request-Id 的头，其值与 \d+ 正则表达式匹配（即它的值为一位或多位），则此路由匹配。
Method- Method=GET,POST请求方法是 GET 或 POST ，则此路由匹配。
Before- Before=2017-01-20T17:42:47.789+08:00[Asia/Shanghai]在2017年01月20日17时42分47.789秒之前的请求，才会被转发
After- Before=2017-01-20T17:42:47.789+08:00[Asia/Shanghai]在2017年01月20日17时42分47.789秒之后的请求，才会被转发
Between- Between=2017-01-20T17:42:47.789+08:00[Asia/Shanghai],2017-01-21T17:42:47.789+08:00[Asia/Shanghai]在2017年01月20日17时42分47.789秒到在2017年01月21日17时42分47.789秒之间的请求，才会被转发

4.4 过滤器配置
过滤器分类
全局过滤器GlobalFilter
网关过滤器GatewayFilter
自定义过滤器
  • 全局过滤器GlobalFilter：作用在所有路由上，不需要在配置文件中配置，实现GlobalFilter接口即可
  • 网关过滤器GatewayFilter：作用在单一路由或某个路由分组上，通过spring.cloud.gateway.routes.filters配置在具体的路由上，也可以通过配置spring.cloud.gateway.default-filters让它作用于全局路由上。
  • 自定义过滤器：

4.4.1 全局过滤器

/*** Contract for interception-style, chained processing of gateway requests that may be* used to implement cross-cutting, application-agnostic requirements such as security,* timeouts, and others.** Only applies to matched gateway routes.** Copied from framework WebFilter** @author Rossen Stoyanchev* @since 5.0*/
public interface GlobalFilter {/*** Process the Web request and (optionally) delegate to the next {@code GatewayFilter}* through the given {@link GatewayFilterChain}.* @param exchange the current server exchange* @param chain provides a way to delegate to the next filter* @return {@code Mono<Void>} to indicate when request processing is complete*/Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);}

4.4.2 网关过滤器

官网地址：https://docs.spring.io/spring-cloud-gateway/docs/4.0.9/reference/html/#gatewayfilter-factories。这里只列举一些常见的网关过滤器。

  1. 请求头（RequestHeader）相关

    1. AddRequestHeader
    2. RemoveRequestHeader
    3. SetRequestHeader
    spring:cloud:gateway:routes:- id: add_request_header_routeuri: http://example.orgfilters:- AddRequestHeader=X-Request-red, blue- RemoveRequestHeader=X-Request-Foo- SetRequestHeader=X-Request-Red, Blue

  2. 请求参数（RequestParameter）相关

    1. AddRequestParameter
    2. RemoveRequestParameter
    spring:cloud:gateway:routes:- id: add_request_parameter_routeuri: http://example.orgfilters:- AddRequestParameter=red, blue- RemoveRequestParameter=red

  3. 响应头（ResponseHeader）相关

    1. AddResponseHeader
    2. RemoveResponseHeader
    3. SetResponseHeader
    spring:cloud:gateway:routes:- id: add_response_header_routeuri: http://example.orgfilters:- AddResponseHeader=X-Response-Red, Blue- RemoveResponseHeader=X-Response-Foo- SetResponseHeader=X-Response-Red, Blue

  4. 前缀和路径相关

    1. PrefixPath

      spring:cloud:gateway:routes:- id: prefixpath_routeuri: http://example.orgpredicates:- Path=/redfilters:- PrefixPath=/mypath

      浏览器访问地址：http://example.org/red

      实际微服务地址：http://example.org/mypath/red

    2. SetPath

      spring:cloud:gateway:routes:- id: prefixpath_routeuri: http://example.orgpredicates:- Path=/redfilters:- SetPath=/blue

      浏览器访问地址：http://example.org/red

      实际微服务地址：http://example.org/blue

    3. RedirectTo

      spring:cloud:gateway:routes:- id: prefixpath_routeuri: http://example.orgpredicates:- Path=/redfilters:- RedirectTo=302, http://www.baidu.com

      浏览器访问地址：http://example.org/red

      实际微服务地址：http://www.baidu.com

  5. 其他

    1. Default：添加过滤器用于所有路由，相当于全局过滤器。

      spring:cloud:gateway:default-filters:- AddResponseHeader=X-Response-Default-Red, Default-Blue- PrefixPath=/httpbin

如果调用链中再加入远程调用，调用链还是很复杂的！

4.4.3 自定义过滤器

🔔Spring Cloud Gateway自定义过滤器参考另一篇笔记

参考

  • https://mp.weixin.qq.com/s/ua_VlF30fzdMjkuKVnGhvw
  • https://www.cnblogs.com/duanxz/p/14780675.html

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

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

相关文章

基于python+vue超市在线销售系统的设计与实现flask-django-php-nodejs

基于python+vue超市在线销售系统的设计与实现flask-django-php-nodejs

根据此问题&#xff0c;研发一套超市在线销售系统&#xff0c;既能够大大提高信息的检索、变更与维护的工作效率&#xff0c;也能够方便信息系统的管理运用&#xff0c;从而减少信息管理成本&#xff0c;提高效率。 该超市在线销售系统采用B/S架构、并采用python语言以及django…
阅读更多...
拌合楼管理系统(八) c#海康威视摄像头车牌识别

拌合楼管理系统(八) c#海康威视摄像头车牌识别

前言: c#调用海康威视SDK实现车牌识别 原本以为海康威视sdk的Demo里面没有车牌识别的实例,后来发现自己肤浅了,官方是有提供的,只是车牌识别是通过安防布警的方式实现的.程序主动监听,触发告警后获取到车牌信息. 一、接口调用的流程&#xff1a; 首先初始化sdk -> 开…
阅读更多...
CI/CI实战-jenkis结合gitlab 4

CI/CI实战-jenkis结合gitlab 4

实时触发 安装gitlab插件 配置项目触发器 生成令牌并保存 配置gitlab 测试推送 gitlab的实时触发 添加jenkins节点 在jenkins节点上安装docker-ce 新建节点server3 安装git和jdx 在jenkins配置管理中添加节点并配置从节点 关闭master节点的构建任务数
阅读更多...
二分查找法总结

二分查找法总结

目录 1、思路讲解&#xff08;LC704&#xff09;2、代码思路讲解&#xff08;循环不变量&#xff09;&#xff08;1&#xff09; 左闭右闭&#xff08;2&#xff09;左闭右开&#xff08;3&#xff09;总结&#xff1a;左开右闭和左闭右开&#xff08;4&#xff09;复杂度分析 …
阅读更多...
老阳分享|temu跨境电商选品师项目能赚钱吗？

老阳分享|temu跨境电商选品师项目能赚钱吗？

近年来&#xff0c;跨境电商行业蓬勃发展&#xff0c;成为众多创业者追逐的热点。其中&#xff0c;老阳分享的temu跨境电商选品师项目备受关注。那么&#xff0c;这个项目真的能赚钱吗?下面&#xff0c;我们就跟随本文去了解一下。 首先&#xff0c;temu作为拼多多旗下的跨境电…
阅读更多...
数据结构与算法4-冒泡排序

数据结构与算法4-冒泡排序

文章目录 1. 认识冒泡排序2. 图示2.1 图示12.2 图示2 3. 代码 1. 认识冒泡排序 双层for循环&#xff0c;每次选出最大的数“浮”到数组的最后面&#xff1b;时间复杂度O( n 2 n^2 n2)&#xff0c;空间复杂度O(1);重复地遍历待排序的数列&#xff0c;一次比较两个元素&#xff…
阅读更多...
ClickHouse部署安装

ClickHouse部署安装

准备工作 确定防火墙处于关闭状态 CentOS取消打开文件数限制 在hadoop102的 /etc/security/limits.conf文件的末尾加入以下内容 注意&#xff1a;以下操作会修改 Linux 系统配置&#xff0c;如果操作不当可能导致虚拟机无法启动&#xff0c;建议在执行以下操作之前给…
阅读更多...
Vue中的状态管理Vuex，基本使用

Vue中的状态管理Vuex，基本使用

1.什么是Vuex？ Vuex是专门为Vue.js设计的状态管理模式；特点：集中式存储和管理应用程序中所有组件状态，保证状态以一种可预测的方式发生变化。 1.1.什么是状态管理模式？ 先看一个单向数据流的简单示意图 state:驱动应用的数据源 view:以声明方式将state映射到视图 actions：…
阅读更多...
2024智能EDM邮件营销系统使用攻略

2024智能EDM邮件营销系统使用攻略

在数字化营销领域&#xff0c;智能EDM&#xff08;Electronic Direct Mail&#xff09;邮件营销作为一种高效、精准的推广方式&#xff0c;正日益受到企业的高度重视。而要实现这一策略的成功落地&#xff0c;一个高可靠性和高稳定性的专业邮件发送平台则是不可或缺的关键环节。…
阅读更多...
arduino ide 开发esp8266注意事项

arduino ide 开发esp8266注意事项

1.引脚序列号必须是常量来定义&#xff0c;否则会无限重启。 #define p2 2 const int Pin2p2; pinMode(Pin2, OUTPUT); 2.关于wifi的模式&#xff0c;ap,sta&#xff0c;apsta三种模式的初始化必须放在void set_up(){}这个函数里&#xff0c;不能额外搞个自定义函数&#xf…
阅读更多...
Java后端八股------设计模式

Java后端八股------设计模式

Coffee可以设计成接口。
阅读更多...
SpringCloud-Gateway服务网关

SpringCloud-Gateway服务网关

一、网关介绍 1. 为什么需要网关 Gateway网关是我们服务的守门神&#xff0c;所有微服务的统一入口。 网关的核心功能特性&#xff1a; 请求路由 权限控制 限流 架构图&#xff1a; 权限控制&#xff1a;网关作为微服务入口&#xff0c;需要校验用户是是否有请求资格&am…
阅读更多...
Python环境下基于1D-CNN的轴承故障诊断及TSNE特征可视化

Python环境下基于1D-CNN的轴承故障诊断及TSNE特征可视化

1D CNN 处理一维信号具有显著优势&#xff0c;已在很多领域得到初步应用&#xff1a; 心电图监测&#xff1a;将1DCNN应用于心脏病监测&#xff0c;其方法是针对每一个心脏病人的&#xff0c;即对于每个心律失常患者使用该患者特有的训练数据&#xff0c;专门训练出一个紧凑的…
阅读更多...
网络层（IP层）

网络层（IP层）

IP协议的本质&#xff1a;有将数据跨网络传输的能力 而用户需要的是将数据从主机A到主机B可靠地跨网络传输 IP的组成&#xff1a;目标网络目标主机 IP由目标网络和目标主机两部分组成&#xff0c;IP报文要进行传输&#xff0c;要先到达目标网络&#xff0c;然后经过路由器转到…
阅读更多...
保研复习概率论1

保研复习概率论1

1.什么是随机试验&#xff08;random trial&#xff09;&#xff1f; 如果一个试验满足试验可以在相同的条件下重复进行、试验所有可能结果明确可知&#xff08;或者是可知这个范围&#xff09;、每一次试验前会出现哪个结果事先并不确定&#xff0c;那么试验称为随机试验。 …
阅读更多...
利用 Claude 3 on Amazon Bedrock 和 Streamlit 的“终极组合”，开发智能对话体验

利用 Claude 3 on Amazon Bedrock 和 Streamlit 的“终极组合”，开发智能对话体验

概述 通过本文&#xff0c;您将学会如何利用 Streamlit 框架快速搭建前端交互界面。该界面将集成图像上传功能&#xff0c;让用户可以方便地提交待处理图片。在后端&#xff0c;我们将借助 Amazon Bedrock 的 Message API&#xff0c;调用 Claude 3 家族中的 Sonnet 模型对图像…
阅读更多...
代码随想录算法训练营Day55 ||leetCode 583. 两个字符串的删除操作 || 72. 编辑距离

代码随想录算法训练营Day55 ||leetCode 583. 两个字符串的删除操作 || 72. 编辑距离

583. 两个字符串的删除操作 这道题的状态方程比上一题简单一些 初始化如下 class Solution { public:int minDistance(string word1, string word2) {vector<vector<int>> dp(word1.size() 1, vector<int>(word2.size() 1));for (int i 0; i < word1…
阅读更多...
Kafka生产者相关概念

Kafka生产者相关概念

文章目录 Kafka工作流程Kafka文件存储生产者分区策略生产者ISR生产者ack机制数据一致性问题ExactlyOnce Kafka工作流程 Kafka中消息是以topic进行分类的&#xff0c;Producer生产消息&#xff0c;Consumer消费消息&#xff0c;都是面向topic的。 Topic是逻辑上的概念&#xff…
阅读更多...
Qt 压缩/解压文件

Qt 压缩/解压文件

前面讲了很多Qt的文件操作&#xff0c;文件操作自然就包括压缩与解压缩文件了&#xff0c;正好最近项目里要用到压缩以及解压缩文件&#xff0c;所以就研究了一下Qt如何压缩与解压缩文件。 QZipReader/QZipWriter QZipReader 和 QZipWriter 类提供了用于读取和写入 ZIP 格式文…
阅读更多...
SpringCloud Gateway工作流程

SpringCloud Gateway工作流程

Spring Cloud Gateway的工作流程 具体的流程&#xff1a; 用户发送请求到网关 请求断言&#xff0c;用户请求到达网关后&#xff0c;由Gateway Handler Mapping&#xff08;网关处理器映射&#xff09;进行Predicates&#xff08;断言&#xff09;&#xff0c;看一下哪一个符合…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023