SchedulerX:Menghubungkan aplikasi Spring Boot ke SchedulerX

1.1 Konfigurasi dasar

1.2 Konfigurasi notifikasi

1. Tambahkan dependensi yang diperlukan ke file pom.xml.

   Tambahkan dependensi SchedulerxWorker yang diperlukan ke file pom.xml aplikasi Spring Boot Anda agar aplikasi Spring Boot dapat menggunakan fitur-fitur yang disediakan oleh SchedulerX.

   Catatan

   SchedulerX mendukung aplikasi Spring Boot 2.x dan 3.x.

   <dependency>
     <groupId>com.aliyun.schedulerx</groupId>
     <artifactId>schedulerx2-spring-boot-starter</artifactId>
     <version>${schedulerx2.version}</version>
     <!-- If you use Logback, you must exclude Log4j and Log4j 2. -->
     <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>                   

   Penting

   Ganti <version>${schedulerx2.version}</version> dengan versi agen terbaru. Contoh: <version>1.11.5</version>. Untuk informasi selengkapnya, lihat Catatan rilis agen.

2. Konfigurasikan parameter.

   Dalam file konfigurasi application.properties aplikasi Spring Boot, tambahkan parameter yang diperlukan oleh SchedulerxWorker, seperti informasi koneksi dan autentikasi. Parameter tersebut diperlukan agar aplikasi Spring Boot dapat terhubung ke aplikasi SchedulerX.

   spring.schedulerx2.endpoint=${endpoint}
   spring.schedulerx2.namespace=${namespace}
   spring.schedulerx2.groupId=${groupId}
   # The appKey parameter is supported only in versions 1.2.1 and later.
   spring.schedulerx2.appKey=${appKey}
   
   # If you do not use an appKey, you can use an Alibaba Cloud AccessKey and SecretKey, or an STS token.
   #spring.schedulerx2.aliyunAccessKey=${aliyunAccessKey}
   #spring.schedulerx2.aliyunSecretKey=${aliyunSecretKey} 
   #spring.schedulerx2.stsToken=${aliyunStsToken}                  

   Sumber parameter:

   Masuk ke Konsol SchedulerX. Di panel navigasi kiri, klik Applications. Pada halaman Applications, temukan aplikasi yang ingin Anda kelola lalu klik AccessConfig di kolom Operasi. Di panel AccessConfig, pilih Spring Boot dari daftar tarik-turun.

   

   Penting

   Periksa apakah SchedulerX dan agen berada di wilayah yang sama. Jika tidak, agen gagal terhubung ke SchedulerX.

   Jika aplikasi Spring Boot Anda berjalan di server non-Alibaba Cloud atau di lingkungan lokal, pastikan Anda telah mengaktifkan akses Internet ke aplikasi Spring Boot dan membuat aplikasi SchedulerX di wilayah Internet. Untuk informasi selengkapnya, lihat Menghubungkan ke SchedulerX melalui Internet dari lingkungan lokal.

   Catatan

   Jika aplikasi klien Anda berisi beberapa layanan atau Anda perlu mengisolasi tugas terjadwal untuk pengelolaan izin, Anda dapat membuat beberapa aplikasi di konsol untuk mencapai manajemen detail halus. Misalnya, untuk aplikasi klien bernama animals, Anda dapat membuat dua aplikasi di konsol: animals.dog dan animals.cat. Anda tidak perlu meminta worker terpisah untuk kedua aplikasi ini. Anda hanya perlu mengonfigurasi spring.schedulerx2.groupId=${groupId} dalam file konfigurasi application.properties dan mencantumkan nama aplikasi yang dipisahkan dengan koma. Contohnya: spring.schedulerx2.groupId=animals.dog,animals.cat.

   Deskripsi parameter:

   • endpoint: titik akhir SchedulerxWorker. Nilai parameter ini harus sesuai dengan titik akhir wilayah tempat aplikasi Anda diterapkan. Untuk informasi selengkapnya, lihat Titik Akhir.

   • 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 User Management.

   • Tabel berikut menjelaskan parameter yang dapat Anda konfigurasi sesuai kebutuhan.

     kunci	Deskripsi	Nilai	Versi awal
     spring.schedulerx2.enabled	Menentukan apakah starter SchedulerX 2.0 diaktifkan. Nilai default: true. Anda tidak perlu mengonfigurasi parameter ini.	true false	0.1.7
     spring.schedulerx2.endpoint	Titik akhir wilayah yang ditentukan. Untuk informasi selengkapnya, lihat Titik Akhir.	T/A	0.1.7
     spring.schedulerx2.namespace	UID namespace. Anda dapat melihat UID namespace di halaman Namespaces di konsol SchedulerX.	T/A	0.1.7
     spring.schedulerx2.groupId	ID aplikasi. Anda dapat melihat ID aplikasi di halaman Applications di konsol SchedulerX.	T/A	0.1.7
     spring.schedulerx2.appKey	Kunci aplikasi. Anda dapat melihat kunci aplikasi di halaman Applications di konsol SchedulerX.	T/A	1.2.1
     spring.schedulerx2.host	Alamat IP aktual jika terdapat beberapa alamat IP. Beberapa alamat IP mungkin ada jika agen menggunakan VPN atau beberapa network interface card (NIC).	T/A	0.1.7
     spring.schedulerx2.port	Port tempat agen mendengarkan. Jika Anda tidak menentukan port, sistem akan memilih port yang tersedia secara acak.	T/A	0.1.7
     spring.schedulerx2.blockAppStart	Menentukan apakah akan memblokir startup aplikasi jika SchedulerX gagal menyelesaikan inisialisasi. Nilai default: true.	true false	1.1.0
     spring.schedulerx2.shareContainerPool	Menentukan apakah semua pekerjaan pada agen diizinkan berbagi kolam thread. Nilai default: false.	true false	1.2.1.2
     spring.schedulerx2.sharePoolSize	Ukuran kolam thread jika Anda mengizinkan semua pekerjaan berbagi kolam. Nilai default: 64.	T/A	1.2.1.2
     spring.schedulerx2.label	Label. Anda dapat menambahkan label ke agen sehingga Anda dapat menggunakan label untuk menentukan worker untuk manajemen pekerjaan. Fitur ini cocok untuk skenario rilis canary dan uji stres.	T/A	1.2.2.2
     spring.schedulerx2.enableCgroupMetrics	Menentukan apakah akan menggunakan cgroup untuk mengumpulkan metrik agen. Nilai default: false. Anda harus mengaktifkan fitur ini secara manual di lingkungan Kubernetes.	true false	1.2.2.2
     spring.schedulerx2.cgroupPathPrefix	Jalur cgroup di dalam kontainer.	Jalur default adalah /sys/fs/cgroup/cpu/. Jika jalur sudah ada, Anda tidak perlu mengonfigurasi parameter ini.	1.2.2.2
     spring.schedulerx2.enableHeartbeatLog	Menentukan apakah akan menampilkan log heartbeat di file ${user.home}/logs/schedulerx/heartbeat.log. Nilai default: true.	true false	1.2.4
     spring.schedulerx2.mapMasterStatusCheckInterval	Interval SchedulerX memeriksa apakah semua tugas telah selesai dalam model Map. Satuan: milidetik. Jika Anda ingin meningkatkan frekuensi penjadwalan pekerjaan dengan granularitas detik, konfigurasikan parameter ini.	3000	1.2.5.2
     spring.schedulerx2.enableSecondDelayCycleIntervalMs	Menentukan apakah akan mengaktifkan presisi milidetik untuk pekerjaan dengan granularitas detik. Nilai default: false. Jika Anda mengatur parameter ini ke true, interval penjadwalan yang ditentukan di konsol untuk pekerjaan dengan granularitas detik akan diinterpretasikan dalam milidetik, bukan detik. Hal ini meningkatkan frekuensi penjadwalan pekerjaan Anda.	true false	1.2.5.2
     spring.schedulerx2.broadcastMasterExecEnable	Menentukan apakah node utama diperlukan untuk menjalankan pekerjaan broadcast. Nilai default: true.	true false	1.8.13
     spring.schedulerx2.broadcastDispatchRetryTimes	Jumlah maksimum percobaan ulang setelah broadcast gagal. Secara default, tidak ada percobaan ulang. Interval percobaan ulang tetap 2 detik.	3	1.8.13
     spring.schedulerx2.enableSecondDelayStandaloneDispatch	Menentukan apakah akan mengaktifkan pengiriman pekerjaan standalone dengan granularitas detik. Nilai default: false.	true false	1.8.13

3. Buat kelas JobProcessor

   Buat kelas JobProcessor dalam aplikasi Spring Boot untuk mengaktifkan penjadwalan pekerjaan.

   Kode contoh berikut menunjukkan cara menjadwalkan kelas JobProcessor sederhana untuk menampilkan pesan secara berkala. Dalam contoh ini, pesan hello schedulerx2.0 ditampilkan.

   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;
   
   @Component
   public class MyHelloJob extends JavaProcessor {
   
       @Override
       public ProcessResult process(JobContext context) throws Exception {
           System.out.println("hello schedulerx2.0");
           return new ProcessResult(true);
       }
   }              

Masuk ke konsol Microservices Engine (MSE). Di panel navigasi kiri, pilih Task Scheduling > SchedulerX Version. Di halaman SchedulerX Version, klik Applications di panel kiri. Kemudian, temukan aplikasi yang ingin Anda kelola lalu klik View instances di kolom Operasi.