Microservices Engine:Connect a Spring Boot application to SchedulerX

1.1 Configure basic settings

1. Log on to the MSE SchedulerX console and select a region in the top navigation bar.

2. In the left navigation pane, click Application Management. Select a Namespace, then click Create Application.

3. Enter the Application Name and Application ID, select the Application Type, and configure any advanced settings. Then click Next.

The following table describes each field:

Expand Advanced Configuration to access additional settings:

1.2 Configure notifications

1. On the Notification Configuration page, select a Notification Channel and set Contacts. Supported notification channels: Text Message, Email, Webhook, and Phone. For webhook configuration details, see Webhook configuration description.

2. Add notification recipients: The following table describes each contact field:

   • Contact Group: all members receive notifications. To create a group, see Create a notification contact or notification contact group.

   • Contact: add individual recipients. Click Add Contact, then click Go To Create Contact and fill in the contact details.

   Field	Description
   Notification Channel	Supported channels: Text Message, Email, Webhook, and Phone.
   Email	The email address of the contact.
   Webhook	Webhook URL for WeCom, Lark, or DingTalk. Separate multiple URLs with commas (,). For DingTalk, add the case-sensitive keyword "SchedulerX" to the robot configuration. For details, see DingTalk Developer Documentation, WeCom Developer Documentation, and Lark Developer Documentation.
   Mobile Phone Number	The mobile phone number of the contact.

   

   

3. After completing the notification configuration, refresh the Application Management page and verify that the new application appears in the list under the selected region and namespace.

2.1 Add the Maven dependency

Add the schedulerx2-spring-boot-starter dependency to your pom.xml:

<dependency>
    <groupId>com.aliyun.schedulerx</groupId>
    <artifactId>schedulerx2-spring-boot-starter</artifactId>
    <version>1.11.5</version> <!-- Replace with the latest version -->
    <!-- Exclude Log4j if you use 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>

2.2 Configure connection parameters

Add the following properties to your application.properties file. Four parameters are required to connect SchedulerxWorker to SchedulerX:

# --- Required ---
spring.schedulerx2.endpoint=<your-endpoint>       # Regional endpoint (see table below)
spring.schedulerx2.namespace=<your-namespace-id>   # Namespace UID from the Namespaces page
spring.schedulerx2.groupId=<your-group-id>         # Application ID from Application Management
spring.schedulerx2.appKey=<your-app-key>           # Application key (agent 1.2.1+)

# --- Alternative authentication (if not using appKey) ---
# spring.schedulerx2.aliyunAccessKey=<your-access-key-id>
# spring.schedulerx2.aliyunSecretKey=<your-access-key-secret>
# spring.schedulerx2.stsToken=<your-sts-token>

Replace the placeholders with your actual values:

To quickly find your connection parameters, go to the Application Management page, click Access Configuration in the Actions column for your application, then select Spring Boot.

2.3 Create a job processor

Extend JavaProcessor to handle scheduled tasks. The following example prints a message each time the job runs:

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