diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java index fb6a9c7..5e785d5 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java @@ -42,7 +42,7 @@ jobLog.setJobGroup(jobInfo.getJobGroup()); jobLog.setJobName(jobInfo.getJobName()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); - logger.info(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); // admin address List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); @@ -89,7 +89,7 @@ // monitor triger JobMonitorHelper.monitor(jobLog.getId()); - logger.info(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); } diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java index fb6a9c7..5e785d5 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java @@ -42,7 +42,7 @@ jobLog.setJobGroup(jobInfo.getJobGroup()); jobLog.setJobName(jobInfo.getJobName()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); - logger.info(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); // admin address List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); @@ -89,7 +89,7 @@ // monitor triger JobMonitorHelper.monitor(jobLog.getId()); - logger.info(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java index fe5726d..9d52ab4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java @@ -35,7 +35,7 @@ public void run() { while (true) { try { - logger.info(">>>>>>>>>>> job monitor beat ... "); + logger.debug(">>>>>>>>>>> job monitor beat ... "); Integer jobLogId = JobMonitorHelper.helper.queue.take(); if (jobLogId != null && jobLogId > 0) { logger.info(">>>>>>>>>>> job monitor heat success, JobLogId:{}", jobLogId); diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java index fb6a9c7..5e785d5 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java @@ -42,7 +42,7 @@ jobLog.setJobGroup(jobInfo.getJobGroup()); jobLog.setJobName(jobInfo.getJobName()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); - logger.info(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); // admin address List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); @@ -89,7 +89,7 @@ // monitor triger JobMonitorHelper.monitor(jobLog.getId()); - logger.info(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java index fe5726d..9d52ab4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java @@ -35,7 +35,7 @@ public void run() { while (true) { try { - logger.info(">>>>>>>>>>> job monitor beat ... "); + logger.debug(">>>>>>>>>>> job monitor beat ... "); Integer jobLogId = JobMonitorHelper.helper.queue.take(); if (jobLogId != null && jobLogId > 0) { logger.info(">>>>>>>>>>> job monitor heat success, JobLogId:{}", jobLogId); diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java index 55a9e9b..6d44db5 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java @@ -21,7 +21,7 @@ String insertSql = "INSERT INTO XXL_JOB_QRTZ_TRIGGER_REGISTRY( `registry_group` , `registry_key` , `registry_value`, `update_time`) VALUES(? , ? , ?, NOW())"; int ret = DBUtil.update(dataSource, updateSql, new Object[]{registGroup, registryKey, registryValue}); if (ret<1) { - ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); + //ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); } return ret; } diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java index fb6a9c7..5e785d5 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java @@ -42,7 +42,7 @@ jobLog.setJobGroup(jobInfo.getJobGroup()); jobLog.setJobName(jobInfo.getJobName()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); - logger.info(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); // admin address List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); @@ -89,7 +89,7 @@ // monitor triger JobMonitorHelper.monitor(jobLog.getId()); - logger.info(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java index fe5726d..9d52ab4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java @@ -35,7 +35,7 @@ public void run() { while (true) { try { - logger.info(">>>>>>>>>>> job monitor beat ... "); + logger.debug(">>>>>>>>>>> job monitor beat ... "); Integer jobLogId = JobMonitorHelper.helper.queue.take(); if (jobLogId != null && jobLogId > 0) { logger.info(">>>>>>>>>>> job monitor heat success, JobLogId:{}", jobLogId); diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java index 55a9e9b..6d44db5 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java @@ -21,7 +21,7 @@ String insertSql = "INSERT INTO XXL_JOB_QRTZ_TRIGGER_REGISTRY( `registry_group` , `registry_key` , `registry_value`, `update_time`) VALUES(? , ? , ?, NOW())"; int ret = DBUtil.update(dataSource, updateSql, new Object[]{registGroup, registryKey, registryValue}); if (ret<1) { - ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); + //ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); } return ret; } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java index 431c790..419854c 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java @@ -40,7 +40,7 @@ public void pushTriggerQueue(RequestModel requestModel) { if (triggerLogIdSet.contains(requestModel.getLogId())) { - logger.info("repeate trigger job, logId:{}", requestModel.getLogId()); + logger.debug("repeate trigger job, logId:{}", requestModel.getLogId()); return; } @@ -58,8 +58,6 @@ this.stopReason = stopReason; } - - int i = 1; @Override public void run() { @@ -83,16 +81,16 @@ String logFileName = XxlJobFileAppender.makeLogFileName(new Date(triggerDate.getLogDateTim()), triggerDate.getLogId()); XxlJobFileAppender.contextHolder.set(logFileName); - logger.info("----------- xxl-job job handle start -----------"); + logger.info("----------- xxl-job job execute start -----------"); handler.execute(handlerParams); } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("JobThread Exception:", e); _status = ResponseModel.FAIL; StringWriter out = new StringWriter(); e.printStackTrace(new PrintWriter(out)); _msg = out.toString(); } - logger.info("----------- xxl-job job handle end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", + logger.info("----------- xxl-job job execute end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", new Object[]{handlerParams, _status, _msg}); // callback handler info @@ -109,7 +107,7 @@ } } } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("----------- xxl-job JobThread Exception:", e); } } @@ -124,6 +122,6 @@ } } - logger.info(">>>>>>>>>>>> xxl-job handlerThrad stoped, hashCode:{}", Thread.currentThread()); + logger.info(">>>>>>>>>>>> xxl-job JobThread stoped, hashCode:{}", Thread.currentThread()); } } diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java index fb6a9c7..5e785d5 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java @@ -42,7 +42,7 @@ jobLog.setJobGroup(jobInfo.getJobGroup()); jobLog.setJobName(jobInfo.getJobName()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); - logger.info(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); // admin address List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); @@ -89,7 +89,7 @@ // monitor triger JobMonitorHelper.monitor(jobLog.getId()); - logger.info(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java index fe5726d..9d52ab4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java @@ -35,7 +35,7 @@ public void run() { while (true) { try { - logger.info(">>>>>>>>>>> job monitor beat ... "); + logger.debug(">>>>>>>>>>> job monitor beat ... "); Integer jobLogId = JobMonitorHelper.helper.queue.take(); if (jobLogId != null && jobLogId > 0) { logger.info(">>>>>>>>>>> job monitor heat success, JobLogId:{}", jobLogId); diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java index 55a9e9b..6d44db5 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java @@ -21,7 +21,7 @@ String insertSql = "INSERT INTO XXL_JOB_QRTZ_TRIGGER_REGISTRY( `registry_group` , `registry_key` , `registry_value`, `update_time`) VALUES(? , ? , ?, NOW())"; int ret = DBUtil.update(dataSource, updateSql, new Object[]{registGroup, registryKey, registryValue}); if (ret<1) { - ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); + //ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); } return ret; } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java index 431c790..419854c 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java @@ -40,7 +40,7 @@ public void pushTriggerQueue(RequestModel requestModel) { if (triggerLogIdSet.contains(requestModel.getLogId())) { - logger.info("repeate trigger job, logId:{}", requestModel.getLogId()); + logger.debug("repeate trigger job, logId:{}", requestModel.getLogId()); return; } @@ -58,8 +58,6 @@ this.stopReason = stopReason; } - - int i = 1; @Override public void run() { @@ -83,16 +81,16 @@ String logFileName = XxlJobFileAppender.makeLogFileName(new Date(triggerDate.getLogDateTim()), triggerDate.getLogId()); XxlJobFileAppender.contextHolder.set(logFileName); - logger.info("----------- xxl-job job handle start -----------"); + logger.info("----------- xxl-job job execute start -----------"); handler.execute(handlerParams); } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("JobThread Exception:", e); _status = ResponseModel.FAIL; StringWriter out = new StringWriter(); e.printStackTrace(new PrintWriter(out)); _msg = out.toString(); } - logger.info("----------- xxl-job job handle end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", + logger.info("----------- xxl-job job execute end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", new Object[]{handlerParams, _status, _msg}); // callback handler info @@ -109,7 +107,7 @@ } } } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("----------- xxl-job JobThread Exception:", e); } } @@ -124,6 +122,6 @@ } } - logger.info(">>>>>>>>>>>> xxl-job handlerThrad stoped, hashCode:{}", Thread.currentThread()); + logger.info(">>>>>>>>>>>> xxl-job JobThread stoped, hashCode:{}", Thread.currentThread()); } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java index 2e37e37..1bf5396 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java @@ -31,7 +31,7 @@ break; } } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error(">>>>>>>>>>> xxl-job TriggerCallbackThread Exception:", e); } } } diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java index fb6a9c7..5e785d5 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java @@ -42,7 +42,7 @@ jobLog.setJobGroup(jobInfo.getJobGroup()); jobLog.setJobName(jobInfo.getJobName()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); - logger.info(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); // admin address List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); @@ -89,7 +89,7 @@ // monitor triger JobMonitorHelper.monitor(jobLog.getId()); - logger.info(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java index fe5726d..9d52ab4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java @@ -35,7 +35,7 @@ public void run() { while (true) { try { - logger.info(">>>>>>>>>>> job monitor beat ... "); + logger.debug(">>>>>>>>>>> job monitor beat ... "); Integer jobLogId = JobMonitorHelper.helper.queue.take(); if (jobLogId != null && jobLogId > 0) { logger.info(">>>>>>>>>>> job monitor heat success, JobLogId:{}", jobLogId); diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java index 55a9e9b..6d44db5 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java @@ -21,7 +21,7 @@ String insertSql = "INSERT INTO XXL_JOB_QRTZ_TRIGGER_REGISTRY( `registry_group` , `registry_key` , `registry_value`, `update_time`) VALUES(? , ? , ?, NOW())"; int ret = DBUtil.update(dataSource, updateSql, new Object[]{registGroup, registryKey, registryValue}); if (ret<1) { - ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); + //ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); } return ret; } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java index 431c790..419854c 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java @@ -40,7 +40,7 @@ public void pushTriggerQueue(RequestModel requestModel) { if (triggerLogIdSet.contains(requestModel.getLogId())) { - logger.info("repeate trigger job, logId:{}", requestModel.getLogId()); + logger.debug("repeate trigger job, logId:{}", requestModel.getLogId()); return; } @@ -58,8 +58,6 @@ this.stopReason = stopReason; } - - int i = 1; @Override public void run() { @@ -83,16 +81,16 @@ String logFileName = XxlJobFileAppender.makeLogFileName(new Date(triggerDate.getLogDateTim()), triggerDate.getLogId()); XxlJobFileAppender.contextHolder.set(logFileName); - logger.info("----------- xxl-job job handle start -----------"); + logger.info("----------- xxl-job job execute start -----------"); handler.execute(handlerParams); } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("JobThread Exception:", e); _status = ResponseModel.FAIL; StringWriter out = new StringWriter(); e.printStackTrace(new PrintWriter(out)); _msg = out.toString(); } - logger.info("----------- xxl-job job handle end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", + logger.info("----------- xxl-job job execute end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", new Object[]{handlerParams, _status, _msg}); // callback handler info @@ -109,7 +107,7 @@ } } } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("----------- xxl-job JobThread Exception:", e); } } @@ -124,6 +122,6 @@ } } - logger.info(">>>>>>>>>>>> xxl-job handlerThrad stoped, hashCode:{}", Thread.currentThread()); + logger.info(">>>>>>>>>>>> xxl-job JobThread stoped, hashCode:{}", Thread.currentThread()); } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java index 2e37e37..1bf5396 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java @@ -31,7 +31,7 @@ break; } } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error(">>>>>>>>>>> xxl-job TriggerCallbackThread Exception:", e); } } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java b/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java index 550d23e..7fe6d04 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java @@ -49,7 +49,7 @@ return localAddress; } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } try { Enumeration interfaces = NetworkInterface.getNetworkInterfaces(); @@ -66,17 +66,17 @@ return address; } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } } } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } } } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } logger.error("Could not get local host ip address, will use 127.0.0.1 instead."); return localAddress; diff --git a/README.md b/README.md index cd7d945..e4d08f3 100644 --- a/README.md +++ b/README.md @@ -708,6 +708,8 @@ - 1、IP工具类获取IP逻辑优化,IP静态缓存; - 2、执行器、调度中心,均支持自定义注册IP地址;解决机器多网卡时错误网卡注册的情况; - 3、任务跨天执行时生成多份日志文件的问题修复; +- 4、底层日志底层日志调整,非敏感日志level调整为debug; +- 5、执行器AppName必须在调度中心配置才允许注册,一个AppName可以配置多个执行器,将会同时注册到对应执行器上; #### 规划中 diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java index 10cc66d..127c36e 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobLogController.java @@ -45,7 +45,6 @@ public String index(Model model, String jobGroup, String jobName) { // 任务组 - List jobGroupList = xxlJobGroupDao.findAll(); model.addAttribute("jobGroup", jobGroup); @@ -92,24 +91,6 @@ return maps; } - /*@RequestMapping("/save") - @ResponseBody - @PermessionLimit(limit=false) - public RemoteCallBack triggerLog(int trigger_log_id, String status, String msg) { - RemoteCallBack callBack = new RemoteCallBack(); - callBack.setStatus(RemoteCallBack.FAIL); - XxlJobLog log = xxlJobLogDao.load(trigger_log_id); - if (log!=null) { - log.setHandleTime(new Date()); - log.setHandleStatus(status); - log.setHandleMsg(msg); - xxlJobLogDao.updateHandleInfo(log); - callBack.setStatus(RemoteCallBack.SUCCESS); - return callBack; - } - return callBack; - }*/ - @RequestMapping("/logDetail") @ResponseBody public ReturnT logDetail(int id){ diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java index b592882..b0e4003 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/resolver/WebExceptionResolver.java @@ -22,7 +22,7 @@ @Override public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) { - logger.error("system catch exception:{}", ex); + logger.error("WebExceptionResolver:{}", ex); ModelAndView mv = new ModelAndView(); HandlerMethod method = (HandlerMethod)handler; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java index 1f063ac..21c8a22 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/callback/XxlJobLogCallbackServer.java @@ -15,7 +15,7 @@ public class XxlJobLogCallbackServer { private static final Logger logger = LoggerFactory.getLogger(XxlJobLogCallbackServer.class); - Server server = null; + private Server server = null; public void start(int callBackPort) throws Exception { final int port = Integer.valueOf(callBackPort); diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java index fb6a9c7..5e785d5 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/RemoteHttpJobBean.java @@ -42,7 +42,7 @@ jobLog.setJobGroup(jobInfo.getJobGroup()); jobLog.setJobName(jobInfo.getJobName()); DynamicSchedulerUtil.xxlJobLogDao.save(jobLog); - logger.info(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger start, jobId:{}", jobLog.getId()); // admin address List adminAddressList = JobRegistryHelper.discover(RegistHelper.RegistType.ADMIN.name(), RegistHelper.RegistType.ADMIN.name()); @@ -89,7 +89,7 @@ // monitor triger JobMonitorHelper.monitor(jobLog.getId()); - logger.info(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); + logger.debug(">>>>>>>>>>> xxl-job trigger end, jobId:{}", jobLog.getId()); } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java index fe5726d..9d52ab4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobMonitorHelper.java @@ -35,7 +35,7 @@ public void run() { while (true) { try { - logger.info(">>>>>>>>>>> job monitor beat ... "); + logger.debug(">>>>>>>>>>> job monitor beat ... "); Integer jobLogId = JobMonitorHelper.helper.queue.take(); if (jobLogId != null && jobLogId > 0) { logger.info(">>>>>>>>>>> job monitor heat success, JobLogId:{}", jobLogId); diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java index 55a9e9b..6d44db5 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/registry/impl/DbRegistHelper.java @@ -21,7 +21,7 @@ String insertSql = "INSERT INTO XXL_JOB_QRTZ_TRIGGER_REGISTRY( `registry_group` , `registry_key` , `registry_value`, `update_time`) VALUES(? , ? , ?, NOW())"; int ret = DBUtil.update(dataSource, updateSql, new Object[]{registGroup, registryKey, registryValue}); if (ret<1) { - ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); + //ret = DBUtil.update(dataSource, insertSql, new Object[]{registGroup, registryKey, registryValue}); } return ret; } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java index 431c790..419854c 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/JobThread.java @@ -40,7 +40,7 @@ public void pushTriggerQueue(RequestModel requestModel) { if (triggerLogIdSet.contains(requestModel.getLogId())) { - logger.info("repeate trigger job, logId:{}", requestModel.getLogId()); + logger.debug("repeate trigger job, logId:{}", requestModel.getLogId()); return; } @@ -58,8 +58,6 @@ this.stopReason = stopReason; } - - int i = 1; @Override public void run() { @@ -83,16 +81,16 @@ String logFileName = XxlJobFileAppender.makeLogFileName(new Date(triggerDate.getLogDateTim()), triggerDate.getLogId()); XxlJobFileAppender.contextHolder.set(logFileName); - logger.info("----------- xxl-job job handle start -----------"); + logger.info("----------- xxl-job job execute start -----------"); handler.execute(handlerParams); } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("JobThread Exception:", e); _status = ResponseModel.FAIL; StringWriter out = new StringWriter(); e.printStackTrace(new PrintWriter(out)); _msg = out.toString(); } - logger.info("----------- xxl-job job handle end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", + logger.info("----------- xxl-job job execute end -----------
Look : ExecutorParams:{}, Status:{}, Msg:{}", new Object[]{handlerParams, _status, _msg}); // callback handler info @@ -109,7 +107,7 @@ } } } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error("----------- xxl-job JobThread Exception:", e); } } @@ -124,6 +122,6 @@ } } - logger.info(">>>>>>>>>>>> xxl-job handlerThrad stoped, hashCode:{}", Thread.currentThread()); + logger.info(">>>>>>>>>>>> xxl-job JobThread stoped, hashCode:{}", Thread.currentThread()); } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java index 2e37e37..1bf5396 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/router/thread/TriggerCallbackThread.java @@ -31,7 +31,7 @@ break; } } catch (Exception e) { - logger.info("JobThread Exception:", e); + logger.error(">>>>>>>>>>> xxl-job TriggerCallbackThread Exception:", e); } } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java b/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java index 550d23e..7fe6d04 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java @@ -49,7 +49,7 @@ return localAddress; } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } try { Enumeration interfaces = NetworkInterface.getNetworkInterfaces(); @@ -66,17 +66,17 @@ return address; } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } } } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } } } } catch (Throwable e) { - logger.warn("Failed to retriving ip address, " + e.getMessage(), e); + logger.error("Failed to retriving ip address, " + e.getMessage(), e); } logger.error("Could not get local host ip address, will use 127.0.0.1 instead."); return localAddress; diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/util/XxlJobNetCommUtil.java b/xxl-job-core/src/main/java/com/xxl/job/core/util/XxlJobNetCommUtil.java index c97f525..ee390f7 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/util/XxlJobNetCommUtil.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/util/XxlJobNetCommUtil.java @@ -112,7 +112,7 @@ HttpEntity entity = response.getEntity(); if (response.getStatusLine().getStatusCode() == 200 && null != entity) { String responseHex = EntityUtils.toString(entity, "UTF-8"); - logger.info("xxl-job, net comm success, requestHex:{}, responseHex:{}", requestHex, responseHex); + logger.debug("xxl-job, net comm success, requestHex:{}, responseHex:{}", requestHex, responseHex); EntityUtils.consume(entity); // i do not know why @@ -133,7 +133,7 @@ failMsg = "http statusCode error, statusCode:" + response.getStatusLine().getStatusCode(); } } catch (Exception e) { - logger.info("", e); + logger.error("", e); /*StringWriter out = new StringWriter(); e.printStackTrace(new PrintWriter(out)); callback.setMsg(out.toString());*/ @@ -146,7 +146,7 @@ try { httpClient.close(); } catch (IOException e) { - logger.info("", e); + logger.error("", e); } } }