一、背景

因为想写个定时任务，公司主打使用阿里云的一些列产品。所以注意到了Schedulerx2.0这个分布式任务调度模式。

二、使用

去看官方文档，就会发现，功能很强大，目前只用到了定时发送的需求，所以简单讲述一下使用。详情官方帮助文档

1）在阿里云创建一个应用，且创建一个命名空间

2）在配置文件配置

schedulex2:
  end-point: XX   公司购买服务所对应的区域ID
  name-space: XX  命名空间
  group-id: XX   应用ID
  app-key: XX    应用key

3）启动类注入

 @Bean
    public SchedulerxWorker initSchedulerxWorker(@Value("${schedulex2.end-point}") String endPoint,
                                                 @Value("${schedulex2.name-space}") String nameSpace,
                                                 @Value("${schedulex2.group-id}") String groupId,
                                                 @Value("${schedulex2.app-key}") String appKey) throws Exception {
        SchedulerxWorker schedulerxWorker = new SchedulerxWorker();
        // SchedulerX初始化失败，是否block应用进程启动
        schedulerxWorker.setBlockAppStart(!Environment.nonProd(ENV));
        schedulerxWorker.setEndpoint(endPoint);
        schedulerxWorker.setNamespace(nameSpace);
        schedulerxWorker.setGroupId(groupId);
        //1.2.1及以上版本需要设置应用key
        schedulerxWorker.setAppKey(appKey);
        //1.2.1以下版本需要设置AK/SK
        //schedulerxWorker.setAliyunAccessKey("xxxx");
        //schedulerxWorker.setAliyunSecretKey("xxxx");
        schedulerxWorker.init();
        return schedulerxWorker;
    }

4）自定义Task extends JavaProcessor

看关系图：

@Slf4j
@Component
public class ExhibitDataTask extends JavaProcessor {

    @Override
    public ProcessResult process(JobContext context) throws Exception {
        log.info("ExhibitDataTask start");

        try {
            // XXX  核心逻辑
            return new ProcessResult(true);
        } catch (Exception e) {
            log.error("定时任务 大屏展示更新基础数据", e);
            return new ProcessResult(false);
        }

    }
}

直接重写 process方法，该方法位于JobProcessor下，足以满足我们的定时功能。
配置且代码完成之后，就会看到如下的页面数据：

三、更多更快更强

• 更多：支持多种时间表达式，任务编排，支持更多的业务场景。单集群支持上千万任务，一天上十亿次调度，支持更多的任务数。
• 更快：支持秒级别调度，处理准实时业务。
• 更强：支持日志查询、原地重跑、重刷数据等多种操作，提供更强的运维能力和排错手段，解决为什么没跑，为什么失败，为什么跑得慢等问题。

目前了解的也仅仅是杯水车薪，继续学习实践中。