基于Springboot外卖系统10:公共字段填充功能+ThreadLocal模块改进

简介: 在新增员工时需要设置创建时间、创建人、修改时间、修改人等字段,在编辑员工时需要设置修改时间、修改人等字段。这些字段属于公共字段,也就是也就是在系统中很多表中都会有这些字段

1. 公共字段自动填充


1.1 问题分析


在新增员工时需要设置创建时间、创建人、修改时间、修改人等字段,在编辑员工时需要设置修改时间、修改人等字段。这些字段属于公共字段,也就是也就是在系统中很多表中都会有这些字段,如下:


41d2a6a14425403dbb3fac06819bcfe1.png


而针对于这些字段的赋值方式为:


A. 在新增数据时, 将createTime、updateTime 设置为当前时间, createUser、updateUser设置为当前登录用户ID。


B. 在更新数据时, 将updateTime 设置为当前时间, updateUser设置为当前登录用户ID。


目前,在项目中处理这些字段都是在每一个业务方法中进行赋值操作,如下


6211f5ecf7e24f7298291354c3fffd28.png


d3bae131f10148af9f1682112f4acfc4.png


如果都按照上述的操作方式来处理这些公共字段, 需要在每一个业务方法中进行操作, 编码相对冗余、繁琐。


改进:使用Mybatis Plus提供的公共字段自动填充功能来简化开发。


1.2 基本功能实现


1.2.1 思路分析


Mybatis Plus公共字段自动填充,即在插入或者更新的时候为指定字段赋予指定的值,好处统一对这些字段进行处理,避免了重复代码。在上述的问题分析中,有四个公共字段需要在新增/更新中进行赋值操作, 具体情况如下:


字段名 赋值时机 说明
createTime 插入(INSERT) 当前时间
updateTime 插入(INSERT) , 更新(UPDATE) 当前时间
createUser 插入(INSERT) 当前登录用户ID
updateUser 插入(INSERT) , 更新(UPDATE)


实现步骤:


1、在实体类的属性上加入@TableField注解,指定自动填充的策略。


2、按照框架要求编写元数据对象处理器,在此类中统一为公共字段赋值,此类需要实现MetaObjectHandler接口。


1.3 代码实现


1). 实体类的属性上加入@TableField注解,指定自动填充的策略。


在员工Employee实体类的公共字段属性上, 加上注解, 指定填充策略。


package com.itheima.reggie.entity;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
/**@Description: 员工实体类 该实体类主要用于和员工表 employee 进行映射。
 * @version v1.0
 * @author LiBiGo
 * @date 2022/8/12 11:05
 */
// 在实体类上添加@Data注解,可以省去代码中大量的 get()、 set()、 toString() 等方法,提高代码的简洁:
@Data
public class Employee implements Serializable {
    private static final long serialVersionUID = 1L;
    private Long id;
    private String username;
    private String name;
    private String password;
    private String phone;
    private String sex;
    // map-underscore-to-camel-case: true
    // 在映射实体或者属性时,将数据库中表名和字段名中的下划线去掉,按照驼峰命名法映射
    private String idNumber; //身份证 因为在配置文件中设置驼峰命名,所以与数据库中的不太一样,数据库中为id_number
    private Integer status;
    @TableField(fill = FieldFill.INSERT) // 插入时填充该属性值
    private LocalDateTime createTime; // 同上 驼峰命名法
    @TableField(fill = FieldFill.INSERT_UPDATE) //插入、更新时填充该属性值
    private LocalDateTime updateTime;   // 同上 驼峰命名法
    @TableField(fill = FieldFill.INSERT)
    private Long createUser;
    @TableField(fill = FieldFill.INSERT_UPDATE) //插入和更新时填充
    private Long updateUser;
}


2). 按照框架要求编写元数据对象处理器,在此类中统一为公共字段赋值,此类需要实现MetaObjectHandler接口。


package com.itheima.reggie.common;
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
/**
 * Description: 自定义元数据对象处理器|统一为公共字段赋值,此类需要实现MetaObjectHandler接口。
 * @author w
 * @version 1.0
 * @date 2022/8/15 12:05
 */
@Component
@Slf4j
public class MyMetaObjecthandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        /**@Description: 插入操作自动填充
         * @version v1.0
         * @author LiBiGo
         * @date 2022/8/15 12:14
         */
        log.info("公共字段自动填充insert...");
        log.info(metaObject.toString());
        metaObject.setValue("createTime", LocalDateTime.now());
        metaObject.setValue("updateTime", LocalDateTime.now());
        metaObject.setValue("createUser", BaseContext.getCurrentId()); // 使用了Thread 看后续
        metaObject.setValue("updateUser", BaseContext.getCurrentId());
    }
    @Override
    public void updateFill(MetaObject metaObject) {
        /**@Description: 更新操作自动填充
         * @version v1.0
         * @author LiBiGo
         * @date 2022/8/15 12:14
         */
        log.info("公共字段自动填充update...");
        log.info(metaObject.toString());
        long id = Thread.currentThread().getId();
        log.info("线程ID:{}",id);
        metaObject.setValue("updateTime", LocalDateTime.now());
        metaObject.setValue("updateUser", BaseContext.getCurrentId());
    }
}


