应用发布后，您可以为应用创建调度任务。
操作步骤
登录任务调度控制台。
在左侧导航栏选择 任务配置。
选择 添加任务 > 简单任务，然后配置以下参数：
参数
说明
任务名称
配置任务的名称，用于识别任务。
应用名称
填写或选择目标应用名称。
支持英文、中文、数字、下划线（_）、短划线（-），50 个字符之内。必须与工程中
application.properties文件的spring.application.name配置的应用名称一致。调度类型
配置任务调度的类型，可选值：
cron 表达式触发：该类型的任务在创建时需要配置 CRON 表达式定时触发任务。
事件触发：该类型的任务通过外部事件触发任务。
定时触发：该类型的任务在创建时也需要配置 CRON 表达式定时触发，并且只能执行一次。
Cron 表达式
配置 CRON 表达式，用于定时触发任务。配置方式请参见 CRON 表达式详解。
仅在 调度类型 为 cron 表达式触发 时配置。
任务分组（可选）
选择或新建一个任务分组，方便归纳管理任务。
执行器名字
必须与代码中任务处理器名字一致，即 实现类 步骤中
getName方法获取的执行器名字。是否分片
选择任务是否开启分片：
不开启分片，任务将只调度到一台客户端服务器上执行。
开启分片，并设置分片数为 N，任务则会同时触发到 N 台客户端服务器上并发执行。
如果您开启了分片，您还需在本地工程编码实现任务分片。代码参见下文 任务分片示例代码 。
自定义参数（可选）
自定义参数支持从控制台向任务传递参数，参数也可以在任务间传递，格式为：
key=value。参数配置说明如下：
参数名：设置自定义参数的名称。
支持英文大小写、数字、下划线（_）, 不能超过 128 字符。
类型 和 参数值：可选类型和参数值配置方式如下。
STRING：支持通用的字符串。
LIST：支持字符串数组，例如：
["aaa","bbb"]。BOOLEAN：支持 true 或 false。
PLACEHOLDER：支持参数替换，目前支持的变量如下：
${sharding}：替换当前分片值，配合简单任务使用。${shardingCount}：替换简单任务配置的分片数。${triggerTime}：替换预期的触发时间。
说明您也可以在业务端通过上下文 context（该对象必须实现 Serializable。）获取和覆盖自定义参数。代码参见下文 获取和覆盖自定义参数示例代码 。
路由策略
选择执行任务的路由策略，可选值：
随机：每次执行都随机分发到客户端服务器上。
定向：每次执行都分发到同一个客户端服务器上。
暂不支持指定客户端服务器 IP。
轮询：每次执行依次分发到每台客户端服务器上。
通信方式
选择任务的通信方式，可选值：
单向 ONEWAY：单向操作，没有返回值。控制台不记录触发记录、无超时、无重试。
高频非重要任务时建议使用。
回调 CALLBACK：双向操作，有返回值。控制台可查看触发记录、可设置超时、可重试。
重要任务时建议使用，触发间隔至少 5 分钟。
任务互斥
选择是否开启任务互斥模式。开启任务互斥模式时，处在“执行中”或“暂停”状态的任务即使已经达到下一个任务触发时间点，仍无法再次触发。本次调度状态以“跳过”标记。默认为不开启。
仅当 通信方式 设置为 回调 CALLBACK 时配置。
漏触发策略
设置任务漏触发时的处理策略，可选值：
忽略：不进行补偿处理。
立即触发：立即重新触发。
时间充裕时触发：是否进行补偿触发取决于下次触发前的剩余时间是否充裕。若当前时间 + 超时时间 < 下次触发时间，则进行补偿触发，并将此次补偿触发插入触发记录；反之，则不触发。多次漏触发进行恢复时仅进行一次补偿触发。
仅当 通信方式 设置为 回调 CALLBACK，且 调度类型 为 cron 表达式触发 时，可配置此项。
超时策略
设置任务执行超时后的处理策略，可选值：
不处理：触发记录和执行记录状态均标记为失败。
按失败策略重试：本次调度记录状态标为失败，并按照 失败处理策略 进行失败重试。重试后本次调度记录将被重置为重试结果。
停止后续触发：执行记录状态为失败，触发记录状态为超时，并且无法再次触发。仅当开启任务互斥模式时可选择此项。
仅当 通信方式 设置为 回调 CALLBACK 时配置。
超时时间
设置任务执行的超时时间，当任务超过此时间未回调则认为执行失败。单位可选择为 分钟 和 小时。
仅当 通信方式 设置为 回调 CALLBACK 时配置。
失败处理策略
设置任务执行失败后的处理策略，可选值：
不重试：失败后不进行重试。
最多重试三次：失败后立即进行重试，但最多重试三次。
重试到下次触发：失败后立即进行重试，直到下次触发时间。
优先级
用于识别任务的重要性，暂无其他作用。
默认为 中等。
描述（可选）
配置任务的描述信息，例如业务含义、影响范围等，最多 1024 个字符。
任务分片示例代码
public class ShardingSchedule implements ISimpleJobHandler { private final Logger LOGGER = LoggerFactory.getLogger(ShardingSchedule.class); private ThreadPoolExecutor threadPool; @Override public String getName() { return "SHARDING_SCHEDULE"; } @Override public ClientCommonResult handle(JobExecuteContext jobExecuteContext) throws Exception { int sharding = jobExecuteContext.getSharding(); //当前机器获取到的分片数 LOGGER.info("current machine sharding is " + sharding); //总的分片数 System.out.println("total sharding num is " + jobExecuteContext.getShardingCount()); System.out.println("activity sharding is" + jobExecuteContext.getActivitySharding()); return ClientCommonResult.buildSuccessResult(); } @Override public ThreadPoolExecutor getThreadPool() { return threadPool; } /** * Setter method for property threadPool. * * @param threadPool value to be assigned to property threadPool */ public void setThreadPool(ThreadPoolExecutor threadPool) { this.threadPool = threadPool; } }获取和覆盖自定义参数示例代码
public class SimpleTaskDemo implements ISimpleJobHandler { @Override public ClientCommonResult handle(JobExecuteContext context) { // 根据 key 获取 obj Object obj = context.getCustomParam("intObj"); // 获取自定义参数 Map<String, Object> paramsMap = context.getCustomParams(); context.putCustomParams("num", 2); List<String> listparam = newArrayList <>(); listparam.add("aaaaaa"); listparam.add("111111"); context.putCustomParams("intparam", 111); context.putCustomParams("stringparam", "dfadsfad1243"); context.putCustomParams("listparam", listparam); // 注意对象必须实现 Serializable context.putCustomParams("objectParam", newObject()); return ClientCommonResult.buildSuccessResult(); } .... }单击 提交。
在任务列表中打开目标任务的 是否启用 开关。
如果有客户端在线，新配置的任务自动有客户端注册。任务在禁用的状态下，您也可以在操作列单击 触发，手动触发一次任务。
