自建执行器与自建注册中心的安全性校验步骤及步骤
官网地址:
能力介绍
构架图
安全性
为增强系统安全性,调度中心和执行器进行安全性校准,双方匹配才准许通信;调度中心和执行器,可通过配置项“xxl.job.”进行的设置。调度中心和执行器,假如还要正常通信,只有两种设置;
权限控制
不同的帐户看见的是不同的页面管理员角度
普通用户角度
日志手动清除
XXL-JOB日志主要包含如下两部份,均支持日志手动清除,说明如下:
任务
配置、启动、停止、重试、终止
灰度上线
调度中心与业务时延任务平台,只需布署一次后长期不须要维护。虽然任务平台,执行器中托管运行着业务作业,作业上线和变更还要重启执行器,尤其是Bean方式任务。
执行器重启或许会中断运行中的任务。虽然,XXL-JOB得益于自建执行器与自建注册中心,可以通过灰度上线的形式,防止因重启造成的任务中断的问题。
方法如下:
信令
支持短信信令,以及预留扩充
迅速接入
1、引入pom配置
com.xuxueli
xxl-job-core
2.3.1-SNAPSHOT
2、配置项
### 调度中心部署根地址 [选填]:如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调";为空则关闭自动注册;xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin### 执行器通讯TOKEN [选填]:非空时启用;xxl.job.accessToken=### 执行器AppName [选填]:执行器心跳注册分组依据;为空则关闭自动注册xxl.job.executor.appname=xxl-job-executor-sample### 执行器注册 [选填]:优先使用该配置作为注册地址,为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。xxl.job.executor.address=### 执行器IP [选填]:默认为空表示自动获取IP,多网卡时可手动设置指定IP,该IP不会绑定Host仅作为通讯实用;地址信息用于 "执行器注册" 和 "调度中心请求并触发任务";xxl.job.executor.ip=### 执行器端口号 [选填]:小于等于0则自动获取;默认端口为9999,单机部署多个执行器时,注意要配置不同执行器端口;xxl.job.executor.port=9999### 执行器运行日志文件存储磁盘路径 [选填] :需要对该路径拥有读写权限;为空则使用默认路径;xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler### 执行器日志文件保存天数 [选填] : 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能;xxl.job.executor.logretentiondays=30
3、配置类
@Configurationpublic 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;
}
}
4、编写业务代码
@Servicepublic class DayJob { @XxlJob("syncDayJob") protected void sync() { XxlJobHelper.log("{}", "--- day job begin ----") // TODO do something
XxlJobHelper.handleFail(); XxlJobHelper.handleSuccess()
}
}
后续计划
小结