如何在quartz中运行时动态创建 job?

如何在quartz中运行时动态创建 job?,第1张

使用SimpleTriggerSimpleTrigger拥有多个重载的构造函数,用以在不同场合下构造出对应的实例:●SimpleTrigger(String name, String group):通过该构造函数指定Trigger所属组和名称;●SimpleTrigger(String name, String group, Date startTime):除指定Trigger所属组和名称外,还可以指定触发的开发时间;●SimpleTrigger(String name, String group, Date startTime, Date endTime, int repeatCount, long repeatInterval):除指定以上信息外,还可以指定结束时间、重复执行次数、时间间隔等参数;●SimpleTrigger(String name, String group, String jobName, String jobGroup, Date startTime, Date endTime, int repeatCount, long repeatInterval):这是最复杂的一个构造函数,在指定触发参数的同时,还通过jobGroup和jobName,让该Trigger和Scheduler中的某个任务关联起来。

优点:与spring集成、动态添加任务、支持集群

缺点:不支持分布式(只能一个任务在一台服务器上执行,不能分片)

将一个任务拆分成多个独立的任务项,由分布式的服务器分别执行某一个或几个分片项。而传统的定时器任务都在一台服务器上执行,如果数据很大那么压力很大。

举例:处理一百万的订单:A服务器处理尾数偶数的订单,B服务器处理尾数奇数的订单。

整合java项目

1、引入quartz 依赖

2、quartz.properties

3、

注意:

1、每一个job执行都是一个新的线程(即使是同一个任务,这个elastic-job不同)但是如果在配置文件quartz.properties中配置的线程消耗完,也还是会陷入阻塞的。根据业务来预估线程池的大小。(所以的任务共享一个线程池)

2、每一个job执行都会创建一个新的job对象,所以想通过job的成员变量来传递信息是不可行的(每次都会初始化)

3、myJob类必须要有空的构造方法

1、方式1:在创建jobDetail是传递JobDataMap,然后通过JobExecutionContext获取JobDataMap

2、方式2:在myjob中定义成员变量,并生成get,set方法

上面我们知道任务间都是并发处理的,那么要考虑并发安全问题。

1、使用@DisallowConcurrentExecution

使用@PersistJobDataAfterExecution注解和jobDataMap.put方法

1、startTime属性:设置trigger第一次触发的时间

2、endTime属性:表示trigger的失效时间点

3、优先级(priority)当多个Trigger并发执行,但是线程不够时触发,会优先执行级别高的Trigger

TriggerBuilder.newTrigger().withPriority(10);

默认时5,数字越大优先级越高

4、错过触发(misfire instructions)

1、withMisfireHandlingInstructionDoNothing策略:错过了什么都不做,等待下一次触发时间

设置每5秒执行一次,任务7秒。

发现这样是不会生效的,因为内部判断了一下错过的时间是否大于misfireThreshold这个值(默认5秒),如果小于还是立即执行。这里我们只失效了2秒,是小于5秒的。

通过quartz.properties设置misfireThreshold的值

这样再运行,发现withMisfireHandlingInstructionDoNothing策略生效了。

2、withMisfireHandlingInstructionFireAndProceed策略:错过立即执行

5、日历(calendar)

1、可以在具体的时间点执行一次

2、可以按照指定间隔时间重复若干次

1、使用cron表达式触发

, 代表并且,如果10,20 10秒和20秒都指向

? 只能出现在日期和星期内,代表没有特定的值。如果使用*号日期了星期会有歧义,这是使用?

L 只能出现在日期和星期内,表示月的最后一天,或者星期六

W 只能出现在日期内,表示最接近这个日期的工作日

1、首先新建一个控制台程序,利用Nuget引入Quartz的程序包,同时会自动引入日志库,用于输入日志,如下图所示。

2、配置项目目录下的App.Config文件,如下图所示,注意configSections一定要放在第一个节点。

3、编写需要执行的任务逻辑,它继承了IJob接口,然后需要实现其中的Exxcute方法,任务逻辑的部分放在Execute里即可。

4、接下来开始编写定时任务程序,首先是初始化任务调度器,如下图所示。

5、然后利用JobBuilder建立任务关联到我们刚才创建的任务逻辑,在创建一个触发器,用来明确此任务在什么时间点执行,执行几次,最后执行start,即可进行任务。

6、最后像下面一样依次往调度器里叠加任务即可,最后统一的执行,如果他们的执行时间需要错开的话,修改执行时间即可。


欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/bake/7893491.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2023-04-11
下一篇2023-04-11

发表评论

登录后才能评论

评论列表(0条)

    保存