1. 程式人生 > 其它 >SpringBoot17:非同步、定時、郵件任務

SpringBoot17:非同步、定時、郵件任務

非同步任務

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;

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

5、訪問http://localhost:8080/hello進行測試,3秒後出現OK,這是同步等待的情況。

問題:我們如果想讓使用者直接得到訊息,就在後臺使用多執行緒的方式進行處理即可,但是每次都需要自己手動去編寫多執行緒的實現的話,太麻煩了,我們只需要用一個簡單的辦法,在我們的方法上加一個簡單的註解即可,如下:

6、給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 Springboot09AsyncApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springboot09AsyncApplication.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.7</version>
  <scope>compile</scope>
</dependency>

2、檢視自動配置類:MailSenderAutoConfiguration

這個類中存在bean,JavaMailSenderImpl

然後我們去看下配置檔案

@ConfigurationProperties(
    prefix = "spring.mail"
)
public class MailProperties {
    private static final Charset DEFAULT_CHARSET;
    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=eccvnqzboomveijb
spring.mail.host=smtp.qq.com
# qq需要配置ssl
spring.mail.properties.mail.smtp.ssl.enabl=true

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

4、Spring單元測試

package com.edgar;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSenderImpl;
import org.springframework.mail.javamail.MimeMessageHelper;

import javax.mail.MessagingException;
import javax.mail.internet.MimeMessage;
import java.io.File;

@SpringBootTest
class Springboot09AsyncApplicationTests {

    @Autowired
    JavaMailSenderImpl mailSender;
    @Test
    void contextLoads() {

        // 一個簡單的郵件~
        SimpleMailMessage mailMessage = new SimpleMailMessage();
        mailMessage.setSubject("小狂神你好呀~");
        mailMessage.setText("謝謝你的狂神說系列課程~");

        mailMessage.setTo("[email protected]");
        mailMessage.setFrom("[email protected]");
        mailSender.send(mailMessage);

    }

    @Test
    void contextLoads2() throws MessagingException {

        // 一個複雜的郵件~
        MimeMessage mimeMessage = mailSender.createMimeMessage();
        // 組裝
        MimeMessageHelper helper = new MimeMessageHelper(mimeMessage,true);

        helper.setSubject("小狂神你好呀~plus");
        helper.setText("<p style='color:red'>謝謝你的狂神說系列課程~</p>",true);

        // 附件
        helper.addAttachment("1.jpg",new File("C:\\Users\\86152\\Pictures\\tool\\1.jpg"));
        helper.addAttachment("2.jpg",new File("C:\\Users\\86152\\Pictures\\tool\\1.jpg"));
        helper.setTo("[email protected]");
        helper.setFrom("[email protected]");
        mailSender.send(mimeMessage);

    }
}

檢視郵箱,郵件接收成功!

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

定時任務

專案開發中經常需要執行一些定時任務,比如需要在每天凌晨的時候,分析一次前一天的日誌資訊,Spring為我們提供了非同步執行任務排程的方式,提供了兩個介面。

  • TaskExecutor介面
  • TaskScheduler介面

兩個註解:

  • @EnableScheduling
  • @Scheduled

cron表示式詳解

Cron表示式是一個字串,字串以5或6個空格隔開,分為6或7個域,每一個域代表一個含義,Cron有如下兩種語法格式:

​ (1) Seconds Minutes Hours DayofMonth Month DayofWeek Year

​ (2)Seconds Minutes Hours DayofMonth Month DayofWeek

  

一、結構

corn從左到右(用空格隔開):秒 分 小時 月份中的日期 月份 星期中的日期 年份

二、各欄位的含義

欄位 允許值 允許的特殊字元
秒(Seconds) 0~59的整數 , - * / 四個字元
分(Minutes 0~59的整數 , - * / 四個字元
小時(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 , - * / 四個字元

注意事項:

  每一個域都使用數字,但還可以出現如下特殊字元,它們的含義是:

  (1):表示匹配該域的任意值。假如在Minutes域使用, 即表示每分鐘都會觸發事件。

  (2)?:只能用在DayofMonth和DayofWeek兩個域。它也匹配域的任意值,但實際不會。因為DayofMonth和DayofWeek會相互影響。例如想在每月的20日觸發排程,不管20日到底是星期幾,則只能使用如下寫法: 13 13 15 20 * ?, 其中最後一位只能用?,而不能使用,如果使用表示不管星期幾都會觸發,實際上並不是這樣。

  (3)-:表示範圍。例如在Minutes域使用5-20,表示從5分到20分鐘每分鐘觸發一次

  (4)/:表示起始時間開始觸發,然後每隔固定時間觸發一次。例如在Minutes域使用5/20,則意味著5分鐘觸發一次,而25,45等分別觸發一次.

  (5),:表示列出列舉值。例如:在Minutes域使用5,20,則意味著在5和20分每分鐘觸發一次。

  (6)L:表示最後,只能出現在DayofWeek和DayofMonth域。如果在DayofWeek域使用5L,意味著在最後的一個星期四觸發。

  (7)W:表示有效工作日(週一到週五),只能出現在DayofMonth域,系統將在離指定日期的最近的有效工作日觸發事件。例如:在 DayofMonth使用5W,如果5日是星期六,則將在最近的工作日:星期五,即4日觸發。如果5日是星期天,則在6日(週一)觸發;如果5日在星期一到星期五中的一天,則就在5日觸發。另外一點,W的最近尋找不會跨過月份 。

  (8)LW:這兩個字元可以連用,表示在某個月最後一個工作日,即最後一個星期五。

  (9)#:用於確定每個月第幾個星期幾,只能出現在DayofWeek域。例如在4#2,表示某月的第二個星期三。

 三、常用表示式例子

  (0)0/20 * * * * ? 表示每20秒 調整任務

  (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觸發

測試步驟:

1、建立一個ScheduledService

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

// 秒   分   時     日   月   周幾
// 0 * * * * MON-FRI
// 注意cron表示式的用法;
@Scheduled(cron = "0/10 * * * * ?")
public void hello(){
    System.out.println("hello,你被執行了~");
}

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

@EnableAsync // 開啟非同步註解功能
@EnableScheduling // 開啟定時功能的註解
@SpringBootApplication
public class Springboot09AsyncApplication {

    public static void main(String[] args) {
        SpringApplication.run(Springboot09AsyncApplication.class, args);
    }

}

3、我們來詳細瞭解下cron表示式;

http://www.bejson.com/othertools/cron/