Filter 实现过滤符合条件的请求并落库

其他系列文章导航

Java基础合集
数据结构与算法合集

设计模式合集

多线程合集

分布式合集

ES合集


文章目录

其他系列文章导航

文章目录

前言

一、配置过滤器类

二、定义数据表、实体类、Mapper

2.1 DDL

2.2 实体类

2.3 Mapper

三、创建一个过滤器

四、实现 Nacos 配置热更新

五、自定义 RequestWrapper 

六、容易踩的坑 

6.1 Java 工具类 Mapper 层报空指针

6.2 工具类中使用 @Value 给静态变量注入值失败

七、总结


前言

Java过滤器(Filter)在Java Servlet API中是一个非常有用的组件,它允许你在请求到达Servlet或JSP之前或之后执行某些操作。

 

需求:当请求进入系统时进行拦截,如果符合拦截规则就将请求详情落库。

背景:SpringCloud 项目,注册中心是 Nacos。


一、配置过滤器类

首先,你需要在你的Spring Boot应用中添加Nacos的依赖。

我们选择 OncePerRequestFilter。

OncePerRequestFilter定义:

OncePerRequestFilter 是 Spring Framework 中的一个过滤器接口,用于处理每个请求只执行一次的逻辑。这个过滤器类型是为了确保某个特定的逻辑只会在一个请求中被执行一次,无论该请求经过了多少个过滤器链。

使用 OncePerRequestFilter 的一个常见场景是,你可能希望在每个请求处理之前或之后执行某些操作,但又不希望这些操作在每个过滤器链中被重复执行。

 

然后,你可以创建一个过滤器类,如下所示:

@Configuration
public class FilterConfig {@Beanpublic FilterRegistrationBean<OncePerRequestFilter> logFilter() {FilterRegistrationBean<OncePerRequestFilter> registration = new FilterRegistrationBean<>();registration.setFilter(new RequestLogFilter());registration.setOrder(Ordered.HIGHEST_PRECEDENCE);return registration;}
}

这个配置类定义了一个过滤器,名为logFilter,它在每个请求上只执行一次(由其实现的OncePerRequestFilter接口保证)。

这个过滤器用于请求日志记录,其顺序被设置为最高优先级。 


二、定义数据表、实体类、Mapper

2.1 DDL

请求时间入库自动生成。

create table C##YYTXD.SHUXX_REQUEST_LOGS
(METHOD  VARCHAR2(10),URI     VARCHAR2(255),HEADERS VARCHAR2(4000),BODY    VARCHAR2(4000),IP      VARCHAR2(255),TIME    TIMESTAMP(6) default CURRENT_TIMESTAMP
)
/

2.2 实体类

定义一个Java实体类,用于映射数据库中的REQUEST_LOGS表。该类使用了Lombok库来简化代码的编写,同时使用了MyBatis Plus库的注解来方便地与数据库交互。

如下所示:

@TableName(value ="REQUEST_LOGS")
@Data
public class RequestLogs implements Serializable {private String method;private String uri;private String headers;private String body;private String ip;@TableField(exist = false)private Date time;@TableField(exist = false)private static final long serialVersionUID = 1L;
}

这个实体类主要用于封装HTTP请求的日志信息,方便存储到数据库中。

每个日志记录可以包含请求的方法、URI、头部信息、正文内容、发起请求的IP地址以及请求的时间等信息。 

2.3 Mapper

@Mapper
public interface RequestLogsMapper extends BaseMapper<RequestLogs> {}
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.mapper.RequestLogsMapper"><resultMap id="BaseResultMap" type="com.domain.po.RequestLogs"><result property="method" column="METHOD" jdbcType="VARCHAR"/><result property="uri" column="URI" jdbcType="VARCHAR"/><result property="headers" column="HEADERS" jdbcType="VARCHAR"/><result property="body" column="BODY" jdbcType="VARCHAR"/><result property="ip" column="IP" jdbcType="VARCHAR"/><result property="time" column="TIME" jdbcType="TIMESTAMP"/></resultMap><sql id="Base_Column_List">METHOD,URL,HEADERS,BODY,IP,TIME</sql></mapper>

