当前位置：首页 > news >正文

KOI技术-事件驱动编程（Sping后端）

news 来源：原创 2025/7/20 21:49:45

请添加图片描述

1 “你日渐平庸，甘于平庸，将继续平庸。”——《以自己喜欢的方式过一生》
2. “总是有人要赢的，那为什么不能是我呢?”——科比·布莱恩特
3. “你那么憎恨那些人，和他们斗了那么久，最终却要变得和他们一样，人世间没有任何理想值得以这样的沉沦作为代价。”——马尔克斯《百年孤独》
4. “如果结果不如你所愿，就在尘埃落定前奋力一搏。”——《夏目友人帐》
5. “人有逆天之时，天无绝人之路。”——《醒世恒言》
6. “有些事不是看到了希望才去坚持，而是因为坚持才会看到希望。”——《十宗罪》
7. “维持现状意味着空耗你的努力和生命。”——纪伯伦

Spring * 事件驱动编程

一. 概念

事件驱动编程是面向事件的，不同于传统的基于顺序的编程，它旨在当事件发生时，再采用行动进行处理的一种编程范式。它使得程序以松耦合的方式进行粘合，实现部分解耦。

二. 主要解决的问题

1.代码的松耦合

将系统复杂的功能拆分为多个部分，每个部分抽象为一个组件，组件与组件之间通过良好定义的接口进行通信；那么他们之间通信的触发若采用引入（依赖）调用的方式，便使得类之间产生了强关系，属于功能耦合，若把他们之间调用的触发抽象为事件，就能降低、解除组件之间的耦合关系。

事件驱动模型，实际上是将组件之间的耦合关系转移到了“事件（Event）”上，但是对于某个领域而言事件（Event）一般具有通用性并且不会频繁变更实现逻辑，所以事件驱动模型可以很好地实现组件之间的解耦。

2.异步编程的需要（MQ 主要用于分布式）

业务场景中，顺序、阻塞式地执行任务会遇到一些比较耗时的中间步骤，但是不希望整个流程都停下来等待这些中间步骤完成，而是触发一个异步操作然后继续执行当前任务，在收到异步操作处理完成的消息之后再执行相关的处理。

使用事件驱动模型实现异步任务的一般思路是：当遇到耗时较大、没有同步执行要求的操作时，针对这个操作触发一个事件，将这个事件加入到任务队列中，直到有一个进程（线程）能够获取并执行这个任务，才开始执行这个任务。

这里大家可能会想到MQ，MQ不就是干这个的吗，对，它确实是做这个的，但是是想一下，我就是一个单机系统或者我是一个底层编程框架，为了实现解耦异步我就要引入MQ，是不是有点大材小用，强制上车的意思。所以：事件编程适用于小范围或者小场景需求，但在框架编程中大量使用。

3.状态模型（状态机，日志记录）

这个场景理解起来比较简单，但是处理这种场景的方式却很多。比如我们需要对实体状态的变更进行监控，（有没有想到禅道-项目管理中的最新动态），对请求的接口做一些日志记录，但日志有可能需要异步。这里大家可能会联想到AOP，确实在状态监控的实现上考虑到的简单方式就是切面变成，这里是想告诉大家，除了切面，事件驱动也可以实现。各有优劣。

三. 设计模式？

可能大家在查询资料或者学习过程中，会看到，事件编程或者状态管理时，会碰到设计模式中的 “观察者模式”，确实这个模式“很符合”这个场景，那问题来了，需要了解他吗？我的建议是需要，为啥？懂了它，手写一个高大上的模式在项目上，岂不是更好，对于理解底层架构来说，也提供了思路，岂不更好。

观察者模式是使用频率较高的设计模式之一。 定义对象间一种一对多的依赖关系，使得当每一个对象改变状态，则所有依赖于它的对象都会得到通知并自动更新。是一种对象行为型模式。

