Microservices Engine:Hubungkan aplikasi Spring Boot ke SchedulerX

1.1 Pengaturan dasar

1.2 Pengaturan notifikasi

1. Tambahkan dependensi ke pom.xml

   Tambahkan dependensi schedulerx2-spring-boot-starter ke file pom.xml proyek Anda untuk menggunakan fitur SchedulerX.

   Catatan

   SchedulerX mendukung koneksi dari Spring Boot 2.x dan 3.x.

   <dependency>
     <groupId>com.aliyun.schedulerx</groupId>
     <artifactId>schedulerx2-spring-boot-starter</artifactId>
     <version>${schedulerx2.version}</version>
     <!-- Jika Anda menggunakan logback, exclude log4j dan log4j2 -->
     <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 client terbaru. Contohnya: <version>1.11.5</version>. Untuk informasi lebih lanjut, lihat Catatan rilis client.

2. Konfigurasikan parameter

   Pada file application.properties aplikasi Spring Boot Anda, tambahkan parameter yang diperlukan untuk menghubungkan SchedulerxWorker ke aplikasi SchedulerX Anda.

   spring.schedulerx2.endpoint=${endpoint}
   spring.schedulerx2.namespace=${namespace}
   spring.schedulerx2.groupId=${groupId}
   # Hanya versi 1.2.1 ke atas yang mendukung konfigurasi appKey.
   spring.schedulerx2.appKey=${appKey}
   
   # Jika Anda tidak menggunakan appKey, Anda dapat menggunakan ID AccessKey dan Rahasia AccessKey Alibaba Cloud, atau token STS.
   #spring.schedulerx2.aliyunAccessKey=${aliyunAccessKey}
   #spring.schedulerx2.aliyunSecretKey=${aliyunSecretKey} 
   #spring.schedulerx2.stsToken=${aliyunStsToken}                   

   Sumber parameter:

   Di Konsol MSE SchedulerX, buka halaman Application Management di panel navigasi kiri. Pada kolom Actions untuk aplikasi target Anda, klik Access Configuration dan pilih Spring Boot sebagai tipe layanan. Di kotak dialog yang muncul, Anda dapat melihat contoh nilai untuk parameter seperti endpoint, namespace, groupId, dan appKey. Salin nilai-nilai tersebut ke lokasi yang sesuai dalam file konfigurasi Anda.

   Penting

   Pastikan region SchedulerX sesuai dengan region client untuk menghindari kegagalan koneksi.

   Jika Anda menggunakan server non-Alibaba Cloud atau lingkungan lokal, pastikan Anda telah mengaktifkan akses jaringan publik dan membuat aplikasi Anda di region publik pada platform penjadwalan. Untuk detail lebih lanjut, lihat Menghubungkan ke lingkungan publik secara lokal.

   Catatan

   Jika aplikasi client Anda mencakup beberapa layanan atau memerlukan pengelolaan izin untuk mengisolasi pekerjaan terjadwal, Anda dapat membuat beberapa aplikasi di Konsol untuk pengelolaan pekerjaan detail halus. Misalnya, jika aplikasi client bernama animals memiliki dua aplikasi, animals.dog dan animals.cat, yang dibuat di Konsol, Anda tidak perlu meminta instans terpisah untuk masing-masing. Sebagai gantinya, Anda dapat mengonfigurasinya dalam file application.properties dengan menentukan beberapa ID aplikasi dalam parameter spring.schedulerx2.groupId=${groupId}, dipisahkan koma, seperti: spring.schedulerx2.groupId=animals.dog,animals.cat.

   Deskripsi parameter:

   • endpoint: Saat menginisialisasi SchedulerxWorker, gunakan region dan titik akhir yang sesuai tempat aplikasi Anda dideploy. Untuk informasi lebih lanjut, lihat Endpoints.

   • namespace: ID namespace. Anda dapat menemukannya di halaman Namespaces di Konsol.

   • groupId dan appKey: groupId adalah ID aplikasi, dan appKey adalah kunci aplikasi. Anda dapat menemukannya di halaman Application Management di Konsol.

   • aliyunAccessKey dan aliyunSecretKey: aliyunAccessKey adalah AccessKey ID Akun Alibaba Cloud Anda, dan aliyunSecretKey adalah AccessKey secret. Anda dapat memperolehnya dari halaman Security Management di Konsol Manajemen Informasi Pengguna.

   • Untuk parameter tambahan, lihat tabel berikut:

     Key	Description	Value	Supported from version
     spring.schedulerx2.enabled	Mengaktifkan starter SchedulerX 2.0. Default: true.	true false	0.1.7
     spring.schedulerx2.endpoint	Menetapkan endpoint untuk region. Untuk informasi lebih lanjut, lihat Endpoints.	None	0.1.7
     spring.schedulerx2.namespace	Menetapkan UID namespace. Anda dapat menemukannya di halaman Namespaces di Konsol.	None	0.1.7
     spring.schedulerx2.groupId	groupId. Anda dapat menemukannya di halaman Application Management di Konsol.	None	0.1.7
     spring.schedulerx2.appKey	appKey. Anda dapat menemukannya di halaman Application Management di Konsol.	None	1.2.1
     spring.schedulerx2.host	Jika Anda memiliki beberapa alamat IP (misalnya, dari VPN atau beberapa kartu jaringan), Anda dapat menentukan alamat IP yang akan digunakan.	None	0.1.7
     spring.schedulerx2.port	Port kustom untuk client mendengarkan. Jika tidak ditetapkan, port acak yang tersedia akan dipilih.	None	0.1.7
     spring.schedulerx2.blockAppStart	Jika true, menghentikan startup aplikasi jika inisialisasi SchedulerX gagal. Default: true.	true false	1.1.0
     spring.schedulerx2.shareContainerPool	Jika true, semua eksekusi pekerjaan di client berbagi satu kolam thread. Default: false.	true false	1.2.1.2
     spring.schedulerx2.sharePoolSize	Menetapkan ukuran kolam thread bersama saat spring.schedulerx2.shareContainerPool bernilai true. Default: 64.	None	1.2.1.2
     spring.schedulerx2.label	Anda dapat menetapkan label pada client yang berbeda dan menentukan label untuk eksekusi pekerjaan dalam manajemen pekerjaan. Ini berguna untuk skenario seperti rilis canary dan uji stres.	None	1.2.2.2
     spring.schedulerx2.enableCgroupMetrics	Menentukan apakah akan menggunakan cgroups untuk mengumpulkan metrik instans client. Ini harus diaktifkan secara manual di lingkungan kontainer (K8s). Default-nya adalah false.	true false	1.2.2.2
     spring.schedulerx2.cgroupPathPrefix	Jalur cgroup di dalam kontainer.	Jalur default adalah /sys/fs/cgroup/cpu/. Jika jalur ini ada, Anda tidak perlu menyetel parameter ini.	1.2.2.2
     spring.schedulerx2.enableHeartbeatLog	Menentukan apakah akan mencetak heartbeat log ke ${user.home}/logs/schedulerx/heartbeat.log. Default-nya adalah true.	true false	1.2.4
     spring.schedulerx2.mapMasterStatusCheckInterval	Interval, dalam milidetik, di mana pekerjaan Map memeriksa penyelesaian sub-pekerjaan. Nilai yang lebih rendah dapat mempercepat penjadwalan untuk pekerjaan tingkat detik.	3000	1.2.5.2
     spring.schedulerx2.enableSecondDelayCycleIntervalMs	Jika true, nilai second_delay dari Konsol diperlakukan sebagai milidetik, bukan detik, sehingga memungkinkan penjadwalan lebih cepat. Default: false.	true false	1.2.5.2
     spring.schedulerx2.broadcastMasterExecEnable	Menentukan apakah node master berpartisipasi dalam eksekusi broadcast job. Default-nya adalah true.	true false	1.8.13
     spring.schedulerx2.broadcastDispatchRetryTimes	Jumlah upaya percobaan ulang untuk pengiriman broadcast yang gagal. Interval percobaan ulang tetap 2 detik dan tidak dapat dikonfigurasi.	3	1.8.13
     spring.schedulerx2.enableSecondDelayStandaloneDispatch	Menentukan apakah akan mengaktifkan dispatch dan eksekusi tingkat kedua untuk pekerjaan mandiri. Nilai default-nya adalah false.	true false	1.8.13

3. Buat kelas job processor

   Buat kelas JobProcessor di aplikasi Spring Boot Anda untuk menangani logika pekerjaan.

   Contoh berikut menunjukkan cara membuat kelas JobProcessor sederhana yang mencetak pesan secara berkala (contoh nama package: com.example.schedulerx.job).

   package com.example.schedulerx.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);
       }
   }              

Masuk ke konsol MSE SchedulerX. Di bilah navigasi kiri, klik Application Management dan periksa Total Instances dari aplikasi target.