SchedulerX:Acceso al entorno de red pública de forma local

Requisitos previos

• Activate SchedulerX

• Create a resource

  Nota

  Al crear una aplicación, seleccione una región Public Network.

Procedimiento

1. Agregue la dependencia de SchedulerxWorker al archivo pom.xml de su aplicación.

   La inicialización de SchedulerxWorker varía según el tipo de aplicación.

   • Para aplicaciones estándar de Java o Spring

     <dependency>
       <groupId>com.aliyun.schedulerx</groupId>
       <artifactId>schedulerx2-worker</artifactId>
       <version>${schedulerx2.version}</version>
       <!--If you use logback, exclude log4j and 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>              

   • Para aplicaciones de Spring Boot

2. Inicialice SchedulerxWorker.

   La inicialización de SchedulerxWorker varía según el tipo de aplicación.

   • Para aplicaciones estándar de Java

     Puede inicializar SchedulerxWorker en la función principal.

     Al inicializar SchedulerxWorker, necesita el endpoint (acm.aliyun.com) correspondiente a la región Public Network donde está desplegada su aplicación.

     1. Inicie sesión en la consola de Distributed Task Scheduling Platform.

     2. En la barra de menú superior de la consola, cambie la región a Public Network.

     3. En el panel de navegación izquierdo, haga clic en Namespaces. En la página Namespaces, busque el Namespace ID.

     4. En el panel de navegación izquierdo, haga clic en Application Management. En la página Application Management, consulte el Application ID (groupId) y la Application Key (appKey), o bien haga clic en Connection Configuration en la columna Actions para obtener la configuración de conexión.

        

     public void initSchedulerxWorker() throws Exception {
         SchedulerxWorker schedulerxWorker = new SchedulerxWorker();
         schedulerxWorker.setEndpoint("xxxx");
         schedulerxWorker.setNamespace("xxxx");
         schedulerxWorker.setGroupId("xxxx");
         // For versions 1.2.1 and later, you must set the application key.
         schedulerxWorker.setAppKey("xxxx");
         schedulerxWorker.init();
     }

     Nota

     • Si una aplicación incluye varios servicios o desea categorizar los trabajos programados, puede crear varios grupos. Por ejemplo, para una aplicación llamada animals, puede crear dos grupos: animals.dogs y animals.cats. No es necesario ejecutar instancias separadas para cada grupo. En su lugar, especifique una lista separada por comas en el parámetro groupId de la configuración de su cliente, como groupId=animals.dogs,animals.cats.

     • Al inicializar el cliente SchedulerxWorker, puede establecer otros parámetros según sea necesario. Para más información, consulte SchedulerxWorker parameters.

   • Para aplicaciones de Spring

     Puede inyectar el bean SchedulerxWorker en el archivo de configuración XML.

     1. Inicie sesión en la consola de Distributed Task Scheduling Platform.

     2. En la barra de menú superior de la consola, cambie la región a Public Network.

     3. En el panel de navegación izquierdo, haga clic en Namespaces. En la página Namespaces, busque el Namespace ID.

     4. En el panel de navegación izquierdo, haga clic en Application Management. En la página Application Management, consulte el Application ID (groupId) y la Application Key (appKey), o bien haga clic en Connection Configuration en la columna Actions para obtener la configuración de conexión.

        

     <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>
         <!-- Set the appKey parameter for versions 1.2.1 and later. -->
         <property name="appKey">
           <value>${appKey}</value>
         </property>
     </bean>

   • Para aplicaciones de Spring Boot

     Agregue las siguientes configuraciones al archivo application.properties:

     1. Inicie sesión en la consola de Distributed Task Scheduling Platform.

     2. En la barra de menú superior de la consola, cambie la región a Public Network.

     3. En el panel de navegación izquierdo, haga clic en Namespaces. En la página Namespaces, busque el Namespace ID.

     4. En el panel de navegación izquierdo, haga clic en Application Management. En la página Application Management, consulte el Application ID (groupId) y la Application Key (appKey), o bien haga clic en Connection Configuration en la columna Actions para obtener la configuración de conexión.

        

     spring.schedulerx2.endpoint=${endpoint}
     spring.schedulerx2.namespace=${namespace}
     spring.schedulerx2.groupId=${groupId}
     # For versions 1.2.1 and later, set the appKey.
     spring.schedulerx2.appKey=${appKey} 

     Nota

     Si una aplicación incluye varios servicios o desea categorizar las tareas programadas, puede crear varios grupos. Por ejemplo, si la aplicación animals tiene dos nuevos grupos, animals.dogs y animals.cats, no necesita solicitar instancias separadas para conectarse a ellos. En el cliente de la aplicación, especifique ambos grupos en el parámetro groupId. Por ejemplo: groupId=animals.dogs,animals.cats.

3. En su aplicación, cree una clase JobProcessor para implementar la programación de tareas.

   El siguiente código de ejemplo muestra cómo implementar una clase JobProcessor sencilla que imprime periódicamente "hello schedulerx2.0".

   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. Ejecute la aplicación local.

Verificación del resultado