JeecgBoot任务调度：Quartz分布式任务管理

2026-02-05 04:13:04作者：温玫谨Lighthearted

你是否还在为企业级应用中的定时任务管理烦恼？服务器集群环境下任务重复执行、任务状态监控困难、动态调整计划繁琐？JeecgBoot基于Quartz框架提供的分布式任务调度解决方案，通过可视化管理界面与自动化配置机制，让任务调度变得简单高效。本文将带你从零开始掌握JeecgBoot任务调度核心功能，解决分布式环境下的任务管理痛点。

一、Quartz任务调度核心架构

JeecgBoot的任务调度模块采用"数据库存储+集群协调"架构，通过Quartz框架实现分布式任务的统一管理。核心组件包括：

任务控制器：提供RESTful API接口，处理任务CRUD与状态流转
服务实现层：封装Quartz调度器操作，实现任务生命周期管理
数据访问层：基于MyBatis-Plus实现任务元数据持久化
实体模型：映射数据库表结构，存储任务配置与运行状态

核心代码结构如下：

org.jeecg.modules.quartz
├── controller/QuartzJobController.java  // 任务管理API
├── service/IQuartzJobService.java       // 任务服务接口
├── service/impl/QuartzJobServiceImpl.java // 服务实现
├── entity/QuartzJob.java                // 任务实体
└── mapper/QuartzJobMapper.java          // 数据访问

任务调度核心流程：

sequenceDiagram
    participant 用户
    participant Controller
    participant Service
    participant Scheduler
    participant 数据库
    
    用户->>Controller: 创建定时任务
    Controller->>Service: saveAndScheduleJob()
    Service->>数据库: 保存任务配置
    Service->>Scheduler: 调度任务
    Scheduler->>数据库: 存储任务状态
    Scheduler-->>Service: 返回调度结果
    Service-->>Controller: 返回操作结果
    Controller-->>用户: 显示成功信息

二、任务管理核心功能实现

2.1 任务CRUD操作

JeecgBoot提供完整的任务生命周期管理接口，通过QuartzJobController实现RESTful API。关键接口包括：

分页查询：支持多条件过滤任务列表

@RequestMapping(value = "/list", method = RequestMethod.GET)
public Result<?> queryPageList(QuartzJob quartzJob, 
                              @RequestParam(defaultValue = "1") Integer pageNo,
                              @RequestParam(defaultValue = "10") Integer pageSize, 
                              HttpServletRequest req) {
    QueryWrapper<QuartzJob> queryWrapper = QueryGenerator.initQueryWrapper(quartzJob, req.getParameterMap());
    Page<QuartzJob> page = new Page<>(pageNo, pageSize);
    IPage<QuartzJob> pageList = quartzJobService.page(page, queryWrapper);
    return Result.ok(pageList);
}

创建任务：保存任务配置并立即调度

@RequiresPermissions("system:quartzJob:add")
@RequestMapping(value = "/add", method = RequestMethod.POST)
public Result<?> add(@RequestBody QuartzJob quartzJob) {
    quartzJobService.saveAndScheduleJob(quartzJob);
    return Result.ok("创建定时任务成功");
}

更新任务：同步修改调度计划

@RequiresPermissions("system:quartzJob:edit")
@RequestMapping(value = "/edit", method ={RequestMethod.PUT, RequestMethod.POST})
public Result<?> eidt(@RequestBody QuartzJob quartzJob) {
    try {
        quartzJobService.editAndScheduleJob(quartzJob);
    } catch (SchedulerException e) {
        return Result.error("更新定时任务失败!");
    }
    return Result.ok("更新定时任务成功!");
}

2.2 任务状态管理

系统支持任务的动态启停控制，通过权限控制确保操作安全性：

暂停任务：

@RequiresPermissions("system:quartzJob:pause")
@GetMapping(value = "/pause")
public Result<Object> pauseJob(@RequestParam String id) {
    QuartzJob job = quartzJobService.getById(id);
    quartzJobService.pause(job);
    return Result.ok("停止定时任务成功");
}

恢复任务：

@RequiresPermissions("system:quartzJob:resume")
@GetMapping(value = "/resume")
public Result<Object> resumeJob(@RequestParam String id) {
    QuartzJob job = quartzJobService.getById(id);
    quartzJobService.resumeJob(job);
    return Result.ok("启动定时任务成功");
}

立即执行：支持任务的即时触发，不影响原调度计划

@RequiresPermissions("system:quartzJob:execute")
@GetMapping("/execute")
public Result<?> execute(@RequestParam String id) {
    QuartzJob quartzJob = quartzJobService.getById(id);
    quartzJobService.execute(quartzJob);
    return Result.ok("执行成功!");
}

2.3 分布式任务协调

在集群环境下，JeecgBoot通过数据库锁机制实现任务的分布式协调，确保同一任务在多节点环境下仅执行一次。核心实现位于QuartzJobServiceImpl：

@Transactional
public boolean saveAndScheduleJob(QuartzJob quartzJob) {
    quartzJob.setDelFlag(CommonConstant.DEL_FLAG_0);
    boolean success = this.save(quartzJob);
    if (success && CommonConstant.STATUS_NORMAL.equals(quartzJob.getStatus())) {
        scheduleJob(quartzJob);  // 调度任务
    }
    return success;
}

三、任务配置与使用指南

3.1 任务实体结构

任务配置信息通过QuartzJob实体映射，关键属性包括：

@TableName("sys_quartz_job")
public class QuartzJob {
    @TableId(type = IdType.ASSIGN_ID)
    private String id;                // 任务ID
    private String jobClassName;      // 任务类名
    private String jobName;           // 任务名称
    private String jobGroup;          // 任务组名
    private String cronExpression;    // Cron表达式
    private String parameter;         // 执行参数
    private String description;       // 任务描述
    @Dict(dicCode = "quartz_status")
    private String status;            // 任务状态(0-正常,1-暂停)
    // getter/setter省略
}

3.2 任务开发步骤

创建任务类：实现Job接口，编写业务逻辑

public class SendMsgJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 任务执行逻辑
        log.info("定时发送消息任务执行...");
    }
}

配置任务：通过界面或API创建任务，设置：
- 任务类名：org.jeecg.modules.message.job.SendMsgJob
- Cron表达式：0 0/30 * * * ? (每30分钟执行一次)
- 任务状态：正常(启动)或暂停
部署与监控：任务自动注册到调度器，可通过列表页监控执行状态

3.3 Cron表达式示例

常用调度计划配置：

表达式	含义
0 0 12 * * ?	每天中午12点执行
0 0/30 9-17 * * ?	工作日9-17点每30分钟执行
0 0 1 * * ?	每天凌晨1点执行
0 0 1 1 * ?	每月1号凌晨1点执行