xxj-job项目集成到springBoot

   <dependency>

        <groupId>com.xuxueli</groupId>

        <artifactId>xxl-job-core</artifactId>

        <version>1.9.1</version>

      </dependency>

@Configuration

@ComponentScan(basePackages = "com.dc.config.jobhandler")

public class XxlJobConfig {

    private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

    @Value("${xxl.job.admin.addresses}")

    private String adminAddresses;

    @Value("${xxl.job.executor.appname}")

    private String appName;

    @Value("${xxl.job.executor.ip}")

    private String ip;

    @Value("${xxl.job.executor.port}")

    private int port;

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

    private String accessToken;

    @Value("${xxl.job.executor.logpath}")

private String logPath;

  private int logRetentionDays=-1;//Log文件定期清理

    @Bean(initMethod = "start", destroyMethod = "destroy")

    public XxlJobExecutor xxlJobExecutor() {

        logger.info(">>>>>>>>>>> xxl-job config init.");

        XxlJobExecutor xxlJobExecutor = new XxlJobExecutor();

        xxlJobExecutor.setAdminAddresses(adminAddresses);

        xxlJobExecutor.setAppName(appName);

        xxlJobExecutor.setIp(ip);

        xxlJobExecutor.setPort(port);

        xxlJobExecutor.setAccessToken(accessToken);

        xxlJobExecutor.setLogPath(logPath);

        xxlJobExecutor.setLogRetentionDays(logRetentionDays);

        return xxlJobExecutor;

    }

}

@JobHandler(value = "exjobHandler")

@Component

public class ExJobHandler extends IJobHandler {

   @Override

   public ReturnT<String> execute(String param) throws Exception {

      System.out.println("启动");

      return SUCCESS;

   }

}

xxl:

  job:

    admin:

      addresses: http://192.168.1.212:8080/xxl-job-admin

    executor:

      appname: xxl-job-executor-sample

      ip: 192.168.1.212

      port: 9999

      logpath: /data/applogs/xxl-job/jobhandler

    accessToken: