xueli.xue пре 9 година
родитељ
комит
a368c707d3

+ 16 - 1
xxl-job-admin/src/main/webapp/WEB-INF/template/jobcode/index.ftl Прегледај датотеку

94
 <textarea id="demoCode" style="display:none;" >
94
 <textarea id="demoCode" style="display:none;" >
95
 package com.xxl.job.service.handler;
95
 package com.xxl.job.service.handler;
96
 
96
 
97
+import java.util.concurrent.TimeUnit;
98
+
97
 import org.slf4j.Logger;
99
 import org.slf4j.Logger;
98
 import org.slf4j.LoggerFactory;
100
 import org.slf4j.LoggerFactory;
101
+import org.springframework.stereotype.Service;
99
 
102
 
100
 import com.xxl.job.client.handler.IJobHandler;
103
 import com.xxl.job.client.handler.IJobHandler;
104
+import com.xxl.job.client.handler.IJobHandler.JobHandleStatus;
105
+import com.xxl.job.client.handler.annotation.JobHander;
101
 
106
 
102
 public class DemoJobHandler extends IJobHandler {
107
 public class DemoJobHandler extends IJobHandler {
103
 	private static transient Logger logger = LoggerFactory.getLogger(DemoJobHandler.class);
108
 	private static transient Logger logger = LoggerFactory.getLogger(DemoJobHandler.class);
104
 	
109
 	
105
 	@Override
110
 	@Override
106
 	public JobHandleStatus handle(String... params) throws Exception {
111
 	public JobHandleStatus handle(String... params) throws Exception {
107
-		logger.info("demo run success...");
112
+		for (int i = 0; i < 5; i++) {
113
+			TimeUnit.SECONDS.sleep(1);
114
+			logger.info("handler run:{}", i);
115
+		}
108
 		return JobHandleStatus.SUCCESS;
116
 		return JobHandleStatus.SUCCESS;
109
 	}
117
 	}
118
+	
119
+	public static void main(String[] args) {
120
+		System.out.println(DemoJobHandler.class.getName());
121
+		System.out.println(DemoJobHandler.class);
122
+	}
123
+	
110
 }
124
 }
125
+
111
 </textarea>
126
 </textarea>
112
 	
127
 	
113
 <@netCommon.comAlert />
128
 <@netCommon.comAlert />

+ 2 - 2
xxl-job-client/src/main/java/com/xxl/job/client/handler/HandlerRepository.java Прегледај датотеку

46
 	
46
 	
47
 	// handler push to queue
47
 	// handler push to queue
48
 	public static String service(Map<String, String> _param) {
48
 	public static String service(Map<String, String> _param) {
49
-		logger.info(">>>>>>>>>>> xxl-job service start, _param:{}", new Object[]{_param});
49
+		logger.debug(">>>>>>>>>>> xxl-job service start, _param:{}", new Object[]{_param});
50
 		
50
 		
51
 		// callback
51
 		// callback
52
 		RemoteCallBack callback = new RemoteCallBack();
52
 		RemoteCallBack callback = new RemoteCallBack();
152
 			return JacksonUtil.writeValueAsString(callback);
152
 			return JacksonUtil.writeValueAsString(callback);
153
 		}
153
 		}
154
 		
154
 		
155
-		logger.info(">>>>>>>>>>> xxl-job service end, triggerData:{}");
155
+		logger.debug(">>>>>>>>>>> xxl-job service end, triggerData:{}");
156
 		return JacksonUtil.writeValueAsString(callback); 
156
 		return JacksonUtil.writeValueAsString(callback); 
157
 	}
157
 	}
158
 	
158