Spring應用接入SchedulerX實現分布式任務調度-微服務引擎-阿里雲

您可以為您的Spring應用快速接入SchedulerX，實現分布式任務調度能力。

前提條件

（可選）已建立命名空間。具體操作，請參見建立命名空間。
已建立資源。具體操作，請參見建立資源。

Spring應用用戶端接入SchedulerX

在應用程式的pom.xml檔案中添加SchedulerxWorker依賴。

請參見用戶端發布記錄，schedulerx2.version使用最新用戶端版本。

<dependency>
  <groupId>com.aliyun.schedulerx</groupId>
  <artifactId>schedulerx2-worker</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>

在xml設定檔中初始化SchedulerxWorker（注入Bean）。
- 初始化SchedulerxWorker時，會用到您部署應用的地區（Region）和對應的Endpoint。詳情請參見Endpoint列表。
- namespace為命名空間ID，可以在控制台命名空間頁面擷取。
- groupId為應用ID，appKey為應用key，可以在控制台應用管理頁面擷取。您也可以在操作列，單擊接入配置擷取對應接入方式的配置資訊。
```
<bean id="schedulerxWorker" class="com.alibaba.schedulerx.worker.SchedulerxWorker">
    <property name="endpoint">
      <value>${endpoint}</value>
    </property>
    <property name="namespace">
      <value>${namespace}</value>
    </property>
    <property name="groupId">
      <value>${groupId}</value>
    </property>
    
    <property name="appKey">
      <value>${appKey}</value>
    </property>
  
</bean>
```
說明
- 一個應用如果包含多個業務，或者想把定時任務進行歸類，可以建立多個分組，例如應用animals建了兩個分組animals.dogs和animals.cats。此時不用申請兩批執行個體分別接入這兩個分組，在應用用戶端中將這兩個分組配置到groupId=後面即可，例如groupId=animals.dogs,animals.cats。
- 在初始化SchedulerxWorker用戶端時，如果還有其它配置需求，可以參考SchedulerxWorker配置參數說明添加配置。

在應用中建立類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);
    }
}

結果驗證

用戶端接入完成，將該應用發布到阿里雲。
登入分布式任務調度平台，在頂部功能表列選擇地區，然後在左側導覽列，單擊應用管理，在應用管理頁面查看執行個體總數。
- 如果執行個體總數為0，說明應用接入失敗。請檢查、修改本地應用。
- 如果執行個體總數不為0，顯示接入的執行個體個數，說明應用接入成功。在操作列單擊查看執行個體，即可在串連執行個體對話方塊中查看執行個體列表。

後續步驟

應用接入SchedulerX完成後，即可在分布式任務調度平台建立調度任務。更多資訊，請參見建立調度任務。