自定义Spring Cloud Gateway过滤器：记录慢请求
在构建微服务架构时，API网关是一个关键组件，它负责路由、负载均衡、安全验证等多种功能。Spring Cloud Gateway提供了强大的扩展能力，允许开发者通过自定义过滤器来增强其功能。本文将详细介绍如何实现一个自定义过滤器，用于记录响应时间超过指定阈值的请求，并展示如何支持微服务的自定义配置。
首先，我们需要创建一个自定义的Gateway过滤器工厂类。这个类将负责缓存请求体，并在请求处理完成后检查响应时间是否超过了设定的阈值。如果超过了，则记录一条警告日志。
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;import java.nio.charset.StandardCharsets;
import java.util.Map;@Slf4j
@Component
public class SlowLoggingGatewayFilterFactory extends AbstractGatewayFilterFactory<SlowLoggingGatewayFilterFactory.Config> {public SlowLoggingGatewayFilterFactory() {super(SlowLoggingGatewayFilterFactory.Config.class);log.info("Loaded GatewayFilterFactory [RequestTimeoutLog]");}@Overridepublic GatewayFilter apply(SlowLoggingGatewayFilterFactory.Config config) {return (exchange, chain) -> {long startTime = System.currentTimeMillis();// 缓存请求体，避免因请求体被消费导致读取不到数据// 使用DataBufferUtils.join将请求体的所有数据缓冲区合并为一个DataBufferreturn DataBufferUtils.join(exchange.getRequest().getBody()).flatMap(dataBuffer -> {// 将合并后的DataBuffer转换为字节数组，并将其转换为字符串byte[] bytes = new byte[dataBuffer.readableByteCount()];dataBuffer.read(bytes);DataBufferUtils.release(dataBuffer);// 释放资源String cachedBody = new String(bytes, StandardCharsets.UTF_8);// 将缓存的请求体存储在ServerWebExchange的属性中，键名为"cachedRequestBody"exchange.getAttributes().put("cachedRequestBody", cachedBody);return chain.filter(exchange);// 继续处理请求链}).doOnSuccessOrError((response, ex) -> {// 计算耗时并记录long duration = System.currentTimeMillis() - startTime;if (config.isEnabled() && duration > config.getTimeout()) {ServerHttpRequest request = exchange.getRequest();String cachedBody = exchange.getAttributeOrDefault("cachedRequestBody", "");Map<String, String> queryParams = request.getQueryParams().toSingleValueMap();log.warn("Slow Request Detected: Method={}, Path={}, QueryParams={}, Body={}, Duration={}ms",request.getMethodValue(), request.getPath(), queryParams, cachedBody, duration);}});};}@Data@AllArgsConstructor@NoArgsConstructorpublic static class Config {// 控制是否超时日志打印private boolean enabled;// 超时阈值，单位毫秒，默认1000毫秒private long timeout = 1000L;}
}
原理很简单，使用 DataBufferUtils.join 将请求体的所有数据缓冲区合并为一个 DataBuffer，然后将其转换为字符串并缓存到 exchange 的属性中。调用 chain.filter(exchange) 继续处理请求链，确保请求可以正常传递到下游微服务。在请求处理完成后（无论成功还是失败），计算请求处理的总耗时。如果配置启用了日志记录并且耗时超过了设定的阈值，则记录一条警告日志。
接下来，需要在 application.yml 文件中配置路由并应用自定义过滤器。
spring:cloud:gateway:routes:- id: api_route_1uri: http://service1.example.compredicates:- Path=/api/v1/**filters:- name: SlowLoggingargs:enabled: truetimeout: 1500- id: api_route_2uri: http://service2.example.compredicates:- Path=/api/v2/**filters:- name: SlowLoggingargs:enabled: falsetimeout: 1000- id: default_routeuri: http://default-service.example.compredicates:- Path=/**filters:- name: SlowLoggingargs:enabled: truetimeout: 2000
-
id: 每个路由的唯一标识符。
-
uri: 目标服务的URI。
-
predicates: 定义路由匹配条件，这里是匹配路径以
/api/开头的请求。 -
- filters
- 定义应用于该路由的过滤器列表。
- name: 过滤器名称，应与自定义过滤器类名中的
GatewayFilterFactory前缀部分一致（去掉后缀）。例如，SlowLoggingGatewayFilterFactory对应的过滤器名称为SlowLogging。 - args: 过滤器的具体参数，这些参数将传递给过滤器的配置类。
启动Spring Boot应用 和 Gateway网关，并发送请求到不同的路由，观察日志输出。例如，如果你发送一个请求到 http://localhost/api/v1/test 并且响应时间超过1500毫秒，你会看到类似以下的日志记录：
WARN Slow Request Detected: Method=GET, Path=/api/v1/test, QueryParams={}, Body=..., Duration=1600ms
通过实现自定义的Spring Cloud Gateway过滤器，我们可以灵活地监控和记录响应时间超过指定阈值的请求。这不仅有助于我们更好地了解系统的性能瓶颈，还可以帮助我们在生产环境中快速定位问题。
相关文章：
自定义Spring Cloud Gateway过滤器：记录慢请求
在构建微服务架构时，API网关是一个关键组件，它负责路由、负载均衡、安全验证等多种功能。Spring Cloud Gateway提供了强大的扩展能力，允许开发者通过自定义过滤器来增强其功能。本文将详细介绍如何实现一个自定义过滤器，用于记录响…...
python 浅拷贝和深拷贝
浅拷贝（Shallow Copy）语法示例代码 1示例代码 2 深拷贝（Deep Copy）语法示例代码 浅拷贝与深拷贝的区别示例：浅拷贝与深拷贝的对比 浅拷贝：只复制外层容器，内层嵌套对象仍然是共享的，…...
uni-app 学习（一）
一、环境搭建和运行 （一）创建项目 直接进行创建 （二）项目结构理解 pages 是页面 静态资源 打包文件，看我们想输出成什么格式 app.vue 页面的入口文件 main.js 是项目的入口文件 存放对打包文件的配置 pages 存放整…...
unity学习37：新版的动画器：动画状态机 Animator
目录 1 给游戏物体添加，新版的动画器 Animator 2 关于 Animator 3 创建 动画器的控制器 Animator Controller 4 打开动画编辑器 Animator 5 动画编辑器 还是Animation 5.1 创建新的动画 5.2 创建第2个动画 5.3 测试2个动画均可用 6 再次打开动画编辑器 A…...
FFmpeg+SDL实现简易视频播放器
参考链接 https://blog.csdn.net/qq_26611129/article/details/98732561 https://www.cnblogs.com/Azion/p/17756274.html https://avmedia.0voice.com/?id49050 https://blog.csdn.net/qq_44825209/article/details/133760652 https://www.cnblogs.com/Azion/p/17525955.htm…...
Vue3实现优雅的前端版本更新提示
背景 在前端项目开发中,当我们发布了新版本后,需要及时通知用户刷新页面以获取最新代码。本文将介绍一种优雅的实现方案。 实现原理 在项目根目录维护一个version.json文件,记录当前版本号前端定期请求version.json检查版本对比本地存储的版本号,如有更新则提示用户 核心代…...
vim常用快捷键
正常模式 在打开文件进入 Vim 后，默认处于正常模式，该模式下的快捷键主要用于光标移动、文本操作等。 光标移动 基本移动：h（左移）、j（下移）、k（上移）、l（右移…...
P1226 【模板】快速幂
P1226 【模板】快速幂 题目描述 给你三个整数 a , b , p a,b,p a,b,p，求 a b m o d p a^b \bmod p abmodp。 输入格式 输入只有一行三个整数，分别代表 a , b , p a,b,p a,b,p。 输出格式 输出一行一个字符串 a^b mod ps，其中 a , b…...
【gRPC-gateway】是否有拦截器的情况添加健康检查的细节，与多路复用runtime.NewServeMux和gRPC区别讲解，与跨域功能，go案例
健康检查详解 什么是健康检查？ 健康检查（Health Checking）是一种机制，用于监控服务的状态，确保服务在运行时是健康的、可用的。通过健康检查，系统可以自动检测服务是否正常工作，并在出现问题时…...
vue开发时，用localStorage常用方法及存储数组方法。
localStorage 可以让你在浏览器中存储键值对，并且在页面关闭后数据依然保留。localStorage 中存储的数据会一直保存在客户端，直到被手动删除或者清除浏览器缓存。 localStorage 中存储的数据在同一浏览器的不同窗口之间是共享的，而 sessionSt…...
HashMap详解+简单手写实现（哈希表）
1. 什么是 HashMap？ HashMap是Java集合框架中的一种数据结构，它实现了Map接口，用于存储键值对（Key-Value Pair）。HashMap允许null键和null值，并且不保证元素的顺序。 --- 2. HashMap 的工作原理 2.1 内…...
解决Did not find dashscope_api_key问题——jupyter设置环境变量
jupyter中使用通义千文langchain 报错 Value error, Did not find dashscope_api_key, please add an environment variable DASHSCOPE_API_KEY which contains it, or pass dashscope_api_key as a named parameter.我本来以为这样就是已经加上了： #导入相关包 i…...
尚硅谷爬虫note003
一、函数 1. 函数的定义 def 函数名（）： 代码 2.函数的调用 函数名（） 3. 定义参数（不调用函数不执行） def sum（a，b） #形参 c a b print（c&…...
算法兵法全略（译文）
目录 始计篇 谋攻篇 军形篇 兵势篇 虚实篇 军争篇 九变篇 行军篇 地形篇 九地篇 火攻篇 用间篇 始计篇 算法，在当今时代，犹如国家关键的战略武器，也是处理各类事务的核心枢纽。算法的世界神秘且变化万千，不够贤能聪慧…...
)
NO.17十六届蓝桥杯备战|do-while循环|break和continue语句|三道练习(C++)
do-while循环 do-while语法形式 在循环语句中 do while 语句的使⽤最少，它的语法如下： //形式1 do 语句; while( 表达式 );//形式2 do { 语句1; 语句2; ... } while( 表达式 );while 和 for 这两种循环都是先判断，条件如果…...
)
【广州大学主办，发表有保障 | IEEE出版，稳定EI检索，往届见刊后快至1个月检索】第二届电气技术与自动化工程国际学术会议 (ETAE 2025)
第二届电气技术与自动化工程国际学术会议 (ETAE 2025) The 2nd International Conference on Electrical Technology and Automation Engineering 大会官网：http://www.icetae.com/【更多详情】 会议时间：2025年4月25-27日 会议地点：…...
Spring Cache 详细讲解
Spring Cache 是 Spring 框架提供的缓存抽象层，通过统一的 API 和注解简化缓存操作，支持多种缓存实现（如 Redis、EhCache、Caffeine 等）。其核心目标是减少重复计算，提升系统性能，同时保持代码简洁性。 1. …...
CPT205 计算机图形学 OpenGL 3D实践（CW2）
文章目录 1. 介绍2. 设计3. 准备阶段4. 角色构建5. 场景构建6. 交互部分6.1 键盘交互6.2 鼠标交互6.3 鼠标点击出多级菜单进行交互 7. 缺点与问题7.1 程序bug7.2 游戏乐趣不足7.3 画面不够好看 8. 完整代码 1. 介绍 前面已经分享过了关于CPT205的CW1的2D作业，这次C…...
Netty的基本架构详解
EventLoopGroup基本认识 我们需要了解的 EventLoopGroup, Netty对EventLoopGroup做了很多的扩展实现，下图是他的家族图谱： 我们上一节课使用的案例，使用的是NioEventLoopGroup，他是NIO的实现，可以看出来他是Multithre…...
2025前端面试题超全面解析（附答案与深度扩展）
文章目录 一、HTML篇（扩展版）1. **HTML5语义化标签的实际应用场景**2. **Web Components实战：如何封装一个自定义按钮组件？**3. **Web Worker的用途与限制** 二、CSS篇（扩展版）1. **CSS盒模型详解ÿ…...
自己搭建可以和deepseek对话的WEB应用
第一步 下载安装anaconda，地址：https://repo.anaconda.com/ 第二步 打开anaconda客户端，打开conda命令行窗口 第三步 创建一个open-webui专属的python专属的虚拟环境，并且指定python具体的版本 conda create --name open…...
Linux系统运行模式和链接
一、系统运行模式 centos6 0 关机模式 1 单用户模式 2 字符模式，无网络连接 3 字符模式 4 预留 5 图形模式 6 重启模式 查看系统当前处于的运行模式 切换为图形模式 init 5 centos7 字符模式 multi-user…...
.NET 9.0 的 Blazor Web App 项目，进度条 ＜progress＞ 组件使用注意事项
一、执行过程中，要刷新 进度条 的显示，需要 延时、释放，否则进度条不 实时 更新，最后一下到 100% // 延时，释放给前端：【必须】，否则进度条不 实时 更新，最后一下到 100await Task.D…...
头歌实验--面向对象程序设计
目录 实验五 类的继承与派生 第1关：简易商品系统 任务描述 答案代码 第2关：公司支出计算 任务描述 答案代码 第3关：棱柱体问题 任务描述 答案代码 实验五 类的继承与派生 第1关：简易商品系统 任务描述 答案代码 #incl…...
IoTDB 断电后无法启动 DataNode，日志提示 Meet error while starting up
问题 IoTDB 1.3.2 版本，断电后 IoTDB 的 DataNode 无法启动，日志如下： 2024-12-16 14:45:41,350 [main] ERROR o.a.i.db.service.DataNode:562 - Meet error while starting up. org.apache.iotdb.commons.exception.StartupException: Fo…...
-E卷B卷-100分)
2024华为OD机试真题-最大报酬(C++)-E卷B卷-100分
2024华为OD机试最新题库-(C卷+D卷+E卷)-(JAVA、Python、C++) 目录 题目描述 输入描述 输出描述 示例一 解题思路 考点 代码 c++ 题目描述 小明每周上班都会拿到自己的工作清单，工作清单内包含n项工作， 每项工作都有对应的耗时时间（单位h）和报酬, 工作的总报酬为…...
jenkins war Windows安装
Windows安装Jenkins 需求1.下载jenkins.war2.编写快速运行脚本3.启动Jenkins4.Jenkins使用 需求 1.支持在Windows下便捷运行Jenkins； 2.支持自定义启动参数； 3.有快速运行的脚步样板。 1.下载jenkins.war Jenkins下载地址：https://get.j…...
HCIA项目实践--RIP相关原理知识面试问题总结回答
9.4 RIP 9.4.1 补充概念 什么是邻居？ 邻居指的是在网络拓扑结构中与某一节点（如路由器）直接相连的其他节点。它们之间可以直接进行通信和数据交互，能互相交换路由信息等，以实现网络中的数据转发和路径选择等功能。&am…...
用大模型学大模型04-模型与网络
目前已经学完深度学习的数学基础，开始学习各种 模型和网络阶段，给出一个从简单到入门的，层层递进的学习路线。并给出学习每种模型需要的前置知识。增加注意力机制，bert, 大模型，gpt, transformer， MOE等流行…...
浏览器扩展实现网址自动替换
作为一个开发爱好者，不能顺畅访问github是很痛苦的，这种状况不知道何时能彻底解决。 目前也有很多方案可以对应这种囧况，我此前知道有一个网站kkgithub，基本上把github的静态内容都搬了过来，我们如果需要访问某个githu…...
适配器模式详解（Java）
一、引言 1.1 定义与类型 适配器模式是一种结构型设计模式，主要目的是将一个类的接口转换为客户期望的另一个接口。这种模式使得原本因为接口不匹配而不能一起工作的类可以一起工作，从而提高了类的复用性。适配器模式分为类适配器和对象适配器两种类型。类适配器使用继承关…...
C语言表驱动法
最近了解到一种C语言的写法，故记录下来，内容来自deepseek。 表驱动法 表驱动法（Table-Driven Approach）是一种编程技术，通过使用表格（数组、结构体数组、哈希表等）来存储数据或逻辑࿰…...
【鸿蒙Next】优秀鸿蒙博客集锦
鸿蒙基础开发：多文件压缩上传及断点续传_鸿蒙 断点续传-CSDN博客...
Django REST Framework：如何获取序列化后的ID
Django REST Framework：如何获取序列化后的ID 😄 嗨，小伙伴们！今天我们来聊一聊Django REST Framework（简称DRF）中一个非常常见的操作：如何获取序列化后的ID。对于那些刚入门的朋友们ÿ…...
deep seek
1.介绍:DeepSeek是一款由国内人工智能公司研发的大型语言模型，拥有强大的自然语言处理能力，能够理解并回答问题，还能辅助写代码、整理资料和解决复杂的数学问题。免费开源，媲美ChatGPT 最近最火爆的AI对话程序。 www.deepseek.com…...
前端设计模式介绍及案例（单例模式、代理模式、工厂模式、装饰者模式、观察者模式）
概要 本文主要介绍了前端设计模式的定义、分类以及常用设计模式的具体案例。 前言 使用设计模式的目的：为了代码可重用性、让代码更容易被他人理解、保证代码可靠性。 设计模式使代码编写真正工程化；设计模式是软件工程的基石脉络，如同大厦…...
开源堡垒机 JumpServer 社区版实战教程：基于 Ubuntu 22.04 离线安装 JumpServer 社区版 v4.4.1
文章目录 开源堡垒机 JumpServer 社区版实战教程：基于 Ubuntu 22.04 离线安装 JumpServer 社区版 v4.4.1一、环境要求1.1 操作系统1.1.1 Ubuntu1.1.2 CentOS 1.2 数据库1.2.1 JumpServer 需要使用的数据库1.2.2 创建数据库 SQL 参考1.2.2.1 PostgreSQL1.2.2.2 MySQL…...
电源测试和测量系统的创新遥感方法可以消除哪些潜在问题
传统的遥感方法 远程感测是一种行之有效的方法，通过消除连接电缆中压降的影响来调节负载点的直流功率。这在测试和测量应用中尤其重要，在这些应用中，电源电压在一系列负载条件下的准确性和一致性通常对于获得准确且可重复的测试结果至关重要…...
10、《Thymeleaf模板引擎：动态页面开发全攻略》
Thymeleaf模板引擎：动态页面开发全攻略 一、Thymeleaf核心价值解析 天然HTML亲和力：Thymeleaf允许直接使用.html文件作为模板，支持浏览器直接预览静态原型，同时通过属性标签（如th:text）实现动态渲染&…...
Day1 25/2/14 FRI
【一周刷爆LeetCode，算法大神左神（左程云）耗时100天打造算法与数据结构基础到高级全家桶教程，直击BTAJ等一线大厂必问算法面试题真题详解（马士兵）】https://www.bilibili.com/video/BV13g41157hK?p3&v…...
untiy3D 让角色动起来,角色动画的使用
1.untiy 商店下载动画模型 2.导入项目 模型拖入到场景中 3.创建动画器控制器 4.动画控制器挂载到plarer上 5.把动画idle和pickup拖入到动画器 6.右键动画创建过渡效果(Make Transition) 6.设置参数用条件控制 7.当选中参数时启动过渡 运行效果 119 (二)用脚本控制动画…...
Word 里面嵌入DeepSeek
目录 一、问题描述 二、解决方法 三、代码 四、注意事项 五、总结 一、问题描述 如何在Word里面嵌入DeepSeek? 二、解决方法 1、新建文档，按 AltF11，进入VB界面。 2、选中文档，右键->插入->模块。 3、进入模块，粘入…...
深入浅出Java反射：掌握动态编程的艺术
小程一言反射何为反射反射核心类反射的基本使用获取Class对象创建对象调用方法访问字段 示例程序应用场景优缺点分析优点缺点 注意 再深入一些反射与泛型反射与注解反射与动态代理反射与类加载器 结语 小程一言 本专栏是对Java知识点的总结。在学习Java的过程中，学习…...
exr 格式下 全景图（经纬图、panorama）转 cubemap
先上效果 （X, -X, Y, -Y, Z, -Z） 下载 exr 经纬图 笔者用的这张：https://polyhaven.com/a/kloofendal_48d_partly_cloudy_puresky 使用 Openexr 的 exrenvmap 工具 下载 我 build 了一份 3.3.2 版本的，免积分下载。 https:/…...
解锁建造者模式：Java 编程中的对象构建秘籍
系列文章目录 后续补充~~~~ 文章目录 一、引言二、建造者模式原理剖析2.1 定义与概念2.2 模式结构与角色2.2.1 产品（Product）2.2.2 建造者（Builder）2.2.3 具体建造者（ConcreteBuilder）2.2.4 指挥者（Director）2.3 工作流程与交互机制三、建造者模式在 Java 中的优势3.1 …...
ArcGIS Pro显示缓存空间不足导致编辑或加载数据显示不完全
ArcGIS Pro对于显示缓存有32GB的限制，所以当缓存设置中，缓存将达到32GB时，会出现编辑、加载slpk显示不全的情况。 清除计算机上的显示缓存方法 1.启动 ArcGlS Pro。单击左下角的设置，然后单击选项； 2.在选项窗口中&…...
大数据、云计算、人工智能等技术深度融合的智慧快消开源了。
智慧快消视频监控平台是一款功能强大且简单易用的实时算法视频监控系统。它的愿景是最底层打通各大芯片厂商相互间的壁垒，省去繁琐重复的适配流程，实现芯片、算法、应用的全流程组合，从而大大减少企业级应用约95%的开发成本。 基于多年的深度…...
C++17 中的 std::reduce：详细教程
文章目录 1. 简介2. 函数签名3. 使用场景3.1 简单的累加操作3.2 自定义归并操作3.3 并行计算的性能优势 4. 注意事项4.1 归并操作的结合律和交换律4.2 默认值的使用 5. 总结 1. 简介 std::reduce 是 C17 标准库中引入的一个算法，用于对范围内的元素进行归并操作。它…...
Python爬虫实战：获取笔趣阁图书信息，并做数据分析
注意：以下内容仅供技术研究，请遵守目标网站的robots.txt规定，控制请求频率避免对目标服务器造成过大压力！ 1. 环境准备与反爬策略 python import requests from bs4 import BeautifulSoup import pandas as pd import re import time import random from fake_useragent …...
win11系统 Docker Desktop提示Docker Engine stopped解决全过程记录
DockerDesktop安装指南以及Windows下WSL2和 Hyper-V相关问题追查 【已解决】win10系统 Docker 提示Docker Engine stopped解决全过程记录 本篇文章主要记录Docker Desktop安装和使用时出现的问题及解决方法，以及后续使用夜神模拟器，关闭了Hyper-V时&am…...