Microservices Engine:Pekerjaan terjadwal Spring

Langkah 2: Tambahkan parameter konfigurasi

Agar SchedulerX dapat mengelola pekerjaan terjadwal Spring Anda, tambahkan konfigurasi berikut ke file 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 mengambil alih pekerjaan terjadwal Spring
spring.schedulerx2.task.scheduling.scheduler=schedulerx
# 3. (Opsional) Aktifkan sinkronisasi otomatis untuk pekerjaan
#spring.schedulerx2.task.scheduling.sync=true
#spring.schedulerx2.regionId=ID wilayah target untuk sinkronisasi. Untuk informasi tentang ID wilayah, lihat Endpoints.
#spring.schedulerx2.aliyunAccessKey=XXXXXXXXX
#spring.schedulerx2.aliyunSecretKey=XXXXXXXXX

Deskripsi parameter:

• Konfigurasi akses aplikasi: Login ke Konsol MSE SchedulerX. Di panel navigasi sebelah kiri, klik Application Management. Di halaman Applications, temukan aplikasi Anda dan klik Access Config di kolom Actions untuk mendapatkan detail konfigurasi. Jika ini pertama kalinya Anda menghubungkan aplikasi, Anda harus membuat kelompok aplikasi.

• Aktifkan sinkronisasi pekerjaan otomatis: Jika Anda memiliki banyak pekerjaan terjadwal Spring yang sudah ada, Anda dapat mengaktifkan sinkronisasi otomatis dalam file konfigurasi aplikasi. Hal ini sangat menyederhanakan proses pembuatan manual yang dijelaskan di Langkah 3. Untuk ID wilayah dalam konfigurasi, lihat ID wilayah di Endpoints.

Langkah 4: Verifikasi integrasi pekerjaan

1. Jalankan aplikasi Spring Anda. Setelah aplikasi berjalan, login ke Konsol MSE SchedulerX. Di panel navigasi sebelah kiri, klik Application Management dan periksa instans yang terhubung dalam kelompok aplikasi. Kehadiran instans mengonfirmasi koneksi berhasil.

Di daftar aplikasi, pastikan Total number of instances untuk aplikasi target lebih besar dari 0. Klik View instances di kolom Operation untuk melihat detail instans.

2. Di panel navigasi sebelah kiri, klik Task Management. Temukan pekerjaan yang sesuai dengan aplikasi Anda, lalu di kolom Actions, klik Run once. Eksekusi yang berhasil menunjukkan bahwa pengaturan telah selesai.

Mengapa timer 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 sebuah 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();

Apakah pekerjaan Spring dapat 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 flag 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";
}