网站seo课程,wordpress 加密 插件,世界工厂采购网登录,网络设计报告3000字异步任务
在Java应用中#xff0c;绝大多数情况下都是通过同步的方式来实现交互处理的#xff1b;但是在处理与第三方系统交互的时候#xff0c;容易造成响应迟缓的情况#xff0c;之前大部分都是使用多线程来完成此类任务#xff0c;其实#xff0c;在Spring 3.x之后绝大多数情况下都是通过同步的方式来实现交互处理的但是在处理与第三方系统交互的时候容易造成响应迟缓的情况之前大部分都是使用多线程来完成此类任务其实在Spring 3.x之后就已经内置了Async来完美解决这个问题。
SpringBoot 实现比较简单 主启动类:添加 注释:EnableAsync
EnableScheduling
EnableAsync
MapperScan(com.hrp.**.dao)
SpringBootApplication
public class EcsApplication {public static void main(String[] args) {SpringApplication.run(EcsApplication.class, args);}}业务方法添加 Async AsyncOverridepublic void TestAsync() {try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(-------------);}controller调用
RequestMapping(myFreeMark)public String myFreeMark(MapString,Object map){map.put(name,zhangsan);map.put(mydate,new Date());asyncServer.TestAsync();System.out.println(FreemarkerControllermyFreeMark);return myFreeMark;}访问看到控制台打印顺序可以知道TestAsync方法异步调用
定时任务
项目开发中经常需要执行一些定时任务比如需要在每天凌晨时候分析一次前 一天的日志信息。Spring为我们提供了异步执行任务调度的方式提供TaskExecutor 、TaskScheduler 接口。
主启动类:增加EnableScheduling
EnableScheduling
EnableAsync
MapperScan(com.hrp.**.dao)
SpringBootApplication
public class EcsApplication {public static void main(String[] args) {SpringApplication.run(EcsApplication.class, args);}}任务类:类增加Service或者Compont注释方法增加Scheduled注解
Service
public class BackUpMysqlTask {/*** Seconds : 可出现, - * /四个字符有效范围为0-59的整数* Minutes : 可出现, - * /四个字符有效范围为0-59的整数* Hours : 可出现, - * /四个字符有效范围为0-23的整数* DayofMonth : 可出现, - * / ? L W C八个字符有效范围为0-31的整数* Month : 可出现, - * /四个字符有效范围为1-12的整数或JAN-DEc* DayofWeek : 可出现, - * / ? L C #四个字符有效范围为1-7的整数或SUN-SAT两个范围。1表示星期天2表示星期一 依次类推* Year : 可出现, - * /四个字符有效范围为1970-2099年*/Scheduled(cron 0 * * * * MON-FRI)public void backUpMysql() {System.out.println();}
}我们可以观察到控制台不断的再打印 这里要讲解cron /*** Seconds : 可出现, - * /四个字符有效范围为0-59的整数* Minutes : 可出现, - * /四个字符有效范围为0-59的整数* Hours : 可出现, - * /四个字符有效范围为0-23的整数* DayofMonth : 可出现, - * / ? L W C八个字符有效范围为0-31的整数* Month : 可出现, - * /四个字符有效范围为1-12的整数或JAN-DEc* DayofWeek : 可出现, - * / ? L C #四个字符有效范围为1-7的整数或SUN-SAT两个范围。1表示星期天2表示星期一 依次类推* Year : 可出现, - * /四个字符有效范围为1970-2099年*/下面简单举几个例子
“0 0 12 * * ?” 每天中午十二点触发 “0 15 10 ? * *” 每天早上1015触发 “0 15 10 * * ?” 每天早上1015触发 “0 15 10 * * ? *” 每天早上1015触发 “0 15 10 * * ? 2005” 2005年的每天早上1015触发 “0 * 14 * * ?” 每天从下午2点开始到2点59分每分钟一次触发 “0 0/5 14 * * ?” 每天从下午2点开始到255分结束每5分钟一次触发 “0 0/5 14,18 * * ?” 每天的下午2点至255和6点至6点55分两个时间段内每5分钟一次触发 “0 0-5 14 * * ?” 每天14:00至14:05每分钟一次触发 “0 10,44 14 ? 3 WED” 三月的每周三的1410和1444触发 “0 15 10 ? * MON-FRI” 每个周一、周二、周三、周四、周五的1015触发
邮件任务
准备工作
做过邮件的都大家都知道 所以我们要是使用qq邮箱发送必须有登录qq邮箱的权限 开启smtp服务,发送短信我们就可以获取一个授权码,自己拷贝下来下图的授权码记录下来
开始
添加依赖
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-mail/artifactId/dependency配置 mail:host: smtp.qq.com 其他邮箱需要修改username: 邮箱账户password: 授权码properties:mail:smtp:ssl:enable: true测试代码 Autowiredprivate JavaMailSender javaMailSender;Testvoid contextLoads() {SimpleMailMessage simpleMailMessage new SimpleMailMessage();simpleMailMessage.setText(ddd);simpleMailMessage.setSubject(主题);simpleMailMessage.setTo();simpleMailMessage.setFrom();javaMailSender.send(simpleMailMessage);}我们可以查收到邮件
上面是普通的邮件
发送html内容 Testpublic void testSend() throws MessagingException {MimeMessage mimeMessage javaMailSender.createMimeMessage();MimeMessageHelper messageHelper new MimeMessageHelper(mimeMessage);messageHelper.setSubject(标题);messageHelper.setTo(dhcc.com.cn);messageHelper.setFrom(qq.com);messageHelper.setText(h1标题/h1br/p这是内容/p, true);javaMailSender.send(messageHelper.getMimeMessage());}这里需要注意的是setText的时候需要传一个布尔值进去表名需要使用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 {/*** 简单文本邮件* param to 接收者邮件* param subject 邮件主题* param contnet 邮件内容*/public void sendSimpleMail(String to, String subject, String contnet);/*** HTML 文本邮件* param to 接收者邮件* param subject 邮件主题* param contnet HTML内容* throws MessagingException*/public void sendHtmlMail(String to, String subject, String contnet) throws MessagingException;/*** 附件邮件* param to 接收者邮件* param subject 邮件主题* param contnet HTML内容* param filePath 附件路径* throws MessagingException*/public void sendAttachmentsMail(String to, String subject, String contnet,String filePath) throws MessagingException;/*** 图片邮件* param to 接收者邮件* param subject 邮件主题* param contnet HTML内容* 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;Autowiredprivate JavaMailSender mailSender;/*** 简单文本邮件* param to 接收者邮件* param subject 邮件主题* param contnet 邮件内容*/Overridepublic 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内容* throws MessagingException*/Overridepublic 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内容* param filePath 附件路径* throws MessagingException*/Overridepublic 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内容* param rscPath 图片路径* param rscId 图片ID* throws MessagingException*/Overridepublic void sendInlinkResourceMail(String to, String subject, String contnet,String rscPath, String rscId) {logger.info(发送静态邮件开始: {},{},{},{},{}, 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(发送静态邮件成功!);} catch (MessagingException e) {logger.info(发送静态邮件失败: , 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 {Autowiredprivate MailService mailService;// Resource
// private TemplateEngine templateEngine;Testpublic void sendSimpleMail() {mailService.sendSimpleMail(wufagangdhcc.com.cn,测试spring boot imail-主题,测试spring boot imail - 内容);}Testpublic void sendHtmlMail() throws MessagingException {String content html\n body\n h3hello world/h3\n h1html/h1\n body\n /html\n;mailService.sendHtmlMail(wufagangdhcc.com.cn,这是一封HTML邮件,content);}Testpublic void sendAttachmentsMail() throws MessagingException {String filePath D:\\projects\\20200727\\ecs\\src\\main\\resources\\system.properties;String content html\n body\n h3hello world/h3\n h1html/h1\n h1附件传输/h1\n body\n /html\n;mailService.sendAttachmentsMail(wufagangdhcc.com.cn,这是一封HTML邮件,content, filePath);}Testpublic 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 h3hello world/h3 h1html/h1 h1图片邮件/h1 img srccid:rscId/img body /html;mailService.sendInlinkResourceMail(wufagangdhcc.com.cn,这是一封图片邮件,content, imgPath, rscId);}Testpublic void testTemplateMailTest() throws MessagingException {
// Context context new Context();
// context.setVariable(id,ispringboot);
//
// String emailContent templateEngine.process(emailTeplate, context);
// mailService.sendHtmlMail(ispringboot163.com,这是一封HTML模板邮件,emailContent);}
}
