springboot整合QuartZ郵件檔案上傳JPA

一. 定時任務

定時任務就是指定時執行某一個流程方法。在Java中有很多種方式去實作它，如果隻需要簡單的方式可以采用SpringTask，如果需要分布式那麼可以使用QuartZ。

1.1 內建SpringTask

內建SpringTask無需導入任何其他第三方庫

第一步：編寫對應的任務類A

@Component
public class MyTask1 {
    @Scheduled(cron = "*/6 * * * * ?")
    public void doTask(){
        System.out.println("MyTask1===" + Thread.currentThread().getName()
                + "時間：" + new Date());
    }
}


@Component
public class MyTask2 {
    @Scheduled(fixedRate = 2000)
    public void doTask(){
        System.out.println("MyTask2===" + Thread.currentThread().getName()
                + "時間：" + new Date());
    }
}

第二步：添加配置

@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>{
}

具體代碼位址

springboot整合QuartZ郵件檔案上傳JPA

springboot整合QuartZ郵件檔案上傳JPA

一. 定時任務

1.1 內建SpringTask

1.2 內建quartZ

二. 內建郵件

三. 內建檔案上傳

四. 內建JPA

繼續閱讀

SpringBoot 應用打包為 Docker 鏡像，并設定時區同步

@Value的幾種常用用法

Android的前後端互動架構搭建（okhhtp+springboot+mysql完整版）

start to use skywalkingInstall JDK8Install ESInstall skywalkingRun Springboot JAR

關于Springboot中JSCH使用說明1. JSCH簡介2. JSCH依賴3. 使用方法4. 使用連接配接池

路徑錯誤Maven：Non-resolvable parent POM: Failure to find錯誤

jsch連接配接伺服器執行指令傳回的資料中文亂碼問題問題分析解決

springboot項目時間不一緻解決方案一、springboot項目時間不一緻解決方案

spring mvc 頁面傳遞數組背景接收方式spring mvc 頁面傳遞數組背景接收方式

Swagger-UI的使用一、添加依賴二、建立配置類三、注解

将swagger-ui中的接口導入postman

聊一聊Swagger-UI的那些事情軟體簡介Swagger 原生Bootstrap-ui Bootstrap的UIKnife4j Bootstrap的更新版的UI

springboot使用 swagger-ui 2.10.5 有關版本更新帶來的問題

微服務-性能壓測\緩存redis和分布式鎖redisson和SpringCache

java 8 Lamda 求 List 中 Bigdecimal類型的各種值求最大值求最小值求和求平均值

(SpringBoot)日志種類：log、monitor、access、out、gc、backup