SchedulerX:Hubungkan aplikasi Spring Boot ke SchedulerX

Prasyarat

Sebelum memulai, pastikan Anda memiliki:

• Proyek Spring Boot 2.x atau 3.x

• (Opsional) namespace untuk isolasi resource — lihat bagian "Buat namespace" di Manajemen namespace

Langkah 1: Buat aplikasi SchedulerX

Langkah 2: Tambahkan dependensi SchedulerX

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

<dependency>
  <groupId>com.aliyun.schedulerx</groupId>
  <artifactId>schedulerx2-spring-boot-starter</artifactId>
  <version>1.11.5</version>  <!-- Ganti dengan versi terbaru -->
</dependency>

Jika proyek Anda menggunakan Logback, kecualikan dependensi Log4j yang disertakan:

<dependency>
  <groupId>com.aliyun.schedulerx</groupId>
  <artifactId>schedulerx2-spring-boot-starter</artifactId>
  <version>1.11.5</version>
  <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>

Langkah 3: Konfigurasikan parameter koneksi

Tambahkan properti berikut ke application.properties:

# Wajib: Pengaturan koneksi SchedulerX
spring.schedulerx2.endpoint=${endpoint}
spring.schedulerx2.namespace=${namespace}
spring.schedulerx2.groupId=${groupId}
# Parameter appKey hanya didukung di versi 1.2.1 dan yang lebih baru.
spring.schedulerx2.appKey=${appKey}

# Jika Anda tidak menggunakan appKey, Anda dapat menggunakan AccessKey dan SecretKey Alibaba Cloud, atau token STS.
#spring.schedulerx2.aliyunAccessKey=${aliyunAccessKey}
#spring.schedulerx2.aliyunSecretKey=${aliyunSecretKey}
#spring.schedulerx2.stsToken=${aliyunStsToken}

Sumber parameter:

Login ke Konsol SchedulerX. Di panel navigasi sebelah kiri, klik Applications. Temukan aplikasi yang ingin Anda kelola dan klik AccessConfig di kolom Operation. Di panel AccessConfig, pilih Spring Boot dari dropdown.

Deskripsi parameter:

• endpoint: Titik akhir SchedulerxWorker. Nilainya harus sesuai dengan titik akhir wilayah tempat aplikasi Anda dideploy. Untuk informasi lebih lanjut, lihat Endpoints.

• namespace: ID namespace tempat aplikasi berada. Anda dapat melihat ID namespace di halaman Namespaces di konsol SchedulerX.

• groupId dan appKey: ID dan kunci aplikasi. Anda dapat melihat nilainya di halaman Applications di konsol SchedulerX.

• aliyunAccessKey dan aliyunSecretKey: ID AccessKey dan Rahasia AccessKey Akun Alibaba Cloud Anda. Anda dapat melihat pasangan Kunci Akses di halaman Security Management di Konsol Manajemen Pengguna.

Jika aplikasi menggunakan YAML, tambahkan pengaturan ini ke application.yml sebagai gantinya:

spring:
  schedulerx2:
    endpoint: ${endpoint}
    namespace: ${namespace}
    groupId: ${groupId}
    appKey: ${appKey}

Langkah 4: Buat processor pekerjaan

Buat kelas yang memperluas JavaProcessor untuk mendefinisikan logika pekerjaan. Contoh berikut mencetak pesan setiap kali 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);  // Kembalikan true untuk menunjukkan keberhasilan
    }
}

• @Component mendaftarkan kelas sebagai bean Spring sehingga SchedulerX dapat menemukannya.

• Perluas JavaProcessor dan override process untuk mendefinisikan logika pekerjaan.

• Kembalikan new ProcessResult(true) untuk keberhasilan atau new ProcessResult(false) untuk kegagalan.

Langkah 5: Verifikasi koneksi

1. Jalankan aplikasi Spring Boot Anda.

2. Login ke Konsol MSE SchedulerX. Di panel navigasi sebelah kiri, klik Applications.

3. Temukan aplikasi Anda dan klik View instances di kolom Operation.

   

4. Periksa kolom Total number of instances:

   • 0: Koneksi gagal. Periksa parameter konfigurasi Anda (wilayah, endpoint, namespace, dan GroupID) dan verifikasi konektivitas jaringan.

   • Lebih dari 0: Koneksi berhasil.

Langkah selanjutnya

Setelah koneksi diverifikasi, buat pekerjaan di konsol SchedulerX untuk memicu processor pekerjaan Anda. Lihat bagian "Buat pekerjaan" di Manajemen pekerjaan.

Pemecahan masalah

Lihat juga

• Hubungkan agent ke SchedulerX — metode koneksi lain (non-Spring Boot)

• FAQ tentang alert

• FAQ tentang pekerjaan Spring

• FAQ tentang izin

• FAQ tentang koneksi