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 5a15245f52cfec9f274780a85db315ca28746416..e8928f5f8a9f9e9f0ba70e647f6fd8a6d2ca1e38 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 @@ -1,7 +1,7 @@ package com.xxl.job.admin.controller.resolver; -import com.xxl.job.admin.core.util.JacksonUtil; import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.util.JacksonUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.bind.annotation.ResponseBody; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoConcurrentJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoConcurrentJobBean.java index 22a77f544b8c68b8c35c814c7a921d408ecfe3e8..a64ef5b7198807b4344fed355d398bdbc7f35b02 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoConcurrentJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoConcurrentJobBean.java @@ -21,7 +21,7 @@ package com.xxl.job.admin.core.jobbean.impl; // try { // TimeUnit.SECONDS.sleep(10); // } catch (InterruptedException e) { -// e.printStackTrace(); +// logger.error(e.getMessage(), e); // } // // return false; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoNomalJobBean.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoNomalJobBean.java index 7d5bf667615b8dce31307fad4b6a76dd7c022046..ccb7c41dfb29fe603cb4eec15558769e35bc9f07 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoNomalJobBean.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/jobbean/impl/DemoNomalJobBean.java @@ -23,7 +23,7 @@ package com.xxl.job.admin.core.jobbean.impl; // try { // TimeUnit.SECONDS.sleep(10); // } catch (InterruptedException e) { -// e.printStackTrace(); +// logger.error(e.getMessage(), e); // } // // return false; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/schedule/XxlJobDynamicScheduler.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/schedule/XxlJobDynamicScheduler.java index f30d6144b779870efcc04694a6c05eb7db55f1c8..2a6e56616f2826a448c35014f73d371acee95224 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/schedule/XxlJobDynamicScheduler.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/schedule/XxlJobDynamicScheduler.java @@ -143,7 +143,7 @@ public final class XxlJobDynamicScheduler implements ApplicationContextAware { } } catch (SchedulerException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } } @@ -377,7 +377,7 @@ public final class XxlJobDynamicScheduler implements ApplicationContextAware { } } catch (SchedulerException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); return null; } return jobList; diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/util/JacksonUtil.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/util/JacksonUtil.java deleted file mode 100644 index 16ca016e104eb2ca28baf9afda77e0fa8d407e80..0000000000000000000000000000000000000000 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/util/JacksonUtil.java +++ /dev/null @@ -1,93 +0,0 @@ -package com.xxl.job.admin.core.util; - - -import org.codehaus.jackson.JsonGenerationException; -import org.codehaus.jackson.JsonParseException; -import org.codehaus.jackson.map.JsonMappingException; -import org.codehaus.jackson.map.ObjectMapper; -import org.codehaus.jackson.type.TypeReference; - -import java.io.IOException; -import java.util.HashMap; -import java.util.Map; - -/** - * Jackson util - * - * 1、obj need private and set/get； - * 2、do not support inner class； - * - * @author xuxueli 2015-9-25 18:02:56 - */ -public class JacksonUtil { - private final static ObjectMapper objectMapper = new ObjectMapper(); - public static ObjectMapper getInstance() { - return objectMapper; - } - - /** - * bean、array、List、Map --> json - * - * @param obj - * @return json string - * @throws Exception - */ - public static String writeValueAsString(Object obj) { - try { - return getInstance().writeValueAsString(obj); - } catch (JsonGenerationException e) { - e.printStackTrace(); - } catch (JsonMappingException e) { - e.printStackTrace(); - } catch (IOException e) { - e.printStackTrace(); - } - return null; - } - - /** - * string --> bean、Map、List(array) - * - * @param jsonStr - * @param clazz - * @return obj - * @throws Exception - */ - public static T readValue(String jsonStr, Class clazz) { - try { - return getInstance().readValue(jsonStr, clazz); - } catch (JsonParseException e) { - e.printStackTrace(); - } catch (JsonMappingException e) { - e.printStackTrace(); - } catch (IOException e) { - e.printStackTrace(); - } - return null; - } - public static T readValueRefer(String jsonStr, Class clazz) { - try { - return getInstance().readValue(jsonStr, new TypeReference() { }); - } catch (JsonParseException e) { - e.printStackTrace(); - } catch (JsonMappingException e) { - e.printStackTrace(); - } catch (IOException e) { - e.printStackTrace(); - } - return null; - } - - public static void main(String[] args) { - try { - Map map = new HashMap(); - map.put("aaa", "111"); - map.put("bbb", "222"); - String json = writeValueAsString(map); - System.out.println(json); - System.out.println(readValue(json, Map.class)); - } catch (Exception e) { - e.printStackTrace(); - } - } -} diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/util/MailUtil.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/util/MailUtil.java index e3bec8ef16a3130b32a35ee31266f32d1e93fffd..07e5cc21cb6377ef50ef32f8b903bbfda0ecb6ae 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/util/MailUtil.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/util/MailUtil.java @@ -147,7 +147,7 @@ public class MailUtil { mailSender.send(mimeMessage); return true; } catch (Exception e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } return false; } diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java index 60490fb6ceffeac65ec5cbdae5c4561674981899..d144eff2f2e732f9725a34e6e80223a22b359f1c 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java @@ -226,7 +226,7 @@ public class XxlJobServiceImpl implements XxlJobService { xxlJobLogGlueDao.deleteByJobId(id); return ReturnT.SUCCESS; } catch (SchedulerException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } return ReturnT.FAIL; } @@ -241,7 +241,7 @@ public class XxlJobServiceImpl implements XxlJobService { boolean ret = XxlJobDynamicScheduler.pauseJob(name, group); // jobStatus do not store return ret?ReturnT.SUCCESS:ReturnT.FAIL; } catch (SchedulerException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); return ReturnT.FAIL; } } @@ -256,7 +256,7 @@ public class XxlJobServiceImpl implements XxlJobService { boolean ret = XxlJobDynamicScheduler.resumeJob(name, group); return ret?ReturnT.SUCCESS:ReturnT.FAIL; } catch (SchedulerException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); return ReturnT.FAIL; } } @@ -271,7 +271,7 @@ public class XxlJobServiceImpl implements XxlJobService { XxlJobDynamicScheduler.triggerJob(name, group); return ReturnT.SUCCESS; } catch (SchedulerException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); return ReturnT.FAIL; } } diff --git a/xxl-job-admin/src/test/java/com/xxl/job/dao/impl/AdminBizTest.java b/xxl-job-admin/src/test/java/com/xxl/job/dao/impl/AdminBizTest.java index b65cfb53ef507054ed5a2a8066de2cd956eca98d..6402b8a028d6c44f7f1f08f2d5400c0466bf3298 100644 --- a/xxl-job-admin/src/test/java/com/xxl/job/dao/impl/AdminBizTest.java +++ b/xxl-job-admin/src/test/java/com/xxl/job/dao/impl/AdminBizTest.java @@ -43,7 +43,7 @@ public class AdminBizTest { AdminBiz adminBiz = (AdminBiz) new NetComClientProxy(AdminBiz.class, addressUrl, accessToken).getObject(); int jobId = 1; - ReturnT returnT = adminBiz.triggerJob(1); + ReturnT returnT = adminBiz.triggerJob(jobId); Assert.assertTrue(returnT.getCode() == ReturnT.SUCCESS_CODE); } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/glue/GlueFactory.java b/xxl-job-core/src/main/java/com/xxl/job/core/glue/GlueFactory.java index ba2ba3f114e3c696c6f1b5812e1cc3a646425f83..400cfc093eb2647377dc6446103ee8ec83b6940a 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/glue/GlueFactory.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/glue/GlueFactory.java @@ -75,9 +75,9 @@ public class GlueFactory { try { field.set(instance, fieldBean); } catch (IllegalArgumentException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } catch (IllegalAccessException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java b/xxl-job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java index 27b942be98a49269c0d514296ef866a3c16ffdf1..1a502344b6c2f542d7b85559bdd92a8dacb5016d 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/log/XxlJobFileAppender.java @@ -174,13 +174,13 @@ public class XxlJobFileAppender { return sb.toString(); } } catch (IOException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } finally { if (reader != null) { try { reader.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/util/HttpClientUtil.java b/xxl-job-core/src/main/java/com/xxl/job/core/util/HttpClientUtil.java index 00b646ba1b3dc0b454e4640cbd26477663de0f62..417a80ff26c93fd06b6aa2331df8a7a265adf663 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/util/HttpClientUtil.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/util/HttpClientUtil.java @@ -71,7 +71,7 @@ public class HttpClientUtil { try { httpClient.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } } return responseBytes; @@ -101,7 +101,7 @@ public class HttpClientUtil { } return message; } catch (IOException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); throw e; } } diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/util/JacksonUtil.java b/xxl-job-core/src/main/java/com/xxl/job/core/util/JacksonUtil.java index 5fde5c02bc5c80a14ace616eb368049bc8bcf337..086c0ce147e36eae59bee2f54091a3380fcecc77 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/util/JacksonUtil.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/util/JacksonUtil.java @@ -6,6 +6,8 @@ import org.codehaus.jackson.JsonParseException; import org.codehaus.jackson.map.JsonMappingException; import org.codehaus.jackson.map.ObjectMapper; import org.codehaus.jackson.type.TypeReference; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.IOException; import java.util.HashMap; @@ -20,6 +22,8 @@ import java.util.Map; * @author xuxueli 2015-9-25 18:02:56 */ public class JacksonUtil { + private static Logger logger = LoggerFactory.getLogger(JacksonUtil.class); + private final static ObjectMapper objectMapper = new ObjectMapper(); public static ObjectMapper getInstance() { return objectMapper; @@ -36,11 +40,11 @@ public class JacksonUtil { try { return getInstance().writeValueAsString(obj); } catch (JsonGenerationException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } catch (JsonMappingException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } catch (IOException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } return null; } @@ -57,11 +61,11 @@ public class JacksonUtil { try { return getInstance().readValue(jsonStr, clazz); } catch (JsonParseException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } catch (JsonMappingException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } catch (IOException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } return null; } @@ -69,11 +73,11 @@ public class JacksonUtil { try { return getInstance().readValue(jsonStr, new TypeReference() { }); } catch (JsonParseException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } catch (JsonMappingException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } catch (IOException e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } return null; } @@ -87,7 +91,7 @@ public class JacksonUtil { System.out.println(json); System.out.println(readValue(json, Map.class)); } catch (Exception e) { - e.printStackTrace(); + logger.error(e.getMessage(), e); } } }