String boot 发布事件用法 使用ApplicationEvent和Listener来业务解耦

本文主要是介绍String boot 发布事件用法 使用ApplicationEvent和Listener来业务解耦,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、新建一个实体对象

package com.example.demo.model;import lombok.Data;@Data
public class UserModel {//用户名private String name;//密码private String password;}

二、新建一个Service以及控制器

UserService .java

package com.example.demo.service;import com.example.demo.model.UserModel;public interface UserService {/*** 用户注册* @param userModel*/void register(UserModel userModel);}
UserServiceImpl.java
package com.example.demo.service.impl;import com.example.demo.event.UserRegisterEvent;
import com.example.demo.model.UserModel;
import com.example.demo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Service;@Service
public class UserServiceImpl implements UserService {@AutowiredApplicationContext applicationContext;@Overridepublic void register(UserModel userModel) {userModel.setName("小明");userModel.setPassword("123456");applicationContext.publishEvent(new UserRegisterEvent(this,userModel));}
}
TestController.java
@Autowiredprivate UserService userService;@GetMapping(value = "/test2")public Object test2() {UserModel userModel = new UserModel();userService.register(userModel);return "success";}

三、新建一个UserRegisterEvent类用于发布事件

package com.example.demo.event;import com.example.demo.model.UserModel;
import lombok.Getter;
import org.springframework.context.ApplicationEvent;@Getter
public class UserRegisterEvent extends ApplicationEvent {private UserModel userModel;public UserRegisterEvent(Object source, UserModel userModel) {super(source);this.userModel = userModel;}
}

四、使用@EventListener注解的方式来监听发布事件

package com.example.demo.listener;import com.example.demo.event.UserRegisterEvent;
import com.example.demo.model.UserModel;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;@Component
public class AnnotationRegisterListener {@EventListenerpublic void register(UserRegisterEvent userRegisterEvent){//获取注册用户对象UserModel user = userRegisterEvent.getUserModel();//../省略逻辑//输出注册用户信息System.out.println("@EventListener注册信息,用户名:"+user.getName()+",密码:"+user.getPassword());}
}

运行结果如下

@EventListener注册信息,用户名:小明,密码:123456


 

这篇关于String boot 发布事件用法 使用ApplicationEvent和Listener来业务解耦的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/668012

相关文章

sky-take-out项目中Redis的使用示例详解

《sky-take-out项目中Redis的使用示例详解》SpringCache是Spring的缓存抽象层,通过注解简化缓存管理,支持Redis等提供者,适用于方法结果缓存、更新和删除操作,但无法实现... 目录Spring Cache主要特性核心注解1.@Cacheable2.@CachePut3.@Ca

C#下Newtonsoft.Json的具体使用

《C#下Newtonsoft.Json的具体使用》Newtonsoft.Json是一个非常流行的C#JSON序列化和反序列化库,它可以方便地将C#对象转换为JSON格式,或者将JSON数据解析为C#对... 目录安装 Newtonsoft.json基本用法1. 序列化 C# 对象为 JSON2. 反序列化

修复已被利用的高危漏洞! macOS Sequoia 15.6.1发布

《修复已被利用的高危漏洞!macOSSequoia15.6.1发布》苹果公司于今日发布了macOSSequoia15.6.1更新,这是去年9月推出的macOSSequoia操作... MACOS Sequoia 15.6.1 正式发布!此次更新修复了一个已被黑客利用的严重安全漏洞,并解决了部分中文用户反馈的

RabbitMQ 延时队列插件安装与使用示例详解(基于 Delayed Message Plugin)

《RabbitMQ延时队列插件安装与使用示例详解(基于DelayedMessagePlugin)》本文详解RabbitMQ通过安装rabbitmq_delayed_message_exchan... 目录 一、什么是 RabbitMQ 延时队列? 二、安装前准备✅ RabbitMQ 环境要求 三、安装延时队

Python ORM神器之SQLAlchemy基本使用完全指南

《PythonORM神器之SQLAlchemy基本使用完全指南》SQLAlchemy是Python主流ORM框架,通过对象化方式简化数据库操作,支持多数据库,提供引擎、会话、模型等核心组件,实现事务... 目录一、什么是SQLAlchemy?二、安装SQLAlchemy三、核心概念1. Engine(引擎)

Java Stream 并行流简介、使用与注意事项小结

《JavaStream并行流简介、使用与注意事项小结》Java8并行流基于StreamAPI,利用多核CPU提升计算密集型任务效率,但需注意线程安全、顺序不确定及线程池管理,可通过自定义线程池与C... 目录1. 并行流简介​特点:​2. 并行流的简单使用​示例:并行流的基本使用​3. 配合自定义线程池​示

Java中HashMap的用法详细介绍

《Java中HashMap的用法详细介绍》JavaHashMap是一种高效的数据结构,用于存储键值对,它是基于哈希表实现的,提供快速的插入、删除和查找操作,:本文主要介绍Java中HashMap... 目录一.HashMap1.基本概念2.底层数据结构:3.HashCode和equals方法为什么重写Has

GO语言中函数命名返回值的使用

《GO语言中函数命名返回值的使用》在Go语言中,函数可以为其返回值指定名称,这被称为命名返回值或命名返回参数,这种特性可以使代码更清晰,特别是在返回多个值时,感兴趣的可以了解一下... 目录基本语法函数命名返回特点代码示例命名特点基本语法func functionName(parameters) (nam

Android协程高级用法大全

《Android协程高级用法大全》这篇文章给大家介绍Android协程高级用法大全,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友跟随小编一起学习吧... 目录1️⃣ 协程作用域(CoroutineScope)与生命周期绑定Activity/Fragment 中手

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp