SchedulerX:SchedulerX 2.0 プラットフォームで ElasticJob ジョブをホストする

手順 1: SchedulerX コンソールで名前空間とアプリケーションを作成する

SchedulerX コンソールで名前空間とアプリケーションを作成します。 詳細については、「名前空間を作成する」および「アプリケーションを作成する」をご参照ください。

手順 2: elasticjob 依存関係を追加する

pom.xml ファイルの elasticjob 依存関係の前に、 schedulerx2-plugin-elasticjob 依存関係を追加します。

 <dependency>
     <groupId>com.aliyun.schedulerx</groupId>
     <artifactId>schedulerx2-plugin-elasticjob</artifactId>
     <version>3.0.2.2</version>
</dependency>
<dependency>
    <groupId>org.apache.shardingsphere.elasticjob</groupId>
    <artifactId>elasticjob-lite-spring-boot-starter</artifactId>
    <version>3.0.2</version>
</dependency>

手順 3: SchedulerX をスケジューラとして構成ファイルに追加する

application.yml ファイルで、elasticjob.scheduler=schedulerx 設定項目を追加し、spring.schedulerx2 に関連する構成を追加します。

elasticjob:
  regCenter:
    serverLists: 127.0.0.1:2181
    namespace: elasticjob-test
  scheduler: schedulerx # SchedulerX がスケジューラとして指定されています。 SchedulerX がスケジューラとして指定されていない場合、ElasticJob がスケジューラとして使用されます。
  jobs:
    simpleJob:
      elasticJobClass: com.alibaba.elasticjob.test.processor.SpringBootSimpleJob
      cron: 0/10 * * * * ?
      shardingTotalCount: 1
      overwrite: true
    shardingJob:
      elasticJobClass: com.alibaba.elasticjob.test.processor.SpringBootShardingJob
      cron: 0 * * * * ?
      shardingTotalCount: 3
      shardingItemParameters: 0=Beijing,1=Shanghai,2=Guangzhou
      overwrite: true
# 次の SchedulerX 構成を追加します。
spring:
   schedulerx2:
      endpoint: acm.aliyun.com
      namespace: 433d8b23-xxxx-xxxx-xxxx-90d4d1b9a4af
      groupId: xueren_primary
      appKey: xxxxxxxxxxx
      regionId: public
      aliyunAccessKey: xxxxxxxxxxxx
      aliyunSecretKey: xxxxxxxxxxxx

ElasticJob スケジューラに戻すには、-D パラメータを使用してスケジューラを動的に調整します。 サンプルコード:

-Dspring.schedulerx2.enabled=false -Delasticjob.scheduler=elasticjob

手順 4: アプリケーションが起動時に自動スキャンを実行するための構成を追加する

アプリケーションが起動時に com.alibaba.schedulerx.plugin.* ディレクトリ内のファイルを自動的にスキャンできるように構成を追加します。 サンプルコード:

（オプション）手順 5: ロギングサービスを構成する

クライアントからログを収集するようにロギングサービスを構成できます。 この例では、log4j2 が使用されています。 詳細については、「SchedulerX でサポートされているロギングサービス」をご参照ください。

<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="off">
	<Appenders>
		<Console name="Console" target="SYSTEM_OUT">
			<PatternLayout
				pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %m%n" />
		</Console>
		<SchedulerxLog4j2Appender name="schedulerxLog"
            timeFormat="yyyy-MM-dd'T'HH:mmZ"
            timeZone="UTC"
            ignoreExceptions="true">
        <PatternLayout pattern="%d %-5level [%thread] %logger{0}: %msg"/>
    </SchedulerxLog4j2Appender>
	</Appenders>
	<Loggers>
		<Root level="info">
			<AppenderRef ref="Console" />
		</Root>
		<Logger name="schedulerx" level="info" additivity="false">
			<AppenderRef ref="schedulerxLog" />
		</Logger>
	</Loggers>
</Configuration>

実装クラスのサンプルコード:

手順 6: ジョブの実行を確認する

アプリケーションが起動すると、ジョブは SchedulerX コンソールに自動的に同期されます。

• スケジューリング頻度は秒単位です。 時間のタイプは second_delay に変更されます。

• シャード数が 1 より大きい場合、ジョブはシャーディングモードで実行されます。 それ以外の場合、ジョブはスタンドアロンモードで実行されます。

SchedulerX コンソールでジョブの操作ログを表示できます。