观察者模式实战:Spring Boot中联动更新机制的优雅实现

引言

在许多应用系统中,我们经常需要处理多个表之间的关联更新问题。例如,在教育管理系统中,当学生的基本信息表中的年龄字段发生更改时,我们可能还需要同步更新学生档案表和学生成绩表中的相关信息。本文将通过一个具体的案例,介绍如何在Spring Boot项目中利用观察者模式来优雅地解决这一需求。

观察者模式简介

观察者模式(Observer Pattern)是一种软件设计模式,它定义了对象之间的一种一对多依赖关系,以便当一个对象的状态发生改变时,所有依赖于它的对象都将得到通知并自动更新。在Spring框架中,观察者模式通常通过事件驱动的方式实现。

案例背景

假设我们有一个教育管理系统的Spring Boot项目,其中包含三个主要的数据表:

  • students 表:存储学生的个人信息,包括年龄等。
  • student_records 表:存储学生的档案信息。
  • student_scores 表:存储学生的成绩信息。

我们的目标是在students表中学生的年龄字段发生变更时,能够自动触发student_recordsstudent_scores表中对应记录的更新。

技术栈

  • Java 11
  • Spring Boot 2.x
  • Spring Data JPA

实现步骤

步骤 1: 定义事件

首先,我们需要定义一个事件类,用于表示学生年龄的更新。

 

Java

深色版本

1import org.springframework.context.ApplicationEvent;
2
3public class StudentAgeUpdateEvent extends ApplicationEvent {
4
5    private static final long serialVersionUID = 1L;
6
7    private final Long studentId;
8    private final int newAge;
9
10    public StudentAgeUpdateEvent(Object source, Long studentId, int newAge) {
11        super(source);
12        this.studentId = studentId;
13        this.newAge = newAge;
14    }
15
16    public Long getStudentId() {
17        return studentId;
18    }
19
20    public int getNewAge() {
21        return newAge;
22    }
23}

步骤 2: 创建监听器

接下来,我们需要创建两个监听器类,分别用于监听StudentAgeUpdateEvent事件,并在事件发生时更新学生档案表和学生成绩表。

 

Java

深色版本

1import org.springframework.context.ApplicationListener;
2import org.springframework.stereotype.Component;
3
4@Component
5public class StudentRecordUpdater implements ApplicationListener<StudentAgeUpdateEvent> {
6
7    private final StudentRecordRepository studentRecordRepository;
8
9    public StudentRecordUpdater(StudentRecordRepository studentRecordRepository) {
10        this.studentRecordRepository = studentRecordRepository;
11    }
12
13    @Override
14    public void onApplicationEvent(StudentAgeUpdateEvent event) {
15        Long studentId = event.getStudentId();
16        int newAge = event.getNewAge();
17        // 更新学生档案表
18        studentRecordRepository.updateAge(studentId, newAge);
19    }
20}
 

Java

深色版本

1import org.springframework.context.ApplicationListener;
2import org.springframework.stereotype.Component;
3
4@Component
5public class StudentScoreUpdater implements ApplicationListener<StudentAgeUpdateEvent> {
6
7    private final StudentScoreRepository studentScoreRepository;
8
9    public StudentScoreUpdater(StudentScoreRepository studentScoreRepository) {
10        this.studentScoreRepository = studentScoreRepository;
11    }
12
13    @Override
14    public void onApplicationEvent(StudentAgeUpdateEvent event) {
15        Long studentId = event.getStudentId();
16        int newAge = event.getNewAge();
17        // 更新学生成绩表
18        studentScoreRepository.updateAge(studentId, newAge);
19    }
20}

步骤 3: 发布事件

在学生服务层中,我们需要在年龄字段更新后发布StudentAgeUpdateEvent事件。

 

Java

深色版本

1import org.springframework.beans.factory.annotation.Autowired;
2import org.springframework.context.ApplicationEventPublisher;
3import org.springframework.stereotype.Service;
4
5@Service
6public class StudentService {
7
8    private final ApplicationEventPublisher eventPublisher;
9
10    @Autowired
11    public StudentService(ApplicationEventPublisher eventPublisher) {
12        this.eventPublisher = eventPublisher;
13    }
14
15    public void updateStudentAge(Long studentId, int newAge) {
16        // 更新学生表中的年龄
17        // ...
18        
19        // 发布事件
20        eventPublisher.publishEvent(new StudentAgeUpdateEvent(this, studentId, newAge));
21    }
22}

步骤 4: 事务管理

