为应用实现任务调度（非 EDAS 部署）

操作流程

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

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

创建任务调度分组

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

1. 登录 EDAS 控制台。
2. 在左侧导航栏中选择组件中心 > 分布式任务调度2.0。
3. 在分布式任务调度2.0左侧导航栏选择应用管理。
4. 在应用管理页面选择地域和命名空间，然后单击创建。
   
5. 在创建应用分组对话框的应用名右侧的下拉列表中选择应用，在 Group ID 右侧的文本框中输入应用分组名称，然后单击确定。

   GroupId 建议取一个有业务含义的，例如 tmall.order。Group ID 要求在当前命名空间内唯一，否则将创建失败。

   

   创建完成后，自动返回应用管理页面，在应用列表中查看应用分组是否已存在。

   下面配置的 Namespace 指的是任务调度系统的命名空间列表的命名空间 ID。

   

为应用接入任务调度

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

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

1. 初始化 SchedulerxWorker

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

   • 独立 Java 应用

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

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

        <dependency>
        <groupId>com.aliyun.schedulerx</groupId>
        <artifactId>schedulerx2-worker</artifactId>
        <version>${schedulerx2.version}</version>
        </dependency>                   

     2. 在 main 函数中初始化 SchedulerxWorker。

        初始化 SchedulerxWorker 时，会用到您部署应用的地域（Region）和对应的 Endpoint。它们的关系如下表所示。

        region	endpoint
        华东1（杭州）	addr-hz-internal.edas.aliyun.com
        华东2（上海）	addr-sh-internal.edas.aliyun.com
        华北2（北京）	addr-bj-internal.edas.aliyun.com
        华北3（张家口）	addr-cn-zhangjiakou-internal.edas.aliyun.com
        华南1（深圳）	addr-sz-internal.edas.aliyun.com
        美国（弗吉尼亚）	addr-us-east-1-internal.acm.aliyun.com
        测试（华东1）	acm.aliyun.com

        private static void initSchedulerxWorker() throws Exception {
            SchedulerxWorker schedulerxWorker = new SchedulerxWorker();
            schedulerxWorker.setEndpoint("xxxx");
            schedulerxWorker.setNamespace("xxxx");
            schedulerxWorker.setGroupId("xxxx");
            schedulerxWorker.setAliyunAccessKey("xxxx");
            schedulerxWorker.setAliyunSecretKey("xxxx");
            schedulerxWorker.init();
        }                           

        说明

        • 一个应用如果有不止一个业务，或者想把定时任务进行归类，可以建立多个分组。例如应用名是 animals，新建两个分组 animals.dogs 和 animals.cats。此时不用申请两批实例分别接入 2 个分组，一个应用可以同时接入 2 个分组，在客户端中将这 2 个分组配置到groupId=后面，如groupId=animals.dogs,animals.cats即可。

        • 在初始化 SchedulerxWorker 客户端时，根据实际业务，如果还有其它配置需求，可以参考 SchedulerxWorker 配置参数说明增加配置。

   • Spring 应用

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

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

        <dependency>
        <groupId>com.aliyun.schedulerx</groupId>
        <artifactId>schedulerx2-worker</artifactId>
        <version>${schedulerx2.version}</version>
        </dependency>                    

     2. 在 xml 配置文件中初始化 SchedulerxWorker（注入 Bean）。

        初始化 SchedulerxWorker 时，会用到您部署应用的地域（Region）和对应的 Endpoint。它们的关系如下表所示。

        region	endpoint
        华东1（杭州）	addr-hz-internal.edas.aliyun.com
        华东2（上海）	addr-sh-internal.edas.aliyun.com
        华北2（北京）	addr-bj-internal.edas.aliyun.com
        华北3（张家口）	addr-cn-zhangjiakou-internal.edas.aliyun.com
        华南1（深圳）	addr-sz-internal.edas.aliyun.com
        美国（弗吉尼亚）	addr-us-east-1-internal.acm.aliyun.com
        测试（华东1）	acm.aliyun.com

        <bean id="schedulerxWorker" class="com.alibaba.schedulerx.worker.SchedulerxWorker">
            <property name="endpoint">
              <value>${endpoint}</value>
            </property>
            <property name="namespace">
              <value>${namespace}</value>
            </property>
            //填写之前创建的分组的 Group ID。可以配置多个分组，以英文逗号（,）分隔。
            <property name="groupId">
              <value>${groupId}</value>
            </property>
            <property name="aliyunAccessKey">
              <value>${aliyunAccessKey}</value>
            </property>
            <property name="aliyunSecretKey">
              <value>${aliyunSecretKey}</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. 初始化 SchedulerxWorker。

        初始化 SchedulerxWorker 时，会用到您部署应用的地域（Region）和对应的 Endpoint。它们的关系如下表所示。

        region	endpoint
        华东1（杭州）	addr-hz-internal.edas.aliyun.com
        华东2（上海）	addr-sh-internal.edas.aliyun.com
        华北2（北京）	addr-bj-internal.edas.aliyun.com
        华北3（张家口）	addr-cn-zhangjiakou-internal.edas.aliyun.com
        华南1（深圳）	addr-sz-internal.edas.aliyun.com
        美国（弗吉尼亚）	addr-us-east-1-internal.acm.aliyun.com
        测试（华东1）	acm.aliyun.com

        在 application.properties 文件中添加之前创建的任务分组的 Group ID。

        说明 一个应用如果有不止一个业务，或者想把定时任务进行归类，可以建立多个分组。例如应用名是 animals，新建两个分组 animals.dogs 和 animals.cats。此时不用申请两批实例分别接入 2 个分组，一个应用可以同时接入 2 个分组，在客户端中将这 2 个分组配置到groupId=后面，如groupId=animals.dogs,animals.cats即可。

        spring.schedulerx2.endpoint=${endpoint}
        spring.schedulerx2.namespace=${namespace}
        spring.schedulerx2.groupId=${groupId}
        spring.schedulerx2.aliyunAccessKey=${aliyunAccessKey}
        spring.schedulerx2.aliyunSecretKey=${aliyunSecretKey}                   

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. 将应用部署到阿里云。

   将应用打包，并根据您的实际需求部署到阿里云。