Spring事件处理
创始人
2024-04-28 10:13:51
0

        在实际业务开发中,有时候复杂性的业务之间需要解耦,常用的方法:同步、异步、MQ。但 MQ 重啊,非必要不提升架构复杂度。

        针对同步和异步使用方式:1.定时器 2.Spring Event.

        Spring Event:

                观察者设计模式,一个 Bean 处理完成任务后希望通知其它 Bean 或者说一个 Bean监听另一个Bean 的行为。

配置异步线程池

package com.lean.event.demo.config;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;@Configuration
public class AsynConfig implements AsyncConfigurer {private static final Logger log= LoggerFactory.getLogger(AsynConfig.class);@Bean("taskAsyncPool")public Executor orderTaskAsyncPool() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(10); // 核心线程数executor.setMaxPoolSize(20); // 最大线程数executor.setQueueCapacity(1000); // 队列大小executor.setKeepAliveSeconds(300); // 线程最大空闲时间executor.setThreadNamePrefix("async-Executor-"); // 指定用于新创建的线程名称的前缀。executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 拒绝策略(一共四种,此处省略)executor.initialize();return executor;}@Overridepublic Executor getAsyncExecutor() {return orderTaskAsyncPool();}// 异常处理器@Overridepublic AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {return (ex, method, params) -> log.error(String.format("执行异步任务'%s'", method), ex);}
}

1.同步

import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import org.springframework.context.ApplicationEvent;
/*** 自定义事件 继承ApplicationEvent*/
@Getter
@Setter
@ToString
public class MessageEvent extends ApplicationEvent {//传输的数据对象private String messageId;public MessageEvent(Object source, String messageId) {super(source);this.messageId = messageId;}
}
package com.lean.event.demo.listener;import com.lean.event.demo.events.MessageEvent;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
/*** 同步* 监听器:* 实现方式:*      1.实现ApplicationListener*      2.@EventListener*/
@Slf4j
@Component
public class MessageListener implements ApplicationListener {@SneakyThrows@Overridepublic void onApplicationEvent(MessageEvent event) {String messageId = event.getMessageId();long start = System.currentTimeMillis();long end = System.currentTimeMillis();log.info("{}:耗时:({})毫秒", messageId, (end - start));}
}

2.异步

| 自定义事件

import lombok.AllArgsConstructor;
import lombok.Data;@Data
@AllArgsConstructor
public class MsgEvent {/*** 该类型事件携带的信息*/public String messageId;
}
import com.lean.event.demo.events.MsgEvent;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
@Slf4j
@Component
public class MsgListener {//异步注解 需要开启@EnableAsync异步@Async(value = "taskAsyncPool")@SneakyThrows@EventListener(MsgEvent.class)public void sendMsg(MsgEvent event) {String messageId = event.getMessageId();long start = System.currentTimeMillis();log.info("开发发送短信");log.info("开发发送邮件");long end = System.currentTimeMillis();log.info("{}:发送短信、邮件耗时:({})毫秒", messageId, (end - start));}
}
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;@EnableAsync
@SpringBootApplication
public class SpringLeanEventApplication {public static void main(String[] args) {SpringApplication.run(SpringLeanEventApplication.class, args);}}

3.测试

package com.lean.event.demo.service;import com.lean.event.demo.events.MsgEvent;
import com.lean.event.demo.events.MessageEvent;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Service;
@Slf4j
@Service
@Data
public class MessageService {/** 注入ApplicationContext用来发布事件 */private final ApplicationContext applicationContext;public String testMessage(String messageId) {long start = System.currentTimeMillis();// (同步处理)applicationContext.publishEvent(new MessageEvent(this, messageId));// (异步处理)applicationContext.publishEvent(new MsgEvent(messageId));long end = System.currentTimeMillis();log.info("任务全部完成,总耗时:({})毫秒", end - start);return "购买成功";}
}
package com.lean.event.demo;import com.lean.event.demo.service.MessageService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest
public class MessageServiceTest {@Autowiredprivate MessageService messageService;@Testpublic void buyOrderTest() {messageService.testMessage("123456");}
}

ApplicationEvent: 

类的注释是,被应用事件继承的类,抽象的不能初始化;