三、创建一个过滤器

该过滤器用于记录HTTP请求日志。这个类继承了OncePerRequestFilter,这意味着它会在每个请求上只执行一次。如下所示:

@Component
public class RequestLogFilter extends OncePerRequestFilter {@Resourceprivate RequestLogUriProperties requestLogUrlProperties;@Resourceprivate RequestLogsMapper requestLogsMapper;public RequestLogFilter() {}public static RequestLogFilter requestLogFilter;@PostConstructpublic void init() {requestLogFilter = this;}@Overrideprotected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {String uri = request.getRequestURI();AntPathMatcher matcher = new AntPathMatcher();HttpServletRequest requestWrapper = new RequestWrapper(request);for (String filterUri : requestLogFilter.requestLogUrlProperties.getUris()) {if (!matcher.match(filterUri, uri)) continue;String method = request.getMethod();String ip = request.getRemoteAddr();String body = RequestWrapper.getBodyString(requestWrapper);Enumeration<String> headerNames = request.getHeaderNames();Map<String, String> headers = new HashMap<>();// 遍历所有请求头,并存入Map中while (headerNames.hasMoreElements()) {String headerName = headerNames.nextElement();String headerValue = request.getHeader(headerName);headers.put(headerName, headerValue);}RequestLogs logsDto = new RequestLogs();logsDto.setMethod(method);logsDto.setUri(uri);logsDto.setHeaders(headers.toString());logsDto.setBody(body);logsDto.setIp(ip);requestLogFilter.shuxxRequestLogsMapper.insert(logsDto);}// 继续传递请求filterChain.doFilter(requestWrapper, response);}
}

这个过滤器的主要目的是捕获与特定URI模式匹配的所有HTTP请求,并将这些请求的相关信息记录到日志中。

特定URI模式匹配使用的是 ant url。匹配规则定义在配置文件中。


四、实现 Nacos 配置热更新

配置和初始化一个名为RequestLogUriProperties的bean。

这个bean主要用于存储和获取需要记录日志的URL列表。如下所示:

@Configuration
@ConfigurationProperties(prefix = "request-log")
@RefreshScope
//Nacos配置热更新
public class RequestLogUriProperties {public List<String> getUris() {return uris;}public void setUris(List<String> uris) {this.uris = uris;}private List<String> uris;}

通过与Spring的属性绑定机制结合,在 Nacos 配置文件中定义这些URL,并通过setter方法将其设置到bean中。同时,由于使用了@RefreshScope注解,当这些URL的配置发生变化时,bean会被重新初始化,从而实现配置的热更新。 

注解解释:

