SpringBoot-自定义监听器

news2024/11/26 18:27:47

Spring Boot提供了强大的事件模型,其中包括多种内置监听器,同时也支持开发者自定义监听器。通过实现`ApplicationListener`接口,开发者可以创建自己的监听器,并在Spring Boot应用程序中进行配置。这样一来,在特定的应用程序事件发生时,自定义监听器就能够捕捉到并执行相应的操作,比如读取配置文件、初始化数据等。

自定义监听器的使用不仅仅是为了满足基本的业务需求,更是为了提高应用程序的可维护性和可靠性。通过监控应用程序的运行状态,开发人员可以更加及时地发现潜在的问题,并采取相应的措施。这有助于降低应用程序的故障风险,提高系统的稳定性。

此外,自定义监听器为开发人员提供了一种灵活的扩展方式,使其能够更好地适应不同的业务场景。开发者可以根据具体需求实现不同的监听器,以满足特定功能或业务逻辑的要求。这种灵活性使得Spring Boot应用程序更具可扩展性,更容易应对日益变化的业务需求。

自定义监听器作为Spring Boot框架中强大而灵活的一部分,为开发人员提供了有效的工具,帮助他们更好地监控和管理应用程序,同时为系统的可靠性和可维护性注入了更多的可能性。


一、创建自定义监听器

要创建自定义监听器,首先需要新建一个类,我们称之为MyApplicationListener,并确保该类继承了ApplicationListener接口。这一接口规定了一个名为onApplicationEvent的方法,我们将在这个方法中定义我们监听到特定应用程序事件时的操作。下面是一个简单的实例:

MyApplicationListener.java代码:

import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

@Component
public class MyApplicationListener implements ApplicationListener<ApplicationEvent> {

    @Override
    public void onApplicationEvent(ApplicationEvent event) {
        // 在这里编写监听到特定应用程序事件时的操作
        // 例如,利用RedisUtil工具类往Redis里写入数据
        RedisUtil.writeDataToRedis();
    }
}

在上述代码中,MyApplicationListener类通过实现ApplicationListener接口,成为了一个Spring Bean(通过@Component注解)。这使得Spring Boot应用程序能够自动扫描并注册这个监听器。 


二、利用RedisUtil工具类写入数据

为了在onApplicationEvent方法中使用RedisUtil工具类往Redis里写入数据,我们需要确保RedisUtil类已经存在,并且包含了相关的写入方法。下面是一个简单的示例:

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

@Component
public class RedisUtil {

    private final RedisTemplate<String, String> redisTemplate;

    @Autowired
    public RedisUtil(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public void writeDataToRedis() {
        // 在这里编写往Redis里写入数据的逻辑
        redisTemplate.opsForValue().set("key", "value");
    }
}

在上述代码中,RedisUtil类通过@Component注解成为了一个Spring Bean,使得它可以被其他组件自动注入。writeDataToRedis方法可以根据具体需求编写,执行向Redis写入数据的相关逻辑。

通过这样的设计,我们成功创建了一个自定义监听器MyApplicationListener,在特定应用程序事件发生时,它会调用RedisUtil工具类的方法,实现了向Redis写入数据的功能。这种结构既利用了Spring Boot的事件模型,又灵活地整合了自定义逻辑,为应用程序提供了更多的扩展性和定制化的可能性。


三、测试自定义监听器

接下来,我们将进行自定义监听器的测试,确保它在项目加载时能够自动运行并执行相关操作。

1、观察控制台输出

启动项目,并仔细观察控制台输出。若一切配置正确,你应该能够看到与自定义监听器相关的日志信息。这些日志表明监听器在特定应用程序事件发生时被触发,执行了相应的操作。

我们往监听器里添加日志代码:

import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

@Component
public class MyApplicationListener implements ApplicationListener<ApplicationEvent> {