观察者模式的别名包括发布-订阅（Publish/Subscribe）模式、模型-视图（Model/View）模式、源-监听器（Source/Listener）模式或从属者（Dependents）模式。 看到这些名称有没有想到技术上的一些概念？MQ MVVM HODOOP 监听器
在这里插入图片描述
一些概念：

Subject（目标）：被观察者，它是指被观察的对象。
ConcreteSubject（具体目标）：具体目标是目标类的子类，通常它包含经常发生改变的数据，当它的状态发生改变时，向它的各个观察者发出通知。
Observer（观察者）：观察者将对观察目标的改变做出反应，观察者一般定义为接口，该接口声明了更新数据的方法
update()，因此又称为抽象观察者。
ConcreteObserver（具体观察者）：在具体观察者中维护一个指向具体目标对象的引用，它存储具体观察者的有关状态，这些状态需要和具体目标的状态保持一致；它实现了在抽象观察者Observer
中定义的 update()方法。

在这里插入图片描述
图中涉及UML的关系要理解，图比较重要，看的懂才可以继续。：关联（实线实心箭头）泛化（继承实线空心）实现（虚线空心）聚合（关联关系的一种，实现空心菱形）

四. JDK中的观察者模式（如何自行实现，不是从0开始）

观察者模式在 Java 语言中的地位非常重要。在 JDK 的 java.util 包中，提供了 Observable 类以及 Observer 接口，它们构成了 JDK 对观察者模式的支持（可以去查看下源码，写的比较严谨）。

这种方式不建议使用了，因为在jdk9之后废弃，且存在线程不安全问题，

**（推荐）**java.util.concurrent包中的ConcurrentHashMap和CopyOnWriteArrayList，以及java.util.EventListener相关的API来构建自己的观察者模式实现

五. Spring 的事件驱动编程（正文开始）

1. 概念

事件：ApplicationEvent 是所有事件对象的父类。ApplicationEvent 继承自 jdk 的 EventObject, 所有的事件都需要继承 ApplicationEvent, 并且通过 source 得到事件源。
Spring 也为我们提供了很多内置事件，ContextRefreshedEvent、ContextStartedEvent、ContextStoppedEvent、ContextClosedEvent、RequestHandledEvent。
事件监听：ApplicationListener，也就是观察者，继承自 jdk 的 EventListener，该类中只有一个方法
onApplicationEvent。当监听的事件发生后该方法会被执行。
事件源：ApplicationContext，ApplicationContext 是 Spring 中的核心容器，在事件监听中
ApplicationContext 可以作为事件的发布者，也就是事件源。因为 ApplicationContext 继承自
ApplicationEventPublisher。在 ApplicationEventPublisher
中定义了事件发布的方法：publishEvent(Object event)
事件管理：ApplicationEventMulticaster，用于事件监听器的注册和事件的广播。监听器的注册就是通过它来实现的，它的作用是把Applicationcontext 发布的 Event 广播给它的监听器列表。

2. 核心类

ApplicationEvent 事件类
ApplicationListener 监听器泛型（事件类）
@EventListener 注解同ApplicationListener 作用于方法上，参数是事件类
ApplicationEventPublisher 自动发布事件的处理类，常用的，他是一个借口，自定义时可重写它
ApplicationEventPublisherAware 接口类，用于业务处理中，它包含 setApplicationEventPublisher 的方法，用于指定ApplicationEventPublisher
ApplicationEventMulticaster 用于事件监听器的注册和事件的广播，编程不涉及，但是需要了解下

3. 说一下原理，懂了基本就OVER了，涉及源码，不懂暂时可以

1. 广播器（类结构）

ApplicationEventMulticaster接口：提供了添加/移除监听器以及广播事件给监听器的行为。
AbstractApplicationEventMulticaster抽象类：提供了基础的监听器注册/移除以及查找能力。
SimpleApplicationEventMulticaster类：提供了事件广播功能。

2. 注册广播器和监听器

