添加xxl-job

ad-distribute-starters/ad-distribute-starter-job/pom.xml

@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+		 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+		 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<parent>
+		<artifactId>ad-distribute-starters</artifactId>
+		<groupId>com.baiye</groupId>
+		<version>1.1.0</version>
+	</parent>
+	<modelVersion>4.0.0</modelVersion>
+
+	<artifactId>ad-distribute-starter-job</artifactId>
+
+	<properties>
+		<maven.compiler.source>8</maven.compiler.source>
+		<maven.compiler.target>8</maven.compiler.target>
+	</properties>
+	<dependencies>
+		<!--xxl job-->
+		<dependency>
+			<groupId>com.xuxueli</groupId>
+			<artifactId>xxl-job-core</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-autoconfigure</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-configuration-processor</artifactId>
+			<optional>true</optional>
+		</dependency>
+	</dependencies>
+</project>

ad-distribute-starters/ad-distribute-starter-job/src/main/java/com/baiye/ballcat/common/job/XxlJobAutoConfiguration.java

@@ -0,0 +1,96 @@
+package com.baiye.ballcat.common.job;
+
+
+import com.baiye.ballcat.common.job.properties.XxlExecutorProperties;
+import com.baiye.ballcat.common.job.properties.XxlJobProperties;
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.autoconfigure.AutoConfiguration;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.core.env.Environment;
+import org.springframework.util.StringUtils;
+
+/**
+ * @author lengleng
+ * @date 2019-09-18
+ * <p>
+ * xxl 初始化
+ */
+@Slf4j
+@AutoConfiguration
+@EnableConfigurationProperties(XxlJobProperties.class)
+@ConditionalOnProperty(prefix = XxlJobProperties.PREFIX, name = "enabled", havingValue = "true", matchIfMissing = true)
+@RequiredArgsConstructor
+public class XxlJobAutoConfiguration {
+
+	private final Environment environment;
+
+	@Bean
+	public XxlJobSpringExecutor xxlJobSpringExecutor(XxlJobProperties xxlJobProperties) {
+		if (log.isInfoEnabled()) {
+			log.info(">>>>>>>>>>> xxl-job config init.");
+		}
+		XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+		xxlJobSpringExecutor.setAdminAddresses(xxlJobProperties.getAdmin().getAddresses());
+		XxlExecutorProperties executorProperties = xxlJobProperties.getExecutor();
+		xxlJobSpringExecutor.setAppname(getExecutorName(executorProperties));
+		xxlJobSpringExecutor.setIp(executorProperties.getIp());
+		xxlJobSpringExecutor.setPort(executorProperties.getPort());
+		xxlJobSpringExecutor.setAccessToken(getAccessToken(xxlJobProperties));
+		xxlJobSpringExecutor.setLogPath(getLogPath(executorProperties));
+		xxlJobSpringExecutor.setLogRetentionDays(executorProperties.getLogRetentionDays());
+		xxlJobSpringExecutor.setAddress(executorProperties.getAddress());
+		return xxlJobSpringExecutor;
+	}
+
+	/**
+	 * 获取执行器名称，缺省为Spring Boot应用名称
+	 *
+	 * @param properties 执行器配置
+	 * @return 执行期名称
+	 */
+	private String getExecutorName(XxlExecutorProperties properties) {
+		String appName = properties.getAppname();
+		if (StringUtils.hasText(appName)) {
+			return appName;
+		} else {
+			return environment.getProperty("spring.application.name");
+		}
+	}
+
+	/**
+	 * 获取xxl-job执行器通讯令牌
+	 *
+	 * @param properties 主配置文件
+	 * @return
+	 */
+	private String getAccessToken(XxlJobProperties properties) {
+		if (StringUtils.hasText(properties.getAccessToken())) {
+			return properties.getAccessToken();
+		} else {
+			log.warn("为提升系统安全性，生产环境建议启用调度中心和执行器安全性校验！可通过配置项 “xxl.job.accessToken” 进行AccessToken的设置");
+			return null;
+		}
+	}
+
+	/**
+	 * 获取日志路径
+	 *
+	 * @param properties 执行器配置文件
+	 * @return
+	 */
+	private String getLogPath(XxlExecutorProperties properties) {
+		String logPath = properties.getLogPath();
+		if (StringUtils.hasText(logPath)) {
+			return logPath;
+		}
+		return environment.getProperty("logging.file.path", "logs")
+				.concat("/")
+				.concat(environment.getProperty("spring.application.name"))
+				.concat("/jobs");
+	}
+
+}

