JobPlus
JobPlus知识库 IT 大数据 文章
【Quartz】插件的使用
个人头像
Emmly
2018-07-19 2726人阅读 0人打赏

 Quartz 框架提供了几种用于扩展平台能力的方式。通过使用各种 "钩子" (通常指的就是扩展点)，Quartz 变得很容易被扩展和定制化来适应你的需要。其中一个最简单的扩展框架的方法就是使用 Quartz 插件。本章就来看看如何使用插件机制让 Quartz 进入到之前 Quartz 用户没去过的领域。

 

一、使用Quartz自带插件范例

   下面将使用插件实现从XML得到JOB，不用手工的把job和trigger加到Scheduler中去再来运行，这样就很方便。如果要更改任务，直接在xml中配置就可以了。不用再写java代码。

1、首先是job类：

  1. import java.util.Date;

  2. import java.util.Set;

  3. import org.quartz.DisallowConcurrentExecution;

  4. import org.quartz.InterruptableJob;

  5. import org.quartz.Job;

  6. import org.quartz.JobDataMap;

  7. import org.quartz.JobExecutionContext;

  8. import org.quartz.JobExecutionException;

  9. import org.quartz.JobKey;

  10. import org.quartz.PersistJobDataAfterExecution;

  11. import org.quartz.UnableToInterruptJobException;

  12. import org.slf4j.Logger;

  13. import org.slf4j.LoggerFactory;

  14. @PersistJobDataAfterExecution

  15. @DisallowConcurrentExecution

  16. public class SimpleJob implements Job {

  17. private static Logger log = LoggerFactory.getLogger(SimpleJob.class);

  18. private JobKey jobkey=null;

  19. @Override

  20. public void execute(JobExecutionContext context) throws JobExecutionException {

  21. jobkey = context.getJobDetail().getKey();

  23. log.info("Excuting job: " + jobkey + " executing at " + new Date()+" fire by: "+context.getTrigger().getKey());

  25. if(context.getMergedJobDataMap().size()>0){

  26.     Set<String>  keys= context.getMergedJobDataMap().keySet();

  27. for (String key : keys) {

  28. String value= context.getMergedJobDataMap().getString(key);

  29. log.info(" jobdatamap entry: "+key+" = "+value);

  30. }

  31. context.setResult("hello");

  32. }

  35. }

  36. }