Spring容器初始化时， org.springframework.context.support.AbstractApplicationContext 在refresh()方法中，会进行广播器和监听器的注册。

初始化事件广播器(initApplicationEventMulticaster)
注册监听器(registerListeners)
事件广播
- publistEvent
- multicastEvent

4. 实操效果

定义事件

@EqualsAndHashCode(callSuper = true)
@Data
@Builder
public class DemoEvent extends ApplicationEvent {private String name;public DemoEvent(String source) {super(source);this.name = source;}public DemoEvent(Object source, Clock clock) {super(source, clock);}
}

定义事件监听

方式一：采用注解 适合业务编程@Component
public class DemoEventListener {@EventListener(DemoEvent.class)public void demoListener(DemoEvent event){System.out.println(event.getName());}
}方式二： 适合底层框架编程
public class DemoEventListenerIm implements ApplicationListener<DemoEvent> {@Overridepublic void onApplicationEvent(DemoEvent event) {System.out.println(event.getName());}
}

定义事件发布（可不写，框架编程需要）

@Component
public class DemoPublisher implements ApplicationEventPublisherAware {private ApplicationEventPublisher applicationEventPublisher;@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {this.applicationEventPublisher = applicationEventPublisher;}public void publishEvent(DemoEvent event) {System.out.println("publish event");applicationEventPublisher.publishEvent(event);}}

测试

@SpringBootTest(classes = EventApplication.class)
@RunWith(SpringRunner.class)
public class TestApplication {@Autowiredprivate ApplicationEventPublisher publisher;@Testpublic void demoEvenTest() {DemoEvent demoEvent = new DemoEvent("hello");publisher.publishEvent(demoEvent);System.out.println("laile");}
}

5. 其他注意点

事务监听器

@EnableTransactionManagement开启事务支持，@TransactionalEventListener标识事务监听器。
- 发布事件的操作必须在事务(@Transactional)内进行，否则监听器不会生效，也可以将fallbackExecution标志设置为true(@TransactionalEventListener(fallbackExecution = true))
- 可以配置在事务的哪个阶段来监听事务(默认在事务提交后监听),@TransactionalEventListener(phase = TransactionPhase.AFTER_COMPLETION)。
异步支持

@EnableAsync开启异步支持，@Async标识监听器异步处理。开启异步执行后，方法的异常不会抛出，只能在方法内部处理。

条件监听