 EventObject: 父类

 事件携带一个 Objecgt 对象,可以被发布。

事件监听者,监听到这个事件后,触发自定义逻辑 ( 操作 Object 对象);

注意:

        事件发布后,都会被监听ApplicationEvent的监听对象所监听到。

代码

相关内容

热门资讯

安卓双系统添加应用,轻松实现多... 你有没有想过,你的安卓手机里可以同时运行两个系统呢?听起来是不是很酷?想象一边是熟悉的安卓系统,一边...
pipo安卓进系统慢,探究pi... 最近是不是发现你的Pipo安卓系统更新或者运行起来特别慢?别急,今天就来给你好好分析分析这个问题,让...
怎样使用安卓手机系统,安卓手机... 你有没有发现,安卓手机已经成为我们生活中不可或缺的一部分呢?从早晨闹钟响起,到晚上睡前刷剧,安卓手机...
双系统安卓安装caj,轻松实现... 你有没有想过,你的安卓手机里装上双系统,是不是就能同时享受安卓和Windows系统的乐趣呢?没错,这...
安卓使用ios系统教程,安卓用... 你是不是也和我一样,对安卓手机上的iOS系统充满了好奇?想要体验一下苹果的优雅和流畅?别急,今天我就...
安卓系统gps快速定位,畅享便... 你有没有遇到过这样的情况:手机里装了各种地图导航软件,但每次出门前都要等上好几分钟才能定位成功,急得...
安卓手机系统更新原理,原理与流... 你有没有发现,你的安卓手机最近是不是总在提醒你更新系统呢?别急,别急,让我来给你揭秘一下安卓手机系统...
安卓系统通知管理,全面解析与优... 你有没有发现,手机里的通知就像是一群调皮的小精灵,时不时地跳出来和你互动?没错,说的就是安卓系统的通...
安卓系统手机哪买,揭秘哪里购买... 你有没有想过,拥有一部安卓系统手机是多么酷的事情呢?想象你可以自由安装各种应用,不受限制地探索各种功...
安卓系统 ipv4,基于安卓系... 你知道吗?在智能手机的世界里,有一个系统可是无人不知、无人不晓,那就是安卓系统。而在这个庞大的安卓家...
目前安卓是什么系统,探索安卓系... 亲爱的读者,你是否曾好奇过,如今安卓系统究竟是什么模样?在这个科技飞速发展的时代,操作系统如同人体的...
安卓6.0系统比5.0,从5.... 你有没有发现,自从手机更新了安卓6.0系统,感觉整个人都清爽了不少呢?没错,今天咱们就来聊聊这个话题...
安卓2.36系统升级,功能革新... 你知道吗?最近安卓系统又来了一次大变身,那就是安卓2.36系统升级!这可不是一个小打小闹的更新,而是...
安卓系统源码怎么打开,并可能需... 你有没有想过,安卓系统的源码就像是一扇神秘的门,隐藏着无数的技术秘密?想要打开这扇门,你得掌握一些小...
安卓8.0系统体验视频,智能革... 你有没有听说安卓8.0系统最近可是火得一塌糊涂啊!作为一个紧跟科技潮流的数码达人,我当然要来给你好好...
宣传系统漫画app安卓,探索安... 亲爱的读者们,你是否曾在某个午后,百无聊赖地打开手机,想要寻找一些轻松愉悦的读物?今天,我要给你介绍...
鸿蒙替换安卓系统吗,开启智能生... 你知道吗?最近科技圈里可是炸开了锅,因为华为的新操作系统鸿蒙系统,据说要大举进军手机市场,替换掉安卓...
手机安卓系统深度清理,解锁手机... 手机里的东西是不是越来越多,感觉就像一个装满了杂物的储物柜?别急,今天就来教你一招——手机安卓系统深...
安卓上的windows系统,融... 你有没有想过,在安卓手机上也能体验到Windows系统的魅力呢?没错,这就是今天我要跟你分享的神奇故...
安卓系统焦点变化事件,Andr... 你知道吗?在安卓系统的世界里,最近发生了一件超级有趣的事情——焦点变化事件。这可不是什么小打小闹,它...