XXL-JOB分布式任務(wù)調(diào)度平臺(tái)(真·保姆級(jí)教程)

https://gitee.com/xuxueli0323/xxl-job.git

@Configuration
public?class?XxlJobConfig?{
????private?Logger?logger?=?LoggerFactory.getLogger(XxlJobConfig.class);

????@Value("${xxl.job.admin.addresses}")
????private?String?adminAddresses;

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

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

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

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

????@Value("${xxl.job.executor.port}")
????private?int?port;

????@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.setAddress(address);
????????xxlJobSpringExecutor.setIp(ip);
????????xxlJobSpringExecutor.setPort(port);
????????xxlJobSpringExecutor.setAccessToken(accessToken);
????????xxlJobSpringExecutor.setLogPath(logPath);
????????xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);

????????return?xxlJobSpringExecutor;
????}

????/**
?????*?針對(duì)多網(wǎng)卡、容器內(nèi)部署等情況，可借助?"spring-cloud-commons"?提供的?"InetUtils"?組件靈活定制注冊(cè)IP；
?????*
?????*????? 1、引入依賴：
?????*??????????
?????*?????????????org.springframework.cloud
?????*?????????????spring-cloud-commons
?????*?????????????${version}
?????*?????????
?????*
?????*??????2、配置文件，或者容器啟動(dòng)變量
?????*??????????spring.cloud.inetutils.preferred-networks:?'xxx.xxx.xxx.'
?????*
?????*??????3、獲取IP
?????*??????????String?ip_?=?inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
?????*/


}

xxl:
??job:
????admin:
??????#?調(diào)度中心部署跟地址?[選填]：如調(diào)度中心集群部署存在多個(gè)地址則用逗號(hào)分隔。
??????#?執(zhí)行器將會(huì)使用該地址進(jìn)行"執(zhí)行器心跳注冊(cè)"和"任務(wù)結(jié)果回調(diào)"；為空則關(guān)閉自動(dòng)注冊(cè)；
??????addresses:?http://127.0.0.1:8086/xxl-job-admin
????#?執(zhí)行器通訊TOKEN [選填]：非空時(shí)啟用；
????accessToken:
????executor:
??????#?執(zhí)行器AppName [選填]：執(zhí)行器心跳注冊(cè)分組依據(jù)；為空則關(guān)閉自動(dòng)注冊(cè)
??????appname:?xxl-job-executor-mileage
??????#?執(zhí)行器注冊(cè)?[選填]：優(yōu)先使用該配置作為注冊(cè)地址，為空時(shí)使用內(nèi)嵌服務(wù)?”IP:PORT“?作為注冊(cè)地址。
??????#從而更靈活的支持容器類型執(zhí)行器動(dòng)態(tài)IP和動(dòng)態(tài)映射端口問題。
??????address:
??????#?執(zhí)行器IP [選填]：默認(rèn)為空表示自動(dòng)獲取IP，多網(wǎng)卡時(shí)可手動(dòng)設(shè)置指定IP，該IP不會(huì)綁定Host僅作為通訊實(shí)用；
??????#?地址信息用于?"執(zhí)行器注冊(cè)"?和?"調(diào)度中心請(qǐng)求并觸發(fā)任務(wù)"；
??????ip:
??????#?執(zhí)行器端口號(hào)?[選填]：小于等于0則自動(dòng)獲取；默認(rèn)端口為9999，單機(jī)部署多個(gè)執(zhí)行器時(shí)，注意要配置不同執(zhí)行器端口；
??????port:?8088
??????#?執(zhí)行器運(yùn)行日志文件存儲(chǔ)磁盤路徑?[選填]?：需要對(duì)該路徑擁有讀寫權(quán)限；為空則使用默認(rèn)路徑；
??????logpath:?/data/applogs/xxl-job/jobhandler
??????#?執(zhí)行器日志文件保存天數(shù)?[選填]?：?過期日志自動(dòng)清理, 限制值大于等于3時(shí)生效;?否則, 如-1, 關(guān)閉自動(dòng)清理功能；
??????logretentiondays:?30
logging:
??config:?classpath:logback.xml??????

@Component
public?class?MileageXxlJob?{
????private?static?Logger?logger?=?LoggerFactory.getLogger(SampleXxlJob.class);


????/**
?????*?1、簡(jiǎn)單任務(wù)示例（Bean模式）
?????*/
????@XxlJob("mileageJobHandler")
????public?void?mileageJobHandler()?throws?Exception?{
????????XxlJobHelper.log("XXL-JOB,?Hello?World.");

????????for?(int?i?=?0;?i?5;?i++)?{
????????????XxlJobHelper.log("beat?at:"?+?i);
????????????System.out.println("ok");
????????????TimeUnit.SECONDS.sleep(2);
????????}
????????//?default?success
????}
}????