在我们的工作中,常常会用到异步处理任务,比如我们在网站上发送邮件,后台会去发送邮件,此时前台会造成响应不动,直到邮件发送完毕,响应才会成功,所以我们一般会采用多线程的方式去处理这些任务。还有一些定时任务,比如需要在每天凌晨的时候,分析一次前一天的日志信息。还有就是邮件的发送,微信的前身也是邮件服务呢?这些东西都是怎么实现的呢?其实SpringBoot都给我们提供了对应的支持,我们上手使用十分的简单,只需要开启一些注解支持,配置一些配置文件即可!那我们来看看吧~

异步任务

1.创建一个SpringBoot项目导入Web模块。创建一个Service包

image-20200414214720750

2.创建一个AsyncService类.编写方法,假装正在处理数据,使用线程设置一些延时,模拟同步等待的情况。

1
2
3
4
5
6
7
8
9
10
11
12
@Service
public class AsyncService {
public void hello(){

try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("数据正在处理....");
}
}

image-20200414214929685

异步处理还是非常常用的,比如我们在网站上发送邮件,后台会去发送邮件,此时前台会造成响应不动,直到邮件发送完毕,响应才会成功,所以我们一般会采用多线程的方式去处理这些任务。

3.编写controller包.创建一个AsyncController类

1
2
3
4
5
6
7
8
9
10
11
12
@RestController
public class AsyncController {

@Autowired
AsyncService asyncService;

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

image-20200414215150649

5.启动项目访问http://localhost:8080/hello 进行测试,3秒后出现ok,这是同步等待的情况。

2154

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

6、给hello方法添加@Async注解.

image-20200414215930622

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

1
2
3
4
5
6
7
8
@EnableAsync//开启异步注解功能
@SpringBootApplication
public class Springboot09TestApplication {

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

image-20200414220042969

7.重启测试,网页瞬间响应,后台代码依旧执行!实现了异步任务~

2202

定时任务

项目开发中经常需要执行一些定时任务,比如需要在每天凌晨的时候,分析一次前一天的日志信息,Spring为我们提供了异步执行任务调度的方式,提供了两个接口。

  • TaskExecutor接口
  • TaskScheduler接口

两个注解:

