Microservices Engine:SchedulerX への Spring アプリケーションの接続

次のサンプルコードの 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>              

• SchedulerxWorker を初期化するには、アプリケーションがデプロイされているリージョンと一致するエンドポイントを指定する必要があります。詳細については、「エンドポイント」をご参照ください。

• namespace は、アプリケーションが属する名前空間の ID を指定します。名前空間 ID は、SchedulerX コンソールの [名前空間] ページで確認できます。

• groupId はアプリケーションのグループ ID を指定し、appKey はアプリケーションのキーを指定します。グループ ID とアプリケーションキーは、SchedulerX コンソールの [アプリケーション管理] ページで確認できます。また、アプリケーションの [操作] 列にある [アクセス設定] をクリックして、アクセスモードの設定情報を確認することもできます。

  

<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>
    <!--エージェントのバージョンが 1.2.1 以降の場合は、アプリケーションキーを指定する必要があります。-->
    <property name="appKey">
      <value>${appKey}</value>
    </property>
  
</bean>

次のコードは、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"); // "hello schedulerx2.0" を出力します。
        return new ProcessResult(true);
    }
}