From 2858a6c47c048b9a6f2b7c03f84946e193b69963 Mon Sep 17 00:00:00 2001 From: RenKaiGe Date: Mon, 11 Mar 2019 14:20:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=A1=B9=E7=9B=AE=E4=B8=AD?= =?UTF-8?q?=E7=9A=84=E6=97=A5=E5=BF=97=E6=A1=86=E6=9E=B6=E4=B8=BAlog4j2?= =?UTF-8?q?=E5=BC=82=E6=AD=A5=E5=BD=A2=E5=BC=8F=E8=BE=93=E5=87=BA,?= =?UTF-8?q?=E8=A7=A3=E5=86=B3mybatis=E6=97=A5=E5=BF=97=E5=9C=A8=E6=8E=A7?= =?UTF-8?q?=E5=88=B6=E5=8F=B0=E7=9B=B4=E6=8E=A5=E6=89=93=E5=8D=B0=E7=AD=89?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 60 ++++++++---- .../interceptor/DataSourceAInterceptor.java | 6 +- .../interceptor/DataSourceBInterceptor.java | 6 +- src/main/java/com/nis/util/DateUtils.java | 5 +- src/main/java/com/nis/util/HiveJDBC.java | 7 +- src/main/java/com/nis/util/JedisUtils.java | 1 + .../elasticsearch/ElasticsearchSqlDao.java | 10 +- .../nis/util/httpclient/HttpClientUtil.java | 9 +- .../java/com/nis/util/redis/RedisDao.java | 5 +- .../nis/util/redis/SaveRedisListThread.java | 5 +- .../com/nis/util/redis/SaveRedisThread.java | 8 +- .../nis/web/controller/BaseController.java | 76 +++++++-------- .../web/controller/BaseRestController.java | 3 +- .../restful/DataDictionaryController.java | 22 ++--- .../controller/restful/ServiceController.java | 5 +- .../restful/SystemFunStatusController.java | 12 +-- .../com/nis/web/service/AuditLogThread.java | 5 +- .../com/nis/web/service/BaseLogService.java | 33 ++++--- .../service/ServicesRequestLogService.java | 49 ++++------ .../restful/ConfigJedisServiceimpl.java | 24 +++-- .../service/restful/ConfigPzIdService.java | 3 - .../service/restful/ConfigSourcesService.java | 6 +- .../restful/DataDictionaryService.java | 7 +- .../nis/web/service/restful/EventService.java | 23 ++--- .../restful/SystemHomePageService.java | 7 +- .../com/nis/web/task/SyncRedisToCluster.java | 31 +++++-- .../nis/web/test/HelloWorldController.java | 1 - src/main/resources/log4j.properties | 23 ----- src/main/resources/log4j2.xml | 93 +++++++++++++++++++ src/main/resources/mybatis-config.xml | 2 +- src/main/webapp/WEB-INF/web.xml | 2 +- 31 files changed, 336 insertions(+), 213 deletions(-) delete mode 100644 src/main/resources/log4j.properties create mode 100644 src/main/resources/log4j2.xml diff --git a/pom.xml b/pom.xml index ff5fb3c..16fcc7c 100644 --- a/pom.xml +++ b/pom.xml @@ -394,24 +394,44 @@ - - org.slf4j - slf4j-api - ${slf4j.version} - + + + + + - - org.slf4j - slf4j-log4j12 - ${slf4j.version} - + + + + + - - - log4j - log4j - 1.2.14 - + + org.apache.logging.log4j + log4j-jcl + 2.11.2 + + + org.apache.logging.log4j + log4j-slf4j-impl + 2.11.2 + + + org.apache.logging.log4j + log4j-core + 2.11.2 + + + org.apache.logging.log4j + log4j-api + 2.11.2 + + + + + + + org.mybatis @@ -537,6 +557,14 @@ org.mortbay.jetty jsp-api-2.1 + + log4j + log4j + + + org.slf4j + slf4j-log4j12 + diff --git a/src/main/java/com/nis/interceptor/DataSourceAInterceptor.java b/src/main/java/com/nis/interceptor/DataSourceAInterceptor.java index 874c560..62946c1 100644 --- a/src/main/java/com/nis/interceptor/DataSourceAInterceptor.java +++ b/src/main/java/com/nis/interceptor/DataSourceAInterceptor.java @@ -3,15 +3,15 @@ package com.nis.interceptor; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.web.servlet.HandlerInterceptor; import org.springframework.web.servlet.ModelAndView; import com.nis.datasource.CustomerContextHolder; public class DataSourceAInterceptor implements HandlerInterceptor { - Logger logger = Logger.getLogger(DataSourceAInterceptor.class); - + private static final Logger logger =LoggerFactory.getLogger(DataSourceAInterceptor.class); @Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception { diff --git a/src/main/java/com/nis/interceptor/DataSourceBInterceptor.java b/src/main/java/com/nis/interceptor/DataSourceBInterceptor.java index 5370018..d1c423f 100644 --- a/src/main/java/com/nis/interceptor/DataSourceBInterceptor.java +++ b/src/main/java/com/nis/interceptor/DataSourceBInterceptor.java @@ -3,14 +3,16 @@ package com.nis.interceptor; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.web.servlet.HandlerInterceptor; import org.springframework.web.servlet.ModelAndView; import com.nis.datasource.CustomerContextHolder; public class DataSourceBInterceptor implements HandlerInterceptor { - Logger logger = Logger.getLogger(DataSourceBInterceptor.class); + private static final Logger logger =LoggerFactory.getLogger(DataSourceBInterceptor.class); + @Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception { diff --git a/src/main/java/com/nis/util/DateUtils.java b/src/main/java/com/nis/util/DateUtils.java index c7ecdd4..e0b6920 100644 --- a/src/main/java/com/nis/util/DateUtils.java +++ b/src/main/java/com/nis/util/DateUtils.java @@ -12,7 +12,8 @@ import java.util.HashMap; import java.util.Map; import org.apache.commons.lang3.time.DateFormatUtils; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import com.zdjizhi.utils.StringUtil; @@ -23,7 +24,7 @@ import com.zdjizhi.utils.StringUtil; * @version 2014-4-15 */ public class DateUtils extends org.apache.commons.lang3.time.DateUtils { - public static final Logger logger = Logger.getLogger(DateUtils.class); + public static final Logger logger =LoggerFactory.getLogger(DateUtils.class); private static String[] parsePatterns = { "yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM", "yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM", "yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM" }; diff --git a/src/main/java/com/nis/util/HiveJDBC.java b/src/main/java/com/nis/util/HiveJDBC.java index 527c38a..d7d0f96 100644 --- a/src/main/java/com/nis/util/HiveJDBC.java +++ b/src/main/java/com/nis/util/HiveJDBC.java @@ -18,18 +18,19 @@ import java.util.List; import java.util.Map; import java.util.Properties; -import com.zdjizhi.utils.StringUtil; import org.apache.ibatis.mapping.ResultMap; import org.apache.ibatis.mapping.ResultMapping; import org.apache.ibatis.session.SqlSessionFactory; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import com.nis.domain.Page; import com.nis.util.redis.SaveRedisListThread; import com.nis.web.service.SpringContextHolder; +import com.zdjizhi.utils.StringUtil; public class HiveJDBC { - private final static Logger logger = Logger.getLogger(HiveJDBC.class); + private static final Logger logger =LoggerFactory.getLogger(HiveJDBC.class); static Connection conn = null; static ResultSet rs = null; static Statement st = null; diff --git a/src/main/java/com/nis/util/JedisUtils.java b/src/main/java/com/nis/util/JedisUtils.java index 5957dfc..d2880d6 100644 --- a/src/main/java/com/nis/util/JedisUtils.java +++ b/src/main/java/com/nis/util/JedisUtils.java @@ -221,6 +221,7 @@ public class JedisUtils { */ public static Jedis getResource(int redisDb) throws JedisException { JedisSentinelPool jedisSentinelPool = SpringContextHolder.getBean(JedisSentinelPool.class); +// JedisPool jedisSentinelPool = SpringContextHolder.getBean(JedisPool.class); if (jedisSentinelPool == null) { throw new ServiceRuntimeException("redis连接池为空,请联系管理员检查程序", diff --git a/src/main/java/com/nis/util/elasticsearch/ElasticsearchSqlDao.java b/src/main/java/com/nis/util/elasticsearch/ElasticsearchSqlDao.java index b8211c6..c708193 100644 --- a/src/main/java/com/nis/util/elasticsearch/ElasticsearchSqlDao.java +++ b/src/main/java/com/nis/util/elasticsearch/ElasticsearchSqlDao.java @@ -21,23 +21,25 @@ import java.util.Iterator; import java.util.List; import java.util.Map; -import com.zdjizhi.utils.StringUtil; import org.apache.http.client.ClientProtocolException; import org.apache.ibatis.mapping.ResultMap; import org.apache.ibatis.mapping.ResultMapping; import org.apache.ibatis.session.SqlSessionFactory; -import org.apache.log4j.Logger; import org.json.JSONArray; import org.json.JSONException; import org.json.JSONObject; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import com.nis.domain.LogEntity; import com.nis.domain.Page; import com.nis.util.Constants; +import com.nis.util.HiveJDBC; import com.nis.util.JsonMapper; import com.nis.util.StringUtils; import com.nis.util.httpclient.HttpClientUtil; import com.nis.web.service.SpringContextHolder; +import com.zdjizhi.utils.StringUtil; /** * @ClassName: ElasticsearchSqlUtil.java @@ -48,7 +50,9 @@ import com.nis.web.service.SpringContextHolder; */ @SuppressWarnings({"unchecked","rawtypes"}) public class ElasticsearchSqlDao { - private static final Logger logger=Logger.getLogger(ElasticsearchSqlDao.class); + + private static final Logger logger =LoggerFactory.getLogger(ElasticsearchSqlDao.class); + private static final SqlSessionFactory sqlSessionFactory=SpringContextHolder.getBean(SqlSessionFactory.class); private static final Map> fieldsMapMap=new HashMap<>(); public void init(Class clazz){ diff --git a/src/main/java/com/nis/util/httpclient/HttpClientUtil.java b/src/main/java/com/nis/util/httpclient/HttpClientUtil.java index d3f393a..b44dbfb 100644 --- a/src/main/java/com/nis/util/httpclient/HttpClientUtil.java +++ b/src/main/java/com/nis/util/httpclient/HttpClientUtil.java @@ -10,12 +10,10 @@ package com.nis.util.httpclient; import java.io.IOException; import java.util.ArrayList; -import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; -import com.nis.util.JsonMapper; import org.apache.http.NameValuePair; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.entity.UrlEncodedFormEntity; @@ -26,7 +24,10 @@ import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.nis.util.JsonMapper; /** * @ClassName: HttpClientBean.java @@ -36,7 +37,7 @@ import org.apache.log4j.Logger; * @version V1.0 */ public class HttpClientUtil { - protected final Logger logger = Logger.getLogger(HttpClientUtil.class); + protected static final Logger logger =LoggerFactory.getLogger(HttpClientUtil.class); /** * 处理get请求. * @param url 请求路径 diff --git a/src/main/java/com/nis/util/redis/RedisDao.java b/src/main/java/com/nis/util/redis/RedisDao.java index a6a22b8..88f35d3 100644 --- a/src/main/java/com/nis/util/redis/RedisDao.java +++ b/src/main/java/com/nis/util/redis/RedisDao.java @@ -18,7 +18,8 @@ import javax.annotation.PostConstruct; import javax.annotation.PreDestroy; import org.apache.commons.pool2.impl.GenericObjectPoolConfig; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import com.nis.util.BeanHelper; import com.nis.util.Configurations; @@ -37,7 +38,7 @@ import redis.clients.jedis.JedisPool; * @version V1.0 */ public class RedisDao { - protected final Logger logger = Logger.getLogger(RedisDao.class); + protected static final Logger logger =LoggerFactory.getLogger(RedisDao.class); private JedisCluster cluster=null; private JedisClusterPipeline jcp=null; diff --git a/src/main/java/com/nis/util/redis/SaveRedisListThread.java b/src/main/java/com/nis/util/redis/SaveRedisListThread.java index 06e6ef5..9c74ab2 100644 --- a/src/main/java/com/nis/util/redis/SaveRedisListThread.java +++ b/src/main/java/com/nis/util/redis/SaveRedisListThread.java @@ -2,13 +2,14 @@ package com.nis.util.redis; import java.util.List; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import com.nis.web.service.SpringContextHolder; public class SaveRedisListThread extends Thread { private static RedisDao redisDao = SpringContextHolder.getBean(RedisDao.class); - protected final Logger logger = Logger.getLogger(this.getClass()); + protected static final Logger logger =LoggerFactory.getLogger(SaveRedisListThread.class); private String key; private List value; diff --git a/src/main/java/com/nis/util/redis/SaveRedisThread.java b/src/main/java/com/nis/util/redis/SaveRedisThread.java index 0386c60..b588a8e 100644 --- a/src/main/java/com/nis/util/redis/SaveRedisThread.java +++ b/src/main/java/com/nis/util/redis/SaveRedisThread.java @@ -1,15 +1,13 @@ package com.nis.util.redis; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; -import com.nis.util.Constants; import com.nis.util.JsonMapper; -import com.nis.util.redis.RedisDao; import com.nis.web.service.SpringContextHolder; public class SaveRedisThread extends Thread { private static RedisDao redisDao = SpringContextHolder.getBean(RedisDao.class); - protected final Logger logger = Logger.getLogger(this.getClass()); - + protected static final Logger logger =LoggerFactory.getLogger(SaveRedisThread.class); private String key; private Object value; private int expire; diff --git a/src/main/java/com/nis/web/controller/BaseController.java b/src/main/java/com/nis/web/controller/BaseController.java index 6f36d34..6b47a16 100644 --- a/src/main/java/com/nis/web/controller/BaseController.java +++ b/src/main/java/com/nis/web/controller/BaseController.java @@ -7,7 +7,8 @@ import java.util.Date; import javax.servlet.http.HttpServletResponse; import org.apache.commons.lang3.StringEscapeUtils; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.ui.Model; @@ -29,62 +30,60 @@ import com.nis.web.service.SystemService; import com.nis.web.service.UserService; public class BaseController { - + @Autowired protected UserService userService; - + @Autowired protected SystemService systemService; - + @Autowired protected OfficeService officeService; - + @Autowired protected AreaService areaService; - + @Autowired protected RoleService roleService; - + @Autowired protected MenuService menuService; - + @Autowired protected LogService logService; - + @Autowired protected SwaggerLogService swaggerLogService; - - @Autowired + + @Autowired protected ArchiveServcie archiveServcie; - - @Autowired + + @Autowired protected DictService dictService; - - - protected final Logger logger = Logger.getLogger(this.getClass()); - - + + protected static final Logger logger = LoggerFactory.getLogger(BaseController.class); + /** * 管理基础路径 */ @Value("${adminPath}") protected String adminPath; - + /** * 前端基础路径 */ @Value("${frontPath}") protected String frontPath; - + /** * 前端URL后缀 */ @Value("${urlSuffix}") protected String urlSuffix; - - + /** * 客户端返回JSON字符串 + * * @param response * @param object * @return @@ -92,10 +91,10 @@ public class BaseController { protected String renderString(HttpServletResponse response, Object object) { return renderString(response, JsonMapper.toJsonString(object), "application/json"); } - - + /** * 客户端返回字符串 + * * @param response * @param string * @return @@ -103,44 +102,43 @@ public class BaseController { protected String renderString(HttpServletResponse response, String string, String type) { try { response.reset(); - response.setContentType(type); - response.setCharacterEncoding("utf-8"); + response.setContentType(type); + response.setCharacterEncoding("utf-8"); response.getWriter().print(string); return null; } catch (IOException e) { return null; } } - - + /** * 添加Model消息 + * * @param */ protected void addMessage(Model model, String... messages) { StringBuilder sb = new StringBuilder(); - for (String message : messages){ - sb.append(message).append(messages.length>1?"
":""); + for (String message : messages) { + sb.append(message).append(messages.length > 1 ? "
" : ""); } model.addAttribute("message", sb.toString()); } - + /** * 添加Flash消息 + * * @param */ protected void addMessage(RedirectAttributes redirectAttributes, String... messages) { StringBuilder sb = new StringBuilder(); - for (String message : messages){ - sb.append(message).append(messages.length>1?"
":""); + for (String message : messages) { + sb.append(message).append(messages.length > 1 ? "
" : ""); } redirectAttributes.addFlashAttribute("message", sb.toString()); } - + /** - * 初始化数据绑定 - * 1. 将所有传递进来的String进行HTML编码，防止XSS攻击 - * 2. 将字段中Date类型转换为String类型 + * 初始化数据绑定 1. 将所有传递进来的String进行HTML编码，防止XSS攻击 2. 将字段中Date类型转换为String类型 */ @InitBinder protected void initBinder(WebDataBinder binder) { @@ -150,6 +148,7 @@ public class BaseController { public void setAsText(String text) { setValue(text == null ? null : StringEscapeUtils.escapeHtml4(text.trim())); } + @Override public String getAsText() { Object value = getValue(); @@ -164,8 +163,5 @@ public class BaseController { } }); } - - - } diff --git a/src/main/java/com/nis/web/controller/BaseRestController.java b/src/main/java/com/nis/web/controller/BaseRestController.java index 53d0889..850857c 100644 --- a/src/main/java/com/nis/web/controller/BaseRestController.java +++ b/src/main/java/com/nis/web/controller/BaseRestController.java @@ -47,7 +47,8 @@ import com.zdjizhi.utils.StringUtil; * @version V1.0 */ public class BaseRestController { - protected final Logger logger = LoggerFactory.getLogger(this.getClass()); + + protected static final Logger logger =LoggerFactory.getLogger(BaseRestController.class); private SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); /** diff --git a/src/main/java/com/nis/web/controller/restful/DataDictionaryController.java b/src/main/java/com/nis/web/controller/restful/DataDictionaryController.java index 3fb74f1..1436eb5 100644 --- a/src/main/java/com/nis/web/controller/restful/DataDictionaryController.java +++ b/src/main/java/com/nis/web/controller/restful/DataDictionaryController.java @@ -6,8 +6,8 @@ import java.util.Map; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import com.nis.web.service.AuditLogThread; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.RequestMapping; @@ -20,13 +20,13 @@ import com.nis.listener.SystemConfigListener; import com.nis.restful.RestServiceException; import com.nis.util.Constants; import com.nis.web.controller.BaseRestController; +import com.nis.web.service.AuditLogThread; import com.nis.web.service.ServicesRequestLogService; import com.nis.web.service.restful.DataDictionaryService; @RestController //@RequestMapping("${servicePath}") public class DataDictionaryController extends BaseRestController { - protected final Logger logger = Logger.getLogger(this.getClass()); @Autowired private DataDictionaryService dataDictionaryService; @Autowired @@ -47,7 +47,7 @@ public class DataDictionaryController extends BaseRestController { try { dataDictPage = dataDictionaryService.getDataDictList(page, dataDictionaryValue); } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "数据字典获取失败"); } return serviceResponse(thread, start, request, response, "编译配置获取成功", dataDictPage); @@ -62,7 +62,7 @@ public class DataDictionaryController extends BaseRestController { return serviceResponse(thread, start, request, response, "编译配置获取成功", dataDictionaryService.getDataDictList()); } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "数据字典获取失败"); } @@ -89,7 +89,7 @@ public class DataDictionaryController extends BaseRestController { } return serviceResponse(thread, start, request, response, "添加数据字典成功", "ok"); } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "添加数据字典失败"); } @@ -107,7 +107,7 @@ public class DataDictionaryController extends BaseRestController { } return serviceResponse(thread, start, request, response, "删除数据字典值成功", "ok"); } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "删除数据字典值失败"); } @@ -125,7 +125,7 @@ public class DataDictionaryController extends BaseRestController { } return serviceResponse(thread, start, request, response, "删除数据字典名称成功", "ok"); } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "删除数据字典名称失败"); } } @@ -148,7 +148,7 @@ public class DataDictionaryController extends BaseRestController { // } // return "/test/page/dataDict/addOrUpdateDataDict.jsp"; } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "获取数据字典对象失败"); } } @@ -166,7 +166,7 @@ public class DataDictionaryController extends BaseRestController { } return serviceResponse(thread, start, request, response, "修改数据字典成功", "ok"); } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "修改数据字典失败"); } @@ -184,7 +184,7 @@ public class DataDictionaryController extends BaseRestController { } return serviceResponse(thread, start, request, response, "数据字典更新成功", "ok"); } catch (Exception e) { - logger.error(e); + logger.error(e.getMessage()); throw new RestServiceException(thread, start, "数据字典更新失败"); } diff --git a/src/main/java/com/nis/web/controller/restful/ServiceController.java b/src/main/java/com/nis/web/controller/restful/ServiceController.java index 05b90d7..cfdefa2 100644 --- a/src/main/java/com/nis/web/controller/restful/ServiceController.java +++ b/src/main/java/com/nis/web/controller/restful/ServiceController.java @@ -9,7 +9,8 @@ package com.nis.web.controller.restful; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; @@ -29,7 +30,7 @@ import com.nis.web.service.restful.ControlLogService; /*@RestController @RequestMapping("${servicePath}")*/ public class ServiceController extends BaseRestController{ - protected final Logger logger = Logger.getLogger(this.getClass()); + protected static final Logger logger =LoggerFactory.getLogger(ServiceController.class); @Autowired protected ControlLogService logService; diff --git a/src/main/java/com/nis/web/controller/restful/SystemFunStatusController.java b/src/main/java/com/nis/web/controller/restful/SystemFunStatusController.java index 70d6575..b22e07f 100644 --- a/src/main/java/com/nis/web/controller/restful/SystemFunStatusController.java +++ b/src/main/java/com/nis/web/controller/restful/SystemFunStatusController.java @@ -5,9 +5,8 @@ import java.util.Map; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import com.nis.web.service.AuditLogThread; -import com.zdjizhi.utils.StringUtil; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; @@ -21,9 +20,11 @@ import com.nis.restful.RestServiceException; import com.nis.util.Constants; import com.nis.util.OracleErrorCodeUtil; import com.nis.web.controller.BaseRestController; +import com.nis.web.service.AuditLogThread; import com.nis.web.service.ServicesRequestLogService; import com.nis.web.service.restful.SystemFunStatusService; import com.wordnik.swagger.annotations.ApiOperation; +import com.zdjizhi.utils.StringUtil; /** * @ClassName: SystemFunStatusController.java @@ -36,8 +37,7 @@ import com.wordnik.swagger.annotations.ApiOperation; //@RequestMapping("${servicePath}/cfg/v1") @SuppressWarnings("rawtypes") public class SystemFunStatusController extends BaseRestController { - protected final Logger logger = Logger.getLogger(this.getClass()); - + private static final Logger logger =LoggerFactory.getLogger(SystemFunStatusController.class); @Autowired protected SystemFunStatusService systemFunStatusService; @@ -70,7 +70,6 @@ public class SystemFunStatusController extends BaseRestController { thread.setExceptionInfo(e.getMessage()+" "+e.getCause()); e.printStackTrace(); logger.error(e.getMessage()); - logger.error(e.getCause()); if(e instanceof RestServiceException) {throw e;} String info=OracleErrorCodeUtil.getOraCode(e); if(!StringUtil.isEmpty(info)) { @@ -111,7 +110,6 @@ public class SystemFunStatusController extends BaseRestController { thread.setExceptionInfo(e.getMessage()+" "+e.getCause()); e.printStackTrace(); logger.error(e.getMessage()); - logger.error(e.getCause()); if(e instanceof RestServiceException) {throw e; } String info=OracleErrorCodeUtil.getOraCode(e); if(!StringUtil.isEmpty(info)) { diff --git a/src/main/java/com/nis/web/service/AuditLogThread.java b/src/main/java/com/nis/web/service/AuditLogThread.java index e6c5992..cdb610f 100644 --- a/src/main/java/com/nis/web/service/AuditLogThread.java +++ b/src/main/java/com/nis/web/service/AuditLogThread.java @@ -21,7 +21,8 @@ import javax.servlet.ServletInputStream; import javax.servlet.ServletRequest; import javax.servlet.http.HttpServletRequest; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import com.nis.datasource.CustomerContextHolder; @@ -34,7 +35,7 @@ import com.nis.datasource.CustomerContextHolder; * @version V1.0 */ public class AuditLogThread implements Runnable { - private Logger logger = Logger.getLogger(AuditLogThread.class); + private Logger logger =LoggerFactory.getLogger(AuditLogThread.class); private ServicesRequestLogService service; private String remoteAddr; private String requestURI; diff --git a/src/main/java/com/nis/web/service/BaseLogService.java b/src/main/java/com/nis/web/service/BaseLogService.java index 1532e52..b9fbe69 100644 --- a/src/main/java/com/nis/web/service/BaseLogService.java +++ b/src/main/java/com/nis/web/service/BaseLogService.java @@ -1,5 +1,21 @@ package com.nis.web.service; +import java.io.Serializable; +import java.lang.reflect.Field; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import javax.servlet.http.HttpServletRequest; + +import org.apache.ibatis.mapping.ResultMap; +import org.apache.ibatis.mapping.ResultMapping; +import org.apache.ibatis.session.SqlSessionFactory; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; + import com.nis.domain.LogEntity; import com.nis.domain.Page; import com.nis.domain.restful.NtcCollectVoipLog; @@ -13,19 +29,6 @@ import com.nis.util.elasticsearch.ElasticsearchSqlDao; import com.zdjizhi.utils.DateUtils; import com.zdjizhi.utils.StringUtil; import com.zdjizhi.utils.TimeConstants; -import org.apache.ibatis.mapping.ResultMap; -import org.apache.ibatis.mapping.ResultMapping; -import org.apache.ibatis.session.SqlSessionFactory; -import org.apache.log4j.Logger; -import org.springframework.beans.factory.annotation.Autowired; - -import javax.servlet.http.HttpServletRequest; -import java.io.Serializable; -import java.lang.reflect.Field; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; /** * 基础日志Service基类 @@ -36,7 +39,9 @@ import java.util.Map; @SuppressWarnings({ "rawtypes" }) public abstract class BaseLogService { - protected final Logger logger = Logger.getLogger(this.getClass()); + + + protected static final Logger logger =LoggerFactory.getLogger(BaseLogService.class); @Autowired protected ElasticsearchSqlDao elasticsearchSqlDao; diff --git a/src/main/java/com/nis/web/service/ServicesRequestLogService.java b/src/main/java/com/nis/web/service/ServicesRequestLogService.java index a960373..c63517e 100644 --- a/src/main/java/com/nis/web/service/ServicesRequestLogService.java +++ b/src/main/java/com/nis/web/service/ServicesRequestLogService.java @@ -26,7 +26,8 @@ import java.util.regex.Pattern; import org.apache.ibatis.mapping.ResultMapping; import org.apache.ibatis.session.SqlSessionFactory; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -47,7 +48,8 @@ import com.nis.web.dao.ServicesRequestLogDao; */ @Service public class ServicesRequestLogService { - protected final Logger logger = Logger.getLogger(this.getClass()); + + protected final Logger logger = LoggerFactory.getLogger(ServicesRequestLogService.class); @Autowired public ServicesRequestLogDao servicesRequestLogDao; @@ -57,38 +59,25 @@ public class ServicesRequestLogService { } else { servicesRequestLogDao.insertLogLog(log); } - } /** * * saveRequestLog(记录请求日志) (这里描述这个方法适用条件 – 可选) * - * @param requestAddr - * request中的参数 - * @param requestURI - * request中的参数 - * @param queryString - * request中的参数 - * @param contextPath - * request中的参数 响应 - * @param operator - * 操作人 - * @param version - * 版本 - * @param opAction - * 操作行为 - * @param opTime - * 操作时间 - * @param content - * 请求体 - * @param requestTime - * 请求到达服务器时间 - * @param consumerTime - * 耗时 void + * @param requestAddr request中的参数 + * @param requestURI request中的参数 + * @param queryString request中的参数 + * @param contextPath request中的参数 响应 + * @param operator 操作人 + * @param version 版本 + * @param opAction 操作行为 + * @param opTime 操作时间 + * @param content 请求体 + * @param requestTime 请求到达服务器时间 + * @param consumerTime 耗时 void * @throws UnknownHostException - * @exception @since - * 1.0.0 + * @exception @since 1.0.0 */ public void saveRequestLog(String requestAddr, String requestURI, String queryString, String contextPath, String operator, String version, int opAction, Date opTime, Object content, Date requestTime, @@ -199,10 +188,8 @@ public class ServicesRequestLogService { * * @param data * @throws IllegalArgumentException - * @throws IllegalAccessException - * void - * @exception @since - * 1.0.0 + * @throws IllegalAccessException void + * @exception @since 1.0.0 */ public void save(ServicesRequestLog data) throws IllegalArgumentException, IllegalAccessException { SqlSessionFactory sqlSessionFactory = SpringContextHolder.getBean(SqlSessionFactory.class); diff --git a/src/main/java/com/nis/web/service/restful/ConfigJedisServiceimpl.java b/src/main/java/com/nis/web/service/restful/ConfigJedisServiceimpl.java index b238c24..9fac9bb 100644 --- a/src/main/java/com/nis/web/service/restful/ConfigJedisServiceimpl.java +++ b/src/main/java/com/nis/web/service/restful/ConfigJedisServiceimpl.java @@ -440,6 +440,8 @@ public class ConfigJedisServiceimpl implements ConfigRedisService { @Override public boolean saveMaatConfig(Map> configMap) { + long currentTimeMillis = System.currentTimeMillis(); + if (configMap != null && configMap.size() > 0) { int count = 0; Jedis resource = JedisUtils.getResource(0); @@ -492,6 +494,8 @@ public class ConfigJedisServiceimpl implements ConfigRedisService { addMaatRelation(configMap, transaction); addStatisticsReal(configMap, transaction); transaction.exec(); + long end = System.currentTimeMillis(); + logger.warn("执行ConfigJedisServiceImpl.saveMaatConfig用时{}毫秒", end - currentTimeMillis); return true; } else { transaction.discard(); @@ -936,10 +940,12 @@ public class ConfigJedisServiceimpl implements ConfigRedisService { } } else { - throw new ServiceRuntimeException( - "未从" + idRelaRedisDBIndex + "号redis库(编译,分组,域关系)中获取配置compileId=" + configId - + ",对应的redisdb信息,请联系开发人员检查删除逻辑是否正确或redis数据是否出现了异常", - RestBusinessCode.KeyNotExistsInRedis.getValue()); +// throw new ServiceRuntimeException( +// "未从" + idRelaRedisDBIndex + "号redis库(编译,分组,域关系)中获取配置compileId=" + configId +// + ",对应的redisdb信息,请联系开发人员检查删除逻辑是否正确或redis数据是否出现了异常", +// RestBusinessCode.KeyNotExistsInRedis.getValue()); + logger.error("不存在的配置id{}", configId); + } // } } @@ -1011,11 +1017,11 @@ public class ConfigJedisServiceimpl implements ConfigRedisService { list.add(i); } serviceConfigMap.put(129, list); - delMaatConfig(serviceConfigMap,false); + delMaatConfig(serviceConfigMap, false); } @Override - public boolean delMaatConfig(Map> serviceConfigMap,boolean isStart) { + public boolean delMaatConfig(Map> serviceConfigMap, boolean isStart) { if (serviceConfigMap != null && serviceConfigMap.size() > 0) { Jedis resource = JedisUtils.getResource(0); Transaction transaction = resource.multi(); @@ -1036,7 +1042,7 @@ public class ConfigJedisServiceimpl implements ConfigRedisService { // 按序号选择Redis数据库 transaction.select(redisDb); removeConfig(id, maatXmlConfig, maatVersion, service, transaction, redisDb, - idRelaRedisDBIndex,isStart); + idRelaRedisDBIndex, isStart); } } else { throw new ServiceRuntimeException("删除配置时,未发现对应的配置id信息,请检查配置参数是否正确", @@ -1090,8 +1096,6 @@ public class ConfigJedisServiceimpl implements ConfigRedisService { return false; } - - /** * 获取关联关系中每个关系中的-前部分 * @@ -1115,7 +1119,7 @@ public class ConfigJedisServiceimpl implements ConfigRedisService { * @param service 业务类型 * @param redisTemplate * @param maatRelation id对应关系对象 - * @param isStart 是否将配置置为生效 + * @param isStart 是否将配置置为生效 */ private void removeConfig(Long id, MaatXmlConfig maatXmlConfig, Double maatVersion, int service, Transaction transaction, int redisDBIndex, int idRelaRedisDBIndex, boolean isStart) { diff --git a/src/main/java/com/nis/web/service/restful/ConfigPzIdService.java b/src/main/java/com/nis/web/service/restful/ConfigPzIdService.java index 9e09f14..bc7195f 100644 --- a/src/main/java/com/nis/web/service/restful/ConfigPzIdService.java +++ b/src/main/java/com/nis/web/service/restful/ConfigPzIdService.java @@ -9,7 +9,6 @@ import java.util.LinkedList; import java.util.List; import java.util.Map; -import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -27,8 +26,6 @@ import com.zdjizhi.utils.StringUtil; */ @Service public class ConfigPzIdService extends BaseLogService { - - protected final Logger logger = Logger.getLogger(this.getClass()); /** * 持久层对象 */ diff --git a/src/main/java/com/nis/web/service/restful/ConfigSourcesService.java b/src/main/java/com/nis/web/service/restful/ConfigSourcesService.java index 6730f4e..1abecf9 100644 --- a/src/main/java/com/nis/web/service/restful/ConfigSourcesService.java +++ b/src/main/java/com/nis/web/service/restful/ConfigSourcesService.java @@ -122,6 +122,8 @@ public class ConfigSourcesService extends BaseService { */ public void saveMaatConfig(AuditLogThread thread, long start, List configCompileList, StringBuffer sb) throws Exception { + + long currentTimeMillis = System.currentTimeMillis(); Map> maatMap = new HashMap>(); Map> configMap = new HashMap>(); @@ -207,7 +209,6 @@ public class ConfigSourcesService extends BaseService { } } maatConfig.setIpClientRangeMapList(dstMaplList); - if (maatMap.containsKey(service)) { maatMap.get(service).add(maatConfig); } else { @@ -254,6 +255,9 @@ public class ConfigSourcesService extends BaseService { } } logger.info("---------------调用Redis maat配置新增接口---------------------"); + + long end = System.currentTimeMillis(); + logger.warn("执行ConfigSourcesService.saveMaatConfig用时{}毫秒",end-currentTimeMillis); configRedisService.saveMaatConfig(configMap); } diff --git a/src/main/java/com/nis/web/service/restful/DataDictionaryService.java b/src/main/java/com/nis/web/service/restful/DataDictionaryService.java index 4e53238..37523c9 100644 --- a/src/main/java/com/nis/web/service/restful/DataDictionaryService.java +++ b/src/main/java/com/nis/web/service/restful/DataDictionaryService.java @@ -4,9 +4,12 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; -import org.apache.log4j.Logger; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; + import com.nis.domain.Page; import com.nis.domain.restful.DataDictionaryName; import com.nis.domain.restful.DataDictionaryValue; @@ -14,7 +17,7 @@ import com.nis.web.dao.DataDictionaryDao; @Service public class DataDictionaryService { - protected final Logger logger1 = Logger.getLogger(this.getClass()); + protected final Logger logger = LoggerFactory.getLogger(DataDictionaryService.class); @Autowired private DataDictionaryDao dataDictionaryDao; diff --git a/src/main/java/com/nis/web/service/restful/EventService.java b/src/main/java/com/nis/web/service/restful/EventService.java index 33f0e0b..3279594 100644 --- a/src/main/java/com/nis/web/service/restful/EventService.java +++ b/src/main/java/com/nis/web/service/restful/EventService.java @@ -1,20 +1,22 @@ package com.nis.web.service.restful; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + import com.nis.domain.Page; import com.nis.domain.restful.EventKeyProtection; import com.nis.domain.restful.EventMonitorOrBlock; import com.nis.util.CalendarUtils; import com.nis.util.DateUtils; import com.nis.web.dao.EventServiceDao; -import org.springframework.stereotype.Service; -import org.springframework.beans.factory.annotation.Autowired; -import org.apache.log4j.Logger; - -import java.text.ParseException; -import java.text.SimpleDateFormat; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; /** * @author GouGe @@ -24,8 +26,7 @@ import java.util.List; public class EventService { @Autowired EventServiceDao eventServiceDao; - - protected final Logger logger = Logger.getLogger(SystemHomePageService.class); + protected final Logger logger = LoggerFactory.getLogger(EventService.class); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); /** diff --git a/src/main/java/com/nis/web/service/restful/SystemHomePageService.java b/src/main/java/com/nis/web/service/restful/SystemHomePageService.java index 7095c9f..d437f0a 100644 --- a/src/main/java/com/nis/web/service/restful/SystemHomePageService.java +++ b/src/main/java/com/nis/web/service/restful/SystemHomePageService.java @@ -11,7 +11,8 @@ import java.util.Map; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; -import org.apache.log4j.Logger; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -30,7 +31,9 @@ public class SystemHomePageService { @Autowired SystemHomePageDao systemHomePageDao; - protected final Logger logger = Logger.getLogger(SystemHomePageService.class); + protected final Logger logger =LoggerFactory.getLogger(SystemHomePageService.class); + + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 获取地域流量 diff --git a/src/main/java/com/nis/web/task/SyncRedisToCluster.java b/src/main/java/com/nis/web/task/SyncRedisToCluster.java index 0e3f963..cb4991b 100644 --- a/src/main/java/com/nis/web/task/SyncRedisToCluster.java +++ b/src/main/java/com/nis/web/task/SyncRedisToCluster.java @@ -1,5 +1,20 @@ package com.nis.web.task; +import java.util.ArrayList; +import java.util.Collections; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Set; +import java.util.TreeSet; +import java.util.UUID; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.context.annotation.PropertySource; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + import com.nis.restful.RestBusinessCode; import com.nis.restful.ServiceRuntimeException; import com.nis.util.Configurations; @@ -8,16 +23,16 @@ import com.nis.util.ExceptionUtil; import com.nis.util.JedisUtils; import com.nis.web.service.SpringContextHolder; import com.nis.web.service.restful.ConfigJedisServiceimpl; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.context.annotation.PropertySource; -import org.springframework.stereotype.Component; -import redis.clients.jedis.*; + +import redis.clients.jedis.Jedis; +import redis.clients.jedis.JedisCluster; +import redis.clients.jedis.JedisPool; +import redis.clients.jedis.ScanParams; +import redis.clients.jedis.ScanResult; +import redis.clients.jedis.Tuple; import redis.clients.jedis.exceptions.JedisException; import redis.clients.util.JedisClusterCRC16; -import java.util.*; - @Component @PropertySource(value = { "classpath:nis.properties", "classpath:jdbc.properties" }) public class SyncRedisToCluster { @@ -57,7 +72,7 @@ public class SyncRedisToCluster { } } - //@Scheduled(cron = "${syncRedisToClusterCron}") +// @Scheduled(cron = "${syncRedisToClusterCron}") public void syncRedisToCluster() { JedisCluster jedisCluster = getResource(); String requestId = UUID.randomUUID().toString(); diff --git a/src/main/java/com/nis/web/test/HelloWorldController.java b/src/main/java/com/nis/web/test/HelloWorldController.java index e1f01c5..8b1c11d 100644 --- a/src/main/java/com/nis/web/test/HelloWorldController.java +++ b/src/main/java/com/nis/web/test/HelloWorldController.java @@ -69,7 +69,6 @@ public class HelloWorldController extends BaseController{ @RequestMapping("/testPathVariable/{id}") public String testPathVariable(@PathVariable("id") int id){ - logger.info(id); return "success"; } diff --git a/src/main/resources/log4j.properties b/src/main/resources/log4j.properties deleted file mode 100644 index 2e2930c..0000000 --- a/src/main/resources/log4j.properties +++ /dev/null @@ -1,23 +0,0 @@ -#Log4j -log4j.rootLogger=info,console,file -# 控制台日志设置 -log4j.appender.console=org.apache.log4j.ConsoleAppender -log4j.appender.console.Threshold=info -log4j.appender.console.layout=org.apache.log4j.PatternLayout -log4j.appender.console.layout.ConversionPattern=[%d{yyyy-MM-dd HH\:mm\:ss}] [%-5p] [Thread\:%t] %l %x - <%m>%n - -# 文件日志设置 -log4j.appender.file=org.apache.log4j.DailyRollingFileAppender -log4j.appender.file.Threshold=info -log4j.appender.file.encoding=UTF-8 -log4j.appender.file.Append=true -#tomcat启动时首先判断CATALINA_HOME环境变量是否为空，如果为空，就将当前目录设为CATALINA_HOME的值,所以这里log4j可以直接使用环境变量的值 -log4j.appender.file.file=${catalina.home}/logs/nis.log -log4j.appender.file.DatePattern='.'yyyy-MM-dd -log4j.appender.file.layout=org.apache.log4j.PatternLayout -#log4j.appender.file.layout.ConversionPattern=%d{HH:mm:ss} %X{ip} [%t] %5p %c{1} %m%n -log4j.appender.file.layout.ConversionPattern=[%d{yyyy-MM-dd HH\:mm\:ss}] [%-5p] %X{ip} [Thread\:%t] %l %x - %m%n -#MyBatis 配置，com.nis.web.dao是mybatis接口所在包 -log4j.logger.com.nis.web.dao=debug -#bonecp数据源配置 -log4j.category.com.jolbox=debug,console \ No newline at end of file diff --git a/src/main/resources/log4j2.xml b/src/main/resources/log4j2.xml new file mode 100644 index 0000000..0c89a32 --- /dev/null +++ b/src/main/resources/log4j2.xml @@ -0,0 +1,93 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/src/main/resources/mybatis-config.xml b/src/main/resources/mybatis-config.xml index fafc57f..5719af8 100644 --- a/src/main/resources/mybatis-config.xml +++ b/src/main/resources/mybatis-config.xml @@ -47,7 +47,7 @@ - + diff --git a/src/main/webapp/WEB-INF/web.xml b/src/main/webapp/WEB-INF/web.xml index 1b6c81a..47ebaa0 100644 --- a/src/main/webapp/WEB-INF/web.xml +++ b/src/main/webapp/WEB-INF/web.xml @@ -80,7 +80,7 @@ log4jConfigLocation - classpath:log4j.properties + classpath:log4j2.xml