diff --git a/lts-example-jobclient/lts-example-jobclient-java/pom.xml b/lts-example-jobclient/lts-example-jobclient-java/pom.xml index 0d9de20..67828c7 100644 --- a/lts-example-jobclient/lts-example-jobclient-java/pom.xml +++ b/lts-example-jobclient/lts-example-jobclient-java/pom.xml @@ -5,7 +5,7 @@ lts-example-jobclient com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-jobclient/lts-example-jobclient-java/src/main/java/com/github/ltsopensource/example/java/Main.java b/lts-example-jobclient/lts-example-jobclient-java/src/main/java/com/github/ltsopensource/example/java/Main.java index ab63172..56ef97a 100644 --- a/lts-example-jobclient/lts-example-jobclient-java/src/main/java/com/github/ltsopensource/example/java/Main.java +++ b/lts-example-jobclient/lts-example-jobclient-java/src/main/java/com/github/ltsopensource/example/java/Main.java @@ -3,7 +3,7 @@ import com.github.ltsopensource.core.commons.utils.DateUtils; import com.github.ltsopensource.core.domain.Job; import com.github.ltsopensource.jobclient.JobClient; -import com.github.ltsopensource.jobclient.RetryJobClient; +import com.github.ltsopensource.jobclient.JobClientBuilder; import com.github.ltsopensource.jobclient.domain.Response; import java.util.Date; @@ -15,13 +15,20 @@ public class Main { public static void main(String[] args) { - JobClient jobClient = new RetryJobClient(); - jobClient.setNodeGroup("test_jobClient"); - jobClient.setClusterName("test_cluster"); - jobClient.setRegistryAddress("zookeeper://127.0.0.1:2181"); - jobClient.setJobCompletedHandler(new JobCompletedHandlerImpl()); - jobClient.addConfig("job.fail.store", "mapdb"); - jobClient.start(); + // 方式1 +// JobClient jobClient = new RetryJobClient(); +// jobClient.setNodeGroup("test_jobClient"); +// jobClient.setClusterName("test_cluster"); +// jobClient.setRegistryAddress("zookeeper://127.0.0.1:2181"); +// jobClient.setJobCompletedHandler(new JobCompletedHandlerImpl()); +// jobClient.addConfig("job.fail.store", "mapdb"); +// jobClient.start(); + + // 方式2 + JobClient jobClient = new JobClientBuilder() + .setPropertiesConfigure("lts.properties") + .setJobCompletedHandler(new JobCompletedHandlerImpl()) + .build(); submitCronJob(jobClient); submitRepeatJob(jobClient); diff --git a/lts-example-jobclient/lts-example-jobclient-java/src/main/resources/lts.properties b/lts-example-jobclient/lts-example-jobclient-java/src/main/resources/lts.properties new file mode 100644 index 0000000..c30ce68 --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-java/src/main/resources/lts.properties @@ -0,0 +1,12 @@ +lts.jobclient.cluster-name=test_cluster +lts.jobclient.registry-address=zookeeper://127.0.0.1:2181 +lts.jobclient.node-group=test_jobClient +lts.jobclient.use-retry-client=true +lts.jobclient.configs.job.fail.store=mapdb + + +#LTS.JOBCLIENT.CLUSTER-NAME=test_cluster +#LTS.JOBCLIENT.REGISTRY-ADDRESS=zookeeper://127.0.0.1:2181 +#LTS.JOBCLIENT.NODE-GROUP=test_jobClient +#LTS.JOBCLIENT.USE-RETRY-CLIENT=true +#LTS.JOBCLIENT.CONFIGS.job.fail.store=mapdb diff --git a/lts-example-jobclient/lts-example-jobclient-spring-annotation/pom.xml b/lts-example-jobclient/lts-example-jobclient-spring-annotation/pom.xml new file mode 100644 index 0000000..d76581e --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-annotation/pom.xml @@ -0,0 +1,37 @@ + + + + lts-example-jobclient + com.github.ltsopensource + 1.6.8-SNAPSHOT + + 4.0.0 + + lts-example-jobclient-spring-annotation + + + + org.springframework + spring-core + ${springframework.version} + + + org.springframework + spring-beans + ${springframework.version} + + + org.springframework + spring-context + ${springframework.version} + + + org.springframework + spring-context-support + ${springframework.version} + + + + \ No newline at end of file diff --git a/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/JobClientConfig.java b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/JobClientConfig.java new file mode 100644 index 0000000..ca9ad33 --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/JobClientConfig.java @@ -0,0 +1,22 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.jobclient.JobClient; +import com.github.ltsopensource.spring.JobClientFactoryBean; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @author Robert HG (254963746@qq.com) on 4/22/16. + */ +@Configuration +public class JobClientConfig { + + @Bean(name = "jobClient") + public JobClient getJobClient() throws Exception { + JobClientFactoryBean factoryBean = new JobClientFactoryBean(); + factoryBean.setLocations("lts.properties"); + factoryBean.afterPropertiesSet(); + factoryBean.start(); + return factoryBean.getObject(); + } +} diff --git a/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/JobCompletedHandlerImpl.java b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/JobCompletedHandlerImpl.java new file mode 100644 index 0000000..b4b1974 --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/JobCompletedHandlerImpl.java @@ -0,0 +1,25 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.core.commons.utils.CollectionUtils; +import com.github.ltsopensource.core.domain.JobResult; +import com.github.ltsopensource.jobclient.support.JobCompletedHandler; + +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.List; + +/** + * @author Robert HG (254963746@qq.com) on 4/17/16. + */ +public class JobCompletedHandlerImpl implements JobCompletedHandler { + + @Override + public void onComplete(List jobResults) { + // 任务执行反馈结果处理 + if (CollectionUtils.isNotEmpty(jobResults)) { + for (JobResult jobResult : jobResults) { + System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " 任务执行完成:" + jobResult); + } + } + } +} diff --git a/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/Main.java b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/Main.java new file mode 100644 index 0000000..63848ea --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/java/com/github/ltsopensource/example/Main.java @@ -0,0 +1,29 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.core.domain.Job; +import com.github.ltsopensource.jobclient.JobClient; +import com.github.ltsopensource.jobclient.domain.Response; +import org.springframework.context.ApplicationContext; +import org.springframework.context.support.ClassPathXmlApplicationContext; + +/** + * @author Robert HG (254963746@qq.com) on 4/22/16. + */ +public class Main { + + public static void main(String[] args) { + ApplicationContext context = new ClassPathXmlApplicationContext("/lts-jobclient.xml"); + + JobClient jobClient = (JobClient) context.getBean("jobClient"); + + Job job = new Job(); + job.setTaskId("t_realtime_5556666"); + job.setParam("shopId", "1122222221"); + job.setTaskTrackerNodeGroup("test_trade_TaskTracker"); + job.setNeedFeedback(true); + job.setReplaceOnExist(true); // 当任务队列中存在这个任务的时候,是否替换更新 + Response response = jobClient.submitJob(job); + System.out.println(response); + } + +} diff --git a/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/log4j.properties b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/log4j.properties new file mode 100644 index 0000000..4e3c103 --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/log4j.properties @@ -0,0 +1,7 @@ + +log4j.rootLogger=INFO,stdout + +log4j.appender.stdout.Threshold=INFO +log4j.appender.stdout=org.apache.log4j.ConsoleAppender +log4j.appender.stdout.layout=org.apache.log4j.PatternLayout +log4j.appender.stdout.layout.ConversionPattern=[%-5p] [%d{HH:mm:ss}] %c - %m%n \ No newline at end of file diff --git a/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/lts-jobclient.xml b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/lts-jobclient.xml new file mode 100644 index 0000000..341024d --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/lts-jobclient.xml @@ -0,0 +1,14 @@ + + + + + + + \ No newline at end of file diff --git a/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/lts.properties b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/lts.properties new file mode 100644 index 0000000..c30ce68 --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-annotation/src/main/resources/lts.properties @@ -0,0 +1,12 @@ +lts.jobclient.cluster-name=test_cluster +lts.jobclient.registry-address=zookeeper://127.0.0.1:2181 +lts.jobclient.node-group=test_jobClient +lts.jobclient.use-retry-client=true +lts.jobclient.configs.job.fail.store=mapdb + + +#LTS.JOBCLIENT.CLUSTER-NAME=test_cluster +#LTS.JOBCLIENT.REGISTRY-ADDRESS=zookeeper://127.0.0.1:2181 +#LTS.JOBCLIENT.NODE-GROUP=test_jobClient +#LTS.JOBCLIENT.USE-RETRY-CLIENT=true +#LTS.JOBCLIENT.CONFIGS.job.fail.store=mapdb diff --git a/lts-example-jobclient/lts-example-jobclient-spring-xml/pom.xml b/lts-example-jobclient/lts-example-jobclient-spring-xml/pom.xml index 2ba75e0..a610515 100644 --- a/lts-example-jobclient/lts-example-jobclient-spring-xml/pom.xml +++ b/lts-example-jobclient/lts-example-jobclient-spring-xml/pom.xml @@ -5,11 +5,11 @@ lts-example-jobclient com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 - lts-example-jobclient-spring + lts-example-jobclient-spring-xml diff --git a/lts-example-jobclient/lts-example-jobclient-spring-xml/src/main/resources/lts-jobclient.xml b/lts-example-jobclient/lts-example-jobclient-spring-xml/src/main/resources/lts-jobclient.xml index eb85697..718965b 100644 --- a/lts-example-jobclient/lts-example-jobclient-spring-xml/src/main/resources/lts-jobclient.xml +++ b/lts-example-jobclient/lts-example-jobclient-spring-xml/src/main/resources/lts-jobclient.xml @@ -8,18 +8,25 @@ http://www.springframework.org/schema/context/spring-context-4.0.xsd" > + + + + + + + + + + + + + + - - - + - - - mapdb - - \ No newline at end of file diff --git a/lts-example-jobclient/lts-example-jobclient-spring-xml/src/main/resources/lts.properties b/lts-example-jobclient/lts-example-jobclient-spring-xml/src/main/resources/lts.properties new file mode 100644 index 0000000..c30ce68 --- /dev/null +++ b/lts-example-jobclient/lts-example-jobclient-spring-xml/src/main/resources/lts.properties @@ -0,0 +1,12 @@ +lts.jobclient.cluster-name=test_cluster +lts.jobclient.registry-address=zookeeper://127.0.0.1:2181 +lts.jobclient.node-group=test_jobClient +lts.jobclient.use-retry-client=true +lts.jobclient.configs.job.fail.store=mapdb + + +#LTS.JOBCLIENT.CLUSTER-NAME=test_cluster +#LTS.JOBCLIENT.REGISTRY-ADDRESS=zookeeper://127.0.0.1:2181 +#LTS.JOBCLIENT.NODE-GROUP=test_jobClient +#LTS.JOBCLIENT.USE-RETRY-CLIENT=true +#LTS.JOBCLIENT.CONFIGS.job.fail.store=mapdb diff --git a/lts-example-jobclient/lts-example-jobclient-springboot/pom.xml b/lts-example-jobclient/lts-example-jobclient-springboot/pom.xml index 4828874..f82193b 100644 --- a/lts-example-jobclient/lts-example-jobclient-springboot/pom.xml +++ b/lts-example-jobclient/lts-example-jobclient-springboot/pom.xml @@ -5,7 +5,7 @@ lts-example-jobclient com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 lts-example-jobclient-springboot diff --git a/lts-example-jobclient/pom.xml b/lts-example-jobclient/pom.xml index f41e5d9..65b9c5f 100644 --- a/lts-example-jobclient/pom.xml +++ b/lts-example-jobclient/pom.xml @@ -5,14 +5,15 @@ lts-examples com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 pom lts-example-jobclient-springboot - lts-example-jobclient-spring + lts-example-jobclient-spring-xml lts-example-jobclient-java + lts-example-jobclient-spring-annotation lts-example-jobclient diff --git a/lts-example-jobtracker/lts-example-jobtracker-java/pom.xml b/lts-example-jobtracker/lts-example-jobtracker-java/pom.xml index 8656415..052caa8 100644 --- a/lts-example-jobtracker/lts-example-jobtracker-java/pom.xml +++ b/lts-example-jobtracker/lts-example-jobtracker-java/pom.xml @@ -5,7 +5,7 @@ lts-example-jobtracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-jobtracker/lts-example-jobtracker-java/src/main/java/com/github/ltsopensource/example/java/Main.java b/lts-example-jobtracker/lts-example-jobtracker-java/src/main/java/com/github/ltsopensource/example/java/Main.java index bb2bee8..2b0d522 100644 --- a/lts-example-jobtracker/lts-example-jobtracker-java/src/main/java/com/github/ltsopensource/example/java/Main.java +++ b/lts-example-jobtracker/lts-example-jobtracker-java/src/main/java/com/github/ltsopensource/example/java/Main.java @@ -1,6 +1,7 @@ package com.github.ltsopensource.example.java; import com.github.ltsopensource.jobtracker.JobTracker; +import com.github.ltsopensource.jobtracker.JobTrackerBuilder; /** * @author Robert HG (254963746@qq.com) on 4/17/16. @@ -8,21 +9,26 @@ public class Main { public static void main(String[] args) { - final JobTracker jobTracker = new JobTracker(); - // 节点信息配置 - jobTracker.setRegistryAddress("zookeeper://127.0.0.1:2181"); -// jobTracker.setRegistryAddress("redis://127.0.0.1:6379"); - jobTracker.setListenPort(35001); // 默认 35001 - jobTracker.setClusterName("test_cluster"); +// final JobTracker jobTracker = new JobTracker(); +// // 节点信息配置 +// jobTracker.setRegistryAddress("zookeeper://127.0.0.1:2181"); +//// jobTracker.setRegistryAddress("redis://127.0.0.1:6379"); +// jobTracker.setListenPort(35001); // 默认 35001 +// jobTracker.setClusterName("test_cluster"); +// +//// // 设置业务日志记录 mysql +//// jobTracker.addConfig("job.logger", "mysql"); +//// // 任务队列用mysql +//// jobTracker.addConfig("job.queue", "mysql"); +// // mysql 配置 +// jobTracker.addConfig("jdbc.url", "jdbc:mysql://127.0.0.1:3306/lts"); +// jobTracker.addConfig("jdbc.username", "root"); +// jobTracker.addConfig("jdbc.password", "root"); + + final JobTracker jobTracker = new JobTrackerBuilder() + .setPropertiesConfigure("lts.properties") + .build(); -// // 设置业务日志记录 mysql -// jobTracker.addConfig("job.logger", "mysql"); -// // 任务队列用mysql -// jobTracker.addConfig("job.queue", "mysql"); - // mysql 配置 - jobTracker.addConfig("jdbc.url", "jdbc:mysql://127.0.0.1:3306/lts"); - jobTracker.addConfig("jdbc.username", "root"); - jobTracker.addConfig("jdbc.password", "root"); // 启动节点 jobTracker.start(); diff --git a/lts-example-jobtracker/lts-example-jobtracker-java/src/main/resources/lts.properties b/lts-example-jobtracker/lts-example-jobtracker-java/src/main/resources/lts.properties new file mode 100644 index 0000000..fe5439a --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-java/src/main/resources/lts.properties @@ -0,0 +1,8 @@ +lts.jobtracker.cluster-name=test_cluster +lts.jobtracker.listen-port=35001 +lts.jobtracker.registry-address=zookeeper://127.0.0.1:2181 +lts.jobtracker.configs.job.logger=mysql +lts.jobtracker.configs.job.queue=mysql +lts.jobtracker.configs.jdbc.url=jdbc:mysql://127.0.0.1:3306/lts +lts.jobtracker.configs.jdbc.username=root +lts.jobtracker.configs.jdbc.password=root diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/lts-example-jobtracker-spring-annotaion.iml b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/lts-example-jobtracker-spring-annotaion.iml new file mode 100644 index 0000000..84448fe --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/lts-example-jobtracker-spring-annotaion.iml @@ -0,0 +1,45 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/pom.xml b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/pom.xml new file mode 100644 index 0000000..645cb7c --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/pom.xml @@ -0,0 +1,37 @@ + + + + lts-example-jobtracker + com.github.ltsopensource + 1.6.8-SNAPSHOT + + 4.0.0 + + lts-example-jobtracker-spring-annotaion + + + + org.springframework + spring-core + ${springframework.version} + + + org.springframework + spring-beans + ${springframework.version} + + + org.springframework + spring-context + ${springframework.version} + + + org.springframework + spring-context-support + ${springframework.version} + + + + \ No newline at end of file diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/java/com/github/ltsopensource/example/JobTrackerConfig.java b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/java/com/github/ltsopensource/example/JobTrackerConfig.java new file mode 100644 index 0000000..8b9cd52 --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/java/com/github/ltsopensource/example/JobTrackerConfig.java @@ -0,0 +1,23 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.jobtracker.JobTracker; +import com.github.ltsopensource.spring.JobTrackerFactoryBean; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @author Robert HG (254963746@qq.com) on 4/22/16. + */ +@Configuration +public class JobTrackerConfig { + + @Bean(name = "jobTracker") + public JobTracker getJobTracker() throws Exception { + JobTrackerFactoryBean factoryBean = new JobTrackerFactoryBean(); + factoryBean.setLocations("lts.properties"); + factoryBean.afterPropertiesSet(); + factoryBean.start(); + return factoryBean.getObject(); + } + +} diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/java/com/github/ltsopensource/example/Main.java b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/java/com/github/ltsopensource/example/Main.java new file mode 100644 index 0000000..c4b96b5 --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/java/com/github/ltsopensource/example/Main.java @@ -0,0 +1,14 @@ +package com.github.ltsopensource.example; + +import org.springframework.context.ApplicationContext; +import org.springframework.context.support.ClassPathXmlApplicationContext; + +/** + * @author Robert HG (254963746@qq.com) on 4/22/16. + */ +public class Main { + + public static void main(String[] args) { + ApplicationContext context = new ClassPathXmlApplicationContext("/lts-jobtracker.xml"); + } +} diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/log4j.properties b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/log4j.properties new file mode 100644 index 0000000..4e3c103 --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/log4j.properties @@ -0,0 +1,7 @@ + +log4j.rootLogger=INFO,stdout + +log4j.appender.stdout.Threshold=INFO +log4j.appender.stdout=org.apache.log4j.ConsoleAppender +log4j.appender.stdout.layout=org.apache.log4j.PatternLayout +log4j.appender.stdout.layout.ConversionPattern=[%-5p] [%d{HH:mm:ss}] %c - %m%n \ No newline at end of file diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/lts-jobtracker.xml b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/lts-jobtracker.xml new file mode 100644 index 0000000..341024d --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/lts-jobtracker.xml @@ -0,0 +1,14 @@ + + + + + + + \ No newline at end of file diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/lts.properties b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/lts.properties new file mode 100644 index 0000000..fe5439a --- /dev/null +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-annotaion/src/main/resources/lts.properties @@ -0,0 +1,8 @@ +lts.jobtracker.cluster-name=test_cluster +lts.jobtracker.listen-port=35001 +lts.jobtracker.registry-address=zookeeper://127.0.0.1:2181 +lts.jobtracker.configs.job.logger=mysql +lts.jobtracker.configs.job.queue=mysql +lts.jobtracker.configs.jdbc.url=jdbc:mysql://127.0.0.1:3306/lts +lts.jobtracker.configs.jdbc.username=root +lts.jobtracker.configs.jdbc.password=root diff --git a/lts-example-jobtracker/lts-example-jobtracker-spring-xml/pom.xml b/lts-example-jobtracker/lts-example-jobtracker-spring-xml/pom.xml index 8bb990e..2f08e40 100644 --- a/lts-example-jobtracker/lts-example-jobtracker-spring-xml/pom.xml +++ b/lts-example-jobtracker/lts-example-jobtracker-spring-xml/pom.xml @@ -5,11 +5,11 @@ lts-example-jobtracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 - lts-example-jobtracker-spring + lts-example-jobtracker-spring-xml org.springframework diff --git a/lts-example-jobtracker/lts-example-jobtracker-springboot/pom.xml b/lts-example-jobtracker/lts-example-jobtracker-springboot/pom.xml index e1f065f..449fe98 100644 --- a/lts-example-jobtracker/lts-example-jobtracker-springboot/pom.xml +++ b/lts-example-jobtracker/lts-example-jobtracker-springboot/pom.xml @@ -5,7 +5,7 @@ lts-example-jobtracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-jobtracker/pom.xml b/lts-example-jobtracker/pom.xml index ccb7280..67f770c 100644 --- a/lts-example-jobtracker/pom.xml +++ b/lts-example-jobtracker/pom.xml @@ -5,7 +5,7 @@ lts-examples com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 lts-example-jobtracker @@ -13,7 +13,8 @@ lts-example-jobtracker-springboot lts-example-jobtracker-java - lts-example-jobtracker-spring + lts-example-jobtracker-spring-xml + lts-example-jobtracker-spring-annotaion diff --git a/lts-example-monitor/lts-example-monitor-springboot/pom.xml b/lts-example-monitor/lts-example-monitor-springboot/pom.xml index 284cb1f..a290550 100644 --- a/lts-example-monitor/lts-example-monitor-springboot/pom.xml +++ b/lts-example-monitor/lts-example-monitor-springboot/pom.xml @@ -5,7 +5,7 @@ lts-example-monitor com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-monitor/pom.xml b/lts-example-monitor/pom.xml index 55645bd..12cb7a3 100644 --- a/lts-example-monitor/pom.xml +++ b/lts-example-monitor/pom.xml @@ -5,7 +5,7 @@ lts-examples com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 pom diff --git a/lts-example-quartz/pom.xml b/lts-example-quartz/pom.xml index d602f96..fda56f8 100644 --- a/lts-example-quartz/pom.xml +++ b/lts-example-quartz/pom.xml @@ -5,7 +5,7 @@ lts-examples com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-quartz/src/main/java/com/github/ltsopensource/example/QuartzTest.java b/lts-example-quartz/src/main/java/com/github/ltsopensource/example/QuartzTest.java index b20933d..9ee3224 100644 --- a/lts-example-quartz/src/main/java/com/github/ltsopensource/example/QuartzTest.java +++ b/lts-example-quartz/src/main/java/com/github/ltsopensource/example/QuartzTest.java @@ -10,7 +10,7 @@ public class QuartzTest { public void autoRun() throws InterruptedException { - System.out.println(DateUtils.formatYMD_HMS(new Date()) + " 我开始执行了..."); + System.out.println(DateUtils.formatYMD_HMS(new Date()) + " 我执行了..."); } } diff --git a/lts-example-quartz/src/main/resources/lts-quartz.xml b/lts-example-quartz/src/main/resources/lts-quartz.xml index 5fab4fa..5afa07a 100644 --- a/lts-example-quartz/src/main/resources/lts-quartz.xml +++ b/lts-example-quartz/src/main/resources/lts-quartz.xml @@ -70,9 +70,7 @@ - - - + \ No newline at end of file diff --git a/lts-example-quartz/src/main/resources/lts.properties b/lts-example-quartz/src/main/resources/lts.properties new file mode 100644 index 0000000..86abf7f --- /dev/null +++ b/lts-example-quartz/src/main/resources/lts.properties @@ -0,0 +1,14 @@ + +lts.jobclient.cluster-name=test_cluster +lts.jobclient.registry-address=zookeeper://127.0.0.1:2181 +lts.jobclient.node-group=test_jobClient +lts.jobclient.use-retry-client=true +lts.jobclient.configs.job.fail.store=mapdb + +lts.tasktracker.cluster-name=test_cluster +lts.tasktracker.registry-address=zookeeper://127.0.0.1:2181 +#lts.tasktracker.work-threads=64 +lts.tasktracker.node-group=test_trade_TaskTracker +#lts.tasktracker.dispatch-runner.enable=true +#lts.tasktracker.dispatch-runner.shard-value=taskId +lts.tasktracker.configs.job.fail.store=mapdb \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktarcker-springboot/pom.xml b/lts-example-tasktracker/lts-example-tasktarcker-springboot/pom.xml index 6e3993a..604e1b7 100644 --- a/lts-example-tasktracker/lts-example-tasktarcker-springboot/pom.xml +++ b/lts-example-tasktracker/lts-example-tasktarcker-springboot/pom.xml @@ -5,7 +5,7 @@ lts-example-tasktracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-tasktracker/lts-example-tasktarcker-springboot/src/main/java/com/github/ltsopensource/example/springboot/Application.java b/lts-example-tasktracker/lts-example-tasktarcker-springboot/src/main/java/com/github/ltsopensource/example/springboot/Application.java index 1dd69de..7720961 100644 --- a/lts-example-tasktracker/lts-example-tasktarcker-springboot/src/main/java/com/github/ltsopensource/example/springboot/Application.java +++ b/lts-example-tasktracker/lts-example-tasktarcker-springboot/src/main/java/com/github/ltsopensource/example/springboot/Application.java @@ -1,6 +1,5 @@ package com.github.ltsopensource.example.springboot; -import com.github.ltsopensource.spring.boot.annotation.EnableJobTracker; import com.github.ltsopensource.spring.boot.annotation.EnableTaskTracker; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; diff --git a/lts-example-tasktracker/lts-example-tasktracker-java/pom.xml b/lts-example-tasktracker/lts-example-tasktracker-java/pom.xml index fcb8a2a..ac6f3f6 100644 --- a/lts-example-tasktracker/lts-example-tasktracker-java/pom.xml +++ b/lts-example-tasktracker/lts-example-tasktracker-java/pom.xml @@ -5,7 +5,7 @@ lts-example-tasktracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation-shard/pom.xml b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation-shard/pom.xml index 9e459b2..31d973e 100644 --- a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation-shard/pom.xml +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation-shard/pom.xml @@ -5,7 +5,7 @@ lts-example-tasktracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/lts-example-tasktracker-spring-annotation.iml b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/lts-example-tasktracker-spring-annotation.iml new file mode 100644 index 0000000..754b2c8 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/lts-example-tasktracker-spring-annotation.iml @@ -0,0 +1,35 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/pom.xml b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/pom.xml new file mode 100644 index 0000000..8e52910 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/pom.xml @@ -0,0 +1,37 @@ + + + + lts-example-tasktracker + com.github.ltsopensource + 1.6.8-SNAPSHOT + + 4.0.0 + + lts-example-tasktracker-spring-annotation + + + + org.springframework + spring-core + ${springframework.version} + + + org.springframework + spring-beans + ${springframework.version} + + + org.springframework + spring-context + ${springframework.version} + + + org.springframework + spring-context-support + ${springframework.version} + + + + \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/Main.java b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/Main.java new file mode 100644 index 0000000..a4a442e --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/Main.java @@ -0,0 +1,15 @@ +package com.github.ltsopensource.example; + +import org.springframework.context.ApplicationContext; +import org.springframework.context.support.ClassPathXmlApplicationContext; + +/** + * @author Robert HG (254963746@qq.com) on 4/22/16. + */ +public class Main { + + public static void main(String[] args) { + ApplicationContext context = new ClassPathXmlApplicationContext("/lts-tasktracker.xml"); + } + +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/SpringAnnotationJobRunner.java b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/SpringAnnotationJobRunner.java new file mode 100644 index 0000000..66cd817 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/SpringAnnotationJobRunner.java @@ -0,0 +1,43 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.core.domain.Action; +import com.github.ltsopensource.core.logger.Logger; +import com.github.ltsopensource.core.logger.LoggerFactory; +import com.github.ltsopensource.tasktracker.Result; +import com.github.ltsopensource.tasktracker.logger.BizLogger; +import com.github.ltsopensource.tasktracker.runner.JobContext; +import com.github.ltsopensource.tasktracker.runner.JobRunner; +import com.github.ltsopensource.tasktracker.runner.LtsLoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + +/** + * @author Robert HG (254963746@qq.com) on 8/19/14. + */ +public class SpringAnnotationJobRunner implements JobRunner { + + private static final Logger LOGGER = LoggerFactory.getLogger(SpringAnnotationJobRunner.class); + + @Autowired + SpringBean springBean; + + @Override + public Result run(JobContext jobContext) throws Throwable { + try { + Thread.sleep(1000L); + + springBean.hello(); + + // TODO 业务逻辑 + LOGGER.info("我要执行:" + jobContext); + BizLogger bizLogger = LtsLoggerFactory.getBizLogger(); + // 会发送到 LTS (JobTracker上) + bizLogger.info("测试,业务日志啊啊啊啊啊"); + + } catch (Exception e) { + LOGGER.info("Run job failed!", e); + return new Result(Action.EXECUTE_LATER, e.getMessage()); + } + return new Result(Action.EXECUTE_SUCCESS, "执行成功了,哈哈"); + } + +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/SpringBean.java b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/SpringBean.java new file mode 100644 index 0000000..29be8e2 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/SpringBean.java @@ -0,0 +1,15 @@ +package com.github.ltsopensource.example; + +import org.springframework.stereotype.Component; + +/** + * 测试bean 注入 + * @author Robert HG (254963746@qq.com) on 8/4/15. + */ +@Component +public class SpringBean { + + public void hello(){ + System.out.println("我是SpringBean,我执行了"); + } +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/TaskTrackerConfig.java b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/TaskTrackerConfig.java new file mode 100644 index 0000000..37cd905 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/java/com/github/ltsopensource/example/TaskTrackerConfig.java @@ -0,0 +1,35 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.spring.TaskTrackerAnnotationFactoryBean; +import com.github.ltsopensource.tasktracker.TaskTracker; +import org.springframework.beans.BeansException; +import org.springframework.context.ApplicationContext; +import org.springframework.context.ApplicationContextAware; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @author Robert HG (254963746@qq.com) on 4/22/16. + */ +@Configuration +public class TaskTrackerConfig implements ApplicationContextAware { + + private ApplicationContext applicationContext; + + @Override + public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { + this.applicationContext = applicationContext; + } + + @Bean(name = "taskTracker") + public TaskTracker getTaskTracker() throws Exception { + TaskTrackerAnnotationFactoryBean factoryBean = new TaskTrackerAnnotationFactoryBean(); + factoryBean.setApplicationContext(applicationContext); + factoryBean.setJobRunnerClass(SpringAnnotationJobRunner.class); + factoryBean.setLocations("lts.properties"); + factoryBean.afterPropertiesSet(); + factoryBean.start(); + return factoryBean.getObject(); + } + +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/log4j.properties b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/log4j.properties new file mode 100644 index 0000000..4e3c103 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/log4j.properties @@ -0,0 +1,7 @@ + +log4j.rootLogger=INFO,stdout + +log4j.appender.stdout.Threshold=INFO +log4j.appender.stdout=org.apache.log4j.ConsoleAppender +log4j.appender.stdout.layout=org.apache.log4j.PatternLayout +log4j.appender.stdout.layout.ConversionPattern=[%-5p] [%d{HH:mm:ss}] %c - %m%n \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/lts-tasktracker.xml b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/lts-tasktracker.xml new file mode 100644 index 0000000..d63657d --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/lts-tasktracker.xml @@ -0,0 +1,15 @@ + + + + + + + + \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/lts.properties b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/lts.properties new file mode 100644 index 0000000..423e3b1 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-annotation/src/main/resources/lts.properties @@ -0,0 +1,7 @@ +lts.tasktracker.cluster-name=test_cluster +lts.tasktracker.registry-address=zookeeper://127.0.0.1:2181 +#lts.tasktracker.work-threads=64 +lts.tasktracker.node-group=test_trade_TaskTracker +#lts.tasktracker.dispatch-runner.enable=true +#lts.tasktracker.dispatch-runner.shard-value=taskId +lts.tasktracker.configs.job.fail.store=mapdb \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-xml-shard/pom.xml b/lts-example-tasktracker/lts-example-tasktracker-spring-xml-shard/pom.xml index 9af79f3..bebc51f 100644 --- a/lts-example-tasktracker/lts-example-tasktracker-spring-xml-shard/pom.xml +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-xml-shard/pom.xml @@ -5,7 +5,7 @@ lts-example-tasktracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 diff --git a/lts-example-tasktracker/lts-example-tasktracker-spring-xml/pom.xml b/lts-example-tasktracker/lts-example-tasktracker-spring-xml/pom.xml index 3caedcc..28f67de 100644 --- a/lts-example-tasktracker/lts-example-tasktracker-spring-xml/pom.xml +++ b/lts-example-tasktracker/lts-example-tasktracker-spring-xml/pom.xml @@ -5,11 +5,11 @@ lts-example-tasktracker com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 - lts-example-tasktracker-spring + lts-example-tasktracker-spring-xml diff --git a/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/pom.xml b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/pom.xml new file mode 100644 index 0000000..6c7df98 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/pom.xml @@ -0,0 +1,25 @@ + + + + lts-example-tasktracker + com.github.ltsopensource + 1.6.8-SNAPSHOT + + 4.0.0 + + lts-example-tasktracker-springboot-shard + + + + org.springframework.boot + spring-boot + + + org.springframework.boot + spring-boot-autoconfigure + + + + \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/Application.java b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/Application.java new file mode 100644 index 0000000..211dd81 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/Application.java @@ -0,0 +1,20 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.spring.boot.annotation.EnableTaskTracker; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.context.annotation.ComponentScan; + +/** + * @author Robert HG (254963746@qq.com) on 4/9/16. + */ +@SpringBootApplication +@EnableTaskTracker +@ComponentScan("com.github.ltsopensource.example") +public class Application { + + public static void main(String[] args) { + SpringApplication.run(Application.class, args); + } + +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/JobScheduler.java b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/JobScheduler.java new file mode 100644 index 0000000..f3d5c59 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/JobScheduler.java @@ -0,0 +1,58 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.core.domain.Action; +import com.github.ltsopensource.core.domain.Job; +import com.github.ltsopensource.core.logger.Logger; +import com.github.ltsopensource.core.logger.LoggerFactory; +import com.github.ltsopensource.spring.tasktracker.JobRunnerItem; +import com.github.ltsopensource.spring.tasktracker.LTS; +import com.github.ltsopensource.tasktracker.Result; +import com.github.ltsopensource.tasktracker.logger.BizLogger; +import com.github.ltsopensource.tasktracker.runner.LtsLoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + +/** + * @author Robert HG (254963746@qq.com) on 10/20/15. + */ +@LTS +public class JobScheduler { + + private static final Logger LOGGER = LoggerFactory.getLogger(JobScheduler.class); + + @Autowired + SpringBean springBean; + + @JobRunnerItem(shardValue = "111") + public Result runJob1(Job job) throws Throwable { + try { + Thread.sleep(1000L); + + springBean.hello(); + + LOGGER.info("runJob1 我要执行:" + job); + BizLogger bizLogger = LtsLoggerFactory.getBizLogger(); + // 会发送到 LTS (JobTracker上) + bizLogger.info("测试,业务日志啊啊啊啊啊"); + + } catch (Exception e) { + LOGGER.info("Run job failed!", e); + return new Result(Action.EXECUTE_LATER, e.getMessage()); + } + return new Result(Action.EXECUTE_SUCCESS, "执行成功了,哈哈"); + } + + @JobRunnerItem(shardValue = "222") + public void runJob2() throws Throwable { + try { + springBean.hello(); + + LOGGER.info("runJob2 我要执行"); + BizLogger bizLogger = LtsLoggerFactory.getBizLogger(); + // 会发送到 LTS (JobTracker上) + bizLogger.info("测试,业务日志啊啊啊啊啊"); + } catch (Exception e) { + LOGGER.info("Run job failed!", e); + } + } + +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/JobScheduler2.java b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/JobScheduler2.java new file mode 100644 index 0000000..3424803 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/JobScheduler2.java @@ -0,0 +1,58 @@ +package com.github.ltsopensource.example; + +import com.github.ltsopensource.core.domain.Action; +import com.github.ltsopensource.core.domain.Job; +import com.github.ltsopensource.core.logger.Logger; +import com.github.ltsopensource.core.logger.LoggerFactory; +import com.github.ltsopensource.spring.tasktracker.JobRunnerItem; +import com.github.ltsopensource.spring.tasktracker.LTS; +import com.github.ltsopensource.tasktracker.Result; +import com.github.ltsopensource.tasktracker.logger.BizLogger; +import com.github.ltsopensource.tasktracker.runner.LtsLoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + +/** + * @author Robert HG (254963746@qq.com) on 10/20/15. + */ +@LTS +public class JobScheduler2 { + + private static final Logger LOGGER = LoggerFactory.getLogger(JobScheduler.class); + + @Autowired + SpringBean springBean; + + @JobRunnerItem(shardValue = "333") + public Result runJob1(Job job) throws Throwable { + try { + Thread.sleep(1000L); + + springBean.hello(); + + LOGGER.info("runJob3 我要执行:" + job); + BizLogger bizLogger = LtsLoggerFactory.getBizLogger(); + // 会发送到 LTS (JobTracker上) + bizLogger.info("测试,业务日志啊啊啊啊啊"); + + } catch (Exception e) { + LOGGER.info("Run job failed!", e); + return new Result(Action.EXECUTE_LATER, e.getMessage()); + } + return new Result(Action.EXECUTE_SUCCESS, "执行成功了,哈哈"); + } + + @JobRunnerItem(shardValue = "444") + public void runJob2() throws Throwable { + try { + springBean.hello(); + + LOGGER.info("runJob4 我要执行"); + BizLogger bizLogger = LtsLoggerFactory.getBizLogger(); + // 会发送到 LTS (JobTracker上) + bizLogger.info("测试,业务日志啊啊啊啊啊"); + } catch (Exception e) { + LOGGER.info("Run job failed!", e); + } + } + +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/SpringBean.java b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/SpringBean.java new file mode 100644 index 0000000..29be8e2 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/java/com/github/ltsopensource/example/SpringBean.java @@ -0,0 +1,15 @@ +package com.github.ltsopensource.example; + +import org.springframework.stereotype.Component; + +/** + * 测试bean 注入 + * @author Robert HG (254963746@qq.com) on 8/4/15. + */ +@Component +public class SpringBean { + + public void hello(){ + System.out.println("我是SpringBean,我执行了"); + } +} diff --git a/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/resources/application.properties b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/resources/application.properties new file mode 100644 index 0000000..423e3b1 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/resources/application.properties @@ -0,0 +1,7 @@ +lts.tasktracker.cluster-name=test_cluster +lts.tasktracker.registry-address=zookeeper://127.0.0.1:2181 +#lts.tasktracker.work-threads=64 +lts.tasktracker.node-group=test_trade_TaskTracker +#lts.tasktracker.dispatch-runner.enable=true +#lts.tasktracker.dispatch-runner.shard-value=taskId +lts.tasktracker.configs.job.fail.store=mapdb \ No newline at end of file diff --git a/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/resources/log4j.properties b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/resources/log4j.properties new file mode 100644 index 0000000..4e3c103 --- /dev/null +++ b/lts-example-tasktracker/lts-example-tasktracker-springboot-shard/src/main/resources/log4j.properties @@ -0,0 +1,7 @@ + +log4j.rootLogger=INFO,stdout + +log4j.appender.stdout.Threshold=INFO +log4j.appender.stdout=org.apache.log4j.ConsoleAppender +log4j.appender.stdout.layout=org.apache.log4j.PatternLayout +log4j.appender.stdout.layout.ConversionPattern=[%-5p] [%d{HH:mm:ss}] %c - %m%n \ No newline at end of file diff --git a/lts-example-tasktracker/pom.xml b/lts-example-tasktracker/pom.xml index 382e774..b5d64e1 100644 --- a/lts-example-tasktracker/pom.xml +++ b/lts-example-tasktracker/pom.xml @@ -5,16 +5,18 @@ lts-examples com.github.ltsopensource - 1.6.7.1 + 1.6.8-SNAPSHOT 4.0.0 pom lts-example-tasktarcker-springboot lts-example-tasktracker-java - lts-example-tasktracker-spring + lts-example-tasktracker-spring-xml lts-example-tasktracker-spring-annotation-shard lts-example-tasktracker-spring-xml-shard + lts-example-tasktracker-spring-annotation + lts-example-tasktracker-springboot-shard lts-example-tasktracker diff --git a/pom.xml b/pom.xml index a071f3a..03204ac 100644 --- a/pom.xml +++ b/pom.xml @@ -5,7 +5,7 @@ 4.0.0 com.github.ltsopensource lts-examples - 1.6.7.1 + 1.6.8-SNAPSHOT lts-example-jobtracker lts-example-tasktracker @@ -42,7 +42,7 @@ 1.7.2 1.5.4 1.3.3.RELEASE - 1.6.7.1 + 1.6.8-SNAPSHOT 2.2.2