From 33aa6f2295aa7c917d299134d3866620ccad988c Mon Sep 17 00:00:00 2001 From: hugui <254963746@qq.com> Date: Sun, 13 Sep 2015 21:40:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20JobRunner=E7=9A=84?= =?UTF-8?q?=E5=BF=AB=E6=8D=B7=E6=B5=8B=E8=AF=95=E7=94=A8=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 30 +++++++++++++- .../core/logger/support/FailsafeLogger.java | 30 +++++++------- .../example/support/TestJobRunnerTester.java | 33 +++++++++++++++ .../tasktracker/logger/BizLoggerFactory.java | 18 ++++----- .../tasktracker/runner/JobRunnerTester.java | 40 +++++++++++++++++++ 5 files changed, 124 insertions(+), 27 deletions(-) create mode 100644 lts-example/src/main/java/com/lts/example/support/TestJobRunnerTester.java create mode 100644 lts-tasktracker/src/main/java/com/lts/tasktracker/runner/JobRunnerTester.java diff --git a/README.md b/README.md index 9bc59130f..9aef52978 100644 --- a/README.md +++ b/README.md @@ -336,7 +336,35 @@ class JobRunnerB implements JobRunner { return null; } } -``` +``` +##TaskTracker的JobRunner测试 +一般在编写TaskTracker的时候，只需要测试JobRunner的实现逻辑是否正确，又不想启动LTS进行远程测试。为了方便测试，LTS提供了JobRunner的快捷测试方法。自己的测试类集成`com.lts.tasktracker.runner.JobRunnerTester`即可，并实现`initContext`和`newJobRunner`方法即可。如`lts-example`中的例子： + +```java +public class TestJobRunnerTester extends JobRunnerTester { + + public static void main(String[] args) throws Throwable { + // 1. Mock Job 数据 + Job job = new Job(); + job.setTaskId("2313213"); + // 2. 运行测试 + TestJobRunnerTester tester = new TestJobRunnerTester(); + Result result = tester.run(job); + System.out.println(JSONUtils.toJSONString(result)); + } + + @Override + protected void initContext() { + // TODO 初始化Spring容器等 + } + + @Override + protected JobRunner newJobRunner() { + return new TestJobRunner(); + } +} +``` + ##SPI扩展说明 ###LTS-Logger扩展 1. 引入`lts-logger-api-{version}.jar` diff --git a/lts-core/src/main/java/com/lts/core/logger/support/FailsafeLogger.java b/lts-core/src/main/java/com/lts/core/logger/support/FailsafeLogger.java index 721e1ea45..3177ee9af 100755 --- a/lts-core/src/main/java/com/lts/core/logger/support/FailsafeLogger.java +++ b/lts-core/src/main/java/com/lts/core/logger/support/FailsafeLogger.java @@ -27,105 +27,105 @@ private String appendContextMessage(String msg) { public void trace(String msg, Throwable e) { try { logger.trace(appendContextMessage(msg), e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void trace(Throwable e) { try { logger.trace(e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void trace(String msg) { try { logger.trace(appendContextMessage(msg)); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void debug(String msg, Throwable e) { try { logger.debug(appendContextMessage(msg), e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void debug(Throwable e) { try { logger.debug(e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void debug(String msg) { try { logger.debug(appendContextMessage(msg)); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void info(String msg, Throwable e) { try { logger.info(appendContextMessage(msg), e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void info(String msg) { try { logger.info(appendContextMessage(msg)); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void warn(String msg, Throwable e) { try { logger.warn(appendContextMessage(msg), e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void warn(String msg) { try { logger.warn(appendContextMessage(msg)); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void error(String msg, Throwable e) { try { logger.error(appendContextMessage(msg), e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void error(String msg) { try { logger.error(appendContextMessage(msg)); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void error(Throwable e) { try { logger.error(e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void info(Throwable e) { try { logger.info(e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } public void warn(Throwable e) { try { logger.warn(e); - } catch (Throwable t) { + } catch (Throwable ignored) { } } diff --git a/lts-example/src/main/java/com/lts/example/support/TestJobRunnerTester.java b/lts-example/src/main/java/com/lts/example/support/TestJobRunnerTester.java new file mode 100644 index 000000000..f735d6275 --- /dev/null +++ b/lts-example/src/main/java/com/lts/example/support/TestJobRunnerTester.java @@ -0,0 +1,33 @@ +package com.lts.example.support; + +import com.lts.core.commons.utils.JSONUtils; +import com.lts.core.domain.Job; +import com.lts.tasktracker.Result; +import com.lts.tasktracker.runner.JobRunner; +import com.lts.tasktracker.runner.JobRunnerTester; + +/** + * @author Robert HG (254963746@qq.com) on 9/13/15. + */ +public class TestJobRunnerTester extends JobRunnerTester { + + public static void main(String[] args) throws Throwable { + // Mock Job 数据 + Job job = new Job(); + job.setTaskId("2313213"); + // 运行测试 + TestJobRunnerTester tester = new TestJobRunnerTester(); + Result result = tester.run(job); + System.out.println(JSONUtils.toJSONString(result)); + } + + @Override + protected void initContext() { + // TODO 初始化Spring容器 + } + + @Override + protected JobRunner newJobRunner() { + return new TestJobRunner(); + } +} diff --git a/lts-tasktracker/src/main/java/com/lts/tasktracker/logger/BizLoggerFactory.java b/lts-tasktracker/src/main/java/com/lts/tasktracker/logger/BizLoggerFactory.java index 3a3c90aa1..e32d99792 100644 --- a/lts-tasktracker/src/main/java/com/lts/tasktracker/logger/BizLoggerFactory.java +++ b/lts-tasktracker/src/main/java/com/lts/tasktracker/logger/BizLoggerFactory.java @@ -19,6 +19,12 @@ public class BizLoggerFactory { * 保证一个TaskTracker只能有一个Logger, 因为一个jvm可以有多个TaskTracker */ public static BizLogger getLogger(Level level, RemotingClientDelegate remotingClient, TaskTrackerApplication application) { + + // 单元测试的时候返回 Mock + if (Environment.UNIT_TEST == LTSConfig.getEnvironment()) { + return new MockBizLogger(level); + } + String key = application.getConfig().getIdentity(); BizLogger logger = BIZ_LOGGER_CONCURRENT_HASH_MAP.get(key); if (logger == null) { @@ -27,7 +33,7 @@ public static BizLogger getLogger(Level level, RemotingClientDelegate remotingCl if (logger != null) { return logger; } - logger = create(level, remotingClient, application); + logger = new BizLoggerImpl(level, remotingClient, application); BIZ_LOGGER_CONCURRENT_HASH_MAP.put(key, logger); } @@ -35,14 +41,4 @@ public static BizLogger getLogger(Level level, RemotingClientDelegate remotingCl return logger; } - /** - * 单元测试的时候返回 Mock - */ - private static BizLogger create(Level level, RemotingClientDelegate remotingClient, TaskTrackerApplication application) { - if (Environment.UNIT_TEST == LTSConfig.getEnvironment()) { - return new MockBizLogger(level); - } - return new BizLoggerImpl(level, remotingClient, application); - } - } diff --git a/lts-tasktracker/src/main/java/com/lts/tasktracker/runner/JobRunnerTester.java b/lts-tasktracker/src/main/java/com/lts/tasktracker/runner/JobRunnerTester.java new file mode 100644 index 000000000..e2819726f --- /dev/null +++ b/lts-tasktracker/src/main/java/com/lts/tasktracker/runner/JobRunnerTester.java @@ -0,0 +1,40 @@ +package com.lts.tasktracker.runner; + +import com.lts.core.cluster.LTSConfig; +import com.lts.core.constant.Environment; +import com.lts.core.constant.Level; +import com.lts.core.domain.Job; +import com.lts.tasktracker.Result; +import com.lts.tasktracker.logger.BizLoggerFactory; + +/** + * 为了方便JobRunner测试设计的 + * + * @author Robert HG (254963746@qq.com) on 9/13/15. + */ +public abstract class JobRunnerTester { + + public Result run(Job job) throws Throwable { + // 1. 设置LTS环境为 UNIT_TEST + LTSConfig.setEnvironment(Environment.UNIT_TEST); + // 设置 BizLogger + LtsLoggerFactory.setLogger(BizLoggerFactory.getLogger(Level.INFO, null, null)); + // 2. load context (Spring Context 或者其他的) + initContext(); + // 3. new jobRunner + JobRunner jobRunner = newJobRunner(); + // 4. run job + return jobRunner.run(job); + } + + /** + * 初始化上下文 (Spring Context等),准备运行环境 + */ + protected abstract void initContext(); + + /** + * 创建JobRunner + */ + protected abstract JobRunner newJobRunner(); + +}