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

1.1 基本設定の構成

1. MSE SchedulerX コンソールにログインし、上部のナビゲーションバーでリージョンを選択します。

2. 左側のナビゲーションペインで[アプリケーション管理]をクリックし、[名前空間]を選択して、[アプリケーションの作成]をクリックします。

3. [アプリケーション名] および [アプリケーションID] を入力し、[アプリケーションタイプ] を選択して、高度な設定を構成します。その後、[次へ] をクリックします。

次の表は、各フィールドについて説明しています。

[高度な設定] を展開して、追加の設定にアクセスします。

1.2 通知の構成

1. [通知設定] ページで、[通知チャネル] を選択し、[連絡先] を設定します。サポートされている通知チャネルは、[テキストメッセージ]、[E メール]、[Webhook]、[電話] です。Webhook の設定詳細については、「Webhook 設定の説明」をご参照ください。

2. 通知受信者を追加します。次の表は、各連絡先フィールドについて説明しています。

   • 連絡先グループ: すべてのメンバーが通知を受信します。グループを作成するには、「通知連絡先または通知連絡先グループを作成する」をご参照ください。

   • 連絡先: 個々の受信者を追加します。[連絡先の追加] をクリックし、次に [連絡先を作成] をクリックして、連絡先の詳細を入力します。

   [フィールド]	[説明]
   通知チャネル	サポートされているチャンネル: テキストメッセージ、メール、Webhook、および電話。
   E メール	連絡先の E メールアドレス。
   Webhook	WeCom、Lark、または DingTalk の Webhook URL。複数の URL はコンマ (,) で区切ります。DingTalk の場合、ロボット構成に大文字と小文字を区別するキーワード「SchedulerX」を追加します。詳細については、「DingTalk 開発者ドキュメント」、「WeCom 開発者ドキュメント」、および「Lark 開発者ドキュメント」をご参照ください。
   携帯電話番号	連絡先の携帯電話番号。

   

   

3. 通知の構成が完了したら、[アプリケーション管理] ページをリフレッシュし、選択したリージョンと名前空間配下のリストに新しいアプリケーションが表示されることを確認します。

2.1 Maven 依存関係の追加

schedulerx2-spring-boot-starter 依存関係を pom.xml に追加します。

<dependency>
    <groupId>com.aliyun.schedulerx</groupId>
    <artifactId>schedulerx2-spring-boot-starter</artifactId>
    <version>1.11.5</version> <!-- 最新バージョンに置き換えてください -->
    <!-- Logback を使用する場合は Log4j を除外してください -->
    <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>

2.2 接続パラメーターの構成

次のプロパティを application.properties ファイルに追加します。SchedulerxWorker を SchedulerX に接続するには、4 つのパラメーターが必須です。

# --- Required ---
spring.schedulerx2.endpoint=<your-endpoint>       # Regional endpoint (see table below)
spring.schedulerx2.namespace=<your-namespace-id>   # Namespace UID from the Namespaces page
spring.schedulerx2.groupId=<your-group-id>         # Application ID from Application Management
spring.schedulerx2.appKey=<your-app-key>           # Application key (agent 1.2.1+)

# --- Alternative authentication (if not using appKey) ---
# spring.schedulerx2.aliyunAccessKey=<your-access-key-id>
# spring.schedulerx2.aliyunSecretKey=<your-access-key-secret>
# spring.schedulerx2.stsToken=<your-sts-token>

プレースホルダーを実際の値に置き換えてください。

接続パラメーターをすばやく見つけるには、[アプリケーション管理] ページに移動し、アプリケーションの[操作] 列にある[アクセス設定] をクリックし、次に[Spring Boot] を選択します。

2.3 ジョブプロセッサの作成

定期タスクを処理するためには、JavaProcessor を拡張します。次の例では、ジョブが実行されるたびにメッセージが出力されます：

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;
import org.springframework.stereotype.Component;

@Component
public class MyHelloJob extends JavaProcessor {

    @Override
    public ProcessResult process(JobContext context) throws Exception {
        System.out.println("hello schedulerx2.0");
        return new ProcessResult(true);  // 成功を示すために true を返します。
    }
}