2、job触发时间配置，使用quartz_data.xml

  1. <?xml version="1.0" encoding="UTF-8"?>

  2. <job-scheduling-data xmlns="http://www.quartz-scheduler.org/xml/JobSchedulingData"

  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  4. xsi:schemaLocation="http://www.quartz-scheduler.org/xml/JobSchedulingData http://www.quartz-scheduler.org/xml/job_scheduling_data_1_8.xsd"

  5. version="1.8">

  6. <pre-processing-commands>

  7. <delete-jobs-in-group>*</delete-jobs-in-group>  <!-- clear all jobs in scheduler -->

  8. <delete-triggers-in-group>*</delete-triggers-in-group> <!-- clear all triggers in scheduler -->

  9. </pre-processing-commands>

  10. <processing-directives>

  11. <!-- if there are any jobs/trigger in scheduler of same name (as in this file), overwrite them -->

  12. <overwrite-existing-data>true</overwrite-existing-data>

  13. <!-- if there are any jobs/trigger in scheduler of same name (as in this file), and over-write is false, ignore them rather then generating an error -->

  14. <ignore-duplicates>false</ignore-duplicates>

  15. </processing-directives>

  16. <schedule>

  17. <job>

  18. <name>TestJob1</name>

  19. <job-class>com.mucfc.SimpleJob</job-class>

  20. </job>

  22. <job>

  23. <name>TestDurableJob</name>

  24. <job-class>com.mucfc.SimpleJob</job-class>

  25. <durability>true</durability>

  26. <recover>false</recover>

  27. </job>

  29. <trigger>

  30. <simple>

  31. <name>TestSimpleTrigger1AtFiveSecondInterval</name>

  32. <job-name>TestJob1</job-name>

  33. <repeat-count>-1</repeat-count> <!-- repeat indefinitely  -->

  34. <repeat-interval>5000</repeat-interval>  <!--  every 5 seconds -->

  35. </simple>

  36. </trigger>

  38. <job>

  39. <name>TestJob2</name>

  40. <group>GroupOfTestJob2</group>

  41. <description>This is the description of TestJob2</description>

  42. <job-class>com.mucfc.SimpleJob</job-class>

  43. <durability>false</durability>

  44. <recover>true</recover>

  45. <job-data-map>

  46. <entry>

  47. <key>someKey</key>

  48. <value>someValue</value>

  49. </entry>

  50. <entry>

  51. <key>someOtherKey</key>

  52. <value>someOtherValue</value>

  53. </entry>

  54. </job-data-map>

  55. </job>

  57. <trigger>

  58. <simple>

  59. <name>TestSimpleTrigger2AtTenSecondIntervalAndFiveRepeats</name>

  60. <group>GroupOfTestJob2Triggers</group>

  61. <job-name>TestJob2</job-name>

  62. <job-group>GroupOfTestJob2</job-group>

  63. <start-time>2010-02-09T10:15:00</start-time>

  64. <misfire-instruction>MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT</misfire-instruction>

  65. <repeat-count>5</repeat-count>

  66. <repeat-interval>10000</repeat-interval>

  67. </simple>

  68. </trigger>

  70. <trigger>

  71. <cron>

  72. <name>TestCronTrigger2AtEveryMinute</name>

  73. <group>GroupOfTestJob2Triggers</group>

  74. <job-name>TestJob2</job-name>

  75. <job-group>GroupOfTestJob2</job-group>

  76. <job-data-map>

  77. <entry>

  78. <key>someKey</key>

  79. <value>overriddenValue</value>

  80. </entry>

  81. <entry>

  82. <key>someOtherKey</key>

  83. <value>someOtherOverriddenValue</value>

  84. </entry>

  85. </job-data-map>

  86. <cron-expression>0 * * ? * *</cron-expression>

  87. </cron>

  88. </trigger>

  90. <trigger>

  91. <cron>

  92. <name>TestCronTrigger2AtEveryMinuteOnThe45thSecond</name>

  93. <group>GroupOfTestJob2Triggers</group>

  94. <job-name>TestJob2</job-name>

  95. <job-group>GroupOfTestJob2</job-group>

  96. <start-time>2015-05-12T12:26:00.0</start-time>

  97. <end-time>2015-05-16T12:26:00.0</end-time>

  98. <misfire-instruction>MISFIRE_INSTRUCTION_SMART_POLICY</misfire-instruction>

  99. <cron-expression>45 * * ? * *</cron-expression>

  100. <time-zone>America/Los_Angeles</time-zone>

  101. </cron>

  102. </trigger>

  103. </schedule>    

  104. </job-scheduling-data>


