Springboot工程接入xxl-job分布式任务调度

发布于：2022-07-28 ⋅ 阅读:(335) ⋅ 点赞:(0)

版本说明：

Springboot版本：2.6.4

xxl-job:版本：2.2.0（最新请移步文末链接）

xxl-job-core依赖引入：

<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>${xxl-job-core.version}</version>
</dependency>

application.yml配置：

xxl:
  job:
    admin:
      addresses: http://test0-xxl-job.xxx.com //xxl-job私服地址
    accessToken: ${accessToken} //构造XxlJobExecutor时需要，由xxl-job服务端提供
    executor:
      appName: ${sping.application.name}

主要代码说明：

XxlJobConfig(XxlJobSpringExecutor配置)

@Slf4j
@Configuration
public class XxlJobConfig {
    @Value("${xxl.job.admin.addresses}")
    private String adminAddresses;

    @Value("${xxl.job.accessToken}")
    private String accessToken;

    @Value("${xxl.job.executor.appName}")
    private String appName;

    @Bean(initMethod = "start", destroyMethod = "destroy")
    public XxlJobSpringExecutor xxlJobExecutor() throws Exception {
        log.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
        xxlJobSpringExecutor.setAppname(appName);
        xxlJobSpringExecutor.setAccessToken(accessToken);
        return xxlJobSpringExecutor;
    }


}

Job代码：

@Slf4j
@Component
public class StatisticsDataJob {


    @Autowired
    private StatisticsService statisticsService;

    /**
     *  每日统计任务
     * @param str 方法参数不可省
     * @return
     */
    @XxlJob(value = "statisticDailyJob")
    public ReturnT<String> statisticDailyJob(String str) {
        try {
            log.info("topic doc stat job executing...");
            //do some statistics job
            statisticsService.dailyStat();
        } catch (Exception ex) {
            log.error(" handler exception:{}", ex.getMessage(), ex);
            return ReturnT.FAIL;
        }
        return ReturnT.SUCCESS;
    }

}

其中：注解@xxlJob的方法返回值及参数固定，注解中value将在后台配置时使用，如下：