提交 20a1e1ee authored 作者: xueli.xue's avatar xueli.xue

upgrade

上级 4a8e0f10
...@@ -2086,7 +2086,7 @@ data: post-data ...@@ -2086,7 +2086,7 @@ data: post-data
- 20、执行器注册组件优化:注册逻辑调整为异步方式,提高注册性能; - 20、执行器注册组件优化:注册逻辑调整为异步方式,提高注册性能;
- 21、调度过期策略:调度中心错误调度时间的补偿处理策略,包括:忽略、立即补偿触发一次等; - 21、调度过期策略:调度中心错误调度时间的补偿处理策略,包括:忽略、立即补偿触发一次等;
- 22、触发策略强化:除了常规Cron、API、父子任务触发方式外,新增提供 "固定间隔触发、固定延时触发" 两种新触发方式; - 22、触发策略强化:除了常规Cron、API、父子任务触发方式外,新增提供 "固定间隔触发、固定延时触发" 两种新触发方式;
- 23、任务调度生命周期重构:调度(schedule)、触发(trigger)、执行(handle)、回调(callback)、后处理(posthandle); - 23、任务调度生命周期重构:调度(schedule)、触发(trigger)、执行(handle)、回调(callback)、结束(complete);
- 24、执行器鉴权校验:执行器启动时主动校验accessToken,为空则主动Warn告警;(已规划安全强化:AccessToken动态生成、动态启停等) - 24、执行器鉴权校验:执行器启动时主动校验accessToken,为空则主动Warn告警;(已规划安全强化:AccessToken动态生成、动态启停等)
### 7.32 版本 v2.3.0 Release Notes[规划中] ### 7.32 版本 v2.3.0 Release Notes[规划中]
......
package com.xxl.job.admin.controller; package com.xxl.job.admin.controller;
import com.xxl.job.admin.core.exception.XxlJobException; import com.xxl.job.admin.core.exception.XxlJobException;
import com.xxl.job.admin.core.handle.XxlJobPostHandleHelper; import com.xxl.job.admin.core.complete.XxlJobCompleter;
import com.xxl.job.admin.core.model.XxlJobGroup; import com.xxl.job.admin.core.model.XxlJobGroup;
import com.xxl.job.admin.core.model.XxlJobInfo; import com.xxl.job.admin.core.model.XxlJobInfo;
import com.xxl.job.admin.core.model.XxlJobLog; import com.xxl.job.admin.core.model.XxlJobLog;
...@@ -184,7 +184,7 @@ public class JobLogController { ...@@ -184,7 +184,7 @@ public class JobLogController {
log.setHandleCode(ReturnT.FAIL_CODE); log.setHandleCode(ReturnT.FAIL_CODE);
log.setHandleMsg( I18nUtil.getString("joblog_kill_log_byman")+":" + (runResult.getMsg()!=null?runResult.getMsg():"")); log.setHandleMsg( I18nUtil.getString("joblog_kill_log_byman")+":" + (runResult.getMsg()!=null?runResult.getMsg():""));
log.setHandleTime(new Date()); log.setHandleTime(new Date());
XxlJobPostHandleHelper.updateHandleInfoAndFinish(log); XxlJobCompleter.updateHandleInfoAndFinish(log);
return new ReturnT<String>(runResult.getMsg()); return new ReturnT<String>(runResult.getMsg());
} else { } else {
return new ReturnT<String>(500, runResult.getMsg()); return new ReturnT<String>(500, runResult.getMsg());
......
package com.xxl.job.admin.core.handle; package com.xxl.job.admin.core.complete;
import com.xxl.job.admin.core.conf.XxlJobAdminConfig; import com.xxl.job.admin.core.conf.XxlJobAdminConfig;
import com.xxl.job.admin.core.model.XxlJobInfo; import com.xxl.job.admin.core.model.XxlJobInfo;
...@@ -16,8 +16,8 @@ import java.text.MessageFormat; ...@@ -16,8 +16,8 @@ import java.text.MessageFormat;
/** /**
* @author xuxueli 2020-10-30 20:43:10 * @author xuxueli 2020-10-30 20:43:10
*/ */
public class XxlJobPostHandleHelper { public class XxlJobCompleter {
private static Logger logger = LoggerFactory.getLogger(XxlJobPostHandleHelper.class); private static Logger logger = LoggerFactory.getLogger(XxlJobCompleter.class);
/** /**
* common fresh handle entrance (limit only once) * common fresh handle entrance (limit only once)
......
...@@ -34,7 +34,7 @@ public class XxlJobScheduler { ...@@ -34,7 +34,7 @@ public class XxlJobScheduler {
JobFailMonitorHelper.getInstance().start(); JobFailMonitorHelper.getInstance().start();
// admin lose-monitor run ( depend on JobTriggerPoolHelper ) // admin lose-monitor run ( depend on JobTriggerPoolHelper )
JobLogHelper.getInstance().start(); JobCompleteHelper.getInstance().start();
// admin log report start // admin log report start
JobLogReportHelper.getInstance().start(); JobLogReportHelper.getInstance().start();
...@@ -55,7 +55,7 @@ public class XxlJobScheduler { ...@@ -55,7 +55,7 @@ public class XxlJobScheduler {
JobLogReportHelper.getInstance().toStop(); JobLogReportHelper.getInstance().toStop();
// admin lose-monitor stop // admin lose-monitor stop
JobLogHelper.getInstance().toStop(); JobCompleteHelper.getInstance().toStop();
// admin fail-monitor stop // admin fail-monitor stop
JobFailMonitorHelper.getInstance().toStop(); JobFailMonitorHelper.getInstance().toStop();
......
package com.xxl.job.admin.core.thread; package com.xxl.job.admin.core.thread;
import com.xxl.job.admin.core.conf.XxlJobAdminConfig; import com.xxl.job.admin.core.conf.XxlJobAdminConfig;
import com.xxl.job.admin.core.handle.XxlJobPostHandleHelper; import com.xxl.job.admin.core.complete.XxlJobCompleter;
import com.xxl.job.admin.core.model.XxlJobLog; import com.xxl.job.admin.core.model.XxlJobLog;
import com.xxl.job.admin.core.util.I18nUtil; import com.xxl.job.admin.core.util.I18nUtil;
import com.xxl.job.core.biz.model.HandleCallbackParam; import com.xxl.job.core.biz.model.HandleCallbackParam;
...@@ -20,11 +20,11 @@ import java.util.concurrent.*; ...@@ -20,11 +20,11 @@ import java.util.concurrent.*;
* *
* @author xuxueli 2015-9-1 18:05:56 * @author xuxueli 2015-9-1 18:05:56
*/ */
public class JobLogHelper { public class JobCompleteHelper {
private static Logger logger = LoggerFactory.getLogger(JobLogHelper.class); private static Logger logger = LoggerFactory.getLogger(JobCompleteHelper.class);
private static JobLogHelper instance = new JobLogHelper(); private static JobCompleteHelper instance = new JobCompleteHelper();
public static JobLogHelper getInstance(){ public static JobCompleteHelper getInstance(){
return instance; return instance;
} }
...@@ -89,7 +89,7 @@ public class JobLogHelper { ...@@ -89,7 +89,7 @@ public class JobLogHelper {
jobLog.setHandleCode(ReturnT.FAIL_CODE); jobLog.setHandleCode(ReturnT.FAIL_CODE);
jobLog.setHandleMsg( I18nUtil.getString("joblog_lost_fail") ); jobLog.setHandleMsg( I18nUtil.getString("joblog_lost_fail") );
XxlJobPostHandleHelper.updateHandleInfoAndFinish(jobLog); XxlJobCompleter.updateHandleInfoAndFinish(jobLog);
} }
} }
...@@ -175,7 +175,7 @@ public class JobLogHelper { ...@@ -175,7 +175,7 @@ public class JobLogHelper {
log.setHandleTime(new Date()); log.setHandleTime(new Date());
log.setHandleCode(handleCallbackParam.getExecuteResult().getCode()); log.setHandleCode(handleCallbackParam.getExecuteResult().getCode());
log.setHandleMsg(handleMsg.toString()); log.setHandleMsg(handleMsg.toString());
XxlJobPostHandleHelper.updateHandleInfoAndFinish(log); XxlJobCompleter.updateHandleInfoAndFinish(log);
return ReturnT.SUCCESS; return ReturnT.SUCCESS;
} }
......
package com.xxl.job.admin.service.impl; package com.xxl.job.admin.service.impl;
import com.xxl.job.admin.core.thread.JobLogHelper; import com.xxl.job.admin.core.thread.JobCompleteHelper;
import com.xxl.job.admin.core.thread.JobRegistryHelper; import com.xxl.job.admin.core.thread.JobRegistryHelper;
import com.xxl.job.core.biz.AdminBiz; import com.xxl.job.core.biz.AdminBiz;
import com.xxl.job.core.biz.model.HandleCallbackParam; import com.xxl.job.core.biz.model.HandleCallbackParam;
...@@ -19,7 +19,7 @@ public class AdminBizImpl implements AdminBiz { ...@@ -19,7 +19,7 @@ public class AdminBizImpl implements AdminBiz {
@Override @Override
public ReturnT<String> callback(List<HandleCallbackParam> callbackParamList) { public ReturnT<String> callback(List<HandleCallbackParam> callbackParamList) {
return JobLogHelper.getInstance().callback(callbackParamList); return JobCompleteHelper.getInstance().callback(callbackParamList);
} }
@Override @Override
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论