SpringBoot【四】任务

任务

异步任务

在 service 包下建一个 AsyncService 类，编写一个方法，假装正在处理数据，使用线程设置一些延时，模拟同步等待的情况

@Service
public class AsyncService {

    public void hello(){
        try {
            Thread.sleep(3000); //模拟延迟
        } catch (InterruptedException e){
            e.printStackTrace();
        }
        System.out.println("数据正在处理。。。");
    }
}

在 controller 包下建一个 AsyncController 类

@RestController
public class AsyncController {

    @Autowired
    AsyncService asyncService;

    @RequestMapping("/hello")
    public String hello(){
        asyncService.hello();
        return "OK";
    }
}

测试，访问 http://localhost:8080/hello ，3 秒之后才出现 OK，这是同步等待的情况

问题：如果想让用户直接得到消息，就在后台使用多线程的方式进行处理即可，但是每次都需要自己手动去编写多线程的实现的话太麻烦，我们只需要用一个简单的办法，在方法上加一个简单的注解即可

给 hello 方法添加 @Async 注解

// 告诉Spring这是一个异步方法
@Async
public void hello(){
    try {
        Thread.sleep(3000); //模拟延迟
    } catch (InterruptedException e){
        e.printStackTrace();
    }
    System.out.println("数据正在处理。。。");
}

SpringBoot 会自己开一个线程池，进行调用，但是要让这个注解生效，还需要在主程序上添加一个注解@EnableAsync，开启异步注解功能

// 开启异步注解功能
@EnableAsync
@SpringBootApplication
public class Springboot09TestApplication {
   public static void main(String[] args) {
      SpringApplication.run(Springboot09TestApplication.class, args);
   }
}

重启测试，网页瞬间响应，后台代码依旧会有 3 秒的处理时间。

定时任务

接口：
- TaskExecutor 任务执行者
- TaskScheduler 任务调度者
注解：
- @EnableScheduling // 开启定时功能的注解
- @Scheduled //什么时候执行
corn 表达式
- 在线生成网站：http://www.bejson.com/othertools/cron/

创建一个 ScheduledService 类，编写一个方法，这个方法需要定时执行

@Service
public class ScheduledService {

    // 让这个方法在一个特定的时间执行
    // cron 表达式
    // 秒 分 时 日 月 周几
    /*
        "30 10 18 * * ?"  每天的 18点10分30秒 执行一次
        "30 0/5 10,18 * * ?"  每天的 10点和18点，每隔5分钟 执行一次
     */
    @Scheduled(cron = "0 10 18 * * ?")
    public void hello(){
        System.out.println("hello，你被执行了");
    }
}

编写完定时任务之后，需要在主程序上增加 @EnableScheduling 开启定时任务功能

@EnableAsync // 开启异步注解功能
@EnableScheduling // 开启定时功能的注解
@SpringBootApplication
public class Springboot09TestApplication {
   public static void main(String[] args) {
      SpringApplication.run(Springboot09TestApplication.class, args);
   }
}

邮件发送

邮件发送需要引入spring-boot-start-mail
SpringBoot 自动配置MailSenderAutoConfiguration
定义MailProperties内容，配置在application.yml中
自动装配JavaMailSender
测试邮件发送

导入依赖

<!--javax.mail：配置-->
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-mail</artifactId>
</dependency>

查看自动配置类：MailSenderAutoConfiguration，这个类中存在 bean，JavaMailSenderImpl

配置信息类为 MailProperity

@ConfigurationProperties(prefix = "spring.mail")
public class MailProperties {
   private static final Charset DEFAULT_CHARSET = StandardCharsets.UTF_8;
   private String host;
   private Integer port;
   private String username;
   private String password;
   private String protocol = "smtp";
   private Charset defaultEncoding = DEFAULT_CHARSET;
   private Map<String, String> properties = new HashMap<>();
   private String jndiName;
    ...
}

自定义配置 application.properties

spring.mail.username=1064971297@qq.com
# 邮件授权码 gvrpmlapouwjbeci
spring.mail.password=gvrpmlapouwjbeci
spring.mail.host=smtp.qq.com
# 开启加密验证，qq邮箱需要开启
spring.mail.properties.mail.smtp.ssl.enable=true

注意：password 中为邮件授权码，通过【QQ邮箱中的设置->账户->开启pop3和smtp服务】获取

Spring 单元测试

@Autowired
JavaMailSenderImpl mailSender;

@Test
void contextLoads() {
   //一个简单的邮件
   SimpleMailMessage mailMessage = new SimpleMailMessage();

   mailMessage.setSubject("这是主题");
   mailMessage.setText("这是内容");
   mailMessage.setTo("1064971297@qq.com");
   mailMessage.setFrom("1064971297@qq.com");

   mailSender.send(mailMessage);
}

@Test
void contextLoads2() throws MessagingException {
    //一个复杂的邮件
    MimeMessage mimeMessage = mailSender.createMimeMessage();
    //组装
    MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
    helper.setSubject("主题");
    helper.setText("<p style='color:red'>内容</p>", true); //true开启html支持
    // 附件
    helper.addAttachment("1.jpg", new File("C:\Users\Administrator\Desktop\1.jpg"));
    helper.addAttachment("2.jpg", new File("C:\Users\Administrator\Desktop\1.jpg"));

    helper.setTo("1064971297@qq.com");
    helper.setFrom("1064971297@qq.com");

    mailSender.send(mimeMessage);
}

运行，查看邮箱，邮件接收成功。

抽取一个邮件发送的方法：

/**
 * @param html
 * @param subject
 * @param text
 * @param thtml
 * @param filename
 * @param file
 * @param to
 * @param from
 * @throws MessagingException
 * @Author Songzw
 */
public void sendMail(Boolean html, String subject, String text, boolean thtml, String filename, File file, String to, String from) throws MessagingException {
   //一个复杂的邮件
   MimeMessage mimeMessage = mailSender.createMimeMessage();
   //组装
   MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, html);
   helper.setSubject(subject);
   helper.setText(text, thtml); //true开启html支持
   // 附件
   helper.addAttachment(filename, file);

   helper.setTo(to);
   helper.setFrom(from);

   mailSender.send(mimeMessage);
}

SpringBoot【四】 任务

任务

异步任务

定时任务

邮件发送

SpringBoot【四】任务