缺点:不支持分布式(只能一个任务在一台服务器上执行,不能分片)
将一个任务拆分成多个独立的任务项,由分布式的服务器分别执行某一个或几个分片项。而传统的定时器任务都在一台服务器上执行,如果数据很大那么压力很大。
举例:处理一百万的订单: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、首先打开威纶触摸屏与三菱plc编辑软件,并打开需要编辑的项目。2、其次在编辑页面中找到需要添加定时器的组件或区域。
3、最后右键单击该组件或区域,并选择“属性”选项,在属性窗口中找到“定时器”属性,并将其设置为“是”,在“定时器周期”属性中就可以设置定时器了。
jmeter 中使用同步定时器 Synchronizing Timer实现 LoadRunner 中集合点的功能。
模拟多用户并发测试,即多个线程在同一时刻并发请求。
在未使用同步定时器 Synchronizing Timer时
添加-线程组。
添加-取样器-http请求
添加-监听器-用表格查看结果。
将设置线程数为5,可以看出发出的5个请求并未在同一时间开始。
通过使用同步定时器 Synchronizing Timer,可以帮助我们实现并发请求。
添加-定时器-Synchronizing Timer
同步定时器页面参数配置说明:
模拟用户组的数量(Number of Simulated Users to Group by) :就是并发数,集合多少请求后一起发出去。
超时时间以毫秒为单位(Timeout in milliseconds) :指定人数多少秒没集合到算超时,默认为0,会一直等。如果设置1000毫秒的,在1000毫秒内没有凑齐并发数,就会发出去。
可以看到有3个请求是同时发出去的(不会绝对,只会更接近3个),剩下的两个请求没有等到3个,在超过设置的1000ms后同时发出。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)