स्प्रिंग बूट में क्वार्ट्ज जोड़ना

फिर से नमस्कार। विशेष रूप से पाठ्यक्रम के छात्रों के लिए "डेवलपर ऑन द स्प्रिंग फ्रेमवर्क" ने एक दिलचस्प लेख का अनुवाद तैयार किया।

---

मेरे लेख "बचाव के लिए विनिर्देशों" में, मैंने दिखाया कि आप RESTful API में फ़िल्टरिंग को कार्यान्वित करने के लिए स्प्रिंग बूट में JPA स्पेसिफिकेशन का उपयोग कैसे कर सकते हैं। फिर लेख "उन विनिर्देशों का परीक्षण" में यह दिखाया गया कि इन समान विनिर्देशों का परीक्षण कैसे किया जाए।

अगले चरण में, मैंने यह प्रदर्शित करने का निर्णय लिया कि एक कार्य शेड्यूलर को उसी स्प्रिंग बूट एप्लिकेशन में कैसे जोड़ा जाए।

क्वार्ट्ज टास्क शेड्यूलर

स्प्रिंग टीम सरल मावेन निर्भरता के माध्यम से विभिन्न स्प्रिंग बूट स्टार्टर प्लगइन्स प्रदान करके जावा विकास की सुविधा जारी रखती है।

इस लेख में, मैं क्वार्ट्ज शेड्यूलर स्टार्टर पर ध्यान केंद्रित करूंगा, जिसे निम्नलिखित निर्भरता के साथ स्प्रिंग बूट परियोजना में जोड़ा जा सकता है:

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-quartz</artifactId> </dependency> 

कार्यान्वयन काफी सरल है और यहां वर्णित है । आप यहां वर्तमान स्प्रिंग बूट स्टार्टर की पूरी सूची देख सकते हैं।

समायोजन

काम प्रकाशित का उपयोग करते हुए डेविड किस्सा द्वारा , पहला कदम क्वार्ट्ज नौकरियों के लिए स्वत: जोड़ने जोड़ने के लिए है:

 public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory implements ApplicationContextAware { private transient AutowireCapableBeanFactory beanFactory; @Override public void setApplicationContext(final ApplicationContext context) { beanFactory = context.getAutowireCapableBeanFactory(); } @Override protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception { final Object job = super.createJobInstance(bundle); beanFactory.autowireBean(job); return job; } } 

अगला, मूल क्वार्ट्ज कॉन्फ़िगरेशन जोड़ें:

 @Configuration public class QuartzConfig { private ApplicationContext applicationContext; private DataSource dataSource; public QuartzConfig(ApplicationContext applicationContext, DataSource dataSource) { this.applicationContext = applicationContext; this.dataSource = dataSource; } @Bean public SpringBeanJobFactory springBeanJobFactory() { AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory(); jobFactory.setApplicationContext(applicationContext); return jobFactory; } @Bean public SchedulerFactoryBean scheduler(Trigger... triggers) { SchedulerFactoryBean schedulerFactory = new SchedulerFactoryBean(); Properties properties = new Properties(); properties.setProperty("org.quartz.scheduler.instanceName", "MyInstanceName"); properties.setProperty("org.quartz.scheduler.instanceId", "Instance1"); schedulerFactory.setOverwriteExistingJobs(true); schedulerFactory.setAutoStartup(true); schedulerFactory.setQuartzProperties(properties); schedulerFactory.setDataSource(dataSource); schedulerFactory.setJobFactory(springBeanJobFactory()); schedulerFactory.setWaitForJobsToCompleteOnShutdown(true); if (ArrayUtils.isNotEmpty(triggers)) { schedulerFactory.setTriggers(triggers); } return schedulerFactory; } } 

आप उपयोग किए गए गुणों को scheduler() विधि से बाहर रख सकते हैं, लेकिन मैंने विशेष रूप से इस उदाहरण को सरल बनाने का निर्णय लिया है।