@EventListener(condition = “#event.message.contains(‘important’)”)
用于按照条件处理数据，可用与区分数据处理

监听器顺序

@Order控制多个监听器的执行顺序，值越小，监听器越先执行。

到这里您基本就了解了事件编程思路。下面我们聊一聊前端的事件编程。KOI技术-事件驱动编程（前端）

KOI技术-事件驱动编程（Sping后端）

1 “你日渐平庸，甘于平庸，将继续平庸。”——《以自己喜欢的方式过一生》 2. “总是有人要赢的，那为什么不能是我呢?”——科比布莱恩特 3. “你那么憎恨那些人，和他们斗了那么久，最终却要变得和他们一样，…...

编程日记 2025/7/20 21:49:45

ubuntu 20.04 国内源安装docker

先更新软件包，安装备要apt软件 # 更新软件包索引 sudo apt-get update# 安装需要的软件包以使apt能够通过HTTPS使用仓库 sudo apt-get install ca-certificates curl gnupg lsb-release使用阿里云源 # 添加阿里云官方GPG密钥 curl -fsSL http://mirrors.aliyun.co…...

编程日记 2025/7/19 18:30:52

微信小程序 app.json 配置文件解析与应用

目录一、什么是 app.json？ 二、app.json 文件的基本结构三、详细解析 app.json 配置项 1. pages：小程序页面路径配置 2. window：窗口样式配置 3. tabBar：底部标签栏配置 4. networkTimeout：网络请求超时配置 …...

编程日记 2025/7/20 20:49:26

C高级：思维导图Day2

目录总览1 总览2 总览1 压缩与解压缩打包与解包软连接与硬链接 ubuntu下关机与重启指令总览2 结束...

编程日记 2025/7/20 21:05:38

蓝桥杯（Java）（ing）

Java前置知识输入流： （在Java面向对象编程-CSDN博客里面有提过相关知识------IO流） // 快读快写 static BufferedReader in new BufferedReader(new InputStreamReader(System.in)); static BufferedWriter out new BufferedWriter(new…...

编程日记 2025/7/20 21:09:14

[Pro Git#2] 分支管理 | branch fix_bug , feature | 处理合并冲突

目录一、Issue模板文件二、Pull Requests模板文件分支管理 1. 理解分支 2. 创建与管理分支 1. 切换分支与提交历史 2. 合并分支 3. 删除分支 4. 解决合并冲突 6. 查看分支合并情况快速创建并切换分支分支管理策略分支合并模式分支管理原则日常开发环境 …...

编程日记 2025/7/20 21:46:06

Java——集合框架

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档文章目录 1 集合框架概述1.1 内存层面需要针对多个数据进行存储。此时，可以考虑的容器有：1.2 数组存储多个数据方面的特点和弊端1.3 Java集合框架体系…...

编程日记 2025/7/20 21:12:40

Mac 环境 VVenC 编译与编码命令行工具使用教程

VVenC VVenC 是一个开源的高效视频编码器，专门用于支持 H.266/VVC (Versatile Video Coding) 标准的编码。H.266/VVC 是继 HEVC (H.265) 之后的新一代视频编码标准，主要目的是提供比 HEVC 更高的压缩效率，同时保持或提高视频质量。H.266/VVC…...

编程日记 2025/7/20 20:55:44

WebRTC：实现浏览器与移动应用的实时通信

1.技术简介 （Web Real-Time）是一种开放式实时通信技术，旨在使浏览器和移动应用程序通过简单的API即可实现实时音频、视频和数据传输，而无需安装插件或额外软件。它支持网络应用中的点对点通信，例如视频聊天、语音通话…...

编程日记 2025/7/19 23:49:38

curl编译：点击跳转踩坑一 * SSL certificate problem: unable to get local issuer certificate * closing connection #0 curl: (60) SSL certificate problem: unable to get local issuer certificate More details here: https://curl.se/docs/sslcerts.html …...

编程日记 2025/7/20 20:55:45

【NebulaGraph】变化的多跳查询

【NebulaGraph】变化的多跳查询 1. 需求2. 解决方案2.1 确定查询结构2.2 构建查询语句 3. 追加需求：如果增加每一跳都要指定查询某SPACE下的Tag，或者不查询某个Tag怎么办 1. 需求存在多跳请求，其中每一跳是从上一跳查询结果为基础的。但是 …...

编程日记 2025/7/20 20:59:40

【C++】九九乘法表编程题详解与多角度对比分析

博客主页： [小ᶻ☡꙳ᵃⁱᵍᶜ꙳] 本文专栏: C 文章目录 💯前言💯题目概述题目描述 💯老师的实现方法代码解析优点不足 💯我的实现方法代码解析优点不足 💯实现方法对比💯优化与扩展代码优化…...

编程日记 2025/7/14 10:48:50

node.js卸载并重新安装（超详细图文步骤）

卸载node.js 重新安装nodejs 一、卸载 1、首先进入控制面板卸载程序 2、卸载后到文件夹中进行进一步的删除删除上述的几个文件夹每个人可能不一样，总之是找到自己的nodejs安装路径，下面是我的 ①删除C:UsersAdminAppDataRoaming路径下的npm相关文件…...

编程日记 2025/7/20 21:05:37

redis的集群模式与ELK基础

一、redis的集群模式 1.主从复制 （1）概述主从模式：这是redis高可用的基础，哨兵和集群都是建立在此基础之上。主从模式和数据库的主从模式是一样的，主负责写入，然后把写入的数据同步到从服务器&#xff…...

编程日记 2025/7/20 21:03:20

一份关于 Ubuntu 系统下代理配置的故障排查笔记

Ubuntu 网络代理配置与故障排查指南在使用 Ubuntu 系统时，配置网络代理可以帮助提升网络访问速度或突破网络限制。然而，代理配置过程中可能会遇到各种问题。本文将详细介绍如何在 Ubuntu 下配置网络代理，并提供故障排查的步骤和解决方案。 …...

编程日记 2025/7/20 21:09:14

如何用jmeter工具进行性能测试

前言今天我们来说说jmeter如何进行性能测试，我们都知道jmeter工具除了可以进行接口功能测试外，还可以进行性能测试。当项目趋于稳定，根据性能需求就可以着手准备性能测试了，今天就说一说jmeter如何进行性能测试，jmet…...

编程日记 2025/7/20 21:20:01

五、Vue 循环语句

文章目录简介一、基础数组迭代二、对象属性迭代三、整数循环简介在 Vue.js 的世界里，当我们需要处理重复性的结构并依据数据动态渲染时，v-for 指令就成了不可或缺的工具，它赋予开发者简洁且强大的能力，轻松应对各种列表渲染场景…...

编程日记 2025/7/19 23:25:08

HMSC联合物种分布模型

联合物种分布模型（Joint Species Distribution Modelling，JSDM）在生态学领域，特别是群落生态学中发展最为迅速，Hmsc是物种群落分层模型的缩写(Hierarchical Modelling of Species Communities)，它是一种基于…...

编程日记 2025/7/20 5:27:29

【CPU】risc-v指令集和其他指令集的差别(个人草稿)

第三，在 RISC-V 中对于所有指令，要读写的寄存器的标识符总是在同一位置，意味着在解码指令之前，就可以先开始访问寄存器。在许多其他的 ISA 中，某些指令字段在部分指令中被重用作为源目的地，在其他指令中又被…...

编程日记 2025/7/15 11:27:11

处理元素卡在视野边界，滚动到视野内

效果图如下： 本示例处理场景：点击底部的折叠面板，展开后移动端滚动条位置不变，导致展开内容在视图外。造成面板展开无内容的错觉。处理核心API: IntersectionObserver 此API可绑定元素并监听元素是否在视野内。若在视野外…...

编程日记 2025/7/15 1:29:10

环,域,体,整区,理想,极大理想,

环： 定义： 加法交换群乘法半群分配律域的定义： 加法交换群乘法群（去掉0元是交换群） 分配律 Eg:比如整数集合不是域，因为对于乘法来说，去掉0后没有单位元了，但是是环 Eg…...

编程日记 2025/7/17 12:22:17

音视频入门基础：MPEG2-TS专题（22）——FFmpeg源码中，获取TS流的音频信息的实现

音视频入门基础：MPEG2-TS专题系列文章： 音视频入门基础：MPEG2-TS专题（1）——MPEG2-TS官方文档下载音视频入门基础：MPEG2-TS专题（2）——使用FFmpeg命令生成ts文件音视频入门基础…...

编程日记 2025/7/18 14:52:23

大模型—Ollama 结构化输出

Ollama 结构化输出 Ollama现在支持结构化输出，使得可以按照由JSON模式定义的特定格式来约束模型的输出。Ollama的Python和JavaScript库已经更新，以支持结构化输出。结构化输出的用例包括：从文档中解析数据从图像中提取数据结构化所有语言模型响应比JSON模式更可靠和一致开…...

编程日记 2025/7/13 23:33:53

基于Pytorch和yolov8n手搓安全帽目标检测的全过程

一.背景还是之前的主题，使用开源软件为公司搭建安全管理平台，从视觉模型识别安全帽开始。主要参考学习了开源项目 https://github.com/jomarkow/Safety-Helmet-Detection，我是从运行、训练、标注倒过来学习的。由于工作原因，抽空…...

编程日记 2025/7/14 19:53:02

数据结构与算法基础（C语言版）

参考资料：https://www.bilibili.com/video/BV1GW421A7qY/ 所有代码均已在Ubuntu 20.04.6 LTS中测试通过逻辑结构与存储结构逻辑结构逻辑结构指的是数据对象中数据元素间的相互关系，分为以下四种： 集合结构集合结构中的数据元素除了同属于…...

编程日记 2025/7/19 1:10:53

Qt监控系统放大招/历经十几年迭代完善/多屏幕辅屏预览/多层级设备树/网络登录和回放

一、前言说明近期对视频监控系统做了比较大的更新升级，主要就是三点，第一点就是增加了辅屏预览，这个也是好多个客户需要的功能，海康的iVMS-4200客户端就有这个功能，方便在多个屏幕打开不同的视频进行查看&#xff0c…...

编程日记 2025/7/19 10:36:59

使用Locust对MySQL进行负载测试

1.安装环境 pip install locust mysql-connector-python 2.设置测试环境打开MySQL服务打开Navicat新建查询，输入SQL语句 3.编写locust脚本 load_mysql.py # codingutf-8 from locust import User, TaskSet, task, between import mysql.connector import ran…...

编程日记 2025/7/20 11:28:38

layui多图上传,tp8后端接收处理

环境：layui2.9.21\thinkphp8.1 前端代码： layui.use([upload, layer], function() {const upload layui.upload;const layer layui.layer;const $ layui.$;// 上传图片const uploadInstImage upload.render({elem: #uploadImage,url: /admin/demo/…...

编程日记 2025/7/18 15:51:06

【Rust自学】8.3. String类型 Pt.1：字符串的创建、更新与拼接

8.3.0. 本章内容第八章主要讲的是Rust中常见的集合。Rust中提供了很多集合类型的数据结构，这些集合可以包含很多值。但是第八章所讲的集合与数组和元组有所不同。第八章中的集合是存储在堆内存上而非栈内存上的，这也意味着这些集合的数据大小无需在编…...

编程日记 2025/7/20 10:29:32

Linux（Ubuntu）下ESP-IDF下载与安装完整流程（1）

本文主要看参考官网说明，如下：快速入门 - ESP32-S3 - — ESP-IDF 编程指南 latest 文档 Linux 和 macOS 平台工具链的标准设置 - ESP32-S3 - — ESP-IDF 编程指南 latest 文档一、安装准备为了在ESP32-S3中使用ESP-IDF，需要根据操作系统安装一些软件包。可以参考以下安…...

编程日记 2025/7/15 6:47:03

Android性能优化—— 内存优化

Android 系统中，垃圾回收是自动的，比较隐蔽，这就导致一些内存问题表现的并不明显，出现问题后难以定位。常见的内存问题有内存泄漏、内存溢出（Out of Memory）、内存抖动等。我们做内存优化的主要原因有以下…...

编程日记 2025/7/15 7:16:35

【MATLAB第111期】基于MATLAB的sobol全局敏感性分析方法二阶指数计算

【MATLAB第111期】基于MATLAB的sobol全局敏感性分析方法二阶指数计算一、简介在MATLAB中计算Sobol二阶效应指数通常涉及到全局敏感性分析（Global Sensitivity Analysis, GSA），其中Sobol方法是一种流行的技术，用于评估模型输入…...

编程日记 2025/7/14 12:36:58

【Scala】图书项目系统代码演练3.1/BookService

package org.app package serviceimport models.{BookModel, BorrowRecordModel}import org.app.dao.{BookDAO, BorrowRecordDAO}import java.time.LocalDateTime import scala.collection.mutable.ListBuffer// 图书业务逻辑层 class BookService {private val bookDAO new B…...

编程日记 2025/7/15 17:10:10

推荐