这篇文章主要介绍“SpringBoot如何实现ApplicationEvent事件的监听与发布”，在日常操作中，相信很多人在SpringBoot如何实现ApplicationEvent事件的监听与发布问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”SpringBoot如何实现ApplicationEvent事件的监听与发布”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
通过发布订阅模式实现数据的异步处理，比如异步处理邮件发送
项目结构
.
├── 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
<?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>
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);
}
}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;
}
}package com.example.demo.entity;
import lombok.Data;
@Data
public class EmailDto {
private String email;
private String subject;
private String content;
}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;
}
}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);
}
}package com.example.demo.service;
import com.example.demo.entity.EmailDto;
public interface SendEmailService {
void sendEmail(EmailDto emailDto);
}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);
}
}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事件的监听与发布”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