  • @EnableScheduling
  • @Scheduled

1.创建一个ScheduledService.我们里面存在一个hello方法,他需要定时执行,怎么处理呢?使用@Scheduled注解,写入cron表达式值。

1
2
3
4
5
6
7
8
9
10
@Service
public class ScheduledService {
//在一个特定的时间执行这个方法~Timer
//cron表达式
//秒 分 时 日 月 周几
@Scheduled(cron = "0 20 10 * * ?")//每天10点20分整执行
public void hello() {
System.out.println("hello,你被执行了");
}
}

2.这里写完定时任务之后,我们需要在主程序上增加@EnableScheduling 开启定时任务功能

image-20200415094911988

1
2
3
4
5
6
7
8
9
@EnableAsync//开启异步注解功能
@EnableScheduling//开启定时功能的注解
@SpringBootApplication
public class Springboot09TestApplication {

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

3.启动项目测试。core表达式值设为为每天9.54分执行任务(方便我测试)。

954

在9.54时执行了hello方法。打印出了输出语句。

core表达式

字段 允许值 允许的特殊字符
0-59 , - * /
0-59 , - * /
小时 0-23 , - * /
日期 1-31 , - * ? / L W C
月份 1-12 或者 JAN-DEC , - * /
星期 1-7 或者 SUN-SAT , - * ? / L C #
年(可为空) 留空, 1970-2099 , - * /

允许值范围: 0~59 ,不允许为空值,若值不合法,调度器将抛出SchedulerException异常

“*” 代表每隔1秒钟触发

“,” 代表在指定的秒数触发,比如”0,15,45”代表0秒、15秒和45秒时触发任务

“-“ 代表在指定的范围内触发,比如”25-45”代表从25秒开始触发到45秒结束触发,每隔1秒触发1次

“/“ 代表触发步进(step),”/“前面的值代表初始值(“*”等同”0”),后面的值代表偏移量,比如”0/20”或者”*/20”代表从0秒钟开始,每隔20秒钟触发1次,即0秒触发1次,20秒触发1次,40秒触发1次;”5/20”代表5秒触发1次,25秒触发1次,45秒触发1次;”10-45/20”代表在[10,45]内步进20秒命中的时间点触发,即10秒触发1次,30秒触发1次

分钟

允许值范围: 0~59 ,不允许为空值,若值不合法,调度器将抛出SchedulerException异常

“*” 代表每隔1分钟触发

“,” 代表在指定的分钟触发,比如”10,20,40”代表10分钟、20分钟和40分钟时触发任务

“-“ 代表在指定的范围内触发,比如”5-30”代表从5分钟开始触发到30分钟结束触 发,每隔1分钟触发

“/“ 代表触发步进(step),”/“前面的值代表初始值(“*”等同”0”),后面的值代表偏移量,比如”0/25”或者”*/25”代表从0分钟开始,每隔25分钟触发1次,即0分钟触发1次,第25分钟触发1次,第50分钟触发1次;”5/25”代表5分钟触发1次,30分钟触发1次,55分钟触发1次;”10-45/20”代表在[10,45]内步进20分钟命中的时间点触发,即10分钟触发1次,30分钟触发1次

小时

允许值范围: 0~23 ,不允许为空值,若值不合法,调度器将抛出SchedulerException异常

“*” 代表每隔1小时触发

“,” 代表在指定的时间点触发,比如”10,20,23”代表10点钟、20点钟和23点触发任务

“-“ 代表在指定的时间段内触发,比如”20-23”代表从20点开始触发到23点结束触发,每隔1小时触发

“/“ 代表触发步进(step),”/“前面的值代表初始值(“*”等同”0”),后面的值代表偏移量,比如”0/1”或者”*/1”代表从0点开始触发,每隔1小时触发1次;”1/2”代表从1点开始触发,以后每隔2小时触发一次

日期

允许值范围: 1~12 (JAN-DEC),不允许为空值,若值不合法,调度器将抛出SchedulerException异常

“*” 代表每个月都触发

“,” 代表在指定的月份触发,比如”1,6,12”代表1月份、6月份和12月份触发任务

“-“ 代表在指定的月份范围内触发,比如”1-6”代表从1月份开始触发到6月份结束触发,每隔1个月触发

“/“ 代表触发步进(step),”/“前面的值代表初始值(“*”等同”1”),后面的值代表偏移量,比如”1/2”或者”*/2”代表从1月份开始触发,每隔2个月触发1次;”6/6”代表从6月份开始触发,以后每隔6个月触发一次;”1-6/12”表达式意味着每年1月份触发

星期

允许值范围: 1~7 (SUN-SAT),1代表星期天(一星期的第一天),以此类推,7代表星期六(一星期的最后一天),不允许为空值,若值不合法,调度器将抛出SchedulerException异常

“*” 代表每星期都触发;

“?” 与{日期}互斥,即意味着若明确指定{日期}触发,则表示{星期}无意义,以免引起冲突和混乱

“,” 代表在指定的星期约定触发,比如”1,3,5”代表星期天、星期二和星期四触发

“-“ 代表在指定的星期范围内触发,比如”2-4”代表从星期一开始触发到星期三结束触发,每隔1天触发

“/“ 代表触发步进(step),”/“前面的值代表初始值(“*”等同”1”),后面的值代表偏移量,比如”1/3”或者”*/3”代表从星期天开始触发,每隔3天触发1次;”1-5/2”表达式意味着在[1,5]范围内,每隔2天触发,即星期天、星期二、星期四触发

“L” 如果{星期}占位符如果是”L”,即意味着星期的的最后一天触发,即星期六触发,L= 7或者 L = SAT,因此,”5L”意味着一个月的最后一个星期四触发

“#” 用来指定具体的周数,”#”前面代表星期,”#”后面代表本月第几周,比如”2#2”表示本月第二周的星期一,”5#3”表示本月第三周的星期四,因此,”5L”这种形式只不过是”#”的特殊形式而已

年份

允许值范围: 1970~2099 ,允许为空,若值不合法,调度器将抛出SchedulerException异常

“*”代表每年都触发

“,”代表在指定的年份才触发,比如”2011,2012,2013”代表2011年、2012年和2013年触发任务

“-“代表在指定的年份范围内触发,比如”2011-2020”代表从2011年开始触发到2020年结束触发,每隔1年触发

“/“代表触发步进(step),”/“前面的值代表初始值(“*”等同”1970”),后面的值代表偏移量,比如”2011/2”或者”*/2”代表从2011年开始触发,每隔2年触发1次

注意:除了{日期}和{星期}可以使用”?”来实现互斥,表达无意义的信息之外,其他占位符都要具有具体的时间含义,且依赖关系为:年->月->日期(星期)->小时->分钟->秒数

特殊字符

“*”

”字符被用来指定所有的值。如:”“在分钟的字段域里表示“每分钟”。

“?”

“?”字符只在日期域和星期域中使用。它被用来指定“非明确的值”。当你需要通过在这两个域中的一个来指定一些东西的时候,它是有用的。看下面的例子你就会明白。 月份中的日期和星期中的日期这两个元素时互斥的一起应该通过设置一个问号来表明不想设置那个字段。

“-”

“-”字符被用来指定一个范围。如:“10-12”在小时域意味着“10点、11点、12点”。

“,”

“,”字符被用来指定另外的值。如:“MON,WED,FRI”在星期域里表示”星期一、星期三、星期五”。

“/”

“/”字符用于指定增量。如:“0/15”在秒域意思是每分钟的0,15,30和45秒。“5/15”在分钟域表示每小时的5,20,35和50。符号“”在“/”前面(如:/10)等价于0在“/”前面(如:0/10)。记住一条本质:表达式的每个数值域都是一个有最大值和最小值的集合,如:秒域和分钟域的集合是0-59,日期域是1-31,月份域是1-12。字符“/”可以帮助你在每个字符域中取相应的数值。如:“7/6”在月份域的时候只有当7月的时候才会触发,并不是表示每个6月。

“L”

L是‘last’的省略写法可以表示day-of-month和day-of-week域,但在两个字段中的意思不同,例如day-of-month域中表示一个月的最后一天。如果在day-of-week域表示‘7’或者‘SAT’,如果在day-of-week域中前面加上数字,它表示一个月的最后几天,例如‘6L’就表示一个月的最后一个星期五。

“W”

字符“W”只允许日期域出现。这个字符用于指定日期的最近工作日。例如:如果你在日期域中写 “15W”,表示:这个月15号最近的工作日。所以,如果15号是周六,则任务会在14号触发。如果15好是周日,则任务会在周一也就是16号触发。如果是在日期域填写“1W”即使1号是周六,那么任务也只会在下周一,也就是3号触发,“W”字符指定的最近工作日是不能够跨月份的。字符“W”只能配合一个单独的数值使用,不能够是一个数字段,如:1-15W是错误的。

“L”和“W”可以在日期域中联合使用,LW表示这个月最后一周的工作日。

“#”

字符“#”只允许在星期域中出现。这个字符用于指定本月的某某天。例如:“6#3”表示本月第三周的星期五(6表示星期五,3表示第三周)。“2#1”表示本月第一周的星期一。“4#5”表示第五周的星期三。

“C”

字符“C”允许在日期域和星期域出现。这个字符依靠一个指定的“日历”。也就是说这个表达式的值依赖于相关的“日历”的计算结果,如果没有“日历”关联,则等价于所有包含的“日历”。如:日期域是“5C”表示关联“日历”中第一天,或者这个月开始的第一天的后5天。星期域是“1C”表示关联“日历”中第一天,或者星期的第一天的后1天,也就是周日的后一天(周一)。

表达式举例

“0 0 12 * * ?” 每天中午12点触发

“0 15 10 ? * *” 每天上午10:15触发

“0 15 10 * * ?” 每天上午10:15触发

“0 15 10 * * ? *” 每天上午10:15触发

“0 15 10 * * ? 2005” 2005年的每天上午10:15触发

“0 * 14 * * ?” 在每天下午2点到下午2:59期间的每1分钟触发

“0 0/5 14 * * ?” 在每天下午2点到下午2:55期间的每5分钟触发

“0 0/5 14,18 * * ?” 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发

“0 0-5 14 * * ?” 在每天下午2点到下午2:05期间的每1分钟触发

“0 10,44 14 ? 3 WED” 每年三月的星期三的下午2:10和2:44触发

“0 15 10 ? * MON-FRI” 周一至周五的上午10:15触发

“0 15 10 15 * ?” 每月15日上午10:15触发

“0 15 10 L * ?” 每月最后一日的上午10:15触发

“0 15 10 ? * 6L” 每月的最后一个星期五上午10:15触发

“0 15 10 ? * 6L 2002-2005” 2002年至2005年的每月的最后一个星期五上午10:15触发

“0 15 10 ? * 6#3” 每月的第三个星期五上午10:15触发

邮件任务

邮件发送,在我们的日常开发中,也非常的多,Springboot也帮我们做了支持

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

1.引入pom依赖

1
2
3
4
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>

image-20200415100124557

看它引入的依赖,可以看到 jakarta.mail

1
2
3
4
5
6
<dependency>
<groupId>com.sun.mail</groupId>
<artifactId>jakarta.mail</artifactId>
<version>1.6.4</version>
<scope>compile</scope>
</dependency>

2.查看自动配置类:MailSenderAutoConfiguration

image-20200415100753806

image-20200415100820640

然后我们去看下配置文件

image-20200415101054538

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@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.编写配置文件,qq邮箱需要配置ssl

image-20200415101154716

1
2
3
4
5
spring.mail.username=zhang171346168@qq.com
spring.mail.password=授权码
spring.mail.host=smtp.qq.com
#开启加密验证
spring.mail.properties.maill.smtp.ssl.enable=true

获取授权码:在QQ邮箱中的设置->账户->开启pop3和smtp服务

image-20200415101433647

4.Spring单元测试

发送一个简单的邮件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
@Test
void contextLoads() {
//一个简单的邮件
SimpleMailMessage mailMessage = new SimpleMailMessage();

//邮件标题
mailMessage.setSubject("hello,kylin");
//邮件信息
mailMessage.setText("谢谢~");

//收件人
mailMessage.setTo("zhang171346168@qq.com");
//发件人
mailMessage.setFrom("zhang171346168@qq.com");
mailSender.send(mailMessage);
}

image-20200415101604639

发送一封复杂的邮件。带html页面,附件。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
@Test
void contextLoads2() throws MessagingException {
//一个复杂的邮件
MimeMessage mimeMessage = mailSender.createMimeMessage();
//组装
MimeMessageHelper helper = new MimeMessageHelper(mimeMessage,true);//开启多文件

//正文
helper.setSubject("hello,kylin-plus");
helper.setText("<p style='color:red'>非常感谢<p>",true);

//附件
helper.addAttachment("1.jpg",new File("C:\\Users\\kylin\\Pictures\\5a5dafa07cfe3.jpg"));

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

mailSender.send(mimeMessage);
}

image-20200415101746388

启动测试

image-20200415101936439

image-20200415101949110

image-20200415102005944

查看邮箱,邮件接收成功!