Microservices Engine:Hubungkan aplikasi Spring Boot ke SchedulerX

1.1 Konfigurasi pengaturan dasar

1. Masuk ke Konsol MSE SchedulerX dan pilih wilayah di bilah navigasi atas.

2. Di panel navigasi kiri, klik Application Management. Pilih sebuah Namespace, lalu klik Create Application.

3. Masukkan Application Name dan Application ID, pilih Application Type, dan konfigurasikan pengaturan lanjutan jika diperlukan. Lalu klik Next.

Tabel berikut menjelaskan setiap bidang:

Perluas Advanced Configuration untuk mengakses pengaturan tambahan.

1.2 Konfigurasi notifikasi

1. Pada halaman Notification Configuration, pilih Notification Channel dan atur Contact. Saluran notifikasi yang didukung: Text Message, Email, Webhook, dan Phone. Untuk detail konfigurasi webhook, lihat Deskripsi konfigurasi Webhook.

2. Tambahkan penerima notifikasi: Tabel berikut menjelaskan setiap bidang kontak:

   • Contact Group: semua anggota menerima notifikasi. Untuk membuat grup, lihat Buat kontak notifikasi atau grup kontak notifikasi.

   • Contact: tambahkan penerima individual. Klik Add Contact, lalu klik Go To Create Contact dan isi detail kontak.

   Field	Description
   Notification Channel	Saluran yang didukung: Text Message, Email, Webhook, dan Phone.
   Email	Alamat email kontak.
   Webhook	URL Webhook untuk WeCom, Lark, atau DingTalk. Pisahkan beberapa URL dengan koma (,). Untuk DingTalk, tambahkan kata kunci case-sensitive "SchedulerX" ke konfigurasi robot. Untuk detailnya, lihat Dokumentasi Developer DingTalk, Dokumentasi Developer WeCom, dan Dokumentasi Developer Lark.
   Mobile Phone Number	Nomor ponsel kontak.

   

   

3. Setelah menyelesaikan konfigurasi notifikasi, refresh halaman Application Management dan verifikasi bahwa aplikasi baru muncul dalam daftar di bawah wilayah dan namespace yang dipilih.

2.1 Tambahkan dependensi Maven

Tambahkan dependensi schedulerx2-spring-boot-starter ke file pom.xml Anda:

<dependency>
    <groupId>com.aliyun.schedulerx</groupId>
    <artifactId>schedulerx2-spring-boot-starter</artifactId>
    <version>1.11.5</version> <!-- Ganti dengan versi terbaru -->
    <!-- Exclude Log4j jika Anda menggunakan Logback -->
    <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 Konfigurasi parameter koneksi

Tambahkan properti berikut ke file application.properties Anda. Empat parameter diperlukan untuk menghubungkan SchedulerxWorker ke SchedulerX:

# --- Required ---
spring.schedulerx2.endpoint=<your-endpoint>       # Endpoint regional (lihat tabel di bawah)
spring.schedulerx2.namespace=<your-namespace-id>   # UID namespace dari halaman Namespaces
spring.schedulerx2.groupId=<your-group-id>         # Application ID dari Application Management
spring.schedulerx2.appKey=<your-app-key>           # Kunci aplikasi (agent 1.2.1+)

# --- Alternatif autentikasi (jika tidak menggunakan appKey) ---
# spring.schedulerx2.aliyunAccessKey=<your-access-key-id>
# spring.schedulerx2.aliyunSecretKey=<your-access-key-secret>
# spring.schedulerx2.stsToken=<your-sts-token>

Ganti placeholder dengan nilai aktual Anda:

Untuk menemukan parameter koneksi Anda dengan cepat, buka halaman Application Management, klik Access Configuration di kolom Actions untuk aplikasi Anda, lalu pilih Spring Boot.

2.3 Buat job processor

Perluas JavaProcessor untuk menangani tugas terjadwal. Contoh berikut mencetak pesan setiap kali job dijalankan:

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);  // Mengembalikan true untuk menandakan keberhasilan
    }
}