创建调度任务

操作步骤

1. 登录任务调度控制台。

2. 在左侧导航栏选择 任务配置。

3. 选择 添加任务 > 简单任务，然后配置以下参数：

   参数	说明
   任务名称	配置任务的名称，用于识别任务。
   应用名称	填写或选择目标应用名称。 支持英文、中文、数字、下划线（_）、短划线（-），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();
       }
   
   ....
   }

4. 单击 提交。

5. 在任务列表中打开目标任务的 是否启用 开关。

   如果有客户端在线，新配置的任务自动有客户端注册。任务在禁用的状态下，您也可以在操作列单击 触发，手动触发一次任务。