springboot整合QuartZ郵件檔案上傳JPA
阿新 • • 發佈：2019-01-11
springboot整合QuartZ郵件檔案上傳JPA
一. 定時任務
定時任務就是指定時執行某一個流程方法。在Java中有很多種方式去實現它，如果只需要簡單的方式可以採用SpringTask，如果需要分散式那麼可以使用QuartZ。
1.1 整合SpringTask
整合SpringTask無需匯入任何其他第三方庫
第一步：編寫對應的任務類A
@Component
public class MyTask1 {
@Scheduled(cron = "*/6 * * * * ?")
public void doTask(){
System. 第二步：新增配置
@EnableScheduling // 直接在系統配置類上新增即可
@SpringBootApplication
public class Demo11Application {
public static void main(String[] args) {
SpringApplication.run(Demo11Application.class, args);
}
}
cron表示式含義： 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）#:用於確定每個月第幾個星期幾，只能出現在DayofMonth域。例如在4#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觸發
@Scheduled所支援的引數：
1. cron：cron表示式，指定任務在特定時間執行；
2. fixedDelay：表示上一次任務執行完成後多久再次執行，引數型別為long，單位ms；
3. fixedDelayString：與fixedDelay含義一樣，只是引數型別變為String；
4. fixedRate：表示按一定的頻率執行任務，引數型別為long，單位ms；
5. fixedRateString: 與fixedRate的含義一樣，只是將引數型別變為String；
6. initialDelay：表示延遲多久再第一次執行任務，引數型別為long，單位ms；
7. initialDelayString：與initialDelay的含義一樣，只是將引數型別變為String；
8. zone：時區，預設為當前時區，一般沒有用到。
設定SpringTask以多執行緒的方式執行：(只需要在配置類中新增執行緒池的物件即可)
@EnableScheduling
@SpringBootApplication
public class Demo11Application {
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
//執行緒池大小
scheduler.setPoolSize(10);
return scheduler;
}
public static void main(String[] args) {
SpringApplication.run(Demo11Application.class, args);
}
}
1.2 整合quartZ
第一步：匯入包
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
</dependency>
第二步：編寫程式碼
任務類：
public class MyJob1 implements Job {
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
System.out.println("MyJob1====" + Thread.currentThread().getName() + "時間："+new Date());
}
}
public class MyJob2 implements Job {
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
System.out.println("MyJob2====" + Thread.currentThread().getName() + "時間："+new Date());
}
}
計劃類:
@Component
public class JobSchedule {
// 任務排程
@Resource
private Scheduler scheduler;
// 開始執行所有任務
public void startJob() throws SchedulerException {
startJob1(scheduler);
startJob2(scheduler);
scheduler.start();
}
// 獲取Job資訊
public String getJobInfo(String name, String group) throws SchedulerException {
TriggerKey triggerKey = new TriggerKey(name, group);
CronTrigger cronTrigger = (CronTrigger) scheduler.getTrigger(triggerKey);
return String.format("time:%s,state:%s", cronTrigger.getCronExpression(),
scheduler.getTriggerState(triggerKey).name());
}
// 修改某個任務的執行時間
public boolean modifyJob(String name, String group, String time) throws SchedulerException {
Date date = null;
TriggerKey triggerKey = new TriggerKey(name, group);
CronTrigger cronTrigger = (CronTrigger) scheduler.getTrigger(triggerKey);
String oldTime = cronTrigger.getCronExpression();
if (!oldTime.equalsIgnoreCase(time)) {
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(time);
CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(name, group)
.withSchedule(cronScheduleBuilder).build();
date = scheduler.rescheduleJob(triggerKey, trigger);
}
return date != null;
}
// 暫停所有任務
public void pauseAllJob() throws SchedulerException {
scheduler.pauseAll();
}
// 暫停某個任務
public void pauseJob(String name, String group) throws SchedulerException {
JobKey jobKey = new JobKey(name, group);
JobDetail jobDetail = scheduler.getJobDetail(jobKey);
if (jobDetail == null)
return;
scheduler.pauseJob(jobKey);
}
// 恢復所有任務
public void resumeAllJob() throws SchedulerException {
scheduler.resumeAll();
}
// 恢復某個任務
public void resumeJob(String name, String group) throws SchedulerException {
JobKey jobKey = new JobKey(name, group);
JobDetail jobDetail = scheduler.getJobDetail(jobKey);
if (jobDetail == null)
return;
scheduler.resumeJob(jobKey);
}
// 刪除某個任務
public void deleteJob(String name, String group) throws SchedulerException {
JobKey jobKey = new JobKey(name, group);
JobDetail jobDetail = scheduler.getJobDetail(jobKey);
if (jobDetail == null)
return;
scheduler.deleteJob(jobKey);
}
private void startJob1(Scheduler scheduler) throws SchedulerException {
// 建立JobDetail
JobDetail jobDetail = JobBuilder.newJob(MyJob1.class).withIdentity("job1", "group1").build();
// 建立表示式構建者
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/2 * * * * ?");
// 建立觸發器
CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("job1", "group1")
.withSchedule(cronScheduleBuilder).build();
scheduler.scheduleJob(jobDetail, cronTrigger);
}
private void startJob2(Scheduler scheduler) throws SchedulerException {
JobDetail jobDetail = JobBuilder.newJob(MyJob2.class).withIdentity("job2", "group2").build();
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/1 * * * * ?");
CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("job2", "group2")
.withSchedule(cronScheduleBuilder).build();
scheduler.scheduleJob(jobDetail, cronTrigger);
}
}
啟動類：
@Controller
@SpringBootApplication
public class Demo11Application {
@Resource
private JobSchedule jobSchedule;
@Bean
public Scheduler scheduler(){
try {
return new StdSchedulerFactory().getScheduler();
} catch (SchedulerException e) {
e.printStackTrace();
}
return null;
}
@ResponseBody
@RequestMapping("/")
public String index(){
try {
jobSchedule.startJob();
} catch (SchedulerException e) {
e.printStackTrace();
}
return "Job Started!!";
}
public static void main(String[] args) {
SpringApplication.run(Demo11Application.class, args);
}
}
二. 整合郵件
第一步：新增郵件需要的包
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
第二步：新增郵件配置
#郵箱傳送方協議
spring.mail.host=smtp.1000phone.com
#傳送方郵箱
[email protected]
#傳送方密碼(有些郵箱有授權碼，例如QQ郵箱，那麼此處不再使用密碼，而需要使用授權碼)
spring.mail.password=test
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.starttls.required=true
第三步：編寫傳送程式碼
@Component
public class MailService {
@Resource
private JavaMailSender javaMailSender;
@Value("${spring.mail.username}")
private String from;
public void sendMail(String to, String subject, String content){
SimpleMailMessage simpleMailMessage = new SimpleMailMessage();
simpleMailMessage.setFrom(from);
simpleMailMessage.setTo(to);
simpleMailMessage.setSubject(subject);
simpleMailMessage.setText(content);
javaMailSender.send(simpleMailMessage);
}
}
第四步：測試
@RunWith(SpringRunner.class)
@SpringBootTest
public class Demo21ApplicationTests {
@Resource
private MailService mailService;
@Test
public void contextLoads() {
mailService.sendMail("[email protected]", "測試", "測試內容");
}
}
三. 整合檔案上傳
第一步：新增配置：
# 上傳多個檔案總的最大值(預設為1M)
spring.servlet.multipart.max-request-size=10MB
# 單個檔案的最大值(預設為1M)
spring.servlet.multipart.max-file-size=10MB
第二步：編寫程式碼：
四. 整合JPA
第一步：匯入包
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
第二步：編寫程式碼
// 繼承CrudRepository
public interface StudentDAO extends CrudRepository<Student, Integer>{
}
// 繼承PagingAndSortingRepository
public interface StudentDAO extends PagingAndSortingRepository<Student, Integer>{
}
// 繼承JpaRepository
public interface StudentDAO extends JpaRepository<Student, Integer>{
}