前言
最近看了下springboot的异步操作，学到了使用async注解来实现异步操作的功能，这不就立马把项目中的发送邮件通知就都换成了异步的操作，而不是去新建一个线程来发送通知，虽然async注解也是通过新线程的方式来实现，但就很美观。下面就来看看async的简单示例
1. 启动类添加注解@EnableAsync
@SpringBootApplication @MapperScan(basePackages = {"com.fyg.mapper"}) @ServletComponentScan @EnableAsync public class BlogApplication { public static void main(String[] args) throws UnknownHostException { ConfigurableApplicationContext application = SpringApplication.run(BlogApplication.class, args); Environment env = application.getEnvironment(); String ip = InetAddress.getLocalHost().getHostAddress(); String port = env.getProperty("server.port"); String path = env.getProperty("server.servlet.context-path"); System.out.println("\n----------------------------------------------------------\n\t" + "blog is running! Access URLs:\n\t" + "Local: \t\thttp://localhost:" + port + path + "/\n\t" + "External: \thttp://" + ip + ":" + port + path + "/\n\t" + "Knife4j-ui: \thttp://" + ip + ":" + port + path + "/doc.html\n\t" + "----------------------------------------------------------"); } }
2. 在使用的方法上添加注解@Async
@Async("threadPoolTaskExecutor") public void emailNoticeMe(String subject,String content) { // 构建一个邮件对象 SimpleMailMessage message = new SimpleMailMessage(); // 设置邮件主题 message.setSubject(subject); // 设置邮件发送者 message.setFrom(Objects.requireNonNull(javaMailSender.getUsername())); // 设置邮件接收者，可以有多个接收者，中间用逗号隔开 message.setTo("1248954763@qq.com"); // 设置邮件发送日期 message.setSentDate(new Date()); // 设置邮件的正文 message.setText(content); // 发送邮件 javaMailSender.send(message); }
可以指定线程池的名称，以上代码我是已经指定了，不指定名称就会使用默认的线程池
3.调用
@Transactional(rollbackFor = Exception.class) public ResponseResult applyFriendLink(FriendLink friendLink) { Assert.isTrue(StringUtils.isNotBlank(friendLink.getUrl()),"输入正确的网址!"); friendLink.setStatus(APPLY.getCode()); Assert.isTrue(!friendLink.getUrl().contains("fyg.com") && !friendLink.getUrl().contains("baidu.com"),"不合法的网址！"); //如果已经申请过友链 再次接入则会进行下架处理 需重新审核 FriendLink entity = baseMapper.selectOne(new QueryWrapper<FriendLink>() .eq(SqlConf.URL,friendLink.getUrl())); if (entity != null) { friendLink.setId(entity.getId()); baseMapper.updateById(friendLink); }else { baseMapper.insert(friendLink); } //异步操作邮箱发送 emailService.emailNoticeMe("友链接入通知","网站有新的友链接入啦("+friendLink.getUrl()+")，快去审核吧!!!"); return ResponseResult.success(); }
需要注意的是调用方法和被调用方法不能在同类中，否则就会失效
