SchedulerX:Connect a Spring Boot application to SchedulerX

Configurar los ajustes básicos

1. Inicie sesión en la consola de MSE SchedulerX y seleccione una región en la barra de navegación superior.

2. En el panel de navegación izquierdo, haga clic en Application Management. Seleccione un Namespace y haga clic en Create Application.

3. Introduzca la siguiente configuración y haga clic en Next.

   Importante

   Cree los recursos en la región y el namespace correctos. Compruebe que la información del recurso sea válida.

   Setting	Description	Default
   Application Name	Nombre descriptivo de la aplicación.	Ninguna
   Application ID	El GroupID para el acceso del agente. Debe ser único dentro del namespace. Puede coincidir con Application Name.	Ninguna
   Application Type	Regular App: no se despliega en Kubernetes ni requiere trabajos de Kubernetes. k8s App: se despliega en Kubernetes y requiere trabajos de Kubernetes.	Regular App
   Edition	Seleccione una edición según sus necesidades.	Professional Edition
   Simple Log Service	Habilítelo para consultar los registros de programación en la consola. Requiere una configuración de Log4j o Logback.	Off
   load5	Promedio de carga máximo de 5 minutos. No puede superar la cantidad de núcleos de CPU de la máquina cliente.	0
   Memory Usage	Si el uso promedio de memoria de los últimos 5 minutos supera este umbral, el worker se marca como ocupado.	90%
   Disk Usage	Si el uso de disco supera este umbral, la máquina cliente se marca como ocupada.	95%
   Trigger Busy Machine	Continúa activando trabajos cuando la máquina está ocupada.	On

   Setting	Description	Default
   Maximum Number Of Jobs	Cantidad máxima de trabajos compatibles en un grupo.	1000
   Automatic Scale-out	Habilítelo para escalar automáticamente. Requiere Global Job Count.	Off
   Traffic Throttling	Habilítelo para limitar el tráfico. Requiere Task Instance Concurrency.	Off
   Calendar	Programe mediante Financial Day (día de cotización) o Workday (día hábil).	0

   

Configurar las notificaciones

1. En la página Notification Configuration, seleccione un Notification Channel y establezca los Contacts. Agregue los contactos de forma individual o utilice un grupo de contactos. Para crear un grupo de contactos, consulte Crear un contacto de notificación o un grupo de contactos de notificación.

   Setting	Description
   Notification Channel	Text Message, Email, Webhook o Phone.
   Email	Dirección de correo electrónico del contacto.
   Webhook	URL del webhook para WeCom, Lark o DingTalk. Separe varias URL con comas (,). En DingTalk, agregue la palabra clave "SchedulerX" (distingue entre mayúsculas y minúsculas) a la configuración del robot. Para más detalles sobre la configuración del webhook, consulte Descripción de la configuración del webhook. Para obtener información sobre cómo conseguir una URL de webhook, consulte la documentación para desarrolladores de DingTalk, la documentación para desarrolladores de WeCom y la documentación para desarrolladores de Lark.
   Mobile Phone Number	Número de celular del contacto.

   

2. Actualice la página y confirme que su aplicación aparece en la región y el namespace seleccionados.

<dependency>
  <groupId>com.aliyun.schedulerx</groupId>
  <artifactId>schedulerx2-spring-boot-starter</artifactId>
  <version>1.11.5</version>  <!-- Replace with the latest version -->
</dependency>

<dependency>
  <groupId>com.aliyun.schedulerx</groupId>
  <artifactId>schedulerx2-spring-boot-starter</artifactId>
  <version>1.11.5</version>
  <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>

# Required: SchedulerX connection settings
spring.schedulerx2.endpoint=${endpoint}
spring.schedulerx2.namespace=${namespace}
spring.schedulerx2.groupId=${groupId}
# The appKey parameter is supported only in versions 1.2.1 and later.
spring.schedulerx2.appKey=${appKey}

# If you do not use an appKey, you can use an Alibaba Cloud AccessKey and SecretKey, or an STS token.
#spring.schedulerx2.aliyunAccessKey=${aliyunAccessKey}
#spring.schedulerx2.aliyunSecretKey=${aliyunSecretKey}
#spring.schedulerx2.stsToken=${aliyunStsToken}

spring:
  schedulerx2:
    endpoint: ${endpoint}
    namespace: ${namespace}
    groupId: ${groupId}
    appKey: ${appKey}

Parámetros opcionales

Los siguientes parámetros admiten casos de uso avanzados:

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;
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);  // Return true to indicate success
    }
}