package com.itstyle.quartz.job; import java.io.Serializable; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import org.quartz.*; /** * 实现序列化接口、防止重启应用出现quartz Couldn't retrieve job because a required class was not found 的问题 * Job 的实例要到该执行它们的时候才会实例化出来。每次 Job 被执行,一个新的 Job 实例会被创建。 * 其中暗含的意思就是你的 Job 不必担心线程安全性,因为同一时刻仅有一个线程去执行给定 Job 类的实例,甚至是并发执行同一 Job 也是如此。 * @DisallowConcurrentExecution 保证上一个任务执行完后,再去执行下一个任务,这里的任务是同一个任务 */ @DisallowConcurrentExecution public class ChickenJob implements Job,Serializable { private static final long serialVersionUID = 1L; @Override public void execute(JobExecutionContext context){ JobDetail jobDetail = context.getJobDetail(); JobDataMap dataMap = jobDetail.getJobDataMap(); /** * 获取任务中保存的方法名字,动态调用方法 */ String methodName = dataMap.getString("jobMethodName"); try { ChickenJob job = new ChickenJob(); Method method = job.getClass().getMethod(methodName); method.invoke(job); } catch (NoSuchMethodException e) { e.printStackTrace(); } catch (IllegalAccessException e) { e.printStackTrace(); } catch (InvocationTargetException e) { e.printStackTrace(); } } public void test1(){ System.out.println("测试方法1"); } public void test2(){ System.out.println("测试方法2"); } public void test3(){ System.out.println("测试方法3"); } }