2 使用ThreadLocal对公共字段填充功能进行完善


2.1 思路分析


2.1.1 提出设想


前面已经完成公共字段自动填充功能的代码开发,但是还有一个问题没有解决,就是在自动填充createUser和updateUser时设置的用户id是固定值,现在需要改造成动态获取当前登录用户的id。


提出设想:用户登录成功后将用户id存入了HttpSession中,现在从HttpSession中获取不就行了?


857e335a15164b9daf73a17129d31611.png


存在问题:在MyMetaObjectHandler类中是不能直接获得HttpSession对象的,所以需要通过其他方式来获取登录用户id。


2.1.2 分析问题


在修改员工信息时, 业务的执行流程如下图:


32f0877e27e64238b3013c79be2e6c26.png


客户端发送的每次http请求,对应的在服务端都会分配一个新的线程来处理,在处理过程中涉及到下面类中的方法都属于相同的一个线程:


1). LoginCheckFilter的doFilter方法


2). EmployeeController的update方法


3). MyMetaObjectHandler的updateFill方法


我们可以在上述类的方法中加入如下代码(获取当前线程ID,并输出):


long id = Thread.currentThread().getId();
log.info("线程id为:{}",id);


执行编辑员工功能进行验证,通过观察控制台输出可以发现,一次请求对应的线程id是相同的:


433bf9f7dd834e8a91168f02ff794cb9.png


经过上述的分析之后,发现可以使用JDK提供的一个ThreadLocal类来解决此问题。


2.2 ThreadLocal


2.2.1 ThreadLocal基本概述


ThreadLocal并不是一个Thread,而是Thread的局部变量。


当使用ThreadLocal维护变量时,ThreadLocal为每个使用该变量的线程提供独立的变量副本,所以每一个线程都可以独立地改变自己的副本,而不会影响其它线程所对应的副本。


ThreadLocal为每个线程提供单独一份存储空间,具有线程隔离的效果,只有在线程内才能获取到对应的值,线程外则不能访问当前线程对应的值。


2.2.2 ThreadLocal常用方法


A. public void set(T value) : 设置当前线程的线程局部变量的值


B. public T get() : 返回当前线程所对应的线程局部变量的值


C. public void remove() : 删除当前线程所对应的线程局部变量的值


我们可以在LoginCheckFilter的doFilter方法中获取当前登录用户id,并调用ThreadLocal的set方法来设置当前线程的线程局部变量的值(用户id),然后在MyMetaObjectHandler的updateFill方法中调用ThreadLocal的get方法来获得当前线程所对应的线程局部变量的值(用户id)。 如果在后续的操作中, 我们需要在Controller / Service中要使用当前登录用户的ID, 可以直接从ThreadLocal直接获取。


2.3 操作步骤


1). 编写BaseContext工具类,基于ThreadLocal封装的工具类


2). 在LoginCheckFilter的doFilter方法中调用BaseContext来设置当前登录用户的id


3). 在MyMetaObjectHandler的方法中调用BaseContext获取登录用户的id


2.4 代码实现


1). BaseContext工具类


package com.itheima.reggie.common;
/**
 * Description: 基于ThreadLocal封装工具类,用户保存和获取当前登陆用户ID
 * @date 2022/8/15 12:40
 */
public class BaseContext {
    private static ThreadLocal<Long> threadLocal = new ThreadLocal<>();
    /**
     * 设置值
     * @param id
     */
    public static void setCurrentId(Long id){
        threadLocal.set(id);
    }
    /**
     * 获取值
     * @return
     */
    public static Long getCurrentId(){
        return threadLocal.get();
    }
}


2).LoginCheckFilter中存放当前登录用户到ThreadLocal


在doFilter方法中, 判定用户是否登录, 如果用户登录, 在放行之前, 获取HttpSession中的登录用户信息, 调用BaseContext的setCurrentId方法将当前登录用户ID存入ThreadLocal。


package com.itheima.reggie.filter;
import com.alibaba.fastjson.JSON;
import com.itheima.reggie.common.BaseContext;
import com.itheima.reggie.common.R;
import lombok.extern.slf4j.Slf4j;
import org.springframework.util.AntPathMatcher;
import javax.servlet.*;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
/**
 * Description: 检查用户是否已经完成登陆
 */
