当前位置：网站首页>（13）Filter过滤器
（13）Filter过滤器
2022-08-09 14:55:00 【Tommey01】
8，使用 Filter 和 ThreadLocal 组合管理事务
- 8.1，使用 ThreadLocal 来确保所有 dao 操作都在同一个 Connection 连接对象中完成
- 8.2，使用 Filter 过滤器统一给所有的 Service 方法都加上 try-catch ，来进行实现的管理
- 8.3，将所有异常都统一交给 Tomcat ，让 Tomcat 展示友好的错误信息页面
Filter 是什么过滤器
1、Filter 过滤器它是 JavaWeb 的三大组件之一。三大组件分别是：Servlet 程序、Listener 监听器、Filter 过滤器
2、Filter 过滤器它是 JavaEE 的规范。也就是接口
3、Filter 过滤器它的作用是： 拦截请求，过滤响应。
拦截请求常见的应用场景有：
①、权限检查
②、日记操作
③、事务管理
……等等
Filter 的初体验
- Filter 的工作流程图：
Filter 过滤器的使用步骤：
1、编写一个类去实现 Filter 接口
2、实现过滤方法 doFilter()
3、到 web.xml 中去配置 Filter 的拦截路径
Filter 的代码：
public class AdminFilter implements Filter {
/** * doFilter 方法，专门用于拦截请求。可以做权限检查 */
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
HttpServletRequest httpServletRequest = (HttpServletRequest) servletRequest;
HttpSession session = httpServletRequest.getSession();
Object user = session.getAttribute("user");
// 如果等于 null ，说明还没有登录
if (user == null) {
servletRequest.getRequestDispatcher("/admin/a.html").forward(servletRequest,servletResponse);
return;
} else {
// 让程序继续往下访问用户的目标资源
filterChain.doFilter(servletRequest,servletResponse);
}
}
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
@Override
public void destroy() {
}
}
- web.xml 中的配置：
<!--filter 标签用于配置一个 Filter 过滤器 -->
<filter>
<!-- 给 filter 起一个别名 -->
<filter-name>AdminFilter</filter-name>
<!-- 配置 filter 的全类名 -->
<filter-class>com.AdminFilter</filter-class>
</filter>
<!--filter-mapping 配置 Filter 过滤器的拦截路径 -->
<filter-mapping>
<!--filter-name 表示当前的拦截路径给哪个 filter 使用 -->
<filter-name>AdminFilter</filter-name>
<!--url-pattern 配置拦截路径
/ 表示请求地址为： http://ip:port/ 工程路径 / 映射到 IDEA 的 web 目录
/admin/* 表示请求地址为： http://ip:port/ 工程路径 /admin/* --> <url-pattern>/admin/*</url-pattern> </filter-mapping> - a.html 页面 == 登录表单
<form action="http://localhost:8080/15_filter/loginServlet" method="get">
用户名：<input type="text" name="username"/> <br>
密 码：<input type="password" name="password"/> <br>
<input type="submit" />
</form>
- LoginServlet 程序
public class LoginServlet extends HttpServlet {
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
// 解决中文乱码问题
req.setCharacterEncoding("UTF-8");
resp.setContentType("text/html; charset=UTF-8");
String username = req.getParameter("username");
String password = req.getParameter("password");
if ("Tommey周".equals(username) && "123456".equals(password)) {
req.getSession().setAttribute("user",username);
resp.getWriter().write("登录成功");
} else {
req.getRequestDispatcher("/admin/a.html").forward(req,resp);
}
}
}
Filter 的生命周期
Filter 的生命周期包含几个方法
1、构造器方法
2、init 初始化方法
第 1，2 步，在 web 工程启动的时候执行（Filter 已经创建）3、doFilter 过滤方法
第 3 步，每次拦截到请求，就会执行4、destroy 销毁
第 4 步，停止 web 工程的时候，就会执行（停止 web 工程，也会销毁 Filter 过滤器）
FilterConfig 类
FilterConfig 类见名知义，它是 Filter 过滤器的配置文件类。
Tomcat 每次创建 Filter 的时候，也会同时创建一个 FilterConfig 类，这里包含了 Filter 配置文件的配置信息。
FilterConfig 类的作用是获取 filter 过滤器的配置内容
1、获取 Filter 的名称 filter-name 的内容
2、获取在 Filter 中配置的 init-param 初始化参数
3、获取 ServletContext 对象
java 代码：
public class AdminFilter implements Filter {
@Override
public void init(FilterConfig filterConfig) throws ServletException {
System.out.println("Filter 的 的 init(FilterConfig filterConfig) 初始化");
// 1 、获取 Filter 的名称 filter-name 的内容
System.out.println("filter-name 的值是：" + filterConfig.getFilterName());
// 2 、获取在 web.xml 中配置的 init-param 初始化参数
System.out.println(" 初始化参数 username 的值是 ：" + filterConfig.getInitParameter("username"));
System.out.println(" 初始化参数 url 的值是：" + filterConfig.getInitParameter("url"));
// 3 、获取 ServletContext 对象
System.out.println(filterConfig.getServletContext());
}
- web.xml代码：
<!--filter 标签用于配置一个 Filter 过滤器 -->
<filter>
<!-- 给 filter 起一个别名 -->
<filter-name>AdminFilter</filter-name>
<!-- 配置 filter 的全类名 -->
<filter-class>com.AdminFilter</filter-class>
<init-param>
<param-name>username</param-name>
<param-value>root</param-value>
</init-param>
<init-param>
<param-name>url</param-name>
<param-value>jdbc:mysql://localhost3306/test</param-value>
</init-param>
</filter>
FilterChain 过滤器链
- Filter ========》过滤器
- Chain =======》链，链条
- FilterChain ===》 就是过滤器链（多个过滤器如何一起工作）
多个Filter过滤器执行的特点：
1，所有Filter和目标资源默认执行在同一个线程中
2，多个Filter共同执行的时候，它们都使用同一个Request对象
FilterChain.doFilter()方法的作用
1，执行下一个Filter过滤器（如果有Filter）
2，执行目标资源（没有Filter）
在多个Filter过滤器执行的时候，他们执行的优先顺序是由他们在web.xml中从上到下配置的顺序决定的
Filter 的拦截路径
精确匹配
<url-pattern>/target.jsp</url-pattern>，配置的路径表示请求地址必须为：http://ip:port/工程路径/target.jsp目录匹配
<url-pattern>/admin/*</url-pattern>，配置的路径表示请求地址必须为：http://ip:port/工程路径/admin/*后缀名匹配
<url-pattern>*.html</url-pattern>，配置的路径表示请求地址必须以.html 结尾才会拦截到<url-pattern>*.do</url-pattern>，配置的路径表示请求地址必须以.do 结尾才会拦截到<url-pattern>*.action</url-pattern>，配置的路径表示请求地址必须以.action 结尾才会拦截到Filter 过滤器它只关心请求的地址是否匹配，不关心请求的资源是否存在
ThreadLocal 的使用
ThreadLocal 的作用，它可以解决多线程的数据安全问题。
ThreadLocal 它可以给当前线程关联一个数据（可以是普通变量，可以是对象，也可以是数组，集合）
ThreadLocal 的特点：
1、ThreadLocal 可以为当前线程关联一个数据。（它可以像 Map 一样存取数据，key 为当前线程）
2、每一个 ThreadLocal 对象，只能为当前线程关联一个数据，如果要为当前线程关联多个数据，就需要使用多个
ThreadLocal 对象实例。3、每个 ThreadLocal 对象实例定义的时候，一般都是 static 类型
4、ThreadLocal 中保存数据，在线程销毁后。会由 JVM 虚拟自动释放。
示例代码：
ThreadLocalTest 类
public class ThreadLocalTest {
// public static Map<String,Object> data = new Hashtable<String,Object>();
public static ThreadLocal<Object> threadLocal = new ThreadLocal<Object>();
private static Random random = new Random();
public static class Task implements Runnable {
@Override
public void run() {
// 在 Run 方法中，随机生成一个变量（线程要关联的数据），然后以当前线程名为 key 保存到 map 中
Integer i = random.nextInt(1000);
// 获取当前线程名
String name = Thread.currentThread().getName();
System.out.println(" 线程[" + name + "] 生成的随机数是：" + i);
// data.put(name,i);
threadLocal.set(i);
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
new OrderService().createOrder();
// 在 Run 方法结束之前，以当前线程名获取出数据并打印。查看是否可以取出操作
// Object o = data.get(name);
Object o = threadLocal.get();
System.out.println(" 在线程[" + name + "] 快结束时取出关联的数据是：" + o);
}
}
public static void main(String[] args) {
for (int i = 0; i < 3; i++) {
new Thread(new Task()).start();
}
}
}
- OrderService 类：
public class OrderService {
public void createOrder() {
String name = Thread.currentThread().getName();
System.out.println("OrderService 当前线程[" + name + "] 中保存的数据是：" +
ThreadLocalTest.threadLocal.get());
new OrderDao().saveOrder();
}
}
- OrderDao 类：
public class OrderDao {
public void saveOrder() {
String name = Thread.currentThread().getName();
System.out.println("OrderDao 当前线程[" + name + "] 中保存的数据是：" +
ThreadLocalTest.threadLocal.get());
}
}
使用 Filter 和 ThreadLocal 组合管理事务
- 原理分析图：
- JdbcUtils工具类的修改：
public class JdbcUtils {
private static DruidDataSource dataSource;
private static ThreadLocal<Connection> conns = new ThreadLocal<Connection>();
static {
try {
Properties properties = new Properties();
// 读取 jdbc.properties 属性配置文件
InputStream inputStream = JdbcUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
// 从流中加载数据
properties.load(inputStream);
// 创建 数据库连接 池
dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(properties);
} catch (Exception e) {
e.printStackTrace();
}
}
/** * 获取数据库连接池中的连接 * * @return 如果返回 null, 说明获取连接失败 <br/> 有值就是获取连接成功 */
public static Connection getConnection() {
Connection conn = conns.get();
if (conn == null) {
try {
conn = dataSource.getConnection();// 从数据库连接池中获取连接
conns.set(conn); // 保存到 ThreadLocal 对象中，供后面的 jdbc 操作使用
conn.setAutoCommit(false); // 设置为手动管理事务
} catch (SQLException e) {
e.printStackTrace();
}
}
return conn;
}
/** * 提交事务，并关闭释放连接 */
public static void commitAndClose() {
Connection connection = conns.get();
if (connection != null) {
// 如果不等于 null ，说明 之前使用过连接，操作过数据库
try {
connection.commit(); // 提交 事务
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
connection.close(); // 关闭连接，资源资源
} catch (SQLException e) {
e.printStackTrace();
}
}
}
// 一定要执行 remove 操作，否则就会出错。（因为 Tomcat 服务器底层使用了线程池技术）
conns.remove();
}
/** * 回滚事务，并关闭释放连接 */
public static void rollbackAndClose() {
Connection connection = conns.get();
if (connection != null) {
// 如果不等于 null ，说明 之前使用过连接，操作过数据库
try {
connection.rollback();// 回滚事务
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
connection.close(); // 关闭连接，资源资源
} catch (SQLException e) {
e.printStackTrace();
}
}
}
// 一定要执行 remove 操作，否则就会出错。（因为 Tomcat 服务器底层使用了线程池技术）
conns.remove();
}
/** * 关闭连接，放回数据库连接池 * @param conn */
public static void close(Connection conn) {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
- 原理分析图：
- Filter 类代码：
public class TransactionFilter implements Filter {
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
try {
filterChain.doFilter(servletRequest,servletResponse);
JdbcUtils.commitAndClose();// 提交事务
} catch (Exception e) {
JdbcUtils.rollbackAndClose();// 回滚事务
e.printStackTrace();
}
}
@Override
public void destroy() {
}
}
- 在 web.xml 中的配置：
<filter>
<filter-name>TransactionFilter</filter-name>
<filter-class>com.TransactionFilter</filter-class>
</filter>
<filter-mapping>
<filter-name>TransactionFilter</filter-name>
<!-- /* 表示当前工程下所有请求 --> <url-pattern>/*</url-pattern> </filter-mapping> - 把 BaseServlet 中的异常往外抛给 Filter 过滤器
public abstract class BaseServlet extends HttpServlet {
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
doPost(req, resp);
}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
// 解决 post 请求中文乱码问题
// 一定要在获取请求参数之前调用才有效
req.setCharacterEncoding("UTF-8");
String action = req.getParameter("action");
try {
// 获取 action 业务鉴别字符串，获取相应的业务 方法反射对象
Method method = this.getClass().getDeclaredMethod(action, HttpServletRequest.class, HttpServletResponse.class);
System.out.println(method);
// 调用目标业务 方法
method.invoke(this, req, resp);
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException(e);// 把异常抛给 Filter 过滤器
}
}
}
- 在 web.xml 中我们可以通过错误页面配置来进行管理
<!--error-page 标签配置，服务器出错之后，自动跳转的页面 -->
<error-page>
<!--error-code 是错误类型 -->
<error-code>500</error-code>
<!--location 标签表示。要跳转去的页面路径 -->
<location>/pages/error/error500.jsp</location>
</error-page>
<!--error-page 标签配置，服务器出错之后，自动跳转的页面 -->
<error-page>
<!--error-code 是错误类型 -->
<error-code>404</error-code>
<!--location 标签表示。要跳转去的页面路径 -->
<location>/pages/error/error404.jsp</location>
</error-page>
边栏推荐
- 文件操作的实例——下载并合并流式视频文件
- VS2010：出现devenv.sln解决方案保存对话框
- 什么是链游？小白必看！A3
- What is an index in MySql?What kinds of indexes are commonly used?When does an index fail?
- pytorch从零搭建神经网络实现多分类(训练自己的数据集)
- focal loss原理及简单代码实现
- How to achieve long-term benefits through the Tongdaxin quantitative trading interface?
- Qt control - QTextEdit usage record
- NetCore 5.0连接MySql
- Sequelize配置中的timezone测试
猜你喜欢
小型项目如何使用异步任务管理器实现不同业务间的解耦
【小白必看】初始C语言(上)
It is deeply recognized that the compiler can cause differences in the compilation results
Use tensorboard remotely on the server
在服务器上远程使用tensorboard
Common compilation problems
PHP开源 | ysKit(ys工具包) - 微型Web框架
pytorch从零搭建神经网络实现多分类(训练自己的数据集)
Introduction to OpenCV and build the environment
focal loss原理及简单代码实现
随机推荐
LNK1123:转换到COFF期间失败：文件无效或损坏
如何防止浏览器指纹关联
Noun concept summary (not regularly updated ~ ~)
走得通，看得见！你的交通“好帮手”
Several important functional operations of general two-way circular list
.Net Core 技巧小结
For programming trading, focusing on forecast or on countermeasures?
复数与复数域
MIUI12.1.5安装google App store，无需ROOT，不闪退
CV复习：BatchNorm
个人域名备案详细流程（图文并茂）
二叉排序树的左旋与右旋
What is a template engine?What are the common template engines?Introduction to common commands of thymeleaf.
编译器不同，模式不同，对结果的影响
A shortcut method for writing menu commands in C
浏览器中的302你真的知道吗
VS2010：出现devenv.sln解决方案保存对话框
函数调用约定
【C语言初阶】求最小公倍数的三种方法
cropperjs裁剪上传头像使用方法