  • @Configuration: 这是Spring框架的注解,表示该类是一个配置类,用于定义和注册beans。
  • @ConfigurationProperties(prefix = "request-log"): 这个注解将RequestLogUriProperties类与Spring的属性绑定机制结合,使得你可以在外部配置文件中使用request-log前缀来定义属性,并这些属性会自动填充到RequestLogUriProperties类的字段中。
  • @RefreshScope: 这是Spring Cloud的注解,用于支持配置的热更新。当配置发生变化时,带有此注解的bean会被重新初始化。

Nacos 中配置:

request-log:uris:- /index/*- ......

这个配置会拦截所以 uri 是 /index/* 的请求。 


五、自定义 RequestWrapper 

spring boot项目,在过滤器、拦截器或自定义 aop 做统一处理时,获取了request中的inputstream来获取RequestBody里数据,获取之后在Controller里使用@RequestBody注解再获取的话。

就报错:Stream closed。

这是因为 HttpServletRequest 中的 inputstream 是不可重复读的。

所以我们要自定义 RequestWrapper ,对 HttpServletRequest 进行处理。

public class RequestWrapper extends HttpServletRequestWrapper {private final byte[] body;public RequestWrapper(HttpServletRequest request) {super(request);// 获取 requestBody 中的数据body = getBodyString(request).getBytes(StandardCharsets.UTF_8);}//通过覆盖getReader和getInputStream方法,将request中的body数据存储到内存中的输入流,使得body数据能够被多次读取。@Overridepublic BufferedReader getReader() {return new BufferedReader(new InputStreamReader(getInputStream()));}@Overridepublic ServletInputStream getInputStream() {// 定义内存中的输入流final ByteArrayInputStream stream = new ByteArrayInputStream(body);return new ServletInputStream() {@Overridepublic int read() {// 使用内存输入流读取数据return stream.read();}@Overridepublic boolean isFinished() {return false;}@Overridepublic boolean isReady() {return false;}@Overridepublic void setReadListener(ReadListener readListener) {}};}//getBodyString方法用于获取request的body数据并转换为字符串返回。public static String getBodyString(HttpServletRequest request) {StringBuilder sb = new StringBuilder();InputStream inputStream = null;BufferedReader reader = null;try {inputStream = request.getInputStream();reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8));String line;while ((line = reader.readLine()) != null) {sb.append(line);}} catch (IOException e) {e.printStackTrace();} finally {if (inputStream != null) {try {inputStream.close();} catch (IOException e) {e.printStackTrace();}}if (reader != null) {try {reader.close();} catch (IOException e) {e.printStackTrace();}}}return sb.toString();}
}

这个类包装了一个HttpServletRequest对象。这个类的主要目的是重写HttpServletRequestgetReadergetInputStream方法,以便将请求体的数据存储在内存中的输入流,从而允许多次读取请求体的数据。


六、容易踩的坑 

6.1 Java 工具类 Mapper 层报空指针

问题:

在使用Spring框架时,尝试将Service注入到非Spring管理的静态方法或工具类中。在Spring中,依赖注入主要依赖于@Autowired@Resource注解,但是这些注解不适用于静态方法或非Spring管理的类。

原因:

当你在Controller层使用Service时,可以通过@Resource或@Autowired注解轻松注入Service。但在普通类或工具类中使用Service时,会遇到找不到注解的属性值的问题,导致Service为null并报空指针异常。

即使在调用Service的类中添加了@Component注解并加入了Spring容器管理,问题仍然存在。

另外,由于工具类或普通类是静态方法,而Service和Mapper是非静态的,因此无法直接注入到静态方法中。

即使将Service和Mapper注入为静态的,仍然会报空指针异常。

为了解决这个问题,你可以考虑使用单例模式、使用ApplicationContext、重构代码或避免在工具类或普通类中使用静态方法。

解决方法如下:

    public RequestLogFilter() {}public static RequestLogFilter requestLogFilter;@PostConstructpublic void init() {requestLogFilter = this;}

在类的实例化完成后,它的当前实例会被设置为静态字段requestLogFilter的引用。这种模式通常用于单例模式或确保只有一个实例存在的其他模式。

6.2 工具类中使用 @Value 给静态变量注入值失败

问题:

在SpringBoot中使用@value注解只能给普通变量注入值,不能直接给静态变量赋值,直接给静态变量赋值的话这些值会一直为null。

解决方案: 

若要给静态变量赋值,可以使用set()方法,首先在对应的类上加上@Component注解,在set方法上使用value注解(注意set方法不是静态的,否则无法赋值)。

    private static String uri;@Value("${uri}")public void seturi(String uri) {this.uri= uri;}

七、总结

实现一个高效的过滤器需要仔细考虑多个方面,包括规则定义、拦截机制、处理逻辑、性能优化、异常处理、配置管理和安全性。

通过合理地设计和实现过滤器,可以帮助提高系统的安全性、可维护性和可靠性。

此外,了解不同过滤器框架和技术的特点可以帮助你选择最适合你的特定需求的解决方案。


 

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

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

分享86个行业PPT,总有一款适合您

分享86个行业PPT&#xff0c;总有一款适合您 86个行业PPT下载链接&#xff1a;https://pan.baidu.com/s/1avbzwqK8ILLWYIOylK1aRQ?pwd8888 提取码&#xff1a;8888 Python采集代码下载链接&#xff1a;采集代码.zip - 蓝奏云 学习知识费力气&#xff0c;收集整理更不易…

住宅供暖设备行业调研:市场环境将稳定发展阶段中

为使人们生活或进行生产的空间保持在适宜的热状态而设置的供热设施。 向一定的空间加热量的办法&#xff0c;可以直接把产生热量的火炉装在其中;也可以抽出其中的空气&#xff0c;加热后再送回;也可以在其中装置保持在较高温度的物体&#xff0c;向所在空间放热。这种温度较高的…

Elasticsearch:通过 ingest pipeline 对大型文档进行分块

在我之前的文章 “Elasticsearch&#xff1a;使用 LangChain 文档拆分器进行文档分块” 中&#xff0c;我详述了如何通过 LangChain 对大的文档进行分块。那个分块的动作是通过 LangChain 在 Python 中进行实现的。对于使用版权的开发者来说&#xff0c;我们实际上是可以通过 i…

【c++】模板---函数模板

1.泛型编程 如何实现一个通用的交换函数呢&#xff1f; void Swap(int& left, int& right) {int temp left;left right;right temp; } void Swap(double& left, double& right) {double temp left;left right;right temp; } void Swap(char& left,…

嵌入式学习之Linux入门篇笔记——18,makefile基本语法(下)

配套视频学习链接&#xff1a;http://【【北京迅为】嵌入式学习之Linux入门篇】 https://www.bilibili.com/video/BV1M7411m7wT/?p4&share_sourcecopy_web&vd_sourcea0ef2c4953d33a9260910aaea45eaec8 1.wildcard 函数 格式&#xff1a;$&#xff08;wildcard PAT…

爬虫系列-第一个爬虫

&#x1f308;个人主页: 会编程的果子君 ​&#x1f4ab;个人格言:“成为自己未来的主人~” 首先&#xff0c;我们需要回顾一下爬虫的概念&#xff0c;爬虫就是我们通过我们写的程序去抓取互联网上的数据资源&#xff0c;比如&#xff0c;此时我需要百度的资源&#xff0c;在不…

spring Bean生命周期 源代码分析 AbstractAutowireCapableBeanFactory createBean doCreateBean

文章目录 一、生命周期关键步骤1.1 前置条件1.2 创建bean 二、Bean生命周期、核心源码分析2.1 前置条件, 源代码2.2 创建bean, 源代码 一、生命周期关键步骤 1.1 前置条件 1.创建rootBean 生成RootBeanDefinition 2.对bean定义的方法&#xff0c;进行验证、重写 调用方法pre…

Blender教程(基础)-顶点挤出扩展-19

shiftA新建一个平面 编辑模式下&#xff0c;选中三个点&#xff0c;按X弹出按顶点删除 删除完成只剩下一个顶点 选中顶点按字母E在X轴挤出&#xff0c;按字母E在Y轴挤出 选中三个顶点按字母E延Z轴挤出 新建平面&#xff0c;按数字7到顶视图 选中顶点按E延X轴挤出 …

通用的网站炫酷底部美化代码分享

网站炫酷底部美化代码介绍 这段代码采用了最新的前端技术&#xff0c;确保在各种浏览器和设备上都能完美展现。它包含响应式设计元素&#xff0c;这意味着无论用户是通过电脑、平板还是手机访问您的网站&#xff0c;底部都能呈现出最佳的效果。 此外&#xff0c;我们还特别注…

单片机——ISP下载、ICP下载、IAP下载

文章目录 ISPICPIAP ISP 在线系统编程&#xff0c;使用引导程序加上外围UART/SPI接口烧录 其本质是将程序的hex文件烧录到板子里的过程 可以使用flymcu这个软件 System memory是STM32在出厂时&#xff0c;由ST在这个区域内部预置了一段BootLoader&#xff0c; 也就是我们常说…

机器人运动学林沛群——变换矩阵

对于仅有移动&#xff0c;由上图可知&#xff1a; A P B P A P B o r g ^AP^BP^AP_{B org} APBPAPBorg​ 对于仅有转动&#xff0c;可得&#xff1a; A P B A R B P ^AP^A_BR^BP APBA​RBP 将转动与移动混合后&#xff0c;可得&#xff1a; 一个例子 在向量中&#xff…

猫头虎分享已解决Bug || TypeError: this.$store.commit is not a function in Vue

博主猫头虎的技术世界 &#x1f31f; 欢迎来到猫头虎的博客 — 探索技术的无限可能&#xff01; 专栏链接&#xff1a; &#x1f517; 精选专栏&#xff1a; 《面试题大全》 — 面试准备的宝典&#xff01;《IDEA开发秘籍》 — 提升你的IDEA技能&#xff01;《100天精通鸿蒙》 …

c语言中的模拟多态性

在C语言中模拟多态性 多态性是面向对象编程中的一个核心概念&#xff0c;它允许我们通过一个共同的接口来操作不同的数据类型。虽然C语言是一种过程式语言&#xff0c;本身不直接支持面向对象的特性&#xff0c;如继承、封装和多态&#xff0c;但我们可以通过一些技巧来模拟这些…

@RequestBody、@RequestParam、@RequestPart使用方式和使用场景

RequestBody和RequestParam和RequestPart使用方式和使用场景 1.RequestBody2.RequestParam3.RequestPart 1.RequestBody 使用此注解接收参数时&#xff0c;适用于请求体格式为 application/json&#xff0c;只能用对象接收 2.RequestParam 接收的参数是来自HTTP 请求体 或 请…

关于 Ant Design 的 Upload 组件使用 action 自动上传出现跨域问题的解决

问题描述 使用 Ant Design 的 Upload 组件时&#xff0c;可以通过 action 属性指定上传地址实现选择文件自动上传。但在我选择文件上传后浏览器控制台一直出现跨域错误。关键我已经在后端处理了跨域&#xff0c;还是一直会出现跨域错误。而且其它请求都可以正常处理跨域&#…

微软.NET6开发的C#特性——接口和属性

我是荔园微风&#xff0c;作为一名在IT界整整25年的老兵&#xff0c;看到不少初学者在学习编程语言的过程中如此的痛苦&#xff0c;我决定做点什么&#xff0c;下面我就重点讲讲微软.NET6开发人员需要知道的C#特性。 C#经历了多年发展&#xff0c; 进行了多次重大创新&#xf…

如何利用IP定位技术锁定网络攻击者

在当今高度互联的数字世界中&#xff0c;网络安全威胁日益猖獗。为了维护网络空间的安全与稳定&#xff0c;追踪并锁定网络攻击者成为了关键一环。而IP定位技术&#xff0c;作为一种重要的追踪手段&#xff0c;正发挥着越来越重要的作用。 IP定位技术&#xff0c;简而言之&…

软考 系统分析师系列知识点之信息系统战略规划方法(3)

接前一篇文章&#xff1a;软考 系统分析师系列知识点之信息系统战略规划方法&#xff08;2&#xff09; 所属章节&#xff1a; 第7章. 企业信息化战略与实施 第4节. 信息系统战略规划方法 7.4.1 企业系统规划法 7. 确定管理部门对系统的要求 BSP的出发点是管理部门对系统的要…

机器学习--K-近邻算法常见的几种距离算法详解

文章目录 距离度量1 欧式距离(Euclidean Distance)2 曼哈顿距离(Manhattan Distance)3 切比雪夫距离 (Chebyshev Distance)4 闵可夫斯基距离(Minkowski Distance)5 标准化欧氏距离 (Standardized EuclideanDistance)6 余弦距离(Cosine Distance)7 汉明距离(Hamming Distance)【…

后端创建订单

package com.java1234.entity;import io.jsonwebtoken.Claims;/*** jwt验证信息* author java1234_小锋* site www.java1234.com* company Java知识分享网* create 2019-08-13 上午 10:00*/ public class CheckResult {private int errCode;private boolean success;private Cl…