SchedulerX:Menghubungkan aplikasi Spring Boot ke SchedulerX

Prasyarat

Sebelum memulai, pastikan Anda telah memiliki:

• Proyek Spring Boot 2.x atau 3.x

• (Opsional) namespace untuk isolasi resource — lihat bagian "Buat namespace" pada Pengelolaan 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 pada versi 1.2.1 dan 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:

Masuk ke Konsol SchedulerX. Di panel navigasi 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.

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 menandakan sukses
    }
}

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

• Perluas JavaProcessor dan override metode process untuk mendefinisikan logika pekerjaan.

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

Langkah 5: Verifikasi koneksi

1. Jalankan aplikasi Spring Boot Anda.

2. Masuk ke Konsol MSE SchedulerX. Di panel navigasi 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) serta verifikasi konektivitas jaringan.

   • Lebih besar dari 0: Koneksi berhasil.

Langkah selanjutnya

Setelah koneksi diverifikasi, buat pekerjaan di Konsol SchedulerX untuk memicu processor pekerjaan Anda. Lihat bagian "Buat pekerjaan" pada Pengelolaan pekerjaan.

Pemecahan masalah

Lihat juga

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

• FAQ tentang alert

• FAQ tentang pekerjaan Spring

• FAQ tentang izin

• FAQ tentang koneksi