天天看點
傳回

異步、定時、郵件任務

異步、定時、郵件任務

在我們的工作中，常常會用到異步處理任務，比如我們在網站上發送郵件，背景會去發送郵件，此時前台會造成響應不動，直到郵件發送完畢，響應才會成功，是以我們一般會采用多線程的方式去處理這些任務。還有一些定時任務，比如需要在每天淩晨的時候，分析一次前一天的日志資訊。還有就是郵件的發送，微信的前身也是郵件服務呢？這些東西都是怎麼實作的呢？其實SpringBoot都給我們提供了對應的支援，我們上手使用十分的簡單，隻需要開啟一些注解支援，配置一些配置檔案即可！那我們來看看吧~

20.1、異步任務

1、建立一個service包

2、建立一個類AsyncService

異步處理還是非常常用的，比如我們在網站上發送郵件，背景會去發送郵件，此時前台會造成響應不動，直到郵件發送完畢，響應才會成功，是以我們一般會采用多線程的方式去處理這些任務。

編寫方法，假裝正在處理資料，使用線程設定一些延時，模拟同步等待的情況；

@Service
public class AsyncService {
    public void hello(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("業務進行中....");
    }
}

3、編寫controller包

4、編寫AsyncController類

我們去寫一個Controller測試一下

@RestController
public class AsyncController {
    @Autowired
    AsyncService asyncService;
    @GetMapping("/hello")
    public String hello(){
        asyncService.hello();
        return "success";
    }
}

5、通路http://localhost:8080/hello進行測試，3秒後出現success，這是同步等待的情況。

問題：我們如果想讓使用者直接得到消息，就在背景使用多線程的方式進行處理即可，但是每次都需要自己手動去編寫多線程的實作的話，太麻煩了，我們隻需要用一個簡單的辦法，在我們的方法上加一個簡單的注解即可，如下：

6、給hello方法添加@Async注解；

@Service
public class AsyncService {
    //告訴Spring這是一個異步方法
    @Async
    public void hello(){
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("業務進行中....");
    }
}

SpringBoot就會自己開一個線程池，進行調用！但是要讓這個注解生效，我們還需要在主程式上添加一個注解@EnableAsync ，開啟異步注解功能；

@EnableAsync //開啟異步注解功能
@SpringBootApplication
public class SpringbootDemo09Application {
    public static void main(String[] args) {
        SpringApplication.run(SpringbootDemo09Application.class, args);
    }

}

7、重新開機測試，網頁瞬間響應，背景代碼依舊執行！

郵件任務

郵件發送，在我們的日常開發中，也非常的多，Springboot也幫我們做了支援

  • 郵件發送需要引入spring-boot-start-mail
  • SpringBoot 自動配置MailSenderAutoConfiguration
  • 定義MailProperties内容，配置在application.yml中
  • 自動裝配JavaMailSender
  • 測試郵件發送

測試：

1、引入pom依賴

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-mail</artifactId>
</dependency>

看它引入的依賴，可以看到 jakarta.mail

<dependency>
   <groupId>com.sun.mail</groupId>
   <artifactId>jakarta.mail</artifactId>
   <version>1.6.4</version>
   <scope>compile</scope>
</dependency>

2、檢視自動配置類：MailSenderAutoConfiguration

異步、定時、郵件任務

這個類中存在bean，JavaMailSenderImpl

然後我們去看下配置檔案

@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;
   private Map<String, String> properties;
   private String jndiName;
}

3、配置檔案：

[email protected]
spring.mail.password=你的qq授權碼
spring.mail.host=smtp.qq.com
# qq需要配置ssl
spring.mail.properties.mail.smtp.ssl.enable=true

擷取授權碼：在QQ郵箱中的設定->賬戶->開啟pop3和smtp服務

異步、定時、郵件任務

4、Spring單元測試

@Autowired
JavaMailSenderImpl mailSender;
@Test
public void contextLoads() {
   //郵件設定1：一個簡單的郵件
   SimpleMailMessage message = new SimpleMailMessage();
   message.setSubject("通知");
   message.setText("今晚7:30開會");
   message.setTo("[email protected]");
   message.setFrom("[email protected]");
   mailSender.send(message);
}
@Test
public void contextLoads2() throws MessagingException {
   //郵件設定2：一個複雜的郵件
   MimeMessage mimeMessage = mailSender.createMimeMessage();
   MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
   helper.setSubject("通知");
   helper.setText("<b style='color:red'>今天 7:30來開會</b>",true);
   //發送附件
   helper.addAttachment("1.jpg",new File(""));
   helper.addAttachment("2.jpg",new File(""));
   helper.setTo("[email protected]");
   helper.setFrom("[email protected]");
   mailSender.send(mimeMessage);
}

檢視郵箱，郵件接收成功！

我們隻需要使用Thymeleaf進行前後端結合即可開發自己網站郵件收發功能了！

封裝工具類：

/**
     * 
     * @param html:   是否開啟html
     * @param subject 郵件标題
     * @param text   郵件内容
     * @throws Exception
     */
