新增集群任务
集群任务可配置的相关参数
| 参数名 | 参数类型 | 参数值 | 参数规则 | 备注 |
|---|---|---|---|---|
| jobName | String | 任务名称 | ||
| argsStr | String | 执行任务参数 | 封装了对应新增的方法,通过k,v的形式新增 | |
| routeKey | Integer | 执行器路由策略 | @link AllocationAlgorithmEnum | |
| executorInfo | String | 执行器名称 | ||
| triggerType | Integer | 触发类型 | 2. 固定时间 3.CRON 表达式 99.工作流 | |
| triggerInterval | String | 间隔时长 | ||
| blockStrategy | Integer | 阻塞策略 | 1、丢弃 2、覆盖 3、并行 | |
| executorTimeout | Integer | 任务执行超时时间 | 单位:秒 | |
| maxRetryTimes | Integer | 最大重试次数 | ||
| retryInterval | Integer | 重试间隔 | 单位:秒 | |
| description | String | 描述 |
集群任务demo
java
/**
* 新增集群模式的任务
*
* @param jobName 任务名称
* @return 任务id
*/
public Long addClusterJob(String jobName) {
return SnailJobOpenApi.addClusterJob()
.setRouteKey(AllocationAlgorithmEnum.RANDOM)
.setJobName(jobName)
.setExecutorInfo("testJobExecutor")
.setExecutorTimeout(30)
.setDescription("add")
.setBlockStrategy(BlockStrategyEnum.DISCARD)
.setMaxRetryTimes(1)
.setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
.setTriggerInterval(String.valueOf(60))
.addArgsStr("测试数据", 123)
.addArgsStr("addArg", "args")
.setRetryInterval(3)
.execute();
}