58 lines
1.9 KiB
Java
58 lines
1.9 KiB
Java
|
package com.example.snailjob.handler;
|
||
|
|
|
||
|
|
import com.aizuda.snailjob.client.job.core.enums.AllocationAlgorithmEnum;
|
||
|
|
import com.aizuda.snailjob.client.job.core.enums.TriggerTypeEnum;
|
||
|
|
import com.aizuda.snailjob.client.job.core.openapi.SnailJobOpenApi;
|
||
|
|
import com.aizuda.snailjob.common.core.enums.BlockStrategyEnum;
|
||
|
|
import org.springframework.stereotype.Component;
|
||
|
|
|
||
|
|
@Component
|
||
|
|
public class TestAddJobHandler {
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 新增集群模式的任务
|
||
|
|
*
|
||
|
|
* @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();
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 新增集群模式的任务
|
||
|
|
*
|
||
|
|
* @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")
|
||
|
|
.setRetryInterval(3)
|
||
|
|
.execute();
|
||
|
|
|
||
|
|
}
|
||
|
|
}
|