SchedulerX:Terhubung ke SchedulerX melalui Internet

Mengakses parameter konfigurasi

Untuk terhubung ke SchedulerX, setiap aplikasi memerlukan empat nilai konfigurasi, seperti wilayah Internet dan titik akhir acm.aliyun.com.

Untuk mendapatkan nilai-nilai tersebut:

1. Login ke Konsol SchedulerX. Di bilah navigasi atas, pilih wilayah Internet.

2. Di panel navigasi kiri, klik Application Management. Temukan aplikasi Anda dan klik Access configuration di kolom Operation.

   

3. Di panel Access configuration, pilih metode akses dari daftar drop-down (kotak persegi panjang 1 pada gambar berikut). Panel akan menampilkan nilai konfigurasi untuk metode yang dipilih.

   

Hubungkan aplikasi Anda

Langkah-langkah berikut menjelaskan cara menambahkan dependensi Maven, melakukan inisialisasi SchedulerxWorker, dan membuat pekerjaan terjadwal. Pilih instruksi yang sesuai dengan jenis aplikasi Anda.

1. Tambahkan dependensi SchedulerxWorker ke file pom.xml Anda.

   Aplikasi Java atau Spring

   <dependency>
     <groupId>com.aliyun.schedulerx</groupId>
     <artifactId>schedulerx2-worker</artifactId>
     <version>${schedulerx2.version}</version>
     <!--Jika Anda menggunakan Logback, exclude Log4j dan 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>

   Aplikasi Spring Boot

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

2. Gunakan nilai konfigurasi yang diambil dari konsol untuk melakukan inisialisasi SchedulerxWorker. Di panel Access configuration, klik One click copy untuk menyalin nilai-nilai tersebut, atau ganti placeholder di bawah ini secara manual.

   Aplikasi Java

   Lakukan inisialisasi SchedulerxWorker di fungsi utama Anda:

   public void initSchedulerxWorker() throws Exception {
       SchedulerxWorker schedulerxWorker = new SchedulerxWorker();
       schedulerxWorker.setEndpoint("xxxx");     // Ganti dengan endpoint Anda
       schedulerxWorker.setNamespace("xxxx");     // Ganti dengan namespace Anda
       schedulerxWorker.setGroupId("xxxx");       // Ganti dengan ID grup Anda
       // Diperlukan untuk versi agen 1.2.1 atau lebih baru
       schedulerxWorker.setAppKey("xxxx");        // Ganti dengan kunci aplikasi Anda
       schedulerxWorker.init();
   }

   Catatan

   • Kelompok multiple: Untuk mengkategorikan pekerjaan terjadwal atau menyediakan beberapa layanan, buat beberapa kelompok dan tambahkan semua nama kelompok ke parameter groupId. Contohnya, groupId=animals.dogs,animals.cats. Instans dibagikan secara otomatis di seluruh kelompok.

   • Parameter tambahan: Untuk daftar lengkap opsi inisialisasi, lihat Parameter SchedulerxWorker.

   Aplikasi Spring

   Injeksikan bean SchedulerxWorker ke file konfigurasi XML Anda:

   <bean id="schedulerxWorker" class="com.alibaba.schedulerx.worker.SchedulerxWorker">
       <property name="endpoint">
         <value>${endpoint}</value>
       </property>
       <property name="namespace">
         <value>${namespace}</value>
       </property>
       <property name="groupId">
         <value>${groupId}</value>
       </property>
       <!--Diperlukan untuk versi agen 1.2.1 atau lebih baru -->
       <property name="appKey">
         <value>${appKey}</value>
       </property>
   </bean>

   Aplikasi Spring Boot

   Tambahkan properti berikut ke file application.properties Anda:

   spring.schedulerx2.endpoint=${endpoint}
   spring.schedulerx2.namespace=${namespace}
   spring.schedulerx2.groupId=${groupId}
   # Diperlukan untuk versi agen 1.2.1 atau lebih baru
   spring.schedulerx2.appKey=${appKey}

3. Buat kelas yang memperluas JavaProcessor untuk mendefinisikan logika pekerjaan Anda. Contoh berikut mencetak hello schedulerx2.0 setiap kali pekerjaan dijalankan:

   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);
       }
   }

4. Jalankan aplikasi Anda di lingkungan on-premises.

Verifikasi koneksi

Setelah menjalankan aplikasi, verifikasi bahwa aplikasi telah terhubung ke SchedulerX:

1. Publish aplikasi ke Alibaba Cloud setelah aplikasi terhubung ke SchedulerX.

2. Login ke Konsol SchedulerX.

3. Di bilah navigasi atas, pilih wilayah.

4. Di panel navigasi kiri, klik Application Management.

5. Periksa kolom Total number of instances untuk aplikasi Anda.

   • 0 instans: Aplikasi belum terhubung. Periksa kembali konfigurasi akses dan pastikan mesin on-premises Anda dapat mengakses titik akhir SchedulerX.

   • Bukan nol: Aplikasi telah terhubung. Klik View instances di kolom Operation untuk melihat instans yang terhubung di panel Connect to an instance.