本文主要介绍如何快速上手使用 SchedulerX,包括如何创建和配置一个定时任务、定时任务处理器的编写以及定时任务执行客户端 Bean 配置。
主要内容如下:
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
要快速上手使用SchedulerX并创建一个定时任务,执行以下步骤:
添加依赖:确保项目中已添加SchedulerX客户端依赖。例如,使用Maven时,在pom.xml
文件中加入:
<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 {
@Override
public ProcessResult process(ScxSimpleJobContext context) {
System.out.println("Hello World! " + new Date());
return new ProcessResult(true); // true表示执行成功
}
}
登录控制台:访问EDAS或SchedulerX控制台,选择分布式任务调度 > 任务分组,点击新建分组,填写描述后保存。
创建Job:在任务管理页面,点击新建Job,输入任务信息,包括但不限于:
com.schedulerx.test.ExecuteShellJobProcessor
)。0 */1 * * * ?
代表每分钟执行一次。配置参数:确保任务分组ID与客户端Bean中的groupId
属性匹配,区域名称与regionName
属性一致。
java -jar your-app.jar -Dspas.identity=/path/to/your/spas_key
完成以上步骤后,系统将按照设定的时间周期(本例中为每分钟)自动调用ExecuteShellJobProcessor
类,输出“Hello World”信息。