为了确保数据的一致性和完整性,我们还需要在StudentService中添加@Transactional注解,以确保所有的更新操作在一个事务中执行。

 

Java

深色版本

1import org.springframework.transaction.annotation.Transactional;
2import org.springframework.beans.factory.annotation.Autowired;
3import org.springframework.context.ApplicationEventPublisher;
4import org.springframework.stereotype.Service;
5
6@Service
7@Transactional
8public class StudentService {
9
10    // ... 其他代码保持不变
11}

总结

通过上述步骤,我们成功地实现了当学生表中的年龄字段更新时,自动同步更新学生档案表和学生成绩表的功能。这种方法不仅简化了代码,提高了系统的可维护性,还充分利用了Spring框架提供的事件机制和事务管理能力。


请确保你的项目已经正确配置了Spring Boot的事件发布和监听机制,以及Spring Data JPA的实体映射和仓库接口。此外,对于生产环境,建议进行更详尽的错误处理和日志记录,以增强系统的健壮性和可调试性。

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

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

相关文章

独立游戏《星尘异变》UE5 C++程序开发日志6——实现存档和基础设置系统

目录 一、存档类 1.创建一个SaveGame类 2.存储关卡内数据 3.加载关卡数据 4.关于定时器 5.存储全局数据 6.加载全局数据 二、存档栏 1.存档栏的数据结构 2.创建新存档 3.覆盖已有存档 4.删除存档 三、游戏的基础设置 1.存储游戏设置的数据结构 2.初始化设置 3.…

在国产芯片上实现YOLOv5/v8图像AI识别-【1.3】YOLOv5的介绍及使用(训练、导出)更多内容见视频

本专栏主要是提供一种国产化图像识别的解决方案&#xff0c;专栏中实现了YOLOv5/v8在国产化芯片上的使用部署&#xff0c;并可以实现网页端实时查看。根据自己的具体需求可以直接产品化部署使用。 B站配套视频&#xff1a;https://www.bilibili.com/video/BV1or421T74f 数据…

5.5 软件工程-系统测试

系统测试 - 意义和目的 系统测试 - 原则 系统测试 - 测试过程 系统测试 - 测试策略 系统测试 - 测试方法 真题 系统测试 - 测试用例设计 黑盒测试 白盒测试 真题 系统测试 - 调试 系统测试 - 软件度量 真题

Linux输出重定向详解

在 Linux 中&#xff0c;输出重定向是将命令的输出&#xff08;标准输出或错误输出&#xff09;重定向到文件或其他位置的过程。常见的重定向符号包括 >、>>、2> 和 &>。以下是一些常用的输出重定向操作示例&#xff1a; 标准输出重定向 使用 > 符号将命…

vue 实现打字机效果

打字机效果组件&#xff0c;支持像打字机一样模仿键入文本。支持vue 插值语法和表格等打印 ps: 灵感来着于vue-type-writer 但是 这个组件过于简单 就自己整了一个 一、预览 二、代码 组件&#xff1a; <template><div :style"{ visibility: visibility }&qu…

AI 模型本地推理 - YYPOLOE - Python - Windows - GPU - 吸烟检测(目标检测)- 有配套资源直接上手实现

Python 运行 - GPU 推理 - windows 环境准备python 代码 环境准备 FastDeploy预编译库下载 conda config --add channels conda-forge && conda install cudatoolkit11.2 cudnn8.2 pip install fastdeploy_gpu_python-0.0.0-cp38-cp38-win_amd64.whlpython 代码 impo…

虚拟机的状态更新

文章目录 虚拟机的更新一、检查虚拟机的配置1.已连接状态2. 保证镜像源挂载 二、进行更新三、其余事项 虚拟机的更新 虚拟机的更新是确保系统软件包和库的更新&#xff0c;以获得最新的修复和改进&#xff1b;如果长期没有打开单机或者集群&#xff0c;可以考虑先进行一次更新…

Artix7系列FPGA实现SDI视频编解码,基于GTP高速接口,提供3套工程源码和技术支持

目录 1、前言工程概述免责声明 2、相关方案推荐本博已有的 SDI 编解码方案本方案在Xilinx--Kintex系列FPGA上的应用本方案在Xilinx--Zynq系列FPGA上的应用 3、详细设计方案设计原理框图SDI 输入设备Gv8601a 均衡器GTP 高速接口-->解串与串化SMPTE SD/HD/3G SDI IP核BT1120转…

微软Edge浏览器全解析教程

