[XXL-JOB] 项目集成-Framework

xxl,job,项目,集成,framework · 浏览次数 : 18

小编点评

**项目配置文件（job.properties）** ```properties # 是否启用 job.xxl.admin.addresses job.xxl.admin.addresses: http://*****/xxl-job-admin # xxl-job 地址 job.xxl.accessToken: # 定时任务执行器名称 job.xxl.executor.appname: mbp-job # 定时任务执行器端口 job.xxl.executor.port: 9999 # 日志路径 job.xxl.executor.logpath: /data/logs/java/mbp-job # 日志保留天数 job.xxl.executor.logretentiondays: 303 ``` **定时任务类（CmsAdJob.java）** ```java @Job(name = "cmsAdJob", cron = "0 0 1 * * ?") public class CmsAdJob implements SimpleJob { private CmsAdService cmsService; @Override public void execute(final JobContext jobContext) { LoggerUtil.info("===================定时任务开始==================\n"); // 此处写您的定时任务逻辑代码 LoggerUtil.info("===================定时任务结束==================\n"); } private CmsAdService getCmsAdService() { if (cmsService == null) { cmsService = ContextHolder.getContext().getBean(CmsAdService.class); } return cmsService; } } ``` **执行任务** 您可以手动触发任务执行，例如： ```bash # 触发 CMS 广告定时任务 sh runJob.sh ``` **注意** * `job.enable` 设置 `true` 表示使用 xxl-job 配置。 * `job.xxl.executor.appname` 和 `job.xxl.executor.port` 配置定时任务执行器的应用程序名称和端口。 * `job.xxl.executor.logpath` 配置日志记录路径。 * `job.xxl.executor.logretentiondays` 设置日志记录的保留天数。

正文

1、导入pom坐标

<dependency>
     <groupId>com.hbasesoft.framework</groupId>
     <artifactId>framework-job-core</artifactId>
</dependency>
<dependency>
     <groupId>com.hbasesoft.framework</groupId>
     <artifactId>framework-job-xxl</artifactId>
</dependency>

2、项目配置文件配置xxl-job信息

job.enable: true                                      # 是否启用
job.xxl.admin.addresses: http://*****/xxl-job-admin   # xxl-job地址
job.xxl.accessToken:                                  # token 选填
job.xxl.executor.appname: mbp-job                     # 定时任务执行器名称
job.xxl.executor.port: 9999                           
job.xxl.executor.logpath: /data/logs/java/mbp-job     #日志
job.xxl.executor.logretentiondays: 30

3、创建定时任务类

package com.tlc.cms.job;

import com.hbasesoft.framework.common.utils.ContextHolder;
import com.hbasesoft.framework.common.utils.logger.LoggerUtil;
import com.hbasesoft.framework.job.core.JobContext;
import com.hbasesoft.framework.job.core.SimpleJob;
import com.hbasesoft.framework.job.core.annotation.Job;
import com.tlc.cms.entity.CmsAdEntity;
import com.tlc.cms.service.CmsAdService;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.List;

// 1: 添加Job注解
@Job(name = "cmsAdJob", cron = "0 0 1 * * ?")
public class CmsAdJob implements SimpleJob {

    private CmsAdService cmsService;

    // 2: 如果想要在该类内部引用其他Bean,需通过此方法获取Bean对象,不可直接使用注解注入对象
    protected CmsAdService getCmsAdService() {
        if (cmsService == null) {
            cmsService = ContextHolder.getContext().getBean(CmsAdService.class);
        }
        return cmsService;
    }


    @Override
    public void execute(final JobContext jobContext) {
        LoggerUtil.info("===================定时任务开始==================");
        /**
        此处写自己的定时任务逻辑代码
        */
        LoggerUtil.info("===================定时任务结束==================");
    }
}