ad-distribute-starters/ad-distribute-starter-job/src/main/java/com/baiye/ballcat/common/job/properties/XxlAdminProperties.java

@@ -0,0 +1,19 @@
+package com.baiye.ballcat.common.job.properties;
+
+import lombok.Data;
+
+/**
+ * @author lengleng
+ * @date 2019-09-18
+ * <p>
+ * xxl 管控台相关属性
+ */
+@Data
+public class XxlAdminProperties {
+
+	/**
+	 * 调度中心部署跟地址 [选填]：如调度中心集群部署存在多个地址则用逗号分隔。 执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"；为空则关闭自动注册；
+	 */
+	private String addresses;
+
+}

ad-distribute-starters/ad-distribute-starter-job/src/main/java/com/baiye/ballcat/common/job/properties/XxlExecutorProperties.java

@@ -0,0 +1,43 @@
+package com.baiye.ballcat.common.job.properties;
+
+import lombok.Data;
+
+/**
+ * @author lengleng
+ * @date 2019-09-18
+ */
+@Data
+public class XxlExecutorProperties {
+
+	/**
+	 * 执行器AppName [选填]：执行器心跳注册分组依据；为空则取spring应用名
+	 */
+	private String appname;
+
+	/**
+	 * 优先使用该配置作为注册地址，为空时使用内嵌服务 ”IP:PORT“ 作为注册地址 从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。
+	 */
+	private String address;
+
+	/**
+	 * 执行器IP [选填]：默认为空表示自动获取IP，多网卡时可手动设置指定IP ，该IP不会绑定Host仅作为通讯实用；地址信息用于 "执行器注册" 和
+	 * "调度中心请求并触发任务"
+	 */
+	private String ip;
+
+	/**
+	 * 执行器端口号 [选填]：小于等于0则自动获取；单机部署多个执行器且非自动获取端口时，注意要配置不同执行器端口；
+	 */
+	private Integer port = 0;
+
+	/**
+	 * 执行器运行日志文件存储磁盘路径 [选填] ：需要对该路径拥有读写权限；为空则使用默认路径；
+	 */
+	private String logPath;
+
+	/**
+	 * 执行器日志保存天数 [选填] ：值大于3时生效，启用执行器Log文件定期清理功能，否则, 如-1, 关闭自动清理功能；
+	 */
+	private Integer logRetentionDays = 30;
+
+}

ad-distribute-starters/ad-distribute-starter-job/src/main/java/com/baiye/ballcat/common/job/properties/XxlJobProperties.java

@@ -0,0 +1,33 @@
+package com.baiye.ballcat.common.job.properties;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.NestedConfigurationProperty;
+
+/**
+ * @author lengleng
+ * @date 2019-09-18
+ */
+@Data
+@ConfigurationProperties(prefix = XxlJobProperties.PREFIX)
+public class XxlJobProperties {
+
+	public static final String PREFIX = "ballcat.xxl.job";
+
+	/**
+	 * 是否启用分布式调度任务，默认：开启
+	 */
+	private boolean enabled = true;
+
+	/**
+	 * 执行器通讯TOKEN [选填]：非空时启用；
+	 */
+	private String accessToken;
+
+	@NestedConfigurationProperty
+	private XxlAdminProperties admin = new XxlAdminProperties();
+
+	@NestedConfigurationProperty
+	private XxlExecutorProperties executor = new XxlExecutorProperties();
+
+}

ad-distribute-starters/ad-distribute-starter-job/src/main/resources/META-INF/spring.factories

@@ -0,0 +1,4 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+    com.baiye.ballcat.common.job.XxlJobAutoConfiguration
+
+

ad-distribute-starters/ad-distribute-starter-job/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -0,0 +1 @@
+com.baiye.ballcat.common.job.XxlJobAutoConfiguration

ad-distribute-starters/pom.xml

@@ -17,13 +17,15 @@
 		<module>ad-distribute-starter-swagger</module>
 		<module>ad-distribute-starter-file</module>
 		<module>ad-distribute-starter-websocket</module>
-	</modules>
+        <module>ad-distribute-starter-job</module>
+    </modules>
 
 	<dependencies>
 		<dependency>
 			<groupId>org.projectlombok</groupId>
 			<artifactId>lombok</artifactId>
 		</dependency>
+
 	</dependencies>
 
 </project>