Manière correcte de persister à Quartz déclencheurs de base de données

Ici est ma façon de gérer ce scénario.

La première place dans ma Configuration Spring-je spécifier un SchedulerFactoryBean à partir de laquelle je peux injecter le Scheduler dans d'autres haricots.

<bean name="SchedulerFactory"
    class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="applicationContextSchedulerContextKey">
        <value>applicationContext</value>
    </property>
</bean>

Puis, quand je créer un emploi dans mon application je de stocker les détails de la tâche dans la base de données. Ce service est appelé par l'un de mes contrôleurs et les horaires de la poste:

@Component
public class FollowJobService {

    @Autowired
    private FollowJobRepository followJobRepository;

    @Autowired
    Scheduler scheduler;

    @Autowired
    ListableBeanFactory beanFactory;

    @Autowired
    JobSchedulerLocator locator;

    public FollowJob findByClient(Client client){
        return followJobRepository.findByClient(client);
    }

    public void saveAndSchedule(FollowJob job) {
        job.setJobType(JobType.FOLLOW_JOB);
        job.setCreatedDt(new Date());
        job.setIsEnabled(true);
        job.setIsCompleted(false);

        JobContext context = new JobContext(beanFactory, scheduler, locator, job);
        job.setQuartzGroup(context.getQuartzGroup());
        job.setQuartzName(context.getQuartzName());

        followJobRepository.save(job);

        JobSchedulerUtil.schedule(new JobContext(beanFactory, scheduler, locator, job));
    }
}

La JobContext je construis contient des détails sur le travail et est finalement passée à un utilitaire pour les travaux de planification. Ici, c'est que le code de la méthode utilitaire qui fait les horaires de travail. Remarquez que dans mon service, j'ai autowire la JobScheduler et le passer à la JobContext. Notez également que je stocke l'emploi dans la base de données à l'aide de mon référentiel.

/**
 * Schedules a DATA_MINING_JOB for the client. The job will attempt to enter
 * followers of the target into the database.
 */
@Override
public void schedule(JobContext context) {
    Client client = context.getNetworkSociallyJob().getClient();
    this.logScheduleAttempt(context, client);

    JobDetail jobDetails = JobBuilder.newJob(this.getJobClass()).withIdentity(context.getQuartzName(), context.getQuartzGroup()).build();
    jobDetails.getJobDataMap().put("job", context.getNetworkSociallyJob());
    jobDetails.getJobDataMap().put("repositories", context.getRepositories());

    Trigger trigger = TriggerBuilder.newTrigger().withIdentity(context.getQuartzName() + "-trigger", context.getQuartzGroup())
            .withSchedule(cronSchedule(this.getSchedule())).build();

    try {
        context.getScheduler().scheduleJob(jobDetails, trigger);            
        this.logSuccess(context, client);

    } catch (SchedulerException e) {
        this.logFailure(context, client);
        e.printStackTrace();
    }
}

Donc, après tout ce code s'exécute j'ai deux choses se sont produites, mon travail est de les stocker dans la base de données et de son été programmée en utilisant le planificateur quartz. Maintenant, si le redémarrage de l'application, je veux reprogrammer mes tâches avec le planificateur. Pour ce faire, je m'inscrire à un haricot qui implémente ApplicationListener<ContextRefreshedEvent> qui est appelé le Printemps à chaque fois que le conteneur redémarre ou est commencé.

<bean id="jobInitializer" class="com.network.socially.web.jobs.JobInitializer"/>

JobInitializer.class

public class JobInitializer implements ApplicationListener<ContextRefreshedEvent> {

    Logger logger = LoggerFactory.getLogger(JobInitializer.class);

    @Autowired
    DataMiningJobRepository repository;

    @Autowired
    ApplicationJobRepository jobRepository;

    @Autowired
    Scheduler scheduler;

    @Autowired
    JobSchedulerLocator locator;

    @Autowired
    ListableBeanFactory beanFactory;

    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {
        logger.info("Job Initilizer started.");

        //TODO: Modify this call to only pull completed & enabled jobs
        for (ApplicationJob applicationJob : jobRepository.findAll()) {
            if (applicationJob.getIsEnabled() && (applicationJob.getIsCompleted() == null || !applicationJob.getIsCompleted())) {
                JobSchedulerUtil.schedule(new JobContext(beanFactory, scheduler, locator, applicationJob));
            }
        }       
    }

}

Cette classe autowires le planificateur et un référentiel qui saisit les instances de chacune de mes travaux qui mettent en œuvre les ApplicationJob interface. À l'aide de l'information provenant de ces enregistrements de base de données que je peux utiliser mon utilitaire pour reconstruire mon emploi.

Donc, fondamentalement, je sauvegarder manuellement les travaux dans ma base de données et de planifier manuellement par l'injection d'une instance de la Scheduler échéant, des haricots. Pour reportée, j'ai une requête de ma base de données, puis de les programmer à l'aide de la ApplicationListener compte redémarre et du conteneur.

OriginalL'auteur Kevin Bowersox