liuchang/biz_service_ebtp_extend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

定时任务本地测试日志输出

Browse Source
This commit is contained in:
dxc
2021-09-17 15:21:03 +08:00
parent 62c3b62c29
commit d74b1aa932
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/com/chinaunicom/mall/ebtp/extend/executor/jobhandler/SampleXxlJob.java
View File

@ -5,6 +5,7 @@ import com.xxl.job.core.context.XxlJobContext;
import com.xxl.job.core.handler.IJobHandler; import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger; import com.xxl.job.core.log.XxlJobLogger;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -28,10 +29,9 @@ import java.util.concurrent.TimeUnit;
* *
* @author xuxueli 2019-12-11 21:52:51 * @author xuxueli 2019-12-11 21:52:51
*/ */
@Slf4j
@Component @Component
public class SampleXxlJob { public class SampleXxlJob {
private static Logger logger = LoggerFactory.getLogger(SampleXxlJob.class);
/** /**
* 1、简单任务示例（Bean模式） * 1、简单任务示例（Bean模式）
@ -39,7 +39,7 @@ public class SampleXxlJob {
@XxlJob("extendJobHandler") @XxlJob("extendJobHandler")
public ReturnT<String> extendJobHandler(String param) throws Exception { public ReturnT<String> extendJobHandler(String param) throws Exception {
XxlJobLogger.log("XXL-JOB, Hello World."); XxlJobLogger.log("XXL-JOB, Hello World.");
logger.info("XXL-JOB, Hello World."); log.info("本地日志输出 XXL-JOB, Hello World.");
for (int i = 0; i < 5; i++) { for (int i = 0; i < 5; i++) {
XxlJobLogger.log("beat at:" + i); XxlJobLogger.log("beat at:" + i);
TimeUnit.SECONDS.sleep(2); TimeUnit.SECONDS.sleep(2);