3、配置文件

  1. #============================================================================

  2. # Configure Main Scheduler Properties  

  3. #============================================================================

  4. org.quartz.scheduler.instanceName: TestScheduler

  5. org.quartz.scheduler.instanceId: AUTO

  6. org.quartz.scheduler.skipUpdateCheck: true

  7. #============================================================================

  8. # Configure ThreadPool  

  9. #============================================================================

  10. org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool

  11. org.quartz.threadPool.threadCount: 3

  12. org.quartz.threadPool.threadPriority: 5

  13. #============================================================================

  14. # Configure JobStore  

  15. #============================================================================

  16. org.quartz.jobStore.misfireThreshold: 60000

  17. org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore

  18. #org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX

  19. #org.quartz.jobStore.driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate

  20. #org.quartz.jobStore.useProperties: false

  21. #org.quartz.jobStore.dataSource: myDS

  22. #org.quartz.jobStore.tablePrefix: QRTZ_

  23. #org.quartz.jobStore.isClustered: false

  24. #============================================================================

  25. # Configure Datasources  

  26. #============================================================================

  27. #org.quartz.dataSource.myDS.driver: org.postgresql.Driver

  28. #org.quartz.dataSource.myDS.URL: jdbc:postgresql://localhost/dev

  29. #org.quartz.dataSource.myDS.user: jhouse

  30. #org.quartz.dataSource.myDS.password:

  31. #org.quartz.dataSource.myDS.maxConnections: 5

  32. #============================================================================

  33. # Configure Plugins

  34. #============================================================================

  35. org.quartz.plugin.triggHistory.class: org.quartz.plugins.history.LoggingJobHistoryPlugin

  36. org.quartz.plugin.jobInitializer.class: org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin

  37. org.quartz.plugin.jobInitializer.fileNames: quartz_data.xml

  38. org.quartz.plugin.jobInitializer.failOnFileNotFound: true

  39. org.quartz.plugin.jobInitializer.scanInterval: 120

  40. org.quartz.plugin.jobInitializer.wrapInUserTransaction: false

其中org.quartz.plugin.jobInitializer.class: org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin会自动加载quartz_data.xml中的trigger和job到Scheduler

3、测试

  1. import java.util.Calendar;

  2. import java.util.Date;

  3. import java.util.GregorianCalendar;

  4. import org.quartz.DateBuilder;

  5. import org.quartz.JobBuilder;

  6. import org.quartz.JobDetail;

  7. import org.quartz.Matcher;

  8. import org.quartz.Scheduler;

  9. import org.quartz.SchedulerFactory;

  10. import org.quartz.SchedulerMetaData;

  11. import org.quartz.SimpleScheduleBuilder;

  12. import org.quartz.SimpleTrigger;

  13. import org.quartz.Trigger;

  14. import org.quartz.TriggerBuilder;

  15. import org.quartz.impl.StdSchedulerFactory;

  16. import org.quartz.impl.calendar.AnnualCalendar;

  17. import org.quartz.impl.matchers.KeyMatcher;

  18. import org.slf4j.Logger;

  19. import org.slf4j.LoggerFactory;

  20. public class PluginExample {

  21. public static void run() throws Exception {

  22. Logger log = LoggerFactory.getLogger(PluginExample.class);

  23. SchedulerFactory sf = new StdSchedulerFactory();

  24. Scheduler sche = sf.getScheduler();

  25. sche.start();

  27. try {

  28. Thread.sleep(300000L);

  29. } catch (Exception e) {

  30. }

  32.     sche.shutdown();

  33. SchedulerMetaData metaData = sche.getMetaData();

  34. log.info("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");

  35. }

  36. public static void main(String[] args) {

  37. PluginExample simpleExample = new PluginExample();

  38. try {

  39. simpleExample.run();

  40. } catch (Exception e) {

  41. e.printStackTrace();

  42. }

  43. }

  44. }


4、结果：

 

看，不用再把job和trigger手工加到Scheduler中去，它会自动加载XML中定义好的任务，需要做的只是start就行了。


如果觉得我的文章对您有用，请随意打赏。您的支持将鼓励我继续创作！

¥ 打赏支持
98人赞 举报
分享到
用户评价(0)

暂无评价，你也可以发布评价哦:)

7 人收藏了这篇文章
个人头像 个人头像 个人头像 个人头像 个人头像 个人头像 ...

相关文章

腾讯云数据库性能卓越稳定可靠，为您解决数据库运维难题
广告

关于我们

公司介绍

人才招聘

联系方式

法律声明

服务条款

权利声明

隐私声明

帮助中心

使用攻略

建议反馈

联系客服

网站地图

二维码
JobPlus官方公众号
微博
JobPlus官方微博
Copyright © jobplus.com.cn All rights reserved
苏州聘十信息技术有限公司 版权所有苏ICP备16046992号
扫码APP

扫描使用APP

扫码使用

扫描使用小程序