springboot 中異步任務(wù),定時(shí)任務(wù),郵件任務(wù)詳解
更新時(shí)間：2023年09月04日 12:09:52 作者：吳法剛
這篇文章主要介紹了springboot 與異步任務(wù),定時(shí)任務(wù),郵件任務(wù),本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
異步任務(wù)
在Java應(yīng)用中，絕大多數(shù)情況下都是通過(guò)同步的方式來(lái)實(shí)現(xiàn)交互處理的；但是在處理與第三方系統(tǒng)交互的時(shí)候，容易造成響應(yīng)遲緩的情況，之前大部分都是使用多線程來(lái)完成此類(lèi)任務(wù)，其實(shí)，在Spring 3.x之后，就已經(jīng)內(nèi)置了@Async來(lái)完美解決這個(gè)問(wèn)題。
SpringBoot 實(shí)現(xiàn)比較簡(jiǎn)單主啟動(dòng)類(lèi):添加 注釋:@EnableAsync
@EnableScheduling
@EnableAsync
@MapperScan("com.hrp.**.dao")
@SpringBootApplication
public class EcsApplication {
public static void main(String[] args) {
SpringApplication.run(EcsApplication.class, args);
}
}業(yè)務(wù)方法添加 @Async
@Async
@Override
public void TestAsync() {
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("-------------");
}controller調(diào)用
@RequestMapping("myFreeMark")
public String myFreeMark(Map<String,Object> map){
map.put("name","zhangsan");
map.put("mydate",new Date());
asyncServer.TestAsync();
System.out.println("==================FreemarkerController=======myFreeMark=====");
return "myFreeMark";
}
訪問(wèn)看到控制臺(tái)打印順序可以知道TestAsync方法異步調(diào)用
定時(shí)任務(wù)
項(xiàng)目開(kāi)發(fā)中經(jīng)常需要執(zhí)行一些定時(shí)任務(wù)，比如需要在每天凌晨時(shí)候，分析一次前一天的日志信息。Spring為我們提供了異步執(zhí)行任務(wù)調(diào)度的方式，提供TaskExecutor 、TaskScheduler 接口。
主啟動(dòng)類(lèi):增加@EnableScheduling
@EnableScheduling
@EnableAsync
@MapperScan("com.hrp.**.dao")
@SpringBootApplication
public class EcsApplication {
public static void main(String[] args) {
SpringApplication.run(EcsApplication.class, args);
}
}任務(wù)類(lèi):類(lèi)增加@Service或者@Compont注釋方法增加@Scheduled注解
@Service
public class BackUpMysqlTask {
/**
* Seconds : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為0-59的整數(shù)
* Minutes : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為0-59的整數(shù)
* Hours : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為0-23的整數(shù)
* DayofMonth : 可出現(xiàn)", - * / ? L W C"八個(gè)字符，有效范圍為0-31的整數(shù)
* Month : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為1-12的整數(shù)或JAN-DEc
* DayofWeek : 可出現(xiàn)", - * / ? L C #"四個(gè)字符，有效范圍為1-7的整數(shù)或SUN-SAT兩個(gè)范圍。1表示星期天，2表示星期一， 依次類(lèi)推
* Year : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為1970-2099年
*/
@Scheduled(cron = "0 * * * * MON-FRI")
public void backUpMysql() {
System.out.println("===============");
}
}我們可以觀察到控制臺(tái)不斷的再打印這里要講解cron
/**
* Seconds : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為0-59的整數(shù)
* Minutes : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為0-59的整數(shù)
* Hours : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為0-23的整數(shù)
* DayofMonth : 可出現(xiàn)", - * / ? L W C"八個(gè)字符，有效范圍為0-31的整數(shù)
* Month : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為1-12的整數(shù)或JAN-DEc
* DayofWeek : 可出現(xiàn)", - * / ? L C #"四個(gè)字符，有效范圍為1-7的整數(shù)或SUN-SAT兩個(gè)范圍。1表示星期天，2表示星期一， 依次類(lèi)推
* Year : 可出現(xiàn)", - * /"四個(gè)字符，有效范圍為1970-2099年
*/下面簡(jiǎn)單舉幾個(gè)例子：
“0 0 12 * * ?” 每天中午十二點(diǎn)觸發(fā)
“0 15 10 ? * *” 每天早上10：15觸發(fā)
“0 15 10 * * ?” 每天早上10：15觸發(fā)
“0 15 10 * * ? *” 每天早上10：15觸發(fā)
“0 15 10 * * ? 2005” 2005年的每天早上10：15觸發(fā)
“0 * 14 * * ?” 每天從下午2點(diǎn)開(kāi)始到2點(diǎn)59分每分鐘一次觸發(fā)
“0 0/5 14 * * ?” 每天從下午2點(diǎn)開(kāi)始到2：55分結(jié)束每5分鐘一次觸發(fā)
“0 0/5 14,18 * * ?” 每天的下午2點(diǎn)至2：55和6點(diǎn)至6點(diǎn)55分兩個(gè)時(shí)間段內(nèi)每5分鐘一次觸發(fā)
“0 0-5 14 * * ?” 每天14:00至14:05每分鐘一次觸發(fā)
“0 10,44 14 ? 3 WED” 三月的每周三的14：10和14：44觸發(fā)
“0 15 10 ? * MON-FRI” 每個(gè)周一、周二、周三、周四、周五的10：15觸發(fā)
郵件任務(wù)
準(zhǔn)備工作
做過(guò)郵件的都大家都知道
所以我們要是使用qq郵箱發(fā)送必須有登錄qq郵箱的權(quán)限
開(kāi)啟smtp服務(wù),發(fā)送短信我們就可以獲取一個(gè)授權(quán)碼,自己拷貝下來(lái)下圖的授權(quán)碼記錄下來(lái)
開(kāi)始
添加依賴
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>配置
mail:
host: smtp.qq.com 其他郵箱需要修改
username: 郵箱賬戶
password: 授權(quán)碼
properties:
mail:
smtp:
ssl:
enable: true測(cè)試代碼
@Autowired
private JavaMailSender javaMailSender;
@Test
void contextLoads() {
SimpleMailMessage simpleMailMessage = new SimpleMailMessage();
simpleMailMessage.setText("ddd");
simpleMailMessage.setSubject("主題");
simpleMailMessage.setTo("");
simpleMailMessage.setFrom("");
javaMailSender.send(simpleMailMessage);
}我們可以查收到郵件
上面是普通的郵件
發(fā)送html內(nèi)容
@Test
public void testSend() throws MessagingException {
MimeMessage mimeMessage = javaMailSender.createMimeMessage();
MimeMessageHelper messageHelper = new MimeMessageHelper(mimeMessage);
messageHelper.setSubject("標(biāo)題");
messageHelper.setTo("@dhcc.com.cn");
messageHelper.setFrom("@qq.com");
messageHelper.setText("<h1>標(biāo)題</h1><br/><p>這是內(nèi)容</p>", true);
javaMailSender.send(messageHelper.getMimeMessage());
}這里需要注意的是，setText的時(shí)候需要傳一個(gè)布爾值進(jìn)去，表名需要使用HTML樣式。
最后代碼附件
package com.hrp.msage.service;
import javax.mail.MessagingException;
/**
* ecs
*
* @Title: com.hrp.msage.service
* @Date: 2020/7/29 13:48
* @Author: wfg
* @Description:
* @Version:
*/
public interface MailService {
/**
* 簡(jiǎn)單文本郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet 郵件內(nèi)容
*/
public void sendSimpleMail(String to, String subject, String contnet);
/**
* HTML 文本郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet HTML內(nèi)容
* @throws MessagingException
*/
public void sendHtmlMail(String to, String subject, String contnet) throws MessagingException;
/**
* 附件郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet HTML內(nèi)容
* @param filePath 附件路徑
* @throws MessagingException
*/
public void sendAttachmentsMail(String to, String subject, String contnet,
String filePath) throws MessagingException;
/**
* 圖片郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet HTML內(nèi)容
* @param rscPath 圖片路徑
* @param rscId 圖片ID
* @throws MessagingException
*/
public void sendInlinkResourceMail(String to, String subject, String contnet,
String rscPath, String rscId);
}package com.hrp.msage.serviceImpl;
import com.hrp.msage.service.MailService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.FileSystemResource;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Service;
import javax.mail.MessagingException;
import javax.mail.internet.MimeMessage;
import java.io.File;
/**
* ecs
*
* @Title: com.hrp.msage.serviceImpl
* @Date: 2020/7/29 13:48
* @Author: wfg
* @Description:
* @Version:
*/
@Service("mailService")
public class MailServiceImpl implements MailService {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
@Value("${spring.mail.username}")
private String from;
@Autowired
private JavaMailSender mailSender;
/**
* 簡(jiǎn)單文本郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet 郵件內(nèi)容
*/
@Override
public void sendSimpleMail(String to, String subject, String contnet){
SimpleMailMessage message = new SimpleMailMessage();
message.setTo(to);
message.setSubject(subject);
message.setText(contnet);
message.setFrom(from);
mailSender.send(message);
}
/**
* HTML 文本郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet HTML內(nèi)容
* @throws MessagingException
*/
@Override
public void sendHtmlMail(String to, String subject, String contnet) throws MessagingException {
MimeMessage message = mailSender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(message, true);
helper.setTo(to);
helper.setSubject(subject);
helper.setText(contnet, true);
helper.setFrom(from);
mailSender.send(message);
}
/**
* 附件郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet HTML內(nèi)容
* @param filePath 附件路徑
* @throws MessagingException
*/
@Override
public void sendAttachmentsMail(String to, String subject, String contnet,
String filePath) throws MessagingException {
MimeMessage message = mailSender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(message, true);
helper.setTo(to);
helper.setSubject(subject);
helper.setText(contnet, true);
helper.setFrom(from);
FileSystemResource file = new FileSystemResource(new File(filePath));
String fileName = file.getFilename();
helper.addAttachment(fileName, file);
mailSender.send(message);
}
/**
* 圖片郵件
* @param to 接收者郵件
* @param subject 郵件主題
* @param contnet HTML內(nèi)容
* @param rscPath 圖片路徑
* @param rscId 圖片ID
* @throws MessagingException
*/
@Override
public void sendInlinkResourceMail(String to, String subject, String contnet,
String rscPath, String rscId) {
logger.info("發(fā)送靜態(tài)郵件開(kāi)始: {},{},{},{},{}", to, subject, contnet, rscPath, rscId);
MimeMessage message = mailSender.createMimeMessage();
MimeMessageHelper helper = null;
try {
helper = new MimeMessageHelper(message, true);
helper.setTo(to);
helper.setSubject(subject);
helper.setText(contnet, true);
helper.setFrom(from);
FileSystemResource res = new FileSystemResource(new File(rscPath));
helper.addInline(rscId, res);
mailSender.send(message);
logger.info("發(fā)送靜態(tài)郵件成功!");
} catch (MessagingException e) {
logger.info("發(fā)送靜態(tài)郵件失敗: ", e);
}
}
}package com.hrp;
import com.hrp.msage.service.MailService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import javax.mail.MessagingException;
/**
* ecs
*
* @Title: com.hrp
* @Date: 2020/7/29 13:57
* @Author: wfg
* @Description:
* @Version:
*/
@SpringBootTest
public class MailServiceTest {
@Autowired
private MailService mailService;
// @Resource
// private TemplateEngine templateEngine;
@Test
public void sendSimpleMail() {
mailService.sendSimpleMail("wufagang@dhcc.com.cn","測(cè)試spring boot imail-主題","測(cè)試spring boot imail - 內(nèi)容");
}
@Test
public void sendHtmlMail() throws MessagingException {
String content = "<html>\n" +
"<body>\n" +
"<h3>hello world</h3>\n" +
"<h1>html</h1>\n" +
"<body>\n" +
"</html>\n";
mailService.sendHtmlMail("wufagang@dhcc.com.cn","這是一封HTML郵件",content);
}
@Test
public void sendAttachmentsMail() throws MessagingException {
String filePath = "D:\\projects\\20200727\\ecs\\src\\main\\resources\\system.properties";
String content = "<html>\n" +
"<body>\n" +
"<h3>hello world</h3>\n" +
"<h1>html</h1>\n" +
"<h1>附件傳輸</h1>\n" +
"<body>\n" +
"</html>\n";
mailService.sendAttachmentsMail("wufagang@dhcc.com.cn","這是一封HTML郵件",content, filePath);
}
@Test
public void sendInlinkResourceMail() throws MessagingException {
//TODO 改為本地圖片目錄
String imgPath = "D:\\projects\\20200727\\ecs\\src\\main\\resources\\imag\\IMG_20200625_104833.jpg";
String rscId = "admxj001";
String content = "<html>" +
"<body>" +
"<h3>hello world</h3>" +
"<h1>html</h1>" +
"<h1>圖片郵件</h1>" +
"<img src='cid:"+rscId+"'></img>" +
"<body>" +
"</html>";
mailService.sendInlinkResourceMail("wufagang@dhcc.com.cn","這是一封圖片郵件",content, imgPath, rscId);
}
@Test
public void testTemplateMailTest() throws MessagingException {
// Context context = new Context();
// context.setVariable("id","ispringboot");
//
// String emailContent = templateEngine.process("emailTeplate", context);
// mailService.sendHtmlMail("ispringboot@163.com","這是一封HTML模板郵件",emailContent);
}
}到此這篇關(guān)于springboot 與異步任務(wù),定時(shí)任務(wù),郵件任務(wù)的文章就介紹到這了,更多相關(guān)springboot 異步任務(wù),定時(shí)任務(wù),郵件任務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了SpringMVC ModelAndView的用法使用詳解，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-12-12
這篇文章主要介紹了idea替換快捷鍵,批量處理對(duì)象的操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-02-02
這篇文章主要介紹了IDEA多線程文件下載插件開(kāi)發(fā)的步驟詳解,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-12-12
關(guān)于mybatis if else if 條件判斷SQL片段表達(dá)式取值和拼接問(wèn)題
這篇文章主要介紹了mybatis if else if 條件判斷SQL片段表達(dá)式取值和拼接,文章通過(guò)自己真實(shí)使用的例子給大家詳細(xì)介紹，需要的朋友可以參考下2021-09-09
JAVA 集成 PF4J 插件框架的應(yīng)用場(chǎng)景分析
PF4J是一個(gè)強(qiáng)大的Java插件框架,允許開(kāi)發(fā)者將應(yīng)用程序分解為可擴(kuò)展的模塊,本文介紹了PF4J的基本概念和如何在Java項(xiàng)目中集成,本文給大家介紹的非常詳細(xì),感興趣的朋友一起看看吧2025-03-03
本文主要介紹java 的接口和抽象類(lèi),對(duì)接口和抽象類(lèi)進(jìn)行介紹對(duì)比,深入理解,有需要的小伙伴可以參考下2016-07-07
這篇文章主要給大家介紹了關(guān)于java高效讀大文件(csv,text)的幾種處理方式,Java中處理大文件時(shí),通常需要采取一些特定的策略來(lái)避免內(nèi)存溢出或性能問(wèn)題,文中通過(guò)代碼及圖片介紹的非常詳細(xì),需要的朋友可以參考下2024-07-07
關(guān)于如何搭建CAS服務(wù)并將CAS項(xiàng)目導(dǎo)入IDEA
這篇文章主要介紹了關(guān)于如何搭建CAS服務(wù)并將CAS項(xiàng)目導(dǎo)入IDEA的問(wèn)題,文中提供了詳細(xì)的圖文講解,需要的朋友可以參考下,如果有錯(cuò)誤的地方還請(qǐng)指正2023-03-03
這篇文章主要介紹了Java中關(guān)于字符串的編碼方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-06-06
java.net.MalformedURLException異常的解決方法
下面小編就為大家?guī)?lái)一篇java.net.MalformedURLException異常的解決方法。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-05-05