Skip to content

新增固定分片任务

固定分片任务可配置参数

参数名参数类型参数值参数规则备注
jobNameString任务名称
shardingArgsString静态分片参数以数组的形式新增
executorInfoString执行器名称
triggerTypeInteger触发类型2. 固定时间 3.CRON 表达式 99.工作流
triggerIntervalString间隔时长
blockStrategyInteger阻塞策略1、丢弃 2、覆盖 3、并行
executorTimeoutInteger任务执行超时时间单位:秒
maxRetryTimesInteger最大重试次数
retryIntervalInteger重试间隔单位:秒
parallelNumInteger并行数
descriptionString描述

固定分片任务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();
}