新增固定分片任务
固定分片任务可配置参数
| 参数名 | 参数类型 | 参数值 | 参数规则 | 备注 |
|---|---|---|---|---|
| jobName | String | 任务名称 | ||
| shardingArgs | String | 静态分片参数 | 以数组的形式新增 | |
| executorInfo | String | 执行器名称 | ||
| triggerType | Integer | 触发类型 | 2. 固定时间 3.CRON 表达式 99.工作流 | |
| triggerInterval | String | 间隔时长 | ||
| blockStrategy | Integer | 阻塞策略 | 1、丢弃 2、覆盖 3、并行 | |
| executorTimeout | Integer | 任务执行超时时间 | 单位:秒 | |
| maxRetryTimes | Integer | 最大重试次数 | ||
| retryInterval | Integer | 重试间隔 | 单位:秒 | |
| parallelNum | Integer | 并行数 | ||
| description | String | 描述 |
固定分片任务demo
java
/**
* 新增Sharding模式的任务
*
* @param jobName 任务名称
* @return 任务id
*/
public Long addShardingJob(String jobName) {
return SnailJobOpenApi.addShardingJob()
.setJobName(jobName)
.setExecutorInfo("testJobExecutor")
.setExecutorTimeout(30)
.setDescription("add")
.setBlockStrategy(BlockStrategyEnum.DISCARD)
.setMaxRetryTimes(1)
.setTriggerType(TriggerTypeEnum.SCHEDULED_TIME)
.setTriggerInterval(String.valueOf(60))
.addShardingArgs("分片1", "分片2", "分片3")
.setParallelNum(1)
.setRetryInterval(3)
.execute();
}