SchedulerX:Spring jobs

Cara kerja

SchedulerX menggantikan penjadwal tugas Spring bawaan dengan mesin penjadwalannya sendiri:

1. Tambahkan dependensi SchedulerX Spring Boot starter ke proyek Anda.

2. Atur spring.schedulerx2.task.scheduling.scheduler=schedulerx di file application.properties Anda.

3. SchedulerX mengambil kendali atas semua metode @Scheduled dan mengelola eksekusinya melalui konsol.

Setelah pengambilalihan, frekuensi penjadwalan dikendalikan oleh konsol SchedulerX. Ekspresi cron dalam anotasi @Scheduled tetap berada di kode, tetapi tidak lagi menentukan kapan job dijalankan.

Mode eksekusi:

Job yang disinkronisasi otomatis menggunakan mode default Broadcast run untuk mempertahankan perilaku asli Spring. Untuk menjalankan job hanya pada satu node, ubah Execution mode menjadi Stand-alone operation di konsol.

Prasyarat

• Versi agen SchedulerX 1.8.13 atau lebih baru

• Aplikasi Spring Boot yang terhubung ke SchedulerX. Untuk instruksi penyiapan, lihat Hubungkan aplikasi Spring Boot ke SchedulerX

Tambahkan dependensi Maven

Tambahkan dependensi schedulerx2-spring-boot-starter ke file pom.xml Anda. Ganti schedulerx2.version dengan versi terbaru dari catatan rilis agen.

<dependency>
  <groupId>com.aliyun.schedulerx</groupId>
  <artifactId>schedulerx2-spring-boot-starter</artifactId>
  <version>${schedulerx2.version}</version>
  <!-- Exclude Log4j if your application uses Logback -->
  <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>

Pertahankan @EnableScheduling di kelas utama Anda, terlepas dari apakah SchedulerX menangani penjadwalan atau tidak:

@SpringBootApplication
@EnableScheduling // Required -- do not remove
public class SchedulerXWorkerApplication {
    public static void main(String[] args) {
        SpringApplication.run(SchedulerXWorkerApplication.class, args);
    }
}

Kelas job @Scheduled yang sudah ada tidak perlu diubah:

@Service
public class SpringScheduledProcessor {
    @Scheduled(cron = "0/2 * * * * ?")
    public void hello() {
        logger.info(DateUtil.now() + " hello world. start");
        logger.info(DateUtil.now() + " hello world. end");
    }
}

Menambahkan dependensi saja tidak mengubah perilaku job. SchedulerX tidak langsung mengambil alih job terjadwal Spring secara default—job tersebut tetap berjalan di kontainer Spring hingga Anda mengaktifkan pengambilalihan pada langkah berikutnya.

Konfigurasi pengambilalihan SchedulerX

Tambahkan properti berikut ke file application.properties Anda:

# Connect to SchedulerX
spring.schedulerx2.endpoint=${endpoint}
spring.schedulerx2.namespace=${namespace}
spring.schedulerx2.groupId=${groupId}
spring.schedulerx2.appKey=${appKey}

# Enable SchedulerX to take over Spring scheduled jobs
spring.schedulerx2.task.scheduling.scheduler=schedulerx

Untuk mendapatkan parameter koneksi (endpoint, namespace, groupId, appKey):

1. Masuk ke Konsol SchedulerX.

2. Di panel navigasi sebelah kiri, klik Application Management.

3. Temukan aplikasi Anda dan klik Access configuration di kolom Operation.

Jika Anda belum membuat aplikasi di SchedulerX, buat terlebih dahulu sebelum melanjutkan.

# Enable automatic job synchronization
spring.schedulerx2.task.scheduling.sync=true
spring.schedulerx2.regionId=<region-id>
spring.schedulerx2.aliyunAccessKey=<your-access-key>
spring.schedulerx2.aliyunSecretKey=<your-secret-key>

Verifikasi koneksi

1. Jalankan aplikasi Spring Boot Anda.

2. Masuk ke Konsol SchedulerX.

3. Di panel navigasi sebelah kiri, klik Application Management.

4. Periksa kolom Total number of instances untuk aplikasi Anda. Nilai lebih dari 0 menunjukkan koneksi berhasil.

1. Di panel navigasi sebelah kiri, klik Task Management.

2. Temukan job Anda dan klik Run once di kolom Operation.

3. Verifikasi bahwa job dijalankan dengan sukses.

Setelah verifikasi, SchedulerX menyediakan kemampuan tingkat enterprise untuk job Spring Anda, termasuk manajemen dan kontrol visual, kueri log, pelacakan rantai eksekusi, serta peringatan.

FAQ

JobContext jobContext = ContainerFactory.getContainerPool().getContext();

@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..");
    }
    return new ProcessResult(true, "Processing result");
}

@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";
}

JobContext jobContext = ContainerFactory.getContainerPool().getContext();

@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..");
    }
    return new ProcessResult(true, "Processing result");
}

@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";
}