您可以使用SchedulerX 2.0为您部署在EDAS上的独立Java应用、Spring或Spring Boot应用实现分布式任务调度能力。

前提条件

由于SchedulerX是EDAS的组件,所以在使用SchedulerX为应用接入任务调度能力前,需要先在EDAS完成以下工作:

操作流程

应用接入任务调度能力的流程如下:

  1. 在EDAS控制台创建任务调度分组。
  2. 为应用接入任务调度。
  3. 将应用部署到EDAS。

创建任务调度分组

您需要首先为应用创建任务调度分组。该分组的Group ID将作为应用接入任务调度的配置参数。

  1. 登录EDAS控制台
  2. 在左侧导航栏中选择组件中心 > 分布式任务调度(新)
  3. 在左侧导航栏选择应用管理
  4. 应用管理页面顶部菜单栏选择地域,在页面中选择命名空间,然后单击创建应用
  5. 基本配置配置向导页,设置应用名应用ID,然后单击下一步
    创建应用-基本配置
  6. 报警配置配置向导页面,选择报警渠道并设置报警联系人,然后单击完成
    创建应用-报警配置
    创建完成后,自动返回应用管理页面,在应用列表中查看应用分组是否已存在。

为应用接入任务调度

您需要在应用程序中接入任务调度,主要包含以下3步:

  1. 初始化SchedulerxWorker。
  2. 新建实现任务调度的类。
  3. 将应用部署到EDAS。
  1. 初始化SchedulerxWorker

    针对不同应用,在初始化SchedulerxWorker的时候会有所区别,下面分别说明:

    • 独立Java应用
      1. 在应用程序的pom.xml文件中添加SchedulerxWorker依赖。

        <dependency>
        <groupId>com.aliyun.schedulerx</groupId>
        <artifactId>schedulerx2-worker</artifactId>
        // 请参见客户端版本说明,使用最新客户端版本。
        <version>${schedulerx2.version}</version>
        </dependency>                   
      2. 在main函数中初始化SchedulerxWorker。

        /**
        * 初始化SchedulerX客户端
        * @throws Exception初始化失败异常
        */
        private static void initSchedulerxWorker() throws Exception{
         String groupId = "schedulerx-server.defaultGroup";
         SchedulerxWorker schedulerxWorker = new SchedulerxWorker();
         schedulerxWorker.setGroupId(groupId);
         schedulerxWorker.init();
         LOGGER.info("SchedulerxWorker init success. groupId={}", groupId);
        }                                       
        说明
        • 当一个应用有多个分组时,例如应用animals包含两个分组animals.dogsanimals.cats。此时不用申请两批实例分别接入2个分组,一个应用可以同时接入2个分组,在客户端中将这2个分组配置到groupId=后面,用半角逗号(,)分隔即可,例如groupId=animals.dogs,animals.cats
        • 在初始化SchedulerxWorker客户端时,根据实际业务,如果还有其它配置需求,可以参考 SchedulerxWorker配置参数说明增加配置。
    • Spring应用
      1. 在应用程序的pom.xml文件中添加SchedulerxWorker依赖。

        <dependency>
        <groupId>com.aliyun.schedulerx</groupId>
        <artifactId>schedulerx2-worker</artifactId>
        // 请参见客户端版本说明,使用最新客户端版本。
        <version>${schedulerx2.version}</version>
        </dependency>                    
      2. 在xml配置文件中初始化SchedulerxWorker(注入Bean)。

            <bean id="schedulerxWorker" class="com.alibaba.schedulerx.worker.SchedulerxWorker">
                <property name="groupId">
                //填写之前创建的分组的Group ID。可以配置多个分组,以半角逗号(,)分隔。
                  <value>${groupId}</value>
                </property>
            </bean>                   
    • Spring Boot应用
      1. 在应用程序的pom.xml文件中添加SchedulerxWorker依赖。

        schedulerx2.version请使用客户端版本说明中最新客户端版本。

        <dependency>
        <groupId>com.aliyun.schedulerx</groupId>
        <artifactId>schedulerx2-spring-boot-starter</artifactId>
        <version>${schedulerx2.version}</version>
        </dependency>                   
      2. application.properties文件中添加之前创建的分组的 Group ID。

        spring.schedulerx2.groupId=${groupId}                   
        说明 当一个应用有多个分组时,例如应用animals包含两个分组animals.dogsanimals.cats。此时不用申请两批实例分别接入2个分组,一个应用可以同时接入2个分组,在客户端中将这2个分组配置到groupId=后面,用半角逗号(,)分隔即可,例如groupId=animals.dogs,animals.cats
  2. 新建实现调度任务的类。

    在应用中增加类JobProcessor,实现任务调度。本文介绍如何实现最简单的定时打印“Hello SchedulerX2.0”,JobProcessor的代码如下:

    说明 如果您想使用其它调度任务,请参见Demo示例。
    package com.aliyun.schedulerx.test.job;
    
    import com.alibaba.schedulerx.worker.domain.JobContext;
    import com.alibaba.schedulerx.worker.processor.JavaProcessor;
    import com.alibaba.schedulerx.worker.processor.ProcessResult;
    
    @Component
    public class MyHelloJob extends JavaProcessor {
    
        @Override
        public ProcessResult process(JobContext context) throws Exception {
            System.out.println("hello schedulerx2.0");
            return new ProcessResult(true);
        }
    }                        
  3. 将应用部署到EDAS。

    将应用打包,并部署到EDAS。具体操作,请参见应用创建和部署概述(ECS)创建和部署应用概述(K8s)

执行结果

  1. 登录EDAS控制台。
  2. 在顶部菜单栏选择地域。
  3. 在左侧导航栏中选择组件中心 > 分布式任务调度(新),然后在左侧导航栏单击应用管理
  4. 应用管理页面选择之前创建的分组所在命名空间,然后在之前创建的分组的操作列单击连接机器

    • 如果接入成功,可以看到机器列表。
    • 如果接入失败,会弹出暂无可用机器的提示信息。

后续步骤

在您的应用接入调度任务并部署到EDAS后,就可以创建调度任务了。具体操作,请参见创建调度任务