本文介绍如何将本地接入云上公网测试环境来进行本地开发、调试和验证。
前提条件
- 开通SchedulerX(免费)
- 创建应用
说明 在创建应用时,请选择公网地域。
本文介绍如何将本地接入云上公网测试环境来进行本地开发、调试和验证。
<dependency>
<groupId>com.aliyun.schedulerx</groupId>
<artifactId>schedulerx2-worker</artifactId>
<version>${schedulerx2.version}</version>
</dependency>
<dependency>
<groupId>com.aliyun.schedulerx</groupId>
<artifactId>schedulerx2-spring-boot-starter</artifactId>
<version>${schedulerx2.version}</version>
</dependency>
在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
。
在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>
在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
。
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);
}
}
在文档使用中是否遇到以下问题
更多建议
匿名提交