    @Override
    public void onApplicationEvent(ApplicationEvent event) {
        // Spring Boot 应用启动后执行该方法
        System.out.println("Spring Boot 应用启动...");

        // 在这里编写监听到特定应用程序事件时的操作
        // 例如,利用RedisUtil工具类往Redis里写入数据
        RedisUtil.writeDataToRedis();
 
        System.out.println("将数据存入 Redis 中...");
    }
}

启动项目,观察控制台,看到我们的log已经被打出了。

这表示MyApplicationListenerApplicationEvent发生时被触发。 

2、检查Redis是否成功存入

接着,我们来进行第二项测试,确保数据已成功存入Redis。我们要通过访问Redis服务,检查相关数据是否已被写入。具体方法我们采用使用命令行工具或可视化工具连接到Redis服务器的形式,检查键值对是否存在。我们在writeDataToRedis方法中写入了键为 "key"、值为 "value" 的数据,应该在Redis中可以看到相应的数据。 

我们去访问Reids服务,看内容是否已经被存入Redis,看到已经被存入。输入Keys,获得Redis服务保存的所有键值对,如果成功的话,可以看到我们刚刚存入的<"key", “value”>键值对的key,也就是字符串"key"。

通过以上两个测试步骤,我们已经验证自定义监听器在按照预期工作。

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

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

相关文章

神经网络的核心:简单易懂理解 PyTorch 非线性激活函数

目录 torch.nn子函数非线性激活详解 nn.Softmin Softmin 函数简介 函数工作原理 参数详解 使用技巧与注意事项 示例代码 nn.Softmax Softmax 函数简介 函数工作原理 参数详解 使用技巧与注意事项 示例代码 nn.Softmax2d Softmax2d 函数简介 函数工作原理 输入…

FineBI实战项目一(9):每日不同支付方式订单总额/订单笔数

1 明确数据分析目标 统计每种支付方式的订单个数以及订单总金额 2 创建用于保存数据分析结果的表 create table app_order_paytype(id int primary key auto_increment,dt date,pay_type varchar(20),total_money double,total_cnt int ); 3 编写SQL语句进行数据分析 selec…

vue3 修饰符大全(近万字长文)

系列文章目录 TypeScript 从入门到进阶专栏 文章目录 系列文章目录前言一、事件修饰符&#xff08;Event Modifiers&#xff09;1、.stop&#xff08;阻止事件冒泡&#xff09;2、.prevent&#xff08;阻止事件的默认行为&#xff09;3、.capture&#xff08;使用事件捕获模式…

何为算法之空间复杂度

前言 不知前面所讲的算法的十大特征你是否记住了呢&#xff1f;其实除了这十大特征之外&#xff0c;算法还有两个衡量标准。 不同的问题需要使用不同的算法作为策略&#xff0c;不同的算法也可能占用不同的时间和空间来完成相同的任务&#xff0c;这时候&#xff0c;对算法的选…

强化学习的数学原理学习笔记 - RL基础知识

文章目录 Roadmap&#x1f7e1;基础概念贝尔曼方程&#xff08;Bellman Equation&#xff09;基本形式矩阵-向量形式迭代求解状态值 vs. 动作值 &#x1f7e1;贝尔曼最优方程&#xff08;Bellman Optimality Equation&#xff0c;BOE&#xff09;基本形式迭代求解 本系列文章介…

alibabacloud学习笔记02(小滴课堂)

什么是注册中心和常见的注册中心有哪些 介绍什么是Nacos和搭建实战 启动Nacos 使用前要先安装jdk。 linux学习专栏笔记中有&#xff0c;大家可以去看。 关闭nacos: 这样我们就登录了nacos。 项目集成Nacos实现服务直接的调用 每个子模块都去添加。 给每个子模块配置nacos配…

ReentrantLock底层原理学习二

以 ReentrantLock 作为切入点&#xff0c;来看看在这个场景中是如何使用 AQS 来实现线程的同步的 ReentrantLock 的时序图 调用 ReentrantLock 中的 lock()方法&#xff0c;源码的调用过程我使用了时序图来展现。ReentrantLock.lock() 这个是 reentrantLock 获取锁的入口 pu…

小H靶场笔记:DC-4

DC-4 January 4, 2024 2:37 PM Tags: teehee提权 Owner&#xff1a;只惠摸鱼 信息收集 探测靶机ip&#xff0c;发现应该是192.168.199.134 扫一下开放端口&#xff08;22、80&#xff09;、服务、版本、漏洞 根据扫描结果&#xff0c;在80端口可能有CSRF漏洞&#xff0c;…

好书推荐丨人工智能B2B落地实战:基于云和Python的商用解决方案(清华社)

文章目录 写在前面人工智能推荐图书图书简介简明目录 推荐理由粉丝福利写在后面 写在前面 本期博主给大家推荐一本全新正版的好书&#xff1a;《人工智能B2B落地实战&#xff1a;基于云和Python的商用解决方案》&#xff01;这本书来自清华大学出版社&#xff0c;是今年刚刚出…

十八:爬虫-JS逆向(下)

一&#xff1a;AES与DES DES对称加密,是一种比较传统的加密方式,其加密运算、解密运算使用的是同样的密钥&#xff0c;信息的发送者。和信息的接收者在进行信息的传输与处理时&#xff0c;必须共同持有该密钥(称为对称密码),是一种对称加密算法。一般来说加密用的是encrypt()函…

Linux服务器安装操作Nginx

1.下载nginx压缩包 //进入/usr/local目录创建一个文件夹 cd /usr/local mkdir nginx cd nginx //下载tar包 wget http://nginx.org/download/nginx-1.20.1.tar.gz 2.配置nginx安装所需的环境 1. 安装gcc 安装 nginx 需要先将官网下载的源码进行编译&#xff0c;编译依赖 gc…

Linux查找命令@which、find

目录 which概念语法作用 find概念语法按文件名查找按文件大小查找 作用演示一演示二演示三 通配符 总结 which 概念 which 是一个常用的 Linux/Unix 命令&#xff0c;用于查找并显示指定命令的绝对路径。 语法 which 要查找的命令 》无参数。 》 which后面&#xff0c;跟要查…

Android studio Progress Bar 进度条应用设计

一、水平进度条: 1)、xml布局文件: 2)、java文件: progressBar1 = findViewById(R.id.progressBar); progressBar2 = findViewById(R.id.progressBar2); public class AlarmTask extends TimerTask {@Overridepublic void run() {progressValue++;if (progressVa…

计网知识点回归

概述 计算机网络的定义&#xff1a; 不同地理位置的计算机通过通信电路实现资源共享 计算机网络的组成&#xff1a; 资源子网——提供共享的软硬件资源 通信子网——提供信息交换的网络接点和通信线路 计算机网络分类&#xff1a; 按拓扑分&#xff1a;星形 树形 总线型 环形…

清华大学生物信息学课件资料分享

清华大学鲁志老师实验室在网上分享了他们的生信课程学习资料&#xff0c;有电子书&#xff0c;PPT和视频&#xff0c;真是生信学习者的福音。 实验室网址是&#xff1a; https://www.ncrnalab.org/courses/#bioinfo2 可以看到&#xff0c;课程有针对本科生的&#xff0c;也有针…

shp文件与数据库(创建表)

前言 第三方库准备 shp文件是什么&#xff1f;笔者就不多做解释。后面将使用python的一些第三方库 1、sqlalchemy 2、pyshp 3、geoalchemy2 4、geopandas 这四个是主要的库&#xff0c;具体怎么使用可以参考相关教程&#xff0c;当然还有其他库&#xff0c;后面在介绍。…

uniapp 微信小程序跳转外部链接

一、背景&#xff1a; 开发小程序时&#xff0c;跳转到内部路径通常会使用&#xff1a;uni.navigateTo&#xff0c;uni.redirectTo&#xff0c;uni.reLaunch&#xff0c;uni.switchTab等方法&#xff0c;可以跳转到pages.json中已经注册的页面 uni.navigateTo(OBJECT) | uni-…

【KingbaseES】DataGrip配置链接KingbaseES V8R6数据库

新建驱动 填写内容如下&#xff1a; defaultjdbc:kingbase8://{host::localhost}:[{port::54321}]/[{:database::test}] 点击OK保存 测试链接 出现上图证明已经能链接了&#xff0c;保存链接看看数据库是否有我们的数据 发现好像什么都没有 再尝试&#xff0c;发现现在可以…

前端发开的性能优化 请求级:请求前(资源预加载和预读取)

预加载 预加载&#xff1a;是优化网页性能的重要技术&#xff0c;其目的就是在页面加载过程中先提前请求和获取相关的资源信息&#xff0c;减少用户的等待时间&#xff0c;提高用户的体验性。预加载的操作可以尝试去解决一些类似于减少首次内容渲染的时间&#xff0c;提升关键资…

ArkTS - 数据持久化

一、概述 应用数据持久化&#xff0c;是指应用将内存中的数据通过文件或数据库的形式保存到设备上。内存中的数据形态通常是任意的数据结构或数据对象&#xff0c;存储介质上的数据形态可能是文本、数据库、二进制文件等。 持久&#xff08;Persistence&#xff09;&#xff0…