调度持久实体

Question

假设我有一些带有 CronExpression 字段的数据库实体：

@Entity
@Table(name = "job")
public class Job {
    ...
    private CronExpression cronExpression;

}

将其放入石英计划的最佳方法是什么？我使用 Spring3 和 Hibernate。基本上我可以在我的 DAO 中安排它 - 任何时候创建或更新作业 - 但我还需要在应用程序启动时安排所有现有的作业..

感谢您的建议！

Answer 1

您需要 DAO/Repository 来从存储中获取所有 cronExpression。我在内存中创建 DAO

@Repository
public class JobEntityDao {
    public List<JobEntity> findAll() {
        List<JobEntity> list = new ArrayList<JobEntity>();

        JobEntity job1 = new JobEntity("0 0 12 * * ?");
        JobEntity job2 = new JobEntity("0 15 10 ? * *");
        JobEntity job3 = new JobEntity("0 15 10 * * ?");

        list.add(job1);
        list.add(job2);
        list.add(job3);

        return list;
    }
}

和组件来根据您的 cronExpression 创建quartz调度程序。我称之为 QuartzExecutor，

@Service
public class QuartzExecutor {


    private JobEntityDao jobEntityDao;

    @Autowired 
    public QuartzExecutor(JobEntityDao jobEntityDao) throws ParseException, SchedulerException {
        this.jobEntityDao = jobEntityDao; 
        init();
    }

    @SuppressWarnings({ "rawtypes", "unchecked" })
    private void init() throws ParseException, SchedulerException {
        List<JobEntity> jobEntities = jobEntityDao.findAll();

        for (JobEntity jobEntity : jobEntities) {
            System.out.println(jobEntity.cronExpression);

            RunMeTask task = new RunMeTask();

            //specify your sceduler task details
            JobDetail job = new JobDetail();
            job.setName("runMeJob");
            job.setJobClass(RunMeJob.class);

            Map dataMap = job.getJobDataMap();
            dataMap.put("runMeTask", task);

            //configure the scheduler time
            CronTrigger trigger = new CronTrigger();
            trigger.setName("runMeJobTesting");
            trigger.setCronExpression(jobEntity.cronExpression);

            //schedule it
            Scheduler scheduler = new StdSchedulerFactory().getScheduler();
            scheduler.start();
            scheduler.scheduleJob(job, trigger);
        }
    }

}

您可以从 RunMeJob 和 RunMeTask 代码rel="nofollow">http://www.mkyong.com/java/quartz-scheduler-example/。
我知道课程设计不好，但我关心的是尽力解决你的问题。

这是您要找的吗？