SpringBoot项目集成XXL-Job

将自己进大厂前花2万多买的Python教程，整整370集，少走99%的弯路，免费分享给大家~拿走不谢！学不会退出IT界！_哔哩哔哩_bilibili

    
        org.springframework.boot
        spring-boot-starter-web
    

    
        com.xuxueli
        xxl-job-core
        2.1.2
    

# tomcat服务
server.port=7071

# log config
logging.config=classpath:logback.xml


### xxl-job管理平台地址
xxl.job.admin.addresses=http://127.0.0.1:8888/xxl-job-admin

### XXL-JOB通讯的实际端口
xxl.job.executor.appname=my-xxl-job
xxl.job.executor.ip=
xxl.job.executor.port=8881

### xxl-job, access token
xxl.job.accessToken=

### xxl-job log path
xxl.job.executor.logpath=./logs/jobhandler
### xxl-job log retention days
xxl.job.executor.logretentiondays=30

@Configuration
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;

    @Value("${xxl.job.executor.logretentiondays}")
    private int logRetentionDays;


    @Bean
    public XxlJobSpringExecutor xxlJobExecutor() {
        logger.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
        xxlJobSpringExecutor.setAppName(appName);
        xxlJobSpringExecutor.setIp(ip);
        xxlJobSpringExecutor.setPort(port);
        xxlJobSpringExecutor.setAccessToken(accessToken);
        xxlJobSpringExecutor.setLogPath(logPath);
        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);

        return xxlJobSpringExecutor;
    }
}

@Component
public class MyJob {

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

    
    @XxlJob("demoMyJob")
    public ReturnT demoMyJob(String value) {
        ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
        XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());
        System.out.println("时间:"+System.currentTimeMillis()+" 端口号:"+ executorPort+" 总分片数 = "+shardingVO.getTotal()+ "，当前分片序号 = "+shardingVO.getIndex()+", 请求参数" + value);
        return ReturnT.SUCCESS;
    }

    @XxlJob("userMyJob")
    public ReturnT userMyJob(String value) {

        System.out.println("userMyJob:定时任务触发：" + value);
        return ReturnT.SUCCESS;
    }
}