फिर स्थिर तरीके जोड़े जाते हैं जो कार्य और ट्रिगर बनाने के लिए प्रोग्रामेटिक तरीका प्रदान करते हैं:

 @Slf4j @Configuration public class QuartzConfig { ... static SimpleTriggerFactoryBean createTrigger(JobDetail jobDetail, long pollFrequencyMs, String triggerName) { log.debug("createTrigger(jobDetail={}, pollFrequencyMs={}, triggerName={})", jobDetail.toString(), pollFrequencyMs, triggerName); SimpleTriggerFactoryBean factoryBean = new SimpleTriggerFactoryBean(); factoryBean.setJobDetail(jobDetail); factoryBean.setStartDelay(0L); factoryBean.setRepeatInterval(pollFrequencyMs); factoryBean.setName(triggerName); factoryBean.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY); factoryBean.setMisfireInstruction(SimpleTrigger.MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT); return factoryBean; } static CronTriggerFactoryBean createCronTrigger(JobDetail jobDetail, String cronExpression, String triggerName) { log.debug("createCronTrigger(jobDetail={}, cronExpression={}, triggerName={})", jobDetail.toString(), cronExpression, triggerName); // To fix an issue with time-based cron jobs Calendar calendar = Calendar.getInstance(); calendar.set(Calendar.SECOND, 0); calendar.set(Calendar.MILLISECOND, 0); CronTriggerFactoryBean factoryBean = new CronTriggerFactoryBean(); factoryBean.setJobDetail(jobDetail); factoryBean.setCronExpression(cronExpression); factoryBean.setStartTime(calendar.getTime()); factoryBean.setStartDelay(0L); factoryBean.setName(triggerName); factoryBean.setMisfireInstruction(CronTrigger.MISFIRE_INSTRUCTION_DO_NOTHING); return factoryBean; } static JobDetailFactoryBean createJobDetail(Class jobClass, String jobName) { log.debug("createJobDetail(jobClass={}, jobName={})", jobClass.getName(), jobName); JobDetailFactoryBean factoryBean = new JobDetailFactoryBean(); factoryBean.setName(jobName); factoryBean.setJobClass(jobClass); factoryBean.setDurability(true); return factoryBean; } } 

createJobDetail() विधि कार्य बनाने के लिए एक सरल और उपयोगी विधि है।
ट्रिगर्स के लिए दो विकल्प हैं: CRON और सरल ट्रिगर्स पर आधारित।

सेवाएं

क्वार्ट्ज बेस शेड्यूलर अब हमारे स्प्रिंग बूट एप्लिकेशन में कार्य चलाने के लिए तैयार है। अगला, हम सेवाओं के कुछ उदाहरण बनाएंगे जो कि अनुसूचक द्वारा लॉन्च किए जाएंगे।

पहली सेवा सरल सदस्यता आँकड़े प्रदर्शित करती है। यदि आपको याद है, तो मूल परियोजना में उदाहरण एक फिटनेस क्लब से संबंधित था। में MemberService वर्ग MemberService बनाने memberStats() विधि:

 public void memberStats() { List<Member> members = memberRepository.findAll(); int activeCount = 0; int inactiveCount = 0; int registeredForClassesCount = 0; int notRegisteredForClassesCount = 0; for (Member member : members) { if (member.isActive()) { activeCount++; if (CollectionUtils.isNotEmpty(member.getMemberClasses())) { registeredForClassesCount++; } else { notRegisteredForClassesCount++; } } else { inactiveCount++; } } log.info("Member Statics:"); log.info("=============="); log.info("Active member count: {}", activeCount); log.info(" - Registered for Classes count: {}", registeredForClassesCount); log.info(" - Not registered for Classes count: {}", notRegisteredForClassesCount); log.info("Inactive member count: {}", inactiveCount); log.info("=========================="); } 

फिटनेस क्लब कक्षाओं में रुचियों को ट्रैक करने के लिए, classStats() एक classStats() विधि classStats() :

 public void classStats() { List<MemberClass> memberClasses = classRepository.findAll(); Map<String, Integer> memberClassesMap = memberClasses .stream() .collect(Collectors.toMap(MemberClass::getName, c -> 0)); List<Member> members = memberRepository.findAll(); for (Member member : members) { if (CollectionUtils.isNotEmpty(member.getMemberClasses())) { for (MemberClass memberClass : member.getMemberClasses()) { memberClassesMap.merge(memberClass.getName(), 1, Integer::sum); } } } log.info("Class Statics:"); log.info("============="); memberClassesMap.forEach((k,v) -> log.info("{}: {}", k, v)); log.info("=========================="); } 

कार्य

सेवा कोड को चलाने के लिए, आपको उपयुक्त कार्य बनाना होगा। MemberService मैंने एक MemberStatsJob जॉब MemberStatsJob बनाई:

 @Slf4j @Component @DisallowConcurrentExecution public class MemberStatsJob implements Job { @Autowired private MemberService memberService; @Override public void execute(JobExecutionContext context) { log.info("Job ** {} ** starting @ {}", context.getJobDetail().getKey().getName(), context.getFireTime()); memberService.memberStats(); log.info("Job ** {} ** completed. Next job scheduled @ {}", context.getJobDetail().getKey().getName(), context.getNextFireTime()); } } 

MemberClassService सेवा के लिए, MemberClassService वर्ग बनाया गया था:

 @Slf4j @Component @DisallowConcurrentExecution public class MemberClassStatsJob implements Job { @Autowired MemberClassService memberClassService; @Override public void execute(JobExecutionContext context) { log.info("Job ** {} ** starting @ {}", context.getJobDetail().getKey().getName(), context.getFireTime()); memberClassService.classStats(); log.info("Job ** {} ** completed. Next job scheduled @ {}", context.getJobDetail().getKey().getName(), context.getNextFireTime()); } } 

कार्य अनुसूची

इस परियोजना में, हम चाहते हैं कि स्प्रिंग बूट सर्वर शुरू होने पर सभी कार्य शेड्यूल किए जाएं। ऐसा करने के लिए, मैंने QuartzSubmitJobs वर्ग बनाया, जिसमें चार सरल तरीके शामिल हैं। दो विधियाँ नए कार्य बनाती हैं, और दो विधियाँ संगत ट्रिगर बनाती हैं।

 @Configuration public class QuartzSubmitJobs { private static final String CRON_EVERY_FIVE_MINUTES = "0 0/5 * ? * * *"; @Bean(name = "memberStats") public JobDetailFactoryBean jobMemberStats() { return QuartzConfig.createJobDetail(MemberStatsJob.class, "Member Statistics Job"); } @Bean(name = "memberStatsTrigger") public SimpleTriggerFactoryBean triggerMemberStats(@Qualifier("memberStats") JobDetail jobDetail) { return QuartzConfig.createTrigger(jobDetail, 60000, "Member Statistics Trigger"); } @Bean(name = "memberClassStats") public JobDetailFactoryBean jobMemberClassStats() { return QuartzConfig.createJobDetail(MemberClassStatsJob.class, "Class Statistics Job"); } @Bean(name = "memberClassStatsTrigger") public CronTriggerFactoryBean triggerMemberClassStats(@Qualifier("memberClassStats") JobDetail jobDetail) { return QuartzConfig.createCronTrigger(jobDetail, CRON_EVERY_FIVE_MINUTES, "Class Statistics Trigger"); } } 

स्प्रिंग बूट लॉन्च करें

जब सब कुछ तैयार हो जाता है, तो आप स्प्रिंग बूट सर्वर शुरू कर सकते हैं और क्वार्ट्ज आरंभीकरण देख सकते हैं:

 2019-07-14 14:36:51.651 org.quartz.impl.StdSchedulerFactory : Quartz scheduler 'MyInstanceName' initialized from an externally provided properties instance. 2019-07-14 14:36:51.651 org.quartz.impl.StdSchedulerFactory : Quartz scheduler version: 2.3.0 2019-07-14 14:36:51.651 org.quartz.core.QuartzScheduler : JobFactory set to: com.gitlab.johnjvester.jpaspec.config.AutowiringSpringBeanJobFactory@79ecc507 2019-07-14 14:36:51.851 ossconcurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 'applicationTaskExecutor' 2019-07-14 14:36:51.901 aWebConfiguration$JpaWebMvcConfiguration : spring.jpa.open-in-view is enabled by default. Therefore, database queries may be performed during view rendering. Explicitly configure spring.jpa.open-in-view to disable this warning 2019-07-14 14:36:52.051 ossquartz.SchedulerFactoryBean : Starting Quartz Scheduler now 2019-07-14 14:36:52.054 ossquartz.LocalDataSourceJobStore : Freed 0 triggers from 'acquired' / 'blocked' state. 2019-07-14 14:36:52.056 ossquartz.LocalDataSourceJobStore : Recovering 0 jobs that were in-progress at the time of the last shut-down. 2019-07-14 14:36:52.056 ossquartz.LocalDataSourceJobStore : Recovery complete. 2019-07-14 14:36:52.056 ossquartz.LocalDataSourceJobStore : Removed 0 'complete' triggers. 2019-07-14 14:36:52.058 ossquartz.LocalDataSourceJobStore : Removed 0 stale fired job entries. 2019-07-14 14:36:52.058 org.quartz.core.QuartzScheduler : Scheduler MyInstanceName_$_Instance1 started. 

और memberStats() चल रहा है memberStats() नौकरी:

 2019-07-14 14:36:52.096 cgjjpaspec.jobs.MemberStatsJob : Job ** Member Statistics Job ** starting @ Sun Jul 14 14:36:52 EDT 2019 2019-07-14 14:36:52.217 cgjjpaspec.service.MemberService : Member Statics: 2019-07-14 14:36:52.217 cgjjpaspec.service.MemberService : ============== 2019-07-14 14:36:52.217 cgjjpaspec.service.MemberService : Active member count: 7 2019-07-14 14:36:52.217 cgjjpaspec.service.MemberService : - Registered for Classes count: 6 2019-07-14 14:36:52.217 cgjjpaspec.service.MemberService : - Not registered for Classes count: 1 2019-07-14 14:36:52.217 cgjjpaspec.service.MemberService : Inactive member count: 3 2019-07-14 14:36:52.217 cgjjpaspec.service.MemberService : ========================== 2019-07-14 14:36:52.219 cgjjpaspec.jobs.MemberStatsJob : Job ** Member Statistics Job ** completed. Next job scheduled @ Sun Jul 14 14:37:51 EDT 2019 

और फिर classStats() नौकरी कर रहे हैं:

 2019-07-14 14:40:00.006 cgjjpaspec.jobs.MemberClassStatsJob : Job ** Class Statistics Job ** starting @ Sun Jul 14 14:40:00 EDT 2019 2019-07-14 14:40:00.021 cgjjservice.MemberClassService : Class Statics: 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : ============= 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : Tennis: 4 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : FitCore 2000: 3 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : Spin: 2 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : Swimming: 4 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : New Class: 0 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : Basketball: 2 2019-07-14 14:40:00.022 cgjjservice.MemberClassService : ========================== 2019-07-14 14:40:00.022 cgjjpaspec.jobs.MemberClassStatsJob : Job ** Class Statistics Job ** completed. Next job scheduled @ Sun Jul 14 14:45:00 EDT 2019 

निष्कर्ष

उपरोक्त उदाहरण में, मैंने स्प्रिंग बूट पर एक मौजूदा परियोजना का उपयोग किया और बहुत प्रयास के बिना इसमें क्वार्ट्ज अनुसूचक को जोड़ा। मैंने सेवा पद्धतियां बनाईं जो सरल डेटा विश्लेषण करती थीं। इन सेवा विधियों को नौकरी वर्गों द्वारा लॉन्च किया गया था। अंत में, नौकरियों और ट्रिगर्स को चलाने के लिए निर्धारित किया गया था।

पूर्ण स्रोत कोड यहां पाया जा सकता है ।

अगले लेख में, मैं दिखाऊंगा कि क्वार्ट्ज सेटिंग्स की जानकारी देखने के लिए एक RESTful API कैसे जोड़ा जाए।