Microservices Engine:Tugas Spring

Langkah 1: Tambahkan dependensi ke file pom.xml

Tambahkan dependensi dan kelas utama ke file pom.xml aplikasi. Dalam contoh ini, aplikasi Spring Boot digunakan.

Ganti schedulerx2.version dengan versi terbaru dari Agen SchedulerX. Untuk informasi lebih lanjut, lihat Catatan Rilis Agen.

<dependency>
  <groupId>com.aliyun.schedulerx</groupId>
  <artifactId>schedulerx2-spring-boot-starter</artifactId>
  <version>${schedulerx2.version}</version>
  <!-- Jika Anda menggunakan Logback, Anda harus mengecualikan 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>

@SpringBootApplication
@EnableScheduling /**Aktifkan tugas Spring terjadwal.*/
public class SchedulerXWorkerApplication {
    public static void main(String[] args) {
        SpringApplication.run(SchedulerXWorkerApplication.class, args);
    }
}

/** Kelas tugas Spring terjadwal asli*/
@Service
public class SpringScheduledProcessor {
    @Scheduled(cron = "0/2 * * * * ?")
    public void hello() {
        logger.info(DateUtil.now() + " halo dunia. mulai");
        logger.info(DateUtil.now() + " halo dunia. selesai");
    }
}

Langkah 3: (Opsional) Buat tugas terjadwal secara manual

1. Masuk ke konsol MSE, dan buka halaman Versi SchedulerX.

2. Di panel navigasi sisi kiri, klik Tasks.

3. Pada halaman Tasks, klik Create task. Di panel Buat tugas, pilih SpringSchedule dari daftar drop-down Jenis Tugas, dan masukkan nama kelas dan nama metode.

   Parameter	Deskripsi
   Task name	Nama tugas yang ingin Anda buat.
   Description	Deskripsi tugas. Tentukan deskripsi yang ringkas dan jelas untuk memudahkan pencarian dan pengelolaan tugas.
   Application ID	Grup tempat tugas termasuk. Pilih nilai dari daftar drop-down.
   Task type	Bahasa pemrograman yang ingin Anda gunakan untuk membuat tugas. Nilai valid termasuk Java, Shell, Python, Golang, Http, Node.js, XXL-JOB, dan DataWorks. Saat Anda memilih Shell, Python, atau Golang, editor akan ditampilkan. Anda dapat memasukkan skrip di editor. Dalam contoh ini, parameter ini diatur ke SpringSchedule.
   spring scheduleConfiguration	Nama kelas lengkap dan nama metode tugas.
   Execution mode	Mode di mana tugas dijalankan. Mode eksekusi berikut didukung: Operasi mandiri: Tugas dijalankan pada pekerja acak. Penyiaran: Tugas dijalankan secara bersamaan pada semua pekerja, dan sistem menunggu hingga semua pekerja menyelesaikan tugas. Catatan Parameter di bagian Konfigurasi Lanjutan bervariasi berdasarkan mode eksekusi yang dipilih.
   Priority	Jika beberapa tugas dari aplikasi yang sama berjalan pada pekerja yang sama pada saat yang sama, tugas dengan prioritas tinggi dijalankan terlebih dahulu. Namun, jika beberapa tugas dari aplikasi yang sama berjalan pada beberapa pekerja, tugas dengan prioritas berbeda dijadwalkan ke pekerja yang berbeda. Dalam hal ini, tugas dengan prioritas rendah mungkin dijalankan terlebih dahulu. SchedulerX menggunakan antrian preemptible untuk menghindari masalah ini dan memastikan bahwa tugas dengan prioritas lebih tinggi dalam antrian dipicu terlebih dahulu. Untuk informasi lebih lanjut, lihat Lakukan throttling tingkat aplikasi berdasarkan prioritas tugas dalam antrian.
   Task parameters	String acak yang dapat diperoleh dari konteks saat SchedulerX menjalankan tugas.

4. Konfigurasikan frekuensi pemicu.

   Catatan

   Frekuensi yang ditentukan di konsol SchedulerX berlaku, dan konfigurasi anotasi asli @Scheduled dalam kode tugas Spring terjadwal menjadi tidak valid. Namun, anotasi tersebut tetap ada di kode.

   Tabel berikut menjelaskan parameter.

   Parameter	Deskripsi
   Time type	none: Tugas dipicu menggunakan alur kerja. cron: Tugas dijadwalkan berdasarkan ekspresi cron. api: Tugas dipicu dengan memanggil operasi API. fixed_rate: Tugas dipicu pada interval tertentu. second_delay: Tugas dipicu dengan penundaan dari 1 hingga 60 detik. one_time: Tugas hanya dipicu sekali pada titik waktu yang ditentukan.
   cron expression	Ekspresi cron berdasarkan mana tugas dijadwalkan. Anda dapat memasukkan ekspresi cron secara manual berdasarkan sintaks cron. Anda juga dapat menggunakan alat yang disediakan oleh SchedulerX untuk menghasilkan ekspresi cron yang valid secara otomatis.
   Fixed frequency	Interval di mana tugas dipicu. Parameter ini tersedia hanya jika parameter Jenis Tugas diatur ke fixed_rate. Nilainya harus lebih besar dari 60. Unit: detik. Misalnya, nilai 200 menunjukkan bahwa tugas dipicu pada interval 200 detik.
   Fixed delay	Penundaan tetap. Parameter ini tersedia hanya jika parameter Jenis Tugas diatur ke second_delay. Nilai valid: 1 hingga 60. Unit: detik. Misalnya, nilai 5 menunjukkan bahwa tugas dipicu dengan penundaan 5 detik.

   Tabel berikut menjelaskan konfigurasi penjadwalan lanjutan.

   Parameter	Deskripsi
   Time offset	Tentukan offset antara timestamp data yang akan diproses dan waktu ketika tugas dipicu. Anda dapat memperoleh nilai offset dari konteks saat SchedulerX menjalankan tugas.
   Time zone	Pilih zona waktu negara atau wilayah atau pilih zona waktu GMT berdasarkan kebutuhan bisnis Anda.
   Calendar	Pilih Hari Kerja atau Hari Keuangan.

5. Konfigurasikan kondisi peringatan dan metode notifikasi. Untuk informasi lebih lanjut tentang metode notifikasi, lihat Kontak Notifikasi dan Grup Kontak Notifikasi.

   Setelah Anda menyelesaikan konfigurasi, SchedulerX dapat menjalankan tugas Spring terjadwal. Konsol juga memberikan kemampuan O&M tingkat perusahaan kepada tugas Spring asli, termasuk manajemen dan kontrol visual, kueri log tugas, tampilan rantai eksekusi, serta notifikasi dan peringatan eksekusi tugas.