本文介绍如何将本地接入云上公网测试环境来进行本地开发、调试和验证。

前提条件

背景信息

云上公网环境不保证稳定性和数据安全性，只是方便本地开发调试使用。请测试验证完成后，删除任务并在线上正式环境创建相同的任务。

操作步骤

  1. 在应用pom.xml文件中添加SchedulerxWorker依赖。
    针对不同应用，在初始化SchedulerxWorker时会有所不同。
    • 普通Java或Spring应用 
      <dependency>
    <groupId>com.aliyun.schedulerx</groupId>
    <artifactId>schedulerx2-worker</artifactId>
    <version>${schedulerx2.version}</version>
</dependency>
    • Spring Boot应用 
      <dependency>
 <groupId>com.aliyun.schedulerx</groupId>
 <artifactId>schedulerx2-spring-boot-starter</artifactId>
 <version>${schedulerx2.version}</version>
</dependency>
  2. 初始化SchedulerxWorker。
    针对不同应用，在初始化SchedulerxWorker的时候会有所不同。
    • 普通Java应用

      在main函数中初始化SchedulerxWorker。

      private static void initSchedulerxWorker() throws Exception {
    // 测试环境为acm.aliyun.com
    String endpoint = "xxx";
    // 为测试环境命名空间里面的namespace
    String namespace = "xxx-xxx";
    // 替换之前创建的分组的Group ID
    String groupId = "schedulerx.defaultGroup";
    SchedulerxWorker schedulerxWorker = new SchedulerxWorker();
    schedulerxWorker.setGroupId(groupId);
    schedulerxWorker.setNamespace(namespace);
    schedulerxWorker.setEndpoint(endpoint);
    schedulerxWorker.setAliyunAccessKey("xxxx");
    schedulerxWorker.setAliyunSecretKey("xxxx");
    schedulerxWorker.init();
    LOGGER.info("SchedulerxWorker init success. groupId={}", groupId);
}
      说明
      • 一个应用如果包含多个业务，或者想把定时任务进行归类，可以建立多个分组，例如应用animals新建了两个分组animals.dogs和 animals.cats。此时不用申请两批实例分别接入这两个分组，在应用客户端中将这两个分组配置到groupId=后面即可，例如groupId=animals.dogs,animals.cats。
      • 在初始化SchedulerxWorker客户端时，如果还有其它配置需求，可以参考SchedulerxWorker 配置参数说明添加配置。
    • Spring应用

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

      <bean id="schedulerxWorker" class="com.alibaba.schedulerx.worker.SchedulerxWorker">
      // 测试环境为acm.aliyun.com
      <property name="endpoint">
        <value>${endpoint}</value>
      </property>
      <property name="namespace">
        <value>${namespace}</value>
      </property>
      <property name="groupId">
        <value>${groupId}</value>
      </property>
      <property name="aliyunAccessKey">
        <value>${aliyunAccessKey}</value>
      </property>
      <property name="aliyunSecretKey">
        <value>${aliyunSecretKey}</value>
      </property>
</bean>
    • Spring Boot应用

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

      // 测试环境为acm.aliyun.com
spring.schedulerx2.endpoint=acm.aliyun.com
// 测试环境为8080
spring.schedulerx2.endpointPort=8080
// 为测试环境命名空间里面的namespace
spring.schedulerx2.namespace=${namespace}
// 填写之前创建的分组的Group ID
spring.schedulerx2.groupId=${groupId}
spring.schedulerx2.aliyunAccessKey=${aliyunAccessKey}
spring.schedulerx2.aliyunSecretKey=${aliyunSecretKey}
      说明 一个应用如果包含多个业务，或者想把定时任务进行归类，可以建立多个分组，例如应用animals新建了两个分组animals.dogs和animals.cats。此时不用申请两批实例分别接入这两个分组，在应用客户端中将这两个分组配置到groupId=后面即可，例如groupId=animals.dogs,animals.cats。
  3. 在应用中创建类 JobProcessor，实现任务调度。

    本文仅介绍如何实现一个最简单的定时打印“Hello SchedulerX2.0”的 JobProcessor 类。 

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

结果验证

  1. 客户端接入完成，将该应用发布到阿里云。
  2. 登录分布式任务调度平台。
  3. 在顶部菜单栏选择地域。
  4. 在左侧导航栏单击应用管理。
  5. 在应用管理页面查看实例总数。
    • 如果实例总数为 0，则说明应用接入失败。请检查、修改本地应用。
    • 如果实例总数不为 0，显示接入的实例个数，则说明应用接入成功。在操作列单击查看实例，即可在连接实例对话框中查看实例列表。
    应用管理-实例总数