Spring Boot应用接入SchedulerX

1.1基本配置

1.2通知配置

1. 在pom.xml增加依赖配置

   在SpringBoot应用程序的pom.xml文件中添加SchedulerxWorker依赖，以便在Spring Boot应用程序中使用SchedulerX提供的功能。

   说明

   SchedulerX支持SpringBoot2.x和3.x版本接入。

   <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>                   

   重要

   <version>${schedulerx2.version}</version>替换为最新客户端版本。例如：<version>1.11.5</version>。更多信息，请参见客户端版本发布记录。

2. 配置参数

   在SpringBoot应用的配置文件application.properties中添加SchedulerXWorker所需要的参数，例如连接信息、认证信息等，以便连接到SchedulerX应用。

   spring.schedulerx2.endpoint=${endpoint}
   spring.schedulerx2.namespace=${namespace}
   spring.schedulerx2.groupId=${groupId}
   # 1.2.1及以上版本设置appKey
   spring.schedulerx2.appKey=${appKey}
   
   # 1.2.1以下版本设置AK/SK，开启其他特殊配置（例如配置文件定义任务同步、Spring任务自动同步）也需要额外配置以下参数
   #spring.schedulerx2.aliyunAccessKey=${aliyunAccessKey}
   #spring.schedulerx2.aliyunSecretKey=${aliyunSecretKey}                  

   参数来源：

   在分布式任务调度平台左侧导航栏的应用管理页面，单击目标应用操作列的接入配置，选择接入的服务类型为Spring Boot。

   

   重要

   检查SchedulerX地域和客户端地域是否保持一致，否则会造成建立连接失败。

   若您使用的是非阿里云服务器或本地环境，确保您已开放公网访问权限，并在任务调度平台公网地域创建应用。具体信息，可参见在本地接入公网环境。

   说明

   如果您的客户端应用包含多个业务，或者需要将定时任务隔离做权限管理，可以通过在控制台上创建多个应用，实现定时任务的精细化管理。例如，客户端应用animals在控制台上新建了animals.dog和animals.cat两个应用，无需为两个应用分别申请实例，只需在配置文件application.properties中，通过配置spring.schedulerx2.groupId=${groupId}，并以逗号分隔多个应用来实现，如：spring.schedulerx2.groupId=animals.dog,animals.cat。

   参数说明：

   • endpoint：初始化SchedulerxWorker时，将使用您部署应用的地域（Region）和对应的endpoint。更多信息，请参见Endpoint列表。

   • namespace：命名空间ID，可以在控制台的命名空间页面获取。

   • groupId和appKey：groupId应用ID，appKey为应用key，可以在控制台应用管理页面获取。

   • aliyunAccessKey和aliyunSecretKey：aliyunAccessKey为阿里云账号的AccessKeyID，aliyunSecretKey为阿里云账号的AccessKeySecret。您可以登录用户信息管理控制台，在安全信息管理页面获取。

   • 更多参数请参见下表：

     key	描述	设置值	起始版本
     spring.schedulerx2.enabled	是否启用SchedulerX 2.0的starter。默认为true，无需设置。	true false	0.1.7
     spring.schedulerx2.endpoint	设置Region所在的Endpoint。更多信息，请参见Endpoint列表。	无	0.1.7
     spring.schedulerx2.namespace	设置命名空间的UID，可以在控制台命名空间页面获取。	无	0.1.7
     spring.schedulerx2.groupId	应用ID，可以在控制台应用管理页面获取。	无	0.1.7
     spring.schedulerx2.appKey	应用Key，可以在控制台应用管理页面获取。	无	1.2.1
     spring.schedulerx2.host	如果有多个IP（例如VPN或者多网卡），可以设置真实的IP。	无	0.1.7
     spring.schedulerx2.port	用户自定义客户端监听端口。如果不设置，则随机选择一个可用端口。	无	0.1.7
     spring.schedulerx2.blockAppStart	SchedulerX初始化失败是否阻塞应用启动。默认为true。	true false	1.1.0
     spring.schedulerx2.shareContainerPool	客户端所有任务执行是否共享线程池。默认为false。	true false	1.2.1.2
     spring.schedulerx2.sharePoolSize	如果开启共享线程池，可以自定义线程池大小。默认为64。	无	1.2.1.2
     spring.schedulerx2.label	不同客户端可以设置标签，任务管理可以指定标签执行。应用于灰度、压测等场景。	无	1.2.2.2
     spring.schedulerx2.enableCgroupMetrics	是否使用cgroup统计客户端实例的指标。容器（K8s）环境需要手动开启，默认为false。	true false	1.2.2.2
     spring.schedulerx2.cgroupPathPrefix	容器内cgroup的路径。	默认路径为/sys/fs/cgroup/cpu/，如果存在该路径则不需要设置。	1.2.2.2
     spring.schedulerx2.enableHeartbeatLog	是否打印心跳日志，${user.home}/logs/schedulerx/heartbeat.log 默认为true。	true false	1.2.4
     spring.schedulerx2.mapMasterStatusCheckInterval	设置Map模型检测所有子任务结束的频率，单位毫秒。如果秒级别任务需要加快调度频率时，可以设置。	3000	1.2.5.2
     spring.schedulerx2.enableSecondDelayCycleIntervalMs	设置second_delay延迟的单位为毫秒。如果将该值设置为true，控制台设置的秒级别延迟将会变成毫秒，可以加快调度频率，默认为false。	true false	1.2.5.2
     spring.schedulerx2.broadcastMasterExecEnable	主节点是否参与广播任务执行。默认为true。	true false	1.8.13
     spring.schedulerx2.broadcastDispatchRetryTimes	广播分发失败重试次数，默认不重试；重试间隔默认2s，且不可配置。	3	1.8.13
     spring.schedulerx2.enableSecondDelayStandaloneDispatch	是否开启秒级别单机任务分发执行，默认为false。	true false	1.8.13

3. 创建任务处理类

   在SpringBoot应用中创建JobProcessor类，实现任务调度。

   下方示例代码介绍如何定时打印一个简单的JobProcessor类（示例包名：hello schedulerx2.0）。

   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);
       }
   }              

登录分布式任务调度平台，在左侧导航栏的应用管理，单击目标应用操作列的查看实例，查看实例详情信息。