@WebFilter(filterName = "LoginCheckFilter",urlPatterns = "/*")  //设置拦截器,设置拦截的网页区域
@Slf4j
public class LoginCheckFilter implements Filter {
    // 路径匹配器,支持通配符,因为下面的序列使用了通配符
    // AntPathMatcher匹配规则  ? 匹配一个字符    * 匹配0个或多个字符   ** 匹配0个或多个目录/字符
    public static final AntPathMatcher PATH_MATCHER = new AntPathMatcher();
    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        HttpServletRequest request = (HttpServletRequest)servletRequest;
        HttpServletResponse response = (HttpServletResponse)servletResponse;
        //  A. 获取本次请求的URI
        String requestURI = request.getRequestURI();
        log.info("拦截的请求:{}",requestURI);
        // 定义不拦截的序列,只拦截页面数据请求,不拦截页面格式
        String[] urls = new String[]{
                "/employee/login",
                "/employee/logout",
                "/backend/**",
                "/front/**"
        };
        //  B. 判断本次请求, 是否需要登录, 才可以访问
        boolean check = check(urls, requestURI);
        //  C. 如果不需要,则直接放行
        if(check){
            log.info("本次请求{}不需要处理",requestURI);
            filterChain.doFilter(request,response);
            return;
        }
        //  D. 判断登录状态,如果已登录,则直接放行
        if(request.getSession().getAttribute("employee")!=null){
            log.info("用户已登录,用户id为:{}",request.getSession().getAttribute("employee"));
            Long empId = (Long) request.getSession().getAttribute("employee"); // 获取当前用户登陆id
            BaseContext.setCurrentId(empId); //设置线程共享
            filterChain.doFilter(request,response); // 补课 不清楚????????????
            long id = Thread.currentThread().getId();
            log.info("检测是否登陆线程ID:{}",id);
            return;
        }
        //  E. 如果未登录, 则返回未登录结果
        response.getWriter().write(JSON.toJSONString(R.error("NOTLOGIN")));
        return;
    }
    public boolean check(String[] urls,String requestURI){
        /**@Description: 路径匹配,检查本次请求是否需要放行
         * @author LiBiGo
         * @date 2022/8/12 16:50
         */
        for (String url : urls) {
            boolean match = PATH_MATCHER.match(url, requestURI); // 使用通配符对象,配对资源
            if(match){
                return true;
            }
        }
        return false;
    }
}


3). MyMetaObjectHandler中从ThreadLocal中获取


将之前在代码中添加动态调用BaseContext中的getCurrentId方法获取当前登录用户ID


f2d4ee2f7baf4b56bb74a5bbe34d25c4.png


3 功能测试


编写完了元数据对象处理器之后,我们就可以将之前在新增和修改方法中手动赋值的代码删除或注释掉。



e0a6c1e682974d9883699a63ca18d62c.png


ce278de3e2a841538827815d0a3a20e8.png


完善了元数据对象处理器重新启动项目,完成登录操作后,在员工管理模块中,测试增加/更新员工信息功能,直接查询数据库数据变更,看看我们在新增/修改数据时,这些公共字段数据是否能够完成自动填充, 并且看看填充的create_user 及 update_user字段值是不是本地登录用户的ID。

