diff --git a/xxl-job-executor-samples/pom.xml b/xxl-job-executor-samples/pom.xml index c153b2b9..44fcaac7 100644 --- a/xxl-job-executor-samples/pom.xml +++ b/xxl-job-executor-samples/pom.xml @@ -11,12 +11,7 @@ pom - xxl-job-executor-sample-spring xxl-job-executor-sample-springboot - xxl-job-executor-sample-jfinal - xxl-job-executor-sample-nutz - xxl-job-executor-sample-frameless - xxl-job-executor-sample-jboot \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/pom.xml b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/pom.xml deleted file mode 100644 index 499624b9..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/pom.xml +++ /dev/null @@ -1,37 +0,0 @@ - - - 4.0.0 - - com.xuxueli - xxl-job-executor-samples - 2.1.1-SNAPSHOT - - xxl-job-executor-sample-frameless - jar - - ${project.artifactId} - Example executor project for spring boot. - http://www.xuxueli.com/ - - - - - - - org.slf4j - slf4j-log4j12 - ${slf4j-api.version} - - - - - com.xuxueli - xxl-job-core - ${project.parent.version} - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/Application.java b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/Application.java deleted file mode 100644 index fda416e6..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/Application.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.xuxueli.executor.sample.frameless; - -import com.xuxueli.executor.sample.frameless.config.FrameLessXxlJobConfig; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.concurrent.TimeUnit; - -/** - * @author xuxueli 2018-10-31 19:05:43 - */ -public class Application { - private static Logger logger = LoggerFactory.getLogger(Application.class); - - public static void main(String[] args) { - - try { - // start - FrameLessXxlJobConfig.getInstance().initXxlJobExecutor(); - - while (true) { - TimeUnit.HOURS.sleep(1); - } - } catch (Exception e) { - logger.error(e.getMessage(), e); - } finally { - // destory - FrameLessXxlJobConfig.getInstance().destoryXxlJobExecutor(); - } - - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/config/FrameLessXxlJobConfig.java b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/config/FrameLessXxlJobConfig.java deleted file mode 100644 index 28aa06ad..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/config/FrameLessXxlJobConfig.java +++ /dev/null @@ -1,98 +0,0 @@ -package com.xuxueli.executor.sample.frameless.config; - -import com.xuxueli.executor.sample.frameless.jobhandler.CommandJobHandler; -import com.xuxueli.executor.sample.frameless.jobhandler.DemoJobHandler; -import com.xuxueli.executor.sample.frameless.jobhandler.HttpJobHandler; -import com.xuxueli.executor.sample.frameless.jobhandler.ShardingJobHandler; -import com.xxl.job.core.executor.XxlJobExecutor; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.IOException; -import java.io.InputStreamReader; -import java.util.Properties; - -/** - * @author xuxueli 2018-10-31 19:05:43 - */ -public class FrameLessXxlJobConfig { - private static Logger logger = LoggerFactory.getLogger(FrameLessXxlJobConfig.class); - - - private static FrameLessXxlJobConfig instance = new FrameLessXxlJobConfig(); - public static FrameLessXxlJobConfig getInstance() { - return instance; - } - - - private XxlJobExecutor xxlJobExecutor = null; - - /** - * init - */ - public void initXxlJobExecutor() { - - // registry jobhandler - XxlJobExecutor.registJobHandler("demoJobHandler", new DemoJobHandler()); - XxlJobExecutor.registJobHandler("shardingJobHandler", new ShardingJobHandler()); - XxlJobExecutor.registJobHandler("httpJobHandler", new HttpJobHandler()); - XxlJobExecutor.registJobHandler("commandJobHandler", new CommandJobHandler()); - - // load executor prop - Properties xxlJobProp = loadProperties("xxl-job-executor.properties"); - - - // init executor - xxlJobExecutor = new XxlJobExecutor(); - xxlJobExecutor.setAdminAddresses(xxlJobProp.getProperty("xxl.job.admin.addresses")); - xxlJobExecutor.setAppName(xxlJobProp.getProperty("xxl.job.executor.appname")); - xxlJobExecutor.setIp(xxlJobProp.getProperty("xxl.job.executor.ip")); - xxlJobExecutor.setPort(Integer.valueOf(xxlJobProp.getProperty("xxl.job.executor.port"))); - xxlJobExecutor.setAccessToken(xxlJobProp.getProperty("xxl.job.accessToken")); - xxlJobExecutor.setLogPath(xxlJobProp.getProperty("xxl.job.executor.logpath")); - xxlJobExecutor.setLogRetentionDays(Integer.valueOf(xxlJobProp.getProperty("xxl.job.executor.logretentiondays"))); - - // start executor - try { - xxlJobExecutor.start(); - } catch (Exception e) { - logger.error(e.getMessage(), e); - } - } - - /** - * destory - */ - public void destoryXxlJobExecutor() { - if (xxlJobExecutor != null) { - xxlJobExecutor.destroy(); - } - } - - - public static Properties loadProperties(String propertyFileName) { - InputStreamReader in = null; - try { - ClassLoader loder = Thread.currentThread().getContextClassLoader(); - - in = new InputStreamReader(loder.getResourceAsStream(propertyFileName), "UTF-8");; - if (in != null) { - Properties prop = new Properties(); - prop.load(in); - return prop; - } - } catch (IOException e) { - logger.error("load {} error!", propertyFileName); - } finally { - if (in != null) { - try { - in.close(); - } catch (IOException e) { - logger.error("close {} error!", propertyFileName); - } - } - } - return null; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/CommandJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/CommandJobHandler.java deleted file mode 100644 index fb8281a1..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/CommandJobHandler.java +++ /dev/null @@ -1,54 +0,0 @@ -package com.xuxueli.executor.sample.frameless.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.io.BufferedInputStream; -import java.io.BufferedReader; -import java.io.InputStreamReader; - -/** - * 命令行任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -public class CommandJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - String command = param; - int exitValue = -1; - - BufferedReader bufferedReader = null; - try { - // command process - Process process = Runtime.getRuntime().exec(command); - BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream()); - bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream)); - - // command log - String line; - while ((line = bufferedReader.readLine()) != null) { - XxlJobLogger.log(line); - } - - // command exit - process.waitFor(); - exitValue = process.exitValue(); - } catch (Exception e) { - XxlJobLogger.log(e); - } finally { - if (bufferedReader != null) { - bufferedReader.close(); - } - } - - if (exitValue == 0) { - return IJobHandler.SUCCESS; - } else { - return new ReturnT(IJobHandler.FAIL.getCode(), "command exit value("+exitValue+") is failed"); - } - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/DemoJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/DemoJobHandler.java deleted file mode 100644 index 18071564..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/DemoJobHandler.java +++ /dev/null @@ -1,32 +0,0 @@ -package com.xuxueli.executor.sample.frameless.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.util.concurrent.TimeUnit; - -/** - * 任务Handler示例（Bean模式） - * - * 开发步骤： - * 1、继承"IJobHandler"：“com.xxl.job.core.handler.IJobHandler”； - * 2、注册到执行器工厂：在 "JFinalCoreConfig.initXxlJobExecutor" 中手动注册，注解key值对应的是调度中心新建任务的JobHandler属性的值。 - * 3、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志； - * - * @author xuxueli 2015-12-19 19:43:36 - */ -public class DemoJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - XxlJobLogger.log("XXL-JOB, Hello World."); - - for (int i = 0; i < 5; i++) { - XxlJobLogger.log("beat at:" + i); - TimeUnit.SECONDS.sleep(2); - } - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java deleted file mode 100644 index a8748a88..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java +++ /dev/null @@ -1,87 +0,0 @@ -package com.xuxueli.executor.sample.frameless.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.HttpURLConnection; -import java.net.URL; - -/** - * 跨平台Http任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -public class HttpJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // valid - if (param==null || param.trim().length()==0) { - XxlJobLogger.log("URL Empty"); - return FAIL; - } - - // request - HttpURLConnection connection = null; - BufferedReader bufferedReader = null; - try { - // connection - URL realUrl = new URL(param); - connection = (HttpURLConnection) realUrl.openConnection(); - - // connection setting - connection.setRequestMethod("GET"); - connection.setDoOutput(true); - connection.setDoInput(true); - connection.setUseCaches(false); - connection.setReadTimeout(5 * 1000); - connection.setConnectTimeout(3 * 1000); - connection.setRequestProperty("connection", "Keep-Alive"); - connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); - connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8"); - - // do connection - connection.connect(); - - //Map> map = connection.getHeaderFields(); - - // valid StatusCode - int statusCode = connection.getResponseCode(); - if (statusCode != 200) { - throw new RuntimeException("Http Request StatusCode("+ statusCode +") Invalid."); - } - - // result - bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); - StringBuilder result = new StringBuilder(); - String line; - while ((line = bufferedReader.readLine()) != null) { - result.append(line); - } - String responseMsg = result.toString(); - - XxlJobLogger.log(responseMsg); - return SUCCESS; - } catch (Exception e) { - XxlJobLogger.log(e); - return FAIL; - } finally { - try { - if (bufferedReader != null) { - bufferedReader.close(); - } - if (connection != null) { - connection.disconnect(); - } - } catch (Exception e2) { - XxlJobLogger.log(e2); - } - } - - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/ShardingJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/ShardingJobHandler.java deleted file mode 100644 index b45a24eb..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/ShardingJobHandler.java +++ /dev/null @@ -1,34 +0,0 @@ -package com.xuxueli.executor.sample.frameless.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import com.xxl.job.core.util.ShardingUtil; - -/** - * 分片广播任务 - * - * @author xuxueli 2017-07-25 20:56:50 - */ -public class ShardingJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // 分片参数 - ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo(); - XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal()); - - // 业务逻辑 - for (int i = 0; i < shardingVO.getTotal(); i++) { - if (i == shardingVO.getIndex()) { - XxlJobLogger.log("第 {} 片, 命中分片开始处理", i); - } else { - XxlJobLogger.log("第 {} 片, 忽略", i); - } - } - - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/resources/log4j.xml b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/resources/log4j.xml deleted file mode 100644 index 896517e2..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/resources/log4j.xml +++ /dev/null @@ -1,27 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/resources/xxl-job-executor.properties b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/resources/xxl-job-executor.properties deleted file mode 100644 index 70647faf..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/resources/xxl-job-executor.properties +++ /dev/null @@ -1,15 +0,0 @@ -### xxl-job admin address list, such as "http://address" or "http://address01,http://address02" -xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin - -### xxl-job executor address -xxl.job.executor.appname=xxl-job-executor-sample -xxl.job.executor.ip= -xxl.job.executor.port=9994 - -### xxl-job, access token -xxl.job.accessToken= - -### xxl-job log path -xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler -### xxl-job log retention days -xxl.job.executor.logretentiondays=-1 diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/pom.xml b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/pom.xml deleted file mode 100644 index 2e72b064..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/pom.xml +++ /dev/null @@ -1,55 +0,0 @@ - - - - com.xuxueli - xxl-job-executor-samples - 2.1.1-SNAPSHOT - - 4.0.0 - xxl-job-executor-sample-jboot - jar - - - 1.8 - 1.8 - - - - - - io.jboot - jboot - 2.0.9 - - - - - com.xuxueli - xxl-job-core - ${project.parent.version} - - - - junit - junit - 4.11 - test - - - - ch.qos.logback - logback-core - 1.1.11 - - - - ch.qos.logback - logback-classic - 1.1.11 - - - - - diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/JbootApp.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/JbootApp.java deleted file mode 100644 index 79e2b7ac..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/JbootApp.java +++ /dev/null @@ -1,12 +0,0 @@ -package com.xuxueli.executor.sample.jboot; - -import io.jboot.app.JbootApplication; - -/** - * Jboot app - */ -public class JbootApp { - public static void main(String[] args) { - JbootApplication.run(args); - } -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/config/JbootConfig.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/config/JbootConfig.java deleted file mode 100644 index 0f58c348..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/config/JbootConfig.java +++ /dev/null @@ -1,64 +0,0 @@ -package com.xuxueli.executor.sample.jboot.config; - -import com.xuxueli.executor.sample.jboot.jobhandler.CommandJobHandler; -import com.xuxueli.executor.sample.jboot.jobhandler.DemoJobHandler; -import com.xuxueli.executor.sample.jboot.jobhandler.HttpJobHandler; -import com.xuxueli.executor.sample.jboot.jobhandler.ShardingJobHandler; -import com.xxl.job.core.executor.XxlJobExecutor; -import io.jboot.Jboot; -import io.jboot.core.listener.JbootAppListenerBase; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public class JbootConfig extends JbootAppListenerBase { - private Logger logger = LoggerFactory.getLogger(JbootConfig.class); - - // ---------------------- xxl-job executor ---------------------- - private XxlJobExecutor xxlJobExecutor = null; - - private void initXxlJobExecutor() { - - // registry jobhandler - XxlJobExecutor.registJobHandler("demoJobHandler", new DemoJobHandler()); - XxlJobExecutor.registJobHandler("shardingJobHandler", new ShardingJobHandler()); - XxlJobExecutor.registJobHandler("httpJobHandler", new HttpJobHandler()); - XxlJobExecutor.registJobHandler("commandJobHandler", new CommandJobHandler()); - - // init executor - xxlJobExecutor = new XxlJobExecutor(); - xxlJobExecutor.setAdminAddresses(Jboot.configValue("xxl.job.admin.addresses")); - xxlJobExecutor.setAppName(Jboot.configValue("xxl.job.executor.appname")); - xxlJobExecutor.setIp(Jboot.configValue("xxl.job.executor.ip")); - xxlJobExecutor.setPort(Integer.valueOf(Jboot.configValue("xxl.job.executor.port"))); - xxlJobExecutor.setAccessToken(Jboot.configValue("xxl.job.accessToken")); - xxlJobExecutor.setLogPath(Jboot.configValue("xxl.job.executor.logpath")); - xxlJobExecutor.setLogRetentionDays(Integer.valueOf(Jboot.configValue("xxl.job.executor.logretentiondays"))); - - // start executor - try { - xxlJobExecutor.start(); - } catch (Exception e) { - logger.error(e.getMessage(), e); - } - } - - // ---------------------- jboot ---------------------- - - private void destoryXxlJobExecutor() { - if (xxlJobExecutor != null) { - xxlJobExecutor.destroy(); - } - } - - @Override - public void onStart() { - initXxlJobExecutor(); - super.onStart(); - } - - @Override - public void onStop() { - destoryXxlJobExecutor(); - super.onStop(); - } -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/controller/IndexController.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/controller/IndexController.java deleted file mode 100644 index f7a85976..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/controller/IndexController.java +++ /dev/null @@ -1,14 +0,0 @@ -package com.xuxueli.executor.sample.jboot.controller; - -import io.jboot.web.controller.JbootController; -import io.jboot.web.controller.annotation.RequestMapping; - - -@RequestMapping("/") -public class IndexController extends JbootController { - - public void index() { - renderText("xxl job executor running."); - } - -} \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/CommandJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/CommandJobHandler.java deleted file mode 100644 index a73e19ab..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/CommandJobHandler.java +++ /dev/null @@ -1,54 +0,0 @@ -package com.xuxueli.executor.sample.jboot.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.io.BufferedInputStream; -import java.io.BufferedReader; -import java.io.InputStreamReader; - -/** - * 命令行任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -public class CommandJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - String command = param; - int exitValue = -1; - - BufferedReader bufferedReader = null; - try { - // command process - Process process = Runtime.getRuntime().exec(command); - BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream()); - bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream)); - - // command log - String line; - while ((line = bufferedReader.readLine()) != null) { - XxlJobLogger.log(line); - } - - // command exit - process.waitFor(); - exitValue = process.exitValue(); - } catch (Exception e) { - XxlJobLogger.log(e); - } finally { - if (bufferedReader != null) { - bufferedReader.close(); - } - } - - if (exitValue == 0) { - return IJobHandler.SUCCESS; - } else { - return new ReturnT(IJobHandler.FAIL.getCode(), "command exit value("+exitValue+") is failed"); - } - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/DemoJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/DemoJobHandler.java deleted file mode 100644 index baf7e885..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/DemoJobHandler.java +++ /dev/null @@ -1,32 +0,0 @@ -package com.xuxueli.executor.sample.jboot.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.util.concurrent.TimeUnit; - -/** - * 任务Handler示例（Bean模式） - * - * 开发步骤： - * 1、继承"IJobHandler"：“com.xxl.job.core.handler.IJobHandler”； - * 2、注册到执行器工厂：在 "JFinalCoreConfig.initXxlJobExecutor" 中手动注册，注解key值对应的是调度中心新建任务的JobHandler属性的值。 - * 3、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志； - * - * @author xuxueli 2015-12-19 19:43:36 - */ -public class DemoJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - XxlJobLogger.log("XXL-JOB, Hello World."); - - for (int i = 0; i < 5; i++) { - XxlJobLogger.log("beat at:" + i); - TimeUnit.SECONDS.sleep(2); - } - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java deleted file mode 100644 index 2796ecd7..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java +++ /dev/null @@ -1,81 +0,0 @@ -package com.xuxueli.executor.sample.jboot.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.HttpURLConnection; -import java.net.URL; - -/** - * 跨平台Http任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -public class HttpJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // request - HttpURLConnection connection = null; - BufferedReader bufferedReader = null; - try { - // connection - URL realUrl = new URL(param); - connection = (HttpURLConnection) realUrl.openConnection(); - - // connection setting - connection.setRequestMethod("GET"); - connection.setDoOutput(true); - connection.setDoInput(true); - connection.setUseCaches(false); - connection.setReadTimeout(5 * 1000); - connection.setConnectTimeout(3 * 1000); - connection.setRequestProperty("connection", "Keep-Alive"); - connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); - connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8"); - - // do connection - connection.connect(); - - //Map> map = connection.getHeaderFields(); - - // valid StatusCode - int statusCode = connection.getResponseCode(); - if (statusCode != 200) { - throw new RuntimeException("Http Request StatusCode(" + statusCode + ") Invalid."); - } - - // result - bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); - StringBuilder result = new StringBuilder(); - String line; - while ((line = bufferedReader.readLine()) != null) { - result.append(line); - } - String responseMsg = result.toString(); - - XxlJobLogger.log(responseMsg); - return SUCCESS; - } catch (Exception e) { - XxlJobLogger.log(e); - return FAIL; - } finally { - try { - if (bufferedReader != null) { - bufferedReader.close(); - } - if (connection != null) { - connection.disconnect(); - } - } catch (Exception e2) { - XxlJobLogger.log(e2); - } - } - - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/ShardingJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/ShardingJobHandler.java deleted file mode 100644 index 8eb70aa7..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/ShardingJobHandler.java +++ /dev/null @@ -1,34 +0,0 @@ -package com.xuxueli.executor.sample.jboot.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import com.xxl.job.core.util.ShardingUtil; - -/** - * 分片广播任务 - * - * @author xuxueli 2017-07-25 20:56:50 - */ -public class ShardingJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // 分片参数 - ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo(); - XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal()); - - // 业务逻辑 - for (int i = 0; i < shardingVO.getTotal(); i++) { - if (i == shardingVO.getIndex()) { - XxlJobLogger.log("第 {} 片, 命中分片开始处理", i); - } else { - XxlJobLogger.log("第 {} 片, 忽略", i); - } - } - - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/jboot.properties b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/jboot.properties deleted file mode 100644 index d625c614..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/jboot.properties +++ /dev/null @@ -1,19 +0,0 @@ -#jboot port -undertow.port=8082 - - -### xxl-job admin address list, such as "http://address" or "http://address01,http://address02" -xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin - -### xxl-job executor address -xxl.job.executor.appname=xxl-job-executor-sample -xxl.job.executor.ip= -xxl.job.executor.port=9995 - -### xxl-job, access token -xxl.job.accessToken= - -### xxl-job log path -xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler -### xxl-job log retention days -xxl.job.executor.logretentiondays=-1 \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/logback.xml b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/logback.xml deleted file mode 100644 index e5606050..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/resources/logback.xml +++ /dev/null @@ -1,29 +0,0 @@ - - - - logback - - - - - %d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n - - - - - ${log.path} - - ${log.path}.%d{yyyy-MM-dd}.zip - - - %date %level [%thread] %logger{36} [%file : %line] %msg%n - - - - - - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/test/java/com/xuxueli/AppTest.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/test/java/com/xuxueli/AppTest.java deleted file mode 100644 index 470feac7..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/test/java/com/xuxueli/AppTest.java +++ /dev/null @@ -1,18 +0,0 @@ -package com.xuxueli; - -import org.junit.Test; - -import static org.junit.Assert.assertTrue; - -/** - * Unit test for simple App. - */ -public class AppTest { - /** - * Rigorous Test :-) - */ - @Test - public void shouldAnswerWithTrue() { - assertTrue(true); - } -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/pom.xml b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/pom.xml deleted file mode 100644 index 7f70fb30..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/pom.xml +++ /dev/null @@ -1,38 +0,0 @@ - - - - com.xuxueli - xxl-job-executor-samples - 2.1.1-SNAPSHOT - - 4.0.0 - xxl-job-executor-sample-jfinal - war - - - - - com.jfinal - jfinal - 2.2 - - - - - org.slf4j - slf4j-log4j12 - ${slf4j-api.version} - - - - - com.xuxueli - xxl-job-core - ${project.parent.version} - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/config/JFinalCoreConfig.java b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/config/JFinalCoreConfig.java deleted file mode 100644 index 4dff38f5..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/config/JFinalCoreConfig.java +++ /dev/null @@ -1,90 +0,0 @@ -package com.xuxueli.executor.sample.jfinal.config; - -import com.jfinal.config.*; -import com.jfinal.kit.Prop; -import com.jfinal.kit.PropKit; -import com.xuxueli.executor.sample.jfinal.controller.IndexController; -import com.xuxueli.executor.sample.jfinal.jobhandler.CommandJobHandler; -import com.xuxueli.executor.sample.jfinal.jobhandler.DemoJobHandler; -import com.xuxueli.executor.sample.jfinal.jobhandler.HttpJobHandler; -import com.xuxueli.executor.sample.jfinal.jobhandler.ShardingJobHandler; -import com.xxl.job.core.executor.XxlJobExecutor; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * @author xuxueli 2017-08-11 14:17:41 - */ -public class JFinalCoreConfig extends JFinalConfig { - private Logger logger = LoggerFactory.getLogger(JFinalCoreConfig.class); - - // ---------------------- xxl-job executor ---------------------- - private XxlJobExecutor xxlJobExecutor = null; - private void initXxlJobExecutor() { - - // registry jobhandler - XxlJobExecutor.registJobHandler("demoJobHandler", new DemoJobHandler()); - XxlJobExecutor.registJobHandler("shardingJobHandler", new ShardingJobHandler()); - XxlJobExecutor.registJobHandler("httpJobHandler", new HttpJobHandler()); - XxlJobExecutor.registJobHandler("commandJobHandler", new CommandJobHandler()); - - // load executor prop - Prop xxlJobProp = PropKit.use("xxl-job-executor.properties"); - - // init executor - xxlJobExecutor = new XxlJobExecutor(); - xxlJobExecutor.setAdminAddresses(xxlJobProp.get("xxl.job.admin.addresses")); - xxlJobExecutor.setAppName(xxlJobProp.get("xxl.job.executor.appname")); - xxlJobExecutor.setIp(xxlJobProp.get("xxl.job.executor.ip")); - xxlJobExecutor.setPort(xxlJobProp.getInt("xxl.job.executor.port")); - xxlJobExecutor.setAccessToken(xxlJobProp.get("xxl.job.accessToken")); - xxlJobExecutor.setLogPath(xxlJobProp.get("xxl.job.executor.logpath")); - xxlJobExecutor.setLogRetentionDays(xxlJobProp.getInt("xxl.job.executor.logretentiondays")); - - // start executor - try { - xxlJobExecutor.start(); - } catch (Exception e) { - logger.error(e.getMessage(), e); - } - } - private void destoryXxlJobExecutor() { - if (xxlJobExecutor != null) { - xxlJobExecutor.destroy(); - } - } - - // ---------------------- jfinal ---------------------- - - public void configRoute(Routes route) { - route.add("/", IndexController.class); - } - - @Override - public void afterJFinalStart() { - initXxlJobExecutor(); - } - - @Override - public void beforeJFinalStop() { - destoryXxlJobExecutor(); - } - - public void configConstant(Constants constants) { - - } - - public void configPlugin(Plugins plugins) { - - } - - public void configInterceptor(Interceptors interceptors) { - - } - - public void configHandler(Handlers handlers) { - - } - - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/controller/IndexController.java b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/controller/IndexController.java deleted file mode 100644 index 2c47b73f..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/controller/IndexController.java +++ /dev/null @@ -1,11 +0,0 @@ -package com.xuxueli.executor.sample.jfinal.controller; - -import com.jfinal.core.Controller; - -public class IndexController extends Controller { - - public void index(){ - renderText("xxl job executor running."); - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/CommandJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/CommandJobHandler.java deleted file mode 100644 index b6646d28..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/CommandJobHandler.java +++ /dev/null @@ -1,54 +0,0 @@ -package com.xuxueli.executor.sample.jfinal.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.io.BufferedInputStream; -import java.io.BufferedReader; -import java.io.InputStreamReader; - -/** - * 命令行任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -public class CommandJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - String command = param; - int exitValue = -1; - - BufferedReader bufferedReader = null; - try { - // command process - Process process = Runtime.getRuntime().exec(command); - BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream()); - bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream)); - - // command log - String line; - while ((line = bufferedReader.readLine()) != null) { - XxlJobLogger.log(line); - } - - // command exit - process.waitFor(); - exitValue = process.exitValue(); - } catch (Exception e) { - XxlJobLogger.log(e); - } finally { - if (bufferedReader != null) { - bufferedReader.close(); - } - } - - if (exitValue == 0) { - return IJobHandler.SUCCESS; - } else { - return new ReturnT(IJobHandler.FAIL.getCode(), "command exit value("+exitValue+") is failed"); - } - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/DemoJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/DemoJobHandler.java deleted file mode 100644 index bf4e888d..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/DemoJobHandler.java +++ /dev/null @@ -1,32 +0,0 @@ -package com.xuxueli.executor.sample.jfinal.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.util.concurrent.TimeUnit; - -/** - * 任务Handler示例（Bean模式） - * - * 开发步骤： - * 1、继承"IJobHandler"：“com.xxl.job.core.handler.IJobHandler”； - * 2、注册到执行器工厂：在 "JFinalCoreConfig.initXxlJobExecutor" 中手动注册，注解key值对应的是调度中心新建任务的JobHandler属性的值。 - * 3、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志； - * - * @author xuxueli 2015-12-19 19:43:36 - */ -public class DemoJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - XxlJobLogger.log("XXL-JOB, Hello World."); - - for (int i = 0; i < 5; i++) { - XxlJobLogger.log("beat at:" + i); - TimeUnit.SECONDS.sleep(2); - } - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java deleted file mode 100644 index b8b61f9e..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java +++ /dev/null @@ -1,81 +0,0 @@ -package com.xuxueli.executor.sample.jfinal.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.HttpURLConnection; -import java.net.URL; - -/** - * 跨平台Http任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -public class HttpJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // request - HttpURLConnection connection = null; - BufferedReader bufferedReader = null; - try { - // connection - URL realUrl = new URL(param); - connection = (HttpURLConnection) realUrl.openConnection(); - - // connection setting - connection.setRequestMethod("GET"); - connection.setDoOutput(true); - connection.setDoInput(true); - connection.setUseCaches(false); - connection.setReadTimeout(5 * 1000); - connection.setConnectTimeout(3 * 1000); - connection.setRequestProperty("connection", "Keep-Alive"); - connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); - connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8"); - - // do connection - connection.connect(); - - //Map> map = connection.getHeaderFields(); - - // valid StatusCode - int statusCode = connection.getResponseCode(); - if (statusCode != 200) { - throw new RuntimeException("Http Request StatusCode(" + statusCode + ") Invalid."); - } - - // result - bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); - StringBuilder result = new StringBuilder(); - String line; - while ((line = bufferedReader.readLine()) != null) { - result.append(line); - } - String responseMsg = result.toString(); - - XxlJobLogger.log(responseMsg); - return SUCCESS; - } catch (Exception e) { - XxlJobLogger.log(e); - return FAIL; - } finally { - try { - if (bufferedReader != null) { - bufferedReader.close(); - } - if (connection != null) { - connection.disconnect(); - } - } catch (Exception e2) { - XxlJobLogger.log(e2); - } - } - - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/ShardingJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/ShardingJobHandler.java deleted file mode 100644 index bb3fa2c5..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/ShardingJobHandler.java +++ /dev/null @@ -1,34 +0,0 @@ -package com.xuxueli.executor.sample.jfinal.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import com.xxl.job.core.util.ShardingUtil; - -/** - * 分片广播任务 - * - * @author xuxueli 2017-07-25 20:56:50 - */ -public class ShardingJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // 分片参数 - ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo(); - XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal()); - - // 业务逻辑 - for (int i = 0; i < shardingVO.getTotal(); i++) { - if (i == shardingVO.getIndex()) { - XxlJobLogger.log("第 {} 片, 命中分片开始处理", i); - } else { - XxlJobLogger.log("第 {} 片, 忽略", i); - } - } - - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/resources/log4j.xml b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/resources/log4j.xml deleted file mode 100644 index 5a0c5474..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/resources/log4j.xml +++ /dev/null @@ -1,27 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/resources/xxl-job-executor.properties b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/resources/xxl-job-executor.properties deleted file mode 100644 index 7e4bb804..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/resources/xxl-job-executor.properties +++ /dev/null @@ -1,15 +0,0 @@ -### xxl-job admin address list, such as "http://address" or "http://address01,http://address02" -xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin - -### xxl-job executor address -xxl.job.executor.appname=xxl-job-executor-sample -xxl.job.executor.ip= -xxl.job.executor.port=9996 - -### xxl-job, access token -xxl.job.accessToken= - -### xxl-job log path -xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler -### xxl-job log retention days -xxl.job.executor.logretentiondays=-1 diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/webapp/WEB-INF/web.xml b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/webapp/WEB-INF/web.xml deleted file mode 100644 index 208179ce..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/webapp/WEB-INF/web.xml +++ /dev/null @@ -1,32 +0,0 @@ - - - - xxl-job-executor-sample-jfinal - - webAppRootKey - xxl-job-executor-sample-jfinal - - - - - jfinal - com.jfinal.core.JFinalFilter - - configClass - com.xuxueli.executor.sample.jfinal.config.JFinalCoreConfig - - - - jfinal - /* - - - - - index.html - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/webapp/index.html b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/webapp/index.html deleted file mode 100644 index 7085239b..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/webapp/index.html +++ /dev/null @@ -1 +0,0 @@ -i am alive. \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/pom.xml b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/pom.xml deleted file mode 100644 index 5b5dc800..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/pom.xml +++ /dev/null @@ -1,38 +0,0 @@ - - - - com.xuxueli - xxl-job-executor-samples - 2.1.1-SNAPSHOT - - 4.0.0 - xxl-job-executor-sample-nutz - war - - - - - org.nutz - nutz - 1.r.62 - - - - - org.slf4j - slf4j-log4j12 - ${slf4j-api.version} - - - - - com.xuxueli - xxl-job-core - ${project.parent.version} - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/MainModule.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/MainModule.java deleted file mode 100644 index a8163ff9..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/MainModule.java +++ /dev/null @@ -1,23 +0,0 @@ -package com.xuxueli.executor.sample.nutz; - -import com.xuxueli.executor.sample.nutz.config.NutzSetup; -import org.nutz.mvc.annotation.*; -import org.nutz.mvc.ioc.provider.ComboIocProvider; - -/** - * nutz module - * - * @author xuxueli 2017-12-25 17:58:43 - */ -@IocBy(type = ComboIocProvider.class, - args = {"*org.nutz.ioc.loader.annotation.AnnotationIocLoader", - "com.xuxueli.executor.sample.nutz"}) -@Encoding(input = "utf-8", output = "utf-8") -@Modules(scanPackage = true) -@Localization("msg") -@Ok("json") -@Fail("json") -@SetupBy(NutzSetup.class) -public class MainModule { - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/config/NutzSetup.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/config/NutzSetup.java deleted file mode 100644 index eb370ee2..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/config/NutzSetup.java +++ /dev/null @@ -1,65 +0,0 @@ -package com.xuxueli.executor.sample.nutz.config; - -import com.xxl.job.core.executor.XxlJobExecutor; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import org.nutz.ioc.impl.PropertiesProxy; -import org.nutz.mvc.NutConfig; -import org.nutz.mvc.Setup; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * nutz setup - * - * @author xuxueli 2017-12-25 17:58:43 - */ -public class NutzSetup implements Setup { - private Logger logger = LoggerFactory.getLogger(NutzSetup.class); - //public static final Log logger = Logs.get(); - - private XxlJobExecutor xxlJobExecutor = null; - - @Override - public void init(NutConfig cfg) { - - // regist JobHandler - String[] beanNames = cfg.getIoc().getNamesByType(IJobHandler.class); - if (beanNames==null || beanNames.length==0) { - return; - } - for (String beanName : beanNames) { - IJobHandler jobHandler = cfg.getIoc().get(IJobHandler.class, beanName); - String name = jobHandler.getClass().getAnnotation(JobHandler.class).value(); - XxlJobExecutor.registJobHandler(name, jobHandler); - } - - // load executor prop - PropertiesProxy xxlJobProp = new PropertiesProxy("xxl-job-executor.properties"); - - // init executor - xxlJobExecutor = new XxlJobExecutor(); - xxlJobExecutor.setAdminAddresses(xxlJobProp.get("xxl.job.admin.addresses")); - xxlJobExecutor.setAppName(xxlJobProp.get("xxl.job.executor.appname")); - xxlJobExecutor.setIp(xxlJobProp.get("xxl.job.executor.ip")); - xxlJobExecutor.setPort(xxlJobProp.getInt("xxl.job.executor.port")); - xxlJobExecutor.setAccessToken(xxlJobProp.get("xxl.job.accessToken")); - xxlJobExecutor.setLogPath(xxlJobProp.get("xxl.job.executor.logpath")); - xxlJobExecutor.setLogRetentionDays(xxlJobProp.getInt("xxl.job.executor.logretentiondays")); - - // start executor - try { - xxlJobExecutor.start(); - } catch (Exception e) { - logger.error(e.getMessage(), e); - } - } - - @Override - public void destroy(NutConfig cfg) { - if (xxlJobExecutor != null) { - xxlJobExecutor.destroy(); - } - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/CommandJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/CommandJobHandler.java deleted file mode 100644 index adbebcf2..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/CommandJobHandler.java +++ /dev/null @@ -1,58 +0,0 @@ -package com.xuxueli.executor.sample.nutz.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import org.nutz.ioc.loader.annotation.IocBean; - -import java.io.BufferedInputStream; -import java.io.BufferedReader; -import java.io.InputStreamReader; - -/** - * 命令行任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -@JobHandler(value="commandJobHandler") -@IocBean -public class CommandJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - String command = param; - int exitValue = -1; - - BufferedReader bufferedReader = null; - try { - // command process - Process process = Runtime.getRuntime().exec(command); - BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream()); - bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream)); - - // command log - String line; - while ((line = bufferedReader.readLine()) != null) { - XxlJobLogger.log(line); - } - - // command exit - process.waitFor(); - exitValue = process.exitValue(); - } catch (Exception e) { - XxlJobLogger.log(e); - } finally { - if (bufferedReader != null) { - bufferedReader.close(); - } - } - - if (exitValue == 0) { - return IJobHandler.SUCCESS; - } else { - return new ReturnT(IJobHandler.FAIL.getCode(), "command exit value("+exitValue+") is failed"); - } - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/DemoJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/DemoJobHandler.java deleted file mode 100644 index 20f1b3ba..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/DemoJobHandler.java +++ /dev/null @@ -1,38 +0,0 @@ -package com.xuxueli.executor.sample.nutz.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import org.nutz.ioc.loader.annotation.IocBean; - -import java.util.concurrent.TimeUnit; - -/** - * 任务Handler示例（Bean模式） - * - * 开发步骤： - * 1、继承"IJobHandler"：“com.xxl.job.core.handler.IJobHandler”； - * 2、注册到Nutz容器：添加“@IocBean”注解，被Nutz容器扫描为Bean实例； - * 3、注册到执行器工厂：添加“@JobHandler(value="自定义jobhandler名称")”注解，注解value值对应的是调度中心新建任务的JobHandler属性的值。 - * 4、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志； - * - * @author xuxueli 2015-12-19 19:43:36 - */ -@JobHandler(value="demoJobHandler") -@IocBean -public class DemoJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - XxlJobLogger.log("XXL-JOB, Hello World."); - - for (int i = 0; i < 5; i++) { - XxlJobLogger.log("beat at:" + i); - TimeUnit.SECONDS.sleep(2); - } - return SUCCESS; - } - -} - diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java deleted file mode 100644 index 5d2724ec..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java +++ /dev/null @@ -1,85 +0,0 @@ -package com.xuxueli.executor.sample.nutz.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import org.nutz.ioc.loader.annotation.IocBean; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.HttpURLConnection; -import java.net.URL; - -/** - * 跨平台Http任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -@JobHandler(value = "httpJobHandler") -@IocBean -public class HttpJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // request - HttpURLConnection connection = null; - BufferedReader bufferedReader = null; - try { - // connection - URL realUrl = new URL(param); - connection = (HttpURLConnection) realUrl.openConnection(); - - // connection setting - connection.setRequestMethod("GET"); - connection.setDoOutput(true); - connection.setDoInput(true); - connection.setUseCaches(false); - connection.setReadTimeout(5 * 1000); - connection.setConnectTimeout(3 * 1000); - connection.setRequestProperty("connection", "Keep-Alive"); - connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); - connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8"); - - // do connection - connection.connect(); - - //Map> map = connection.getHeaderFields(); - - // valid StatusCode - int statusCode = connection.getResponseCode(); - if (statusCode != 200) { - throw new RuntimeException("Http Request StatusCode(" + statusCode + ") Invalid."); - } - - // result - bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); - StringBuilder result = new StringBuilder(); - String line; - while ((line = bufferedReader.readLine()) != null) { - result.append(line); - } - String responseMsg = result.toString(); - - XxlJobLogger.log(responseMsg); - return SUCCESS; - } catch (Exception e) { - XxlJobLogger.log(e); - return FAIL; - } finally { - try { - if (bufferedReader != null) { - bufferedReader.close(); - } - if (connection != null) { - connection.disconnect(); - } - } catch (Exception e2) { - XxlJobLogger.log(e2); - } - } - - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/ShardingJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/ShardingJobHandler.java deleted file mode 100644 index 9681bf1a..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/ShardingJobHandler.java +++ /dev/null @@ -1,39 +0,0 @@ -package com.xuxueli.executor.sample.nutz.jobhandler; - -import com.xxl.job.core.handler.annotation.JobHandler; -import org.nutz.ioc.loader.annotation.IocBean; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import com.xxl.job.core.util.ShardingUtil; - -/** - * 分片广播任务 - * - * @author xuxueli 2017-07-25 20:56:50 - */ -@JobHandler(value="shardingJobHandler") -@IocBean -public class ShardingJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // 分片参数 - ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo(); - XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal()); - - // 业务逻辑 - for (int i = 0; i < shardingVO.getTotal(); i++) { - if (i == shardingVO.getIndex()) { - XxlJobLogger.log("第 {} 片, 命中分片开始处理", i); - } else { - XxlJobLogger.log("第 {} 片, 忽略", i); - } - } - - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/module/IndexModule.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/module/IndexModule.java deleted file mode 100644 index 0cd0233d..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/module/IndexModule.java +++ /dev/null @@ -1,16 +0,0 @@ -package com.xuxueli.executor.sample.nutz.module; - -import org.nutz.ioc.loader.annotation.IocBean; -import org.nutz.mvc.annotation.At; -import org.nutz.mvc.annotation.Ok; - -@IocBean -public class IndexModule { - - @At("/") - @Ok("json") - public String index() { - return "xxl job executor running."; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/resources/log4j.xml b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/resources/log4j.xml deleted file mode 100644 index b9ba6cef..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/resources/log4j.xml +++ /dev/null @@ -1,27 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/resources/xxl-job-executor.properties b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/resources/xxl-job-executor.properties deleted file mode 100644 index e703e006..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/resources/xxl-job-executor.properties +++ /dev/null @@ -1,15 +0,0 @@ -### xxl-job admin address list, such as "http://address" or "http://address01,http://address02" -xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin - -### xxl-job executor address -xxl.job.executor.appname=xxl-job-executor-sample -xxl.job.executor.ip= -xxl.job.executor.port=9997 - -### xxl-job, access token -xxl.job.accessToken= - -### xxl-job log path -xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler -### xxl-job log retention days -xxl.job.executor.logretentiondays=-1 diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/webapp/WEB-INF/web.xml b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/webapp/WEB-INF/web.xml deleted file mode 100644 index 19f2817f..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/webapp/WEB-INF/web.xml +++ /dev/null @@ -1,32 +0,0 @@ - - - - xxl-job-executor-sample-nutz - - webAppRootKey - xxl-job-executor-sample-nutz - - - - - nutz - org.nutz.mvc.NutFilter - - modules - com.xuxueli.executor.sample.nutz.MainModule - - - - nutz - /* - - - - - index.html - - - diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/webapp/index.html b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/webapp/index.html deleted file mode 100644 index 7085239b..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/webapp/index.html +++ /dev/null @@ -1 +0,0 @@ -i am alive. \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/pom.xml b/xxl-job-executor-samples/xxl-job-executor-sample-spring/pom.xml deleted file mode 100644 index 8ca185ac..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/pom.xml +++ /dev/null @@ -1,52 +0,0 @@ - - 4.0.0 - - com.xuxueli - xxl-job-executor-samples - 2.1.1-SNAPSHOT - - xxl-job-executor-sample-spring - war - - ${project.artifactId} - Executor project for spring boot. - http://www.xuxueli.com/ - - - - - org.springframework - spring-webmvc - ${spring.version} - - - - - org.slf4j - slf4j-log4j12 - ${slf4j-api.version} - - - - - com.xuxueli - xxl-job-core - ${project.parent.version} - - - - - - - org.apache.maven.plugins - maven-war-plugin - ${maven-war-plugin.version} - - false - - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/CommandJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/CommandJobHandler.java deleted file mode 100644 index bc70e91c..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/CommandJobHandler.java +++ /dev/null @@ -1,58 +0,0 @@ -package com.xxl.job.executor.service.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import org.springframework.stereotype.Component; - -import java.io.BufferedInputStream; -import java.io.BufferedReader; -import java.io.InputStreamReader; - -/** - * 命令行任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -@JobHandler(value="commandJobHandler") -@Component -public class CommandJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - String command = param; - int exitValue = -1; - - BufferedReader bufferedReader = null; - try { - // command process - Process process = Runtime.getRuntime().exec(command); - BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream()); - bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream)); - - // command log - String line; - while ((line = bufferedReader.readLine()) != null) { - XxlJobLogger.log(line); - } - - // command exit - process.waitFor(); - exitValue = process.exitValue(); - } catch (Exception e) { - XxlJobLogger.log(e); - } finally { - if (bufferedReader != null) { - bufferedReader.close(); - } - } - - if (exitValue == 0) { - return IJobHandler.SUCCESS; - } else { - return new ReturnT(IJobHandler.FAIL.getCode(), "command exit value("+exitValue+") is failed"); - } - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/DemoJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/DemoJobHandler.java deleted file mode 100644 index a1a9c72d..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/DemoJobHandler.java +++ /dev/null @@ -1,38 +0,0 @@ -package com.xxl.job.executor.service.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import org.springframework.stereotype.Component; - -import java.util.concurrent.TimeUnit; - - -/** - * 任务Handler示例（Bean模式） - * - * 开发步骤： - * 1、继承"IJobHandler"：“com.xxl.job.core.handler.IJobHandler”； - * 2、注册到Spring容器：添加“@Component”注解，被Spring容器扫描为Bean实例； - * 3、注册到执行器工厂：添加“@JobHandler(value="自定义jobhandler名称")”注解，注解value值对应的是调度中心新建任务的JobHandler属性的值。 - * 4、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志； - * - * @author xuxueli 2015-12-19 19:43:36 - */ -@JobHandler(value="demoJobHandler") -@Component -public class DemoJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - XxlJobLogger.log("XXL-JOB, Hello World."); - - for (int i = 0; i < 5; i++) { - XxlJobLogger.log("beat at:" + i); - TimeUnit.SECONDS.sleep(2); - } - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/HttpJobHandler.java deleted file mode 100644 index 7ccd54f2..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/HttpJobHandler.java +++ /dev/null @@ -1,85 +0,0 @@ -package com.xxl.job.executor.service.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import org.springframework.stereotype.Component; - -import java.io.BufferedReader; -import java.io.InputStreamReader; -import java.net.HttpURLConnection; -import java.net.URL; - -/** - * 跨平台Http任务 - * - * @author xuxueli 2018-09-16 03:48:34 - */ -@JobHandler(value = "httpJobHandler") -@Component -public class HttpJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // request - HttpURLConnection connection = null; - BufferedReader bufferedReader = null; - try { - // connection - URL realUrl = new URL(param); - connection = (HttpURLConnection) realUrl.openConnection(); - - // connection setting - connection.setRequestMethod("GET"); - connection.setDoOutput(true); - connection.setDoInput(true); - connection.setUseCaches(false); - connection.setReadTimeout(5 * 1000); - connection.setConnectTimeout(3 * 1000); - connection.setRequestProperty("connection", "Keep-Alive"); - connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); - connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8"); - - // do connection - connection.connect(); - - //Map> map = connection.getHeaderFields(); - - // valid StatusCode - int statusCode = connection.getResponseCode(); - if (statusCode != 200) { - throw new RuntimeException("Http Request StatusCode(" + statusCode + ") Invalid."); - } - - // result - bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); - StringBuilder result = new StringBuilder(); - String line; - while ((line = bufferedReader.readLine()) != null) { - result.append(line); - } - String responseMsg = result.toString(); - - XxlJobLogger.log(responseMsg); - return SUCCESS; - } catch (Exception e) { - XxlJobLogger.log(e); - return FAIL; - } finally { - try { - if (bufferedReader != null) { - bufferedReader.close(); - } - if (connection != null) { - connection.disconnect(); - } - } catch (Exception e2) { - XxlJobLogger.log(e2); - } - } - - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/ShardingJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/ShardingJobHandler.java deleted file mode 100644 index d7f20c2b..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/ShardingJobHandler.java +++ /dev/null @@ -1,38 +0,0 @@ -package com.xxl.job.executor.service.jobhandler; - -import com.xxl.job.core.biz.model.ReturnT; -import com.xxl.job.core.handler.IJobHandler; -import com.xxl.job.core.handler.annotation.JobHandler; -import com.xxl.job.core.log.XxlJobLogger; -import com.xxl.job.core.util.ShardingUtil; -import org.springframework.stereotype.Service; - -/** - * 分片广播任务 - * - * @author xuxueli 2017-07-25 20:56:50 - */ -@JobHandler(value="shardingJobHandler") -@Service -public class ShardingJobHandler extends IJobHandler { - - @Override - public ReturnT execute(String param) throws Exception { - - // 分片参数 - ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo(); - XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal()); - - // 业务逻辑 - for (int i = 0; i < shardingVO.getTotal(); i++) { - if (i == shardingVO.getIndex()) { - XxlJobLogger.log("第 {} 片, 命中分片开始处理", i); - } else { - XxlJobLogger.log("第 {} 片, 忽略", i); - } - } - - return SUCCESS; - } - -} diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/applicationcontext-xxl-job.xml b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/applicationcontext-xxl-job.xml deleted file mode 100644 index 8e06118c..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/applicationcontext-xxl-job.xml +++ /dev/null @@ -1,43 +0,0 @@ - - - - - - - - classpath*:xxl-job-executor.properties - - - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/log4j.xml b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/log4j.xml deleted file mode 100644 index f0a7fc65..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/log4j.xml +++ /dev/null @@ -1,33 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/xxl-job-executor.properties b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/xxl-job-executor.properties deleted file mode 100644 index 2fda3391..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/resources/xxl-job-executor.properties +++ /dev/null @@ -1,15 +0,0 @@ -### xxl-job admin address list, such as "http://address" or "http://address01,http://address02" -xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin - -### xxl-job executor address -xxl.job.executor.appname=xxl-job-executor-sample -xxl.job.executor.ip= -xxl.job.executor.port=9998 - -### xxl-job, access token -xxl.job.accessToken= - -### xxl-job log path -xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler -### xxl-job log retention days -xxl.job.executor.logretentiondays=-1 diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/webapp/WEB-INF/web.xml b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/webapp/WEB-INF/web.xml deleted file mode 100644 index 9179af7b..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/webapp/WEB-INF/web.xml +++ /dev/null @@ -1,31 +0,0 @@ - - - - xxl-job-executor-sample-spring - - webAppRootKey - xxl-job-executor-sample-spring - - - - - contextConfigLocation - classpath*:applicationcontext-*.xml - - - - org.springframework.web.util.Log4jConfigListener - - - org.springframework.web.context.ContextLoaderListener - - - - - index.html - - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/webapp/index.html b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/webapp/index.html deleted file mode 100644 index 7085239b..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/webapp/index.html +++ /dev/null @@ -1 +0,0 @@ -i am alive. \ No newline at end of file