微软Edge浏览器全解析教程 微软Edge浏览器&#xff0c;作为微软公司精心打造的一款现代化网页浏览器&#xff0c;自其首次发布以来&#xff0c;凭借其卓越的性能、出色的用户体验和不断迭代的功能&#xff0c;赢得了广大用户的青睐。本文将全面解析微软Edge浏览器的各个方面&a…

Docker容器下安装Matlab,无需挂载

Matlab的安装需要这些文件 传入ubuntu后&#xff0c;改过相关的文件权限后&#xff0c;发现还是无法挂载 这有可能是docker的安全管理策略导致容器不能挂载&#xff0c;因此采用不挂载形式&#xff0c;直接解压的方式安装Matlab 1.将iso改成zip&#xff0c;并解压 2.解压rar文件…

电机泵盖机器人打磨去毛刺,选德国进口高精度主轴

机器人打磨去毛刺该如何选择主轴呢&#xff1f;首先我们需要考虑的是工件的材质&#xff0c;电机泵盖通常使用铸铁、不锈钢、合金钢等金属材质&#xff0c;因此这类保持的硬度较高&#xff0c;一般会选择功率、扭矩较大的德国进口高精度主轴Kasite 4060 ER-S。 Kasite 4060 ER-…

设计分享—国外网站设计赏析

今天还是给大家分享一些国外的网站设计案例&#xff5e; 蓝蓝设计是一家专注而深入的界面设计公司&#xff0c;为期望卓越的国内外企业提供卓越的大数据可视化界面设计、B端界面设计、桌面端界面设计、APP界面设计、图标定制、用户体验设计、交互设计、UI咨询、高端网站设计、平…

JVM和类加载机制-01[JVM底层架构和JVM调优]

JVM底层 Java虚拟机内存模型JVM组成部分五大内存区域各自的作用虚拟机栈(线程栈)栈帧内存区域 本地方法栈程序计数器为什么jvm要设计程序计数器&#xff1f; 堆方法区 JVM优化-堆详解JVM底层垃圾回收机制jvm调优工具jvisualvm.exeArthas工具使用 Java虚拟机内存模型 JVM跨平台原…

Java中的ArrayList和LinkedList有什么区别?

Java中的ArrayList和LinkedList是两种常用的集合实现类&#xff0c;它们都属于Java集合框架的一部分&#xff0c;但它们在内部实现、性能特点、使用场景等方面存在明显的区别。以下是对这两种集合的详细比较&#xff1a; 1. 数据结构差异 ArrayList&#xff1a;ArrayList是动…

SpringBoot之全局异常处理

默认情况下的异常现象 创建一个接口 &#xff08;接口需要传递参数key&#xff09; RestController RequestMapping("/exception") public class ExceptionController {GetMapping("/accept")public String acceptKey(RequestParam("key") Str…

C语言第5天作业 7月16日

目录 1.求1000以内所有的质数。 2.有1、2、3、4个数字&#xff0c;能组成多少个互不相同且无重复数字的三位数&#xff1f;都是多少&#xff1f; 3.猴子吃桃问题 4.判断最大值 1.求1000以内所有的质数。 质数&#xff1a;只能够1和它本身整除 #include <stdio.h> in…

Camera Raw:首选项

Camera Raw 首选项 Preferences提供了丰富的配置选项&#xff0c;通过合理设置&#xff0c;可以显著提升图像处理的效率和效果。根据个人需求调整这些选项&#xff0c;有助于创建理想的工作环境和输出质量。 ◆ ◆ ◆ 打开 Camera Raw 首选项 方法一&#xff1a;在 Adobe Bri…

Linux系统学习日记——vim操作手册

Vim编辑器是linux下的一个命令行编辑器&#xff0c;类似于我们windows下的记事本。 目录 打开文件 编辑 保存退出 打开文件 打开 hello.c不存在也可以打开&#xff0c;保存时vim会自动创建。 效果 Vim打开时&#xff0c;处于命令模式&#xff0c;即执行命令的模式&#x…

VUE中setup()

在Vue中&#xff0c;setup() 函数是Vue 3.0及更高版本引入的一个重要特性&#xff0c;它是Composition API的入口点。setup() 函数用于初始化组件的状态和逻辑&#xff0c;包括定义响应式数据、方法和生命周期钩子。以下是关于setup() 函数的详细解释&#xff1a; 1. 作用与特…

解决IDEA 中出现已有类、函数找不到的情况

缓存导致部分索引失效&#xff0c;需要刷新缓存并重启idea即可 1、File > Invalidate Cache / Restart... 2、Invalidate and Restart