目录
相关文章
|
3月前
|
JavaScript 前端开发 Java
垃圾分类管理系统基于 Spring Boot Vue 3 微服务架构实操指南
本文介绍了基于Java技术的垃圾分类管理系统开发方案与实施案例。系统采用前后端分离架构,后端使用Spring Boot框架搭配MySQL数据库,前端可选择Vue.js或Java Swing实现。核心功能模块包括垃圾分类查询、科普教育、回收预约等。文中提供了两个典型应用案例:彭湖花园小区使用的Swing桌面系统和基于Spring Boot+Vue的城市管理系统,分别满足不同场景需求。最新技术方案升级为微服务架构,整合Spring Cloud、Redis、Elasticsearch等技术,并采用Docker容器
191 0
|
4月前
|
JavaScript 前端开发 Java
制造业ERP源码,工厂ERP管理系统,前端框架:Vue,后端框架:SpringBoot
这是一套基于SpringBoot+Vue技术栈开发的ERP企业管理系统,采用Java语言与vscode工具。系统涵盖采购/销售、出入库、生产、品质管理等功能,整合客户与供应商数据,支持在线协同和业务全流程管控。同时提供主数据管理、权限控制、工作流审批、报表自定义及打印、在线报表开发和自定义表单功能,助力企业实现高效自动化管理,并通过UniAPP实现移动端支持,满足多场景应用需求。
421 1
|
5月前
|
前端开发 Java 关系型数据库
基于Java+Springboot+Vue开发的鲜花商城管理系统源码+运行
基于Java+Springboot+Vue开发的鲜花商城管理系统(前后端分离),这是一项为大学生课程设计作业而开发的项目。该系统旨在帮助大学生学习并掌握Java编程技能,同时锻炼他们的项目设计与开发能力。通过学习基于Java的鲜花商城管理系统项目,大学生可以在实践中学习和提升自己的能力,为以后的职业发展打下坚实基础。技术学习共同进步
408 7
|
5月前
|
存储 Java 数据库
Spring Boot 注册登录系统:问题总结与优化实践
在Spring Boot开发中,注册登录模块常面临数据库设计、密码加密、权限配置及用户体验等问题。本文以便利店销售系统为例,详细解析四大类问题:数据库字段约束(如默认值缺失)、密码加密(明文存储风险)、Spring Security配置(路径权限不当)以及表单交互(数据丢失与提示不足)。通过优化数据库结构、引入BCrypt加密、完善安全配置和改进用户交互,提供了一套全面的解决方案,助力开发者构建更 robust 的系统。
162 0
|
5月前
|
XML 前端开发 Java
SpringBoot实现文件上传下载功能
本文介绍了如何使用SpringBoot实现文件上传与下载功能,涵盖配置和代码实现。包括Maven依赖配置(如`spring-boot-starter-web`和`spring-boot-starter-thymeleaf`)、前端HTML页面设计、WebConfig路径映射配置、YAML文件路径设置,以及核心的文件上传(通过`MultipartFile`处理)和下载(利用`ResponseEntity`返回文件流)功能的Java代码实现。文章由Colorful_WP撰写,内容详实,适合开发者学习参考。
495 0
|
2月前
|
前端开发 Java API
酒店管理系统基于 JavaFX Spring Boot 和 React 经典项目重构实操
本文介绍了基于现代技术栈的酒店管理系统开发方案,整合了JavaFX、Spring Boot和React三大技术框架。系统采用前后端分离架构,JavaFX构建桌面客户端,React开发Web管理界面,Spring Boot提供RESTful API后端服务。核心功能模块包括客房管理和客户预订流程,文中提供了JavaFX实现的客房管理界面代码示例和React开发的预订组件代码,展示了如何实现客房信息展示、添加修改操作以及在线预订功能。
160 0
|
消息中间件 存储 Java
📨 Spring Boot 3 整合 MQ 构建聊天消息存储系统
本文详细介绍了如何使用Spring Boot 3结合RabbitMQ构建高效可靠的聊天消息存储系统。通过引入消息队列,实现了聊天功能与消息存储的解耦,解决了高并发场景下直接写入数据库带来的性能瓶颈问题。文章首先分析了不同MQ产品的特点及适用场景,最终选择RabbitMQ作为解决方案,因其成熟稳定、灵活路由和易于集成等优势。接着,通过Docker快速部署RabbitMQ,并完成Spring Boot项目的配置与代码实现,包括生产者发送消息、消费者接收并处理消息等功能。最后,通过异步存储机制,既保证了消息的即时性,又实现了可靠持久化。
361 0
📨 Spring Boot 3 整合 MQ 构建聊天消息存储系统
|
4月前
|
供应链 JavaScript BI
ERP系统源码,基于SpringBoot+Vue+ElementUI+UniAPP开发
这是一款专为小微企业打造的 SaaS ERP 管理系统,基于 SpringBoot+Vue+ElementUI+UniAPP 技术栈开发,帮助企业轻松上云。系统覆盖进销存、采购、销售、生产、财务、品质、OA 办公及 CRM 等核心功能,业务流程清晰且操作简便。支持二次开发与商用,提供自定义界面、审批流配置及灵活报表设计,助力企业高效管理与数字化转型。
428 2
ERP系统源码,基于SpringBoot+Vue+ElementUI+UniAPP开发
|
4月前
|
安全 Java API
Spring Boot 功能模块全解析:构建现代Java应用的技术图谱
Spring Boot不是一个单一的工具,而是一个由众多功能模块组成的生态系统。这些模块可以根据应用需求灵活组合,构建从简单的REST API到复杂的微服务系统,再到现代的AI驱动应用。
|
3月前
|
Java 调度 流计算
基于Java 17 + Spring Boot 3.2 + Flink 1.18的智慧实验室管理系统核心代码
这是一套基于Java 17、Spring Boot 3.2和Flink 1.18开发的智慧实验室管理系统核心代码。系统涵盖多协议设备接入(支持OPC UA、MQTT等12种工业协议)、实时异常检测(Flink流处理引擎实现设备状态监控)、强化学习调度(Q-Learning算法优化资源分配)、三维可视化(JavaFX与WebGL渲染实验室空间)、微服务架构(Spring Cloud构建分布式体系)及数据湖建设(Spark构建实验室数据仓库)。实际应用中,该系统显著提升了设备调度效率(响应时间从46分钟降至9秒)、设备利用率(从41%提升至89%),并大幅减少实验准备时间和维护成本。
250 0