Grails：如何从外部库注册Quartz Job

嘿，我来帮你搞定把Quartz Job迁移到外部库并在主应用注册的问题！你已经成功复用了服务，接下来这几步就能搞定Job的部分：

1. 把Quartz Job迁移到外部库 #

首先，把你的Job类移到外部库的合适包下（比如com.yourlibrary.jobs），确保Job能正确注入你已经复用的服务，同时保留Quartz的触发逻辑：

import grails.plugins.quartz.Job
import org.quartz.SimpleTrigger

@Job
class MyReusableJob {
    // 注入你的复用服务（外部库中的服务类）
    MyReusableService myReusableService

    static triggers = {
        simple name: 'myReusableJobTrigger', startDelay: 1000, repeatInterval: 300000 // 5分钟触发一次
    }

    def execute() {
        // 调用服务的定时任务逻辑
        myReusableService.runPeriodicTask()
    }
}

注意：如果外部库还没引入Grails Quartz依赖，要在外部库的build.gradle中添加对应版本的依赖（比如Grails 4+用implementation 'org.grails.plugins:quartz:2.0.13'，版本请匹配你的主应用Grails版本）。

2. 在主应用中注册Job和Trigger #

Grails的Quartz插件默认只会扫描主应用内的Job，所以外部库的Job需要手动注册，有两种常用方式：

方式一：通过resources.groovy注册 #

在主应用的grails-app/conf/spring/resources.groovy中，添加Job和Trigger的Bean配置（和你注册复用服务的逻辑放在一起即可）：

import com.yourlibrary.jobs.MyReusableJob
import com.yourlibrary.services.MyReusableService
import org.quartz.JobDetail
import org.quartz.SimpleTrigger

beans = {
    // 你已经配置好的复用服务Bean
    myReusableService(MyReusableService)

    // 注册JobDetail
    myReusableJobDetail(JobDetail) {
        jobClass = MyReusableJob
        name = 'myReusableJob'
        group = 'reusableJobs'
        durability = true // 确保Job在应用重启后依然保留
    }

    // 注册Trigger，绑定到上面的JobDetail
    myReusableJobTrigger(SimpleTrigger) {
        name = 'myReusableJobTrigger'
        group = 'reusableTriggers'
        jobDetail = ref('myReusableJobDetail')
        startDelay = 1000 // 应用启动后1秒开始执行
        repeatInterval = 300000 // 每5分钟重复一次
    }
}

方式二：使用Spring配置类注册 #

如果你偏好Java/Groovy配置类的风格，可以在主应用中创建一个配置类：

import com.yourlibrary.jobs.MyReusableJob
import org.quartz.JobDetail
import org.quartz.SimpleTrigger
import org.quartz.SimpleScheduleBuilder
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration

@Configuration
class ReusableJobConfiguration {

    @Bean
    JobDetail myReusableJobDetail() {
        JobDetail.builder()
                .ofType(MyReusableJob)
                .withIdentity('myReusableJob', 'reusableJobs')
                .storeDurably(true)
                .build()
    }

    @Bean
    SimpleTrigger myReusableJobTrigger(JobDetail myReusableJobDetail) {
        SimpleTrigger.builder()
                .forJob(myReusableJobDetail)
                .withIdentity('myReusableJobTrigger', 'reusableTriggers')
                .startNow()
                .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                        .withIntervalInMinutes(5)
                        .repeatForever())
                .build()
    }
}

3. 验证配置是否生效 #

启动主应用后，你可以通过以下方式确认Job是否正常工作：

• 查看应用日志，寻找Quartz相关的启动日志，确认Job和Trigger被成功加载
• 手动触发Job测试（Grails 3+用命令：./gradlew quartz-triggerJob --name=myReusableJob，Grails 2用grails quartz.triggerJob --name=myReusableJob）

额外小提示 #

• 确保外部库的依赖已经正确引入到主应用的build.gradle中，否则主应用会找不到Job和服务类
• 如果Job需要传递配置参数，可以在注册Trigger时通过jobDataMap设置，比如在resources.groovy中：

  myReusableJobTrigger(SimpleTrigger) {
      // ...其他配置
      jobDataMap = [taskParam: 'testValue', interval: 300000]
  }
  

  然后在Job的execute方法中通过jobExecutionContext.mergedJobDataMap.get('taskParam')获取参数。

内容的提问来源于stack exchange，提问作者Erando