本文主要介绍如何快速上手使用 SchedulerX,包括如何创建和配置一个定时任务、定时任务处理器的编写以及定时任务执行客户端 Bean 配置。
主要内容如下:
创建定时任务处理器。
创建定时任务并配置任务触发时间周期。
运行客户端,启动调度任务。
下文以建立一个每隔 1 分钟执行一次 Hello World 输出的定时任务为例进行说明。
1、创建定时任务处理器
在工程中添加 SchedulerX -client 依赖<dependency>- <groupId>com.alibaba.edas</groupId>
- <artifactId>schedulerX-client</artifactId>
- <version>1.6.6</version>
- </dependency>
实现 Job 处理器接口
- package com.schedulerx.test;
- import java.util.Date;
- import com.alibaba.edas.schedulerX.ProcessResult;
- import com.alibaba.edas.schedulerX.ScxSimpleJobContext;
- import com.alibaba.edas.schedulerX.ScxSimpleJobProcessor;
- public class ExecuteShellJobProcessor implements ScxSimpleJobProcessor {
- public ProcessResult process(ScxSimpleJobContext context) {
- System.out.println("Hello World! "+new Date());
- return new ProcessResult(true);//true表示执行成功,false表示失败
- }
- }
2、创建定时任务并配置任务触发时间周期
登录 EDAS 控制台, 在左侧菜单栏选择 分布式任务调度 > 任务分组,在右上角单击 新建分组。
在 新建分组 对话框输入分组描述,单击 确定。
在左侧菜单栏选择 分布式任务调度 > 任务管理,在右上角单击 新建 Job。
在 创建任务 对话框输入相应信息,单击 确定。
- 任务分组 ID:对应 schedulerXClient Bean 中的 groupId 属性。
- 区域名称:对应 schedulerXClient Bean 中的 regionName 属性。
启动调度任务。
独立 Java 应用方式
在运行应用的机器安装 EDAS Agent。
把应用打好的 JAR 包上传至应用服务器。
运行主函数 schedulerxTestMain,同时在程序启动时加上参数 -Dspas.identity=/home/admin/.spas_key/default
EDAS 应用管理( WAR 包部署)方式
将应用打好 WAR 包。
在 EDAS 控制台应用管理中创建应用,上传 WAR 包。
在应用管理中启动调度任务应用。
启动调度任务后,系统将会根据您的设定(每隔1分钟)调用实现 Job 处理器接口的类代码(ExecuteShellJobProcessor),完成打印输出 Hello World 的任务。