详解SpringBoot实现ApplicationEvent事件的监听与发布
通过发布订阅模式实现数据的异步处理,比如异步处理邮件发送
新建SpringBoot项目
项目结构
.
├── pom.xml
└── src
└── main
├── java
│ └── com
│ └── example
│ └── demo
│ ├── Application.java
│ ├── config
│ │ └── TaskPoolConfig.java
│ ├── controller
│ │ └── IndexController.java
│ ├── entity
│ │ └── EmailDto.java
│ ├── event
│ │ └── SendEmailEvent.java
│ ├── listener
│ │ └── SendEmailListener.java
│ └── service
│ ├── SendEmailService.java
│ └── impl
│ └── SendEmailServiceImpl.java
└── resources
├── application.yml
├── static
└── templates
实现代码
pom.xml
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.7.7</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.example</groupId> <artifactId>demo</artifactId> <version>0.0.1-SNAPSHOT</version> <name>demo</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> <optional>true</optional> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <excludes> <exclude> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </exclude> </excludes> </configuration> </plugin> </plugins> </build> </project>
Application.java
package com.example.demo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
TaskPoolConfig.java
package com.example.demo.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.concurrent.Executor; /** * 线程池参数配置 **/ @EnableAsync @Configuration public class TaskPoolConfig { /** * 自定义线程池 **/ @Bean public Executor taskExecutor() { //返回可用处理器的Java虚拟机的数量 12 int i = Runtime.getRuntime().availableProcessors(); System.out.println("系统最大线程数 : " + i); ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); //核心线程池大小 executor.setCorePoolSize(16); //最大线程数 executor.setMaxPoolSize(20); //配置队列容量,默认值为Integer.MAX_VALUE executor.setQueueCapacity(99999); //活跃时间 executor.setKeepAliveSeconds(60); //线程名字前缀 executor.setThreadNamePrefix("asyncServiceExecutor -"); //设置此执行程序应该在关闭时阻止的最大秒数,以便在容器的其余部分继续关闭之前等待剩余的任务完成他们的执行 executor.setAwaitTerminationSeconds(60); //等待所有的任务结束后再关闭线程池 executor.setWaitForTasksToCompleteOnShutdown(true); return executor; } }
EmailDto.java
package com.example.demo.entity; import lombok.Data; @Data public class EmailDto { private String email; private String subject; private String content; }
SendEmailEvent.java
package com.example.demo.event; import com.example.demo.entity.EmailDto; import org.springframework.context.ApplicationEvent; /** * 自定义事件 */ public class SendEmailEvent extends ApplicationEvent { private EmailDto emailDto; public SendEmailEvent(EmailDto emailDto) { super(emailDto); this.emailDto = emailDto; } public EmailDto getEmailDto() { return this.emailDto; } }
SendEmailListener.java
package com.example.demo.listener; import com.example.demo.entity.EmailDto; import com.example.demo.event.SendEmailEvent; import com.example.demo.service.SendEmailService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationListener; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; /** * 事件监听器 */ @Component public class SendEmailListener implements ApplicationListener<SendEmailEvent> { @Autowired private SendEmailService sendEmailService; @Async @Override public void onApplicationEvent(SendEmailEvent event) { EmailDto emailDto = event.getEmailDto(); this.sendEmailService.sendEmail(emailDto); } }
SendEmailService.java
package com.example.demo.service; import com.example.demo.entity.EmailDto; public interface SendEmailService { void sendEmail(EmailDto emailDto); }
SendEmailServiceImpl.java
package com.example.demo.service.impl; import com.example.demo.entity.EmailDto; import com.example.demo.service.SendEmailService; import org.springframework.stereotype.Service; @Service public class SendEmailServiceImpl implements SendEmailService { @Override public void sendEmail(EmailDto emailDto) { try { // 模拟耗时3秒 Thread.sleep(3 * 1000); } catch (Exception e) { System.out.println("Email发送异常"); } System.out.println("Email发送成功 " + emailDto); } }
IndexController.java
package com.example.demo.controller; import com.example.demo.entity.EmailDto; import com.example.demo.event.SendEmailEvent; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationEventPublisher; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class IndexController { @Autowired private ApplicationEventPublisher publisher; @GetMapping("/sendEmail") public String sendEmail() { EmailDto emailDto = new EmailDto(); emailDto.setEmail("tom@qq.com"); emailDto.setSubject("邮件标题"); emailDto.setContent("邮件内容"); // 发布事件 publisher.publishEvent(new SendEmailEvent(emailDto)); return "success"; } }
到此这篇关于详解SpringBoot实现ApplicationEvent事件的监听与发布的文章就介绍到这了,更多相关SpringBoot ApplicationEvent事件监听发布内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
关于QueryWrapper,实现MybatisPlus多表关联查询方式
这篇文章主要介绍了关于QueryWrapper,实现MybatisPlus多表关联查询方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教。2022-01-01SpringBoot集成Nacos实现注册中心与配置中心流程详解
这篇文章主要介绍了SpringBoot集成Nacos实现注册中心与配置中心流程,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习吧2023-02-02Spring Security基于JWT实现SSO单点登录详解
这篇文章主要介绍了Spring Security基于JWT实现SSO单点登录详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2019-09-09在SpringBoot中注入RedisTemplate实例异常的解决方案
这篇文章主要介绍了在SpringBoot中注入RedisTemplate实例异常的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教2022-01-01基于idea 的 Java中的get/set方法之优雅的写法
这篇文章主要介绍了基于idea 的 Java中的get/set方法之优雅的写法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧2019-01-01Java实现调用ElasticSearch API的示例详解
这篇文章主要为大家详细介绍了Java调用ElasticSearch API的效果资料,文中的示例代码讲解详细,具有一定的参考价值,感兴趣的可以了解一下2023-03-03
最新评论