|
|
|
@ -14,61 +14,61 @@ import org.springframework.context.annotation.Configuration;
|
|
|
|
|
*/ |
|
|
|
|
@Configuration |
|
|
|
|
public class XxlJobConfig { |
|
|
|
|
private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class); |
|
|
|
|
private final Logger logger = LoggerFactory.getLogger(XxlJobConfig.class); |
|
|
|
|
|
|
|
|
|
@Value("${xxl.job.admin.addresses}") |
|
|
|
|
private String adminAddresses; |
|
|
|
|
@Value("${xxl.job.admin.addresses}") |
|
|
|
|
private String adminAddresses; |
|
|
|
|
|
|
|
|
|
@Value("${xxl.job.executor.appname}") |
|
|
|
|
private String appName; |
|
|
|
|
@Value("${xxl.job.executor.appname}") |
|
|
|
|
private String appName; |
|
|
|
|
|
|
|
|
|
@Value("${xxl.job.executor.ip}") |
|
|
|
|
private String ip; |
|
|
|
|
@Value("${xxl.job.executor.ip}") |
|
|
|
|
private String ip; |
|
|
|
|
|
|
|
|
|
@Value("${xxl.job.executor.port}") |
|
|
|
|
private int port; |
|
|
|
|
@Value("${xxl.job.executor.port}") |
|
|
|
|
private int port; |
|
|
|
|
|
|
|
|
|
@Value("${xxl.job.accessToken}") |
|
|
|
|
private String accessToken; |
|
|
|
|
@Value("${xxl.job.accessToken}") |
|
|
|
|
private String accessToken; |
|
|
|
|
|
|
|
|
|
@Value("${xxl.job.executor.logpath}") |
|
|
|
|
private String logPath; |
|
|
|
|
@Value("${xxl.job.executor.logpath}") |
|
|
|
|
private String logPath; |
|
|
|
|
|
|
|
|
|
@Value("${xxl.job.executor.logretentiondays}") |
|
|
|
|
private int logRetentionDays; |
|
|
|
|
@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); |
|
|
|
|
@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; |
|
|
|
|
} |
|
|
|
|
return xxlJobSpringExecutor; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 针对多网卡、容器内部署等情况,可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP; |
|
|
|
|
* |
|
|
|
|
* 1、引入依赖: |
|
|
|
|
* <dependency> |
|
|
|
|
* <groupId>org.springframework.cloud</groupId> |
|
|
|
|
* <artifactId>spring-cloud-commons</artifactId> |
|
|
|
|
* <version>${version}</version> |
|
|
|
|
* </dependency> |
|
|
|
|
* |
|
|
|
|
* 2、配置文件,或者容器启动变量 |
|
|
|
|
* spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.' |
|
|
|
|
* |
|
|
|
|
* 3、获取IP |
|
|
|
|
* String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress(); |
|
|
|
|
*/ |
|
|
|
|
/** |
|
|
|
|
* 针对多网卡、容器内部署等情况,可借助 "spring-cloud-commons" 提供的 "InetUtils" 组件灵活定制注册IP; |
|
|
|
|
* |
|
|
|
|
* 1、引入依赖: |
|
|
|
|
* <dependency> |
|
|
|
|
* <groupId>org.springframework.cloud</groupId> |
|
|
|
|
* <artifactId>spring-cloud-commons</artifactId> |
|
|
|
|
* <version>${version}</version> |
|
|
|
|
* </dependency> |
|
|
|
|
* |
|
|
|
|
* 2、配置文件,或者容器启动变量 |
|
|
|
|
* spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.' |
|
|
|
|
* |
|
|
|
|
* 3、获取IP |
|
|
|
|
* String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress(); |
|
|
|
|
*/ |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|