在本地接入公网环境

当SchedulerX在公网地域时,只要可以访问公网的机器或容器(例如,非阿里云的机器或本地开发环境),都可以接入SchedulerX。本文介绍如何在本地接入SchedulerX进行测试和开发。

前提条件

操作步骤

  1. 在应用pom.xml文件中添加SchedulerxWorker依赖。不同应用初始化SchedulerxWorker时有所不同:

    普通Java或Spring应用

    <dependency>
      <groupId>com.aliyun.schedulerx</groupId>
      <artifactId>schedulerx2-worker</artifactId>
      <version>${schedulerx2.version}</version>
      <!--如果用的是logback,需要把log4j和log4j2排除掉 -->
      <exclusions>
        <exclusion>
          <groupId>org.apache.logging.log4j</groupId>
          <artifactId>log4j-api</artifactId>
        </exclusion>
        <exclusion>
          <groupId>org.apache.logging.log4j</groupId>
          <artifactId>log4j-core</artifactId>
        </exclusion>
        <exclusion>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
        </exclusion>
      </exclusions>
    </dependency>              

    Spring Boot应用

    <dependency>
      <groupId>com.aliyun.schedulerx</groupId>
      <artifactId>schedulerx2-spring-boot-starter</artifactId>
      <version>${schedulerx2.version}</version>
      <!--如果使用logback,需要将log4j和log4j2排除 -->
      <exclusions>
        <exclusion>
          <groupId>org.apache.logging.log4j</groupId>
          <artifactId>log4j-api</artifactId>
        </exclusion>
        <exclusion>
          <groupId>org.apache.logging.log4j</groupId>
          <artifactId>log4j-core</artifactId>
        </exclusion>
        <exclusion>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
        </exclusion>
      </exclusions>
    </dependency>                   
  2. 获取接入应用的配置信息,如部署应用的公网地域(Region)和对应的Endpoint(acm.aliyun.com)等。

    1. 登录分布式任务调度平台,在顶部菜单栏,将地域切换为公网

    2. 在左侧导航栏,单击应用管理,在应用管理页面,单击操作列的接入配置获取对应接入方式的配置信息。

      image.png

      image.png

      在①处选择不同的接入方式获取接入配置。

  3. 初始化SchedulerxWorker。不同应用在初始化SchedulerxWorker有所不同:

    普通Java应用

    在main函数中初始化SchedulerxWorker。

    public void initSchedulerxWorker() throws Exception {
        SchedulerxWorker schedulerxWorker = new SchedulerxWorker();
        schedulerxWorker.setEndpoint("xxxx");
        schedulerxWorker.setNamespace("xxxx");
        schedulerxWorker.setGroupId("xxxx");
        //1.2.1及以上版本需要设置应用key
        schedulerxWorker.setAppKey("xxxx");
        schedulerxWorker.init();
    }

    接入配置面板,单击一键复制将配置拷贝至对应配置文件中,或将schedulerxWorker.setEndpointschedulerxWorker.setNamespace schedulerxWorker.setGroupIdschedulerxWorker.setAppKey的值设置为步骤2中获取的参数值。

    说明
    • 一个应用如果包含多个业务,或者需将定时任务归类,可以建立多个分组。例如,应用animals新建两个分组animals.dogsanimals.cats。此时,无需申请两批实例分别接入这两个分组,只需在应用客户端中将这两个分组配置到groupId=后面即可,例如groupId=animals.dogs,animals.cats

    • 在初始化SchedulerxWorker客户端时,如需添加其他配置需求,请参见SchedulerxWorker配置参数说明

    Spring应用

    在xml配置文件中注入SchedulerxWorker Bean。

    <bean id="schedulerxWorker" class="com.alibaba.schedulerx.worker.SchedulerxWorker">
        <property name="endpoint">
          <value>${endpoint}</value>
        </property>
        <property name="namespace">
          <value>${namespace}</value>
        </property>
        <property name="groupId">
          <value>${groupId}</value>
        </property>
        <!--1.2.1及以上版本设置appKey -->
        <property name="appKey">
          <value>${appKey}</value>
        </property>
      
    </bean>

    接入配置面板,单击一键复制将配置拷贝至对应配置文件中,或将${endpoint}${namespace}${groupId}${appKey}替换为步骤2中获取的参数值。

    Spring Boot应用

    application.properties文件中添加如下配置:

    spring.schedulerx2.endpoint=${endpoint}
    spring.schedulerx2.namespace=${namespace}
    spring.schedulerx2.groupId=${groupId}
    # 1.2.1及以上版本设置appKey
    spring.schedulerx2.appKey=${appKey} 

    接入配置面板,单击一键复制将配置拷贝至对应配置文件中,或将${endpoint}${namespace}${groupId}${appKey} 替换为步骤2中获取的参数值。

    说明

    如果一个应用包含多个业务,或者需要将定时任务进行归类,可以建立多个分组。例如,应用animals新建了两个分组animals.dogs和animals.cats,此时无需申请两批实例分别接入这两个分组,在应用客户端中将这两个分组配置到groupId=后面即可,例如groupId=animals.dogs,animals.cats

  4. 在应用中创建类JavaProcessor,实现任务调度。

    下方示例代码介绍如何实现一个简单的定时打印hello schedulerx2.0的JavaProcessor类。

    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);
        }
    }          
  5. 运行本地应用。

结果验证

  1. 客户端接入完成,将该应用发布到阿里云。

  2. 登录分布式任务调度平台,在顶部菜单栏选择地域,然后在左侧导航栏,单击应用管理,在应用管理页面查看实例总数

    • 如果实例总数为0,说明应用接入失败。请检查、修改本地应用。

    • 如果实例总数不为0,显示接入的实例个数,说明应用接入成功。在操作列单击查看实例,即可在连接实例对话框中查看实例列表。