SchedulerX:Integrasikan pekerjaan Spring dengan SchedulerX

Langkah 2: Tambahkan parameter konfigurasi

Agar SchedulerX dapat mengelola pekerjaan Spring Anda, tambahkan konfigurasi berikut ke file application.properties Anda.

# 1. Konfigurasi akses aplikasi
spring.schedulerx2.endpoint=${endpoint}
spring.schedulerx2.namespace=${namespace}
spring.schedulerx2.groupId=${groupId}
spring.schedulerx2.appKey=${appKey}

# 2. Aktifkan SchedulerX untuk mengelola pekerjaan Spring
spring.schedulerx2.task.scheduling.scheduler=schedulerx

# 3. Opsional: Aktifkan sinkronisasi otomatis untuk pekerjaan Spring yang sudah ada
#spring.schedulerx2.task.scheduling.sync=true
#spring.schedulerx2.regionId=Tentukan ID wilayah untuk sinkronisasi pekerjaan.
#spring.schedulerx2.aliyunAccessKey=XXXXXXXXX
#spring.schedulerx2.aliyunSecretKey=XXXXXXXXX

Penjelasan parameter:

• Konfigurasi akses aplikasi: Masuk ke Konsol SchedulerX. Di panel navigasi sebelah kiri, klik Application Management. Temukan aplikasi Anda, lalu di kolom Actions, klik Access Configuration untuk mendapatkan kredensial Anda. Jika ini pertama kalinya Anda menghubungkan, Anda harus membuat kelompok aplikasi.

• Konfigurasi sinkronisasi otomatis: Jika Anda memiliki banyak pekerjaan Spring yang sudah ada, Anda dapat mengaktifkan sinkronisasi otomatis untuk menghindari pembuatan tugas secara manual seperti yang dijelaskan di Langkah 3. Untuk daftar ID wilayah, lihat Endpoints.

Langkah 4: Verifikasi integrasi

1. Jalankan aplikasi Spring Anda. Setelah aplikasi berjalan, masuk ke Konsol SchedulerX dan klik Application Management di panel navigasi sebelah kiri. Verifikasi bahwa instans aplikasi Anda muncul dalam daftar.

Di kolom Instances, pastikan jumlahnya lebih dari 0. Anda juga dapat mengklik View Instances di kolom Actions untuk melihat detail instans yang terhubung.

2. Di panel navigasi sebelah kiri, klik task management. Temukan tugas untuk aplikasi Anda dan klik Run Once di kolom Actions. Eksekusi yang berhasil mengonfirmasi integrasi tersebut.

Mengapa pengatur waktu Spring asli tetap berjalan setelah SchedulerX mengambil alih?

Jika scheduler kustom ditentukan dalam aplikasi Anda, SchedulerX akan menimpa scheduler kustom tersebut. Konflik ini biasanya terjadi ketika suatu kelas mengimplementasikan org.springframework.scheduling.annotation.SchedulingConfigurer dan memanggil metode setScheduler dari ScheduledTaskRegistrar, yang menimpa scheduler default.

Untuk mengatasi masalah ini:

1. Cari di proyek Anda kelas apa pun yang mengimplementasikan SchedulingConfigurer.

2. Periksa apakah metode setScheduler dari ScheduledTaskRegistrar dipanggil.

3. Jika salah satu kondisi tersebut benar, beri komentar pada kode scheduler kustom tersebut.

Bagaimana cara mendapatkan konteks pekerjaan dalam pekerjaan Spring?

Panggil ContainerFactory.getContainerPool().getContext() untuk mendapatkan JobContext saat ini:

// Dapatkan konteks pekerjaan SchedulerX di dalam metode @Scheduled
JobContext jobContext = ContainerFactory.getContainerPool().getContext();

Dapatkah pekerjaan Spring mengembalikan hasil pemrosesan?

Hasil pemrosesan dikembalikan berdasarkan metode penjadwalan yang ditentukan. Pekerjaan Spring mendukung dua tipe nilai kembali:

Kedua contoh berikut menggunakan anotasi @Scheduled dengan ekspresi cron.

Mengembalikan ProcessResult

Gunakan ProcessResult untuk menunjukkan status sukses atau gagal beserta pesan hasil:

@Scheduled(cron = "0/5 * * * * ?")
public ProcessResult helloStandalone1() {
    try {
        logger.info(DateUtil.now() + " " + Thread.currentThread().getName() + " hello world. start");
        TimeUnit.SECONDS.sleep(2L);
        logger.info(DateUtil.now() + " " + Thread.currentThread().getName() + " hello world. end");
    } catch (Exception e) {
        e.printStackTrace();
        logger.info(DateUtil.now() + " " + Thread.currentThread().getName() + " hello world. exception end..");
    }
    // Argumen pertama: true untuk sukses, false untuk gagal
    // Argumen kedua: pesan hasil
    return new ProcessResult(true, "Processing result");
}

Mengembalikan String

Kembalikan String secara langsung jika Anda tidak memerlukan indikator eksplisit sukses/gagal:

@Scheduled(cron = "0/5 * * * * ?")
public String helloStandalone2() {
    try {
        logger.info(DateUtil.now() + " " + Thread.currentThread().getName() + " hello world. start");
        TimeUnit.SECONDS.sleep(2L);
        logger.info(DateUtil.now() + " " + Thread.currentThread().getName() + " hello world. end");
    } catch (Exception e) {
        e.printStackTrace();
        logger.info(DateUtil.now() + " " + Thread.currentThread().getName() + " hello world. exception end..");
    }
    return "Processing result";
}