@Test
public void sendMail(Boolean html, String subject, String text) throws Exception {
    //郵件設定2：一個複雜的郵件
    MimeMessage mimeMessage = mailSender.createMimeMessage();
    MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, html);
    helper.setSubject(subject);
    helper.setText(text,true);
    helper.setTo("[email protected]");
    helper.setFrom("[email protected]");
    mailSender.send(mimeMessage);
}

定時任務

項目開發中經常需要執行一些定時任務，比如需要在每天淩晨的時候，分析一次前一天的日志資訊，Spring為我們提供了異步執行任務排程的方式，提供了兩個接口。

  • TaskExecutor接口
  • TaskScheduler接口

兩個注解：

  • @EnableScheduling
  • @Scheduled

cron表達式：

　corn從左到右（用空格隔開）：秒 分 小時 月份中的日期 月份 星期中的日期 年份

字段 允許值 允許的特殊字元
秒（Seconds） 0~59的整數 , - * / 四個字元
分（Minutes）
小時（Hours） 0~23的整數
日期（DayofMonth） 1~31的整數（但是你需要考慮你月的天數） ,- * ? / L W C 八個字元
月份（Month） 1~12的整數或者 JAN-DEC
星期（DayofWeek） 1~7的整數或者 SUN-SAT （1=SUN） , - * ? / L C # 八個字元
年(可選，留白)（Year） 1970~2099
特殊字元 代表含義
, 枚舉 在Minutes域使用5,20，則意味着在5和20分每分鐘觸發一次。
- 表示範圍 例如在Minutes域使用5-20，表示從5分到20分鐘每分鐘觸發一次
* 任意
/ 表示起始時間開始觸發，然後每隔固定時間觸發一次，
? 日/星期沖突比對 隻能用在DayofMonth和DayofWeek兩個域
L 最後 如果在DayofWeek域使用5L,意味着在最後的一個星期四觸發。
W 工作日
C 和calendar聯系後計算過的值
# 用于确定每個月第幾個星期幾，4#2 某月的第二個星期三

測試步驟：-

1、建立一個ScheduledService

我們裡面存在一個hello方法，他需要定時執行，怎麼處理呢？

@Service
public class ScheduledService {
    //秒   分   時     日   月   周幾
    //0 * * * * MON-FRI
    //注意cron表達式的用法；
    @Scheduled(cron = "0 * * * * 0-7")
    public void hello(){
        System.out.println("hello.....");
    }
}

2、這裡寫完定時任務之後，我們需要在主程式上增加@EnableScheduling 開啟定時任務功能

@EnableAsync //開啟異步注解功能
@EnableScheduling //開啟基于注解的定時任務
@SpringBootApplication
public class SpringbootTaskApplication {
   public static void main(String[] args) {
       SpringApplication.run(SpringbootTaskApplication.class, args);
  }
}
           
（1）0/2 * * * * ?   表示每2秒 執行任務
（1）0 0/2 * * * ?   表示每2分鐘 執行任務
（1）0 0 2 1 * ?   表示在每月的1日的淩晨2點調整任務
（2）0 15 10 ? * MON-FRI   表示周一到周五每天上午10:15執行作業
（3）0 15 10 ? 6L 2002-2006   表示2002-2006年的每個月的最後一個星期五上午10:15執行作
（4）0 0 10,14,16 * * ?   每天上午10點，下午2點，4點
（5）0 0/30 9-17 * * ?   朝九晚五工作時間内每半小時
（6）0 0 12 ? * WED   表示每個星期三中午12點
（7）0 0 12 * * ?   每天中午12點觸發
（8）0 15 10 ? * *   每天上午10:15觸發
（9）0 15 10 * * ?     每天上午10:15觸發
（10）0 15 10 * * ?   每天上午10:15觸發
（11）0 15 10 * * ? 2005   2005年的每天上午10:15觸發
（12）0 * 14 * * ?     在每天下午2點到下午2:59期間的每1分鐘觸發
（13）0 0/5 14 * * ?   在每天下午2點到下午2:55期間的每5分鐘觸發
（14）0 0/5 14,18 * * ?     在每天下午2點到2:55期間和下午6點到6:55期間的每5分鐘觸發
（15）0 0-5 14 * * ?   在每天下午2點到下午2:05期間的每1分鐘觸發
（16）0 10,44 14 ? 3 WED   每年三月的星期三的下午2:10和2:44觸發
（17）0 15 10 ? * MON-FRI   周一至周五的上午10:15觸發
（18）0 15 10 15 * ?   每月15日上午10:15觸發
（19）0 15 10 L * ?   每月最後一日的上午10:15觸發
（20）0 15 10 ? * 6L   每月的最後一個星期五上午10:15觸發
（21）0 15 10 ? * 6L 2002-2005   2002年至2005年的每月的最後一個星期五上午10:15觸發
（22）0 15 10 ? * 6#3   每月的第三個星期五上午10:15觸發
spring 定時任務 郵件發送 發送郵件 多線程
上一篇: SpringBoot異步任務@Async
下一篇: celery (芹菜) 異步任務

繼續閱讀