测试定时任务

data-show/show-auto-turnover/src/main/java/com/bailuntec/Application.java

@@ -26,8 +26,26 @@ public class Application {
     private static final String EVENT_RDB_STORAGE_PASSWORD = propertiesUtil.getPropertyAsString("EVENT_RDB_STORAGE_PASSWORD");
 
     public static void main(String[] args) {
-        new JobScheduler(createRegistryCenter(), createJobConfigurationNormal(), createJobEventConfiguration(), new AutoTurnoverJobListener()).init();
-        new JobScheduler(createRegistryCenter(), createJobConfigurationIncrement(), createJobEventConfiguration(), new AutoTurnoverJobListener()).init();
+
+        log.info("starting app...");
+
+        new JobScheduler(createRegistryCenter(),
+                createJobConfigurationNormal(),
+                createJobEventConfiguration(),
+                new AutoTurnoverJobListener()).init();
+
+        new JobScheduler(createRegistryCenter(),
+                createJobConfigurationIncrement(),
+                createJobEventConfiguration(),
+                new AutoTurnoverJobListener()).init();
+
+
+        new JobScheduler(createRegistryCenter(),
+                createJobConfigurationTest(),
+                createJobEventConfiguration(),
+                new AutoTurnoverJobListener()).init();
+
+        log.info("start success");
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
@@ -36,6 +54,7 @@ public class Application {
         return regCenter;
     }
 
+
     private static LiteJobConfiguration createJobConfigurationNormal() {
         JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
                 propertiesUtil.getPropertyAsString("JOB_NAME"),
@@ -58,6 +77,18 @@ public class Application {
         return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
     }
 
+    private static LiteJobConfiguration createJobConfigurationTest() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
+                propertiesUtil.getPropertyAsString("JOB_NAME_INCREMENT"),
+                propertiesUtil.getPropertyAsString("0 0 14 * * ?"),
+                propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT_INCREMENT"))
+                .jobParameter("INCREMENT")
+                .build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, AutoTurnoverJob.class.getCanonicalName());
+        return LiteJobConfiguration.newBuilder(simpleJobConfig).build();
+    }
+
+
     private static JobEventConfiguration createJobEventConfiguration() {
         return new JobEventRdbConfiguration(setUpEventTraceDataSource());
     }

data-show/show-auto-turnover/src/main/resources/log4j.properties

-#log4j.rootLogger=DEBUG,console,dailyFile,im
-#log4j.additivity.org.apache=true
-## 控制台(console)
-#log4j.appender.console=org.apache.log4j.ConsoleAppender
-#log4j.appender.console.Threshold=DEBUG
-#log4j.appender.console.ImmediateFlush=true
-#log4j.appender.console.Target=System.err
-#log4j.appender.console.layout=org.apache.log4j.PatternLayout
-#log4j.appender.console.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
-## 日志文件(logFile)
-#log4j.appender.logFile=org.apache.log4j.FileAppender
-#log4j.appender.logFile.Threshold=DEBUG
-#log4j.appender.logFile.ImmediateFlush=true
-#log4j.appender.logFile.Append=true
-#log4j.appender.logFile.File=/logs/log.log4j
-#log4j.appender.logFile.layout=org.apache.log4j.PatternLayout
-#log4j.appender.logFile.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
-## 回滚文件(rollingFile)
-#log4j.appender.rollingFile=org.apache.log4j.RollingFileAppender
-#log4j.appender.rollingFile.Threshold=DEBUG
-#log4j.appender.rollingFile.ImmediateFlush=true
-#log4j.appender.rollingFile.Append=true
-#log4j.appender.rollingFile.File=/logs/log.log4j
-#log4j.appender.rollingFile.MaxFileSize=200KB
-#log4j.appender.rollingFile.MaxBackupIndex=50
-#log4j.appender.rollingFile.layout=org.apache.log4j.PatternLayout
-#log4j.appender.rollingFile.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
-## 定期回滚日志文件(dailyFile)
-#log4j.appender.dailyFile=org.apache.log4j.DailyRollingFileAppender
-#log4j.appender.dailyFile.Threshold=DEBUG
-#log4j.appender.dailyFile.ImmediateFlush=true
-#log4j.appender.dailyFile.Append=true
-#log4j.appender.dailyFile.File=/logs/log.log4j
-#log4j.appender.dailyFile.DatePattern='.'yyyy-MM-dd
-#log4j.appender.dailyFile.layout=org.apache.log4j.PatternLayout
-#log4j.appender.dailyFile.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
-## 应用于socket
-#log4j.appender.socket=org.apache.log4j.RollingFileAppender
-#log4j.appender.socket.RemoteHost=localhost
-#log4j.appender.socket.Port=5001
-#log4j.appender.socket.LocationInfo=true
-## Set up for Log Factor 5
-#log4j.appender.socket.layout=org.apache.log4j.PatternLayout
-#log4j.appender.socket.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
-## Log Factor 5 Appender
-#log4j.appender.LF5_APPENDER=org.apache.log4j.lf5.LF5Appender
-#log4j.appender.LF5_APPENDER.MaxNumberOfRecords=2000
-## 发送日志到指定邮件
-#log4j.appender.mail=org.apache.log4j.net.SMTPAppender
-#log4j.appender.mail.Threshold=FATAL
-#log4j.appender.mail.BufferSize=10
-#log4j.appender.mail.From = xxx@mail.com
-#log4j.appender.mail.SMTPHost=mail.com
-#log4j.appender.mail.Subject=Log4J Message
-#log4j.appender.mail.To= xxx@mail.com
-#log4j.appender.mail.layout=org.apache.log4j.PatternLayout
-#log4j.appender.mail.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
-## 应用于数据库
-#log4j.appender.database=org.apache.log4j.jdbc.JDBCAppender
-#log4j.appender.database.URL=jdbc:mysql://localhost:3306/test
-#log4j.appender.database.driver=com.mysql.jdbc.Driver
-#log4j.appender.database.user=root
-#log4j.appender.database.password=
-#log4j.appender.database.sql=INSERT INTO LOG4J (Message) VALUES('=[%-5p] %d(%r) --> [%t] %l: %m %x %n')
-#log4j.appender.database.layout=org.apache.log4j.PatternLayout
-#log4j.appender.database.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
-#
-## 自定义Appender
-#log4j.appender.im = net.cybercorlin.util.logger.appender.IMAppender
-#log4j.appender.im.host = mail.cybercorlin.net
-#log4j.appender.im.username = username
-#log4j.appender.im.password = password
-#log4j.appender.im.recipient = corlin@cybercorlin.net
-#log4j.appender.im.layout=org.apache.log4j.PatternLayout
-#log4j.appender.im.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n