这篇文章主要介绍“SpringBoot如何实现ApplicationEvent事件的监听与发布”，在日常操作中，相信很多人在SpringBoot如何实现ApplicationEvent事件的监听与发布问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”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";
}
}