自定义Log4j配置文件和RocketMQ-Client.jar下log文件冲突问题解决

Posted Java硅谷

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了自定义Log4j配置文件和RocketMQ-Client.jar下log文件冲突问题解决相关的知识，希望对你有一定的参考价值。

项目jar正常，我们项目log4j中已经配置了root日志级别level为info，但是启动项目后，自定义logger日志只能打印error级别。
启动服务时总是出现没有设置root logger的日志级别。
 
   
   
 
    
  
    
    
  
  1. 2018-05-09 16:24:34,309 main WARN No Root logger was configured, 
    2. 
  
    
    
  
  2. creating default ERROR-level Root logger with Console appender
    3.
但是我们日志文件已经设置了info级别
 
   
   
 
    
  
    
    
  
  1.  <Root level="INFO">
    2. 
  
    
    
  
  2.       <AppenderRef ref="ConsoleAppend"/>
    3. 
  
    
    
  
  3.     </Root>
    4.

分析

经过debug发现，加载的日志文件不是我们配置的日志文件，而是rocketmq下的配置的日志文件。

打开该配置文件

 
   
   
 
    
  
    
    
  
  1. <!DOCTYPE xml>
    2. 
  
    
    
  
  2. <Configuration status="warn" name="RocketmqClient">
    3. 
  
    
    
  
  3.     <Appenders>
    4. 
  
    
    
  
  4.         <Console name="STDOUT-APPENDER">
    5. 
  
    
    
  
  5.             <PatternLayout pattern="%-5p %c{2} , %m%n"/>
    6. 
  
    
    
  
  6.         </Console>
    7. 
  
    
    
  
  7.         <RollingFile name="RocketmqClientAppender" fileName="${sys:client.logRoot}/rocketmq_client.log"
    8. 
  
    
    
  
  8.                      filePattern="${sys:client.logRoot}/rocketmq_client-%d{yyyy-MM-dd}-%i.log">
    9. 
  
    
    
  
  9.             <PatternLayout pattern="%d{yyy-MM-dd HH\:mm\:ss,SSS} %p %c{1}(%L) - %m%n"/>
    10. 
  
    
    
  
  10.             <Policies>
    11. 
  
    
    
  
  11.                 <TimeBasedTriggeringPolicy/>
    12. 
  
    
    
  
  12.                 <SizeBasedTriggeringPolicy size="1 GB"/>
    13. 
  
    
    
  
  13.             </Policies>
    14. 
  
    
    
  
  14.             <DefaultRolloverStrategy max="${sys:client.logFileMaxIndex}"/>
    15. 
  
    
    
  
  15.         </RollingFile>
    16. 
  
    
    
  
  16.     </Appenders>
    17. 
  
    
    
  
  17.     <Loggers>
    18. 
  
    
    
  
  18.         <logger name="RocketmqClient" level="${sys:client.logLevel}" additivity="false">
    19. 
  
    
    
  
  19.             <appender-ref ref="RocketmqClientAppender"/>
    20. 
  
    
    
  
  20.         </logger>
    21. 
  
    
    
  

    22. 
  
    
    
  
  22.         <logger name="RocketmqCommon" level="${sys:client.logLevel}" additivity="false">
    23. 
  
    
    
  
  23.             <appender-ref ref="RocketmqClientAppender"/>
    24. 
  
    
    
  
  24.         </logger>
    25. 
  
    
    
  

    26. 
  
    
    
  
  26.         <logger name="RocketmqRemoting" level="${sys:client.logLevel}" additivity="false">
    27. 
  
    
    
  
  27.             <appender-ref ref="RocketmqClientAppender"/>
    28. 
  
    
    
  
  28.         </logger>
    29. 
  
    
    
  
  29.     </Loggers>
    30. 
  
    
    
  
  30. </Configuration>
    31.

分析确实不存在root level的配置。

1、我们自定义的日志配置文件

2、目前我们使用的是rocketmq-4.2.0版本

3、分析mq日志配置源码ClientLogger
 
   
   
 
    
  
    
    
  
  1. public class ClientLogger {
    2. 
  
    
    
  

    3. 
  
    
    
  
  3.     public static final String CLIENT_LOG_ROOT = "rocketmq.client.logRoot";
    4. 
  
    
    
  
  4.     public static final String CLIENT_LOG_MAXINDEX = "rocketmq.client.logFileMaxIndex";
    5. 
  
    
    
  
  5.     public static final String CLIENT_LOG_LEVEL = "rocketmq.client.logLevel";
    6. 
  
    
    
  

    7. 
  
    
    
  
  7.     private static Logger log;
    8. 
  
    
    
  

    9. 
  
    
    
  
  9.     private static Logger createLogger(final String loggerName) {
    10. 
  
    
    
  
  10.         //System.getProperty获取logConfigFilePath
    11. 
  
    
    
  
  11.         String logConfigFilePath = System.getProperty("rocketmq.client.log.configFile", System.getenv("ROCKETMQ_CLIENT_LOG_CONFIGFILE"));
    12. 
  
    
    
  
  12.         //是否加载rocketmq.client.log.loadconfig--默认为true
    13. 
  
    
    
  
  13.         Boolean isloadconfig =
    14. 
  
    
    
  
  14.             Boolean.parseBoolean(System.getProperty("rocketmq.client.log.loadconfig", "true"));
    15. 
  
    
    
  
  15.         //log4J日志资源配置
    16. 
  
    
    
  
  16.         final String log4JResourceFile =
    17. 
  
    
    
  
  17.             System.getProperty("rocketmq.client.log4j.resource.fileName", "log4j_rocketmq_client.xml");
    18. 
  
    
    
  
  18.         //logback日志资源配置
    19. 
  
    
    
  
  19.         final String logbackResourceFile =
    20. 
  
    
    
  
  20.             System.getProperty("rocketmq.client.logback.resource.fileName", "logback_rocketmq_client.xml");
    21. 
  
    
    
  
  21.         //log4J2日志资源配置
    22. 
  
    
    
  
  22.         final String log4J2ResourceFile =
    23. 
  
    
    
  
  23.             System.getProperty("rocketmq.client.log4j2.resource.fileName", "log4j2_rocketmq_client.xml");
    24. 
  
    
    
  

    25. 
  
    
    
  
  25.         String clientLogRoot = System.getProperty(CLIENT_LOG_ROOT, System.getProperty("user.home") + "/logs/rocketmqlogs");
    26. 
  
    
    
  
  26.         System.setProperty("client.logRoot", clientLogRoot);
    27. 
  
    
    
  
  27.         String clientLogLevel = System.getProperty(CLIENT_LOG_LEVEL, "INFO");
    28. 
  
    
    
  
  28.         System.setProperty("client.logLevel", clientLogLevel);
    29. 
  
    
    
  
  29.         String clientLogMaxIndex = System.getProperty(CLIENT_LOG_MAXINDEX, "10");
    30. 
  
    
    
  
  30.         System.setProperty("client.logFileMaxIndex", clientLogMaxIndex);
    31. 
  
    
    
  
  31.         //允许加载配置
    32. 
  
    
    
  
  32.         if (isloadconfig) {
    33. 
  
    
    
  
  33.             try {
    34. 
  
    
    
  
  34.                 ILoggerFactory iLoggerFactory = LoggerFactory.getILoggerFactory();
    35. 
  
    
    
  
  35.                 Class classType = iLoggerFactory.getClass();
    36. 
  
    
    
  
  36.                 if (classType.getName().equals("org.slf4j.impl.Log4jLoggerFactory")) {
    37. 
  
    
    
  
  37.                     Class<?> domconfigurator;
    38. 
  
    
    
  
  38.                     Object domconfiguratorobj;
    39. 
  
    
    
  
  39.                     domconfigurator = Class.forName("org.apache.log4j.xml.DOMConfigurator");
    40. 
  
    
    
  
  40.                     domconfiguratorobj = domconfigurator.newInstance();
    41. 
  
    
    
  
  41.                     if (null == logConfigFilePath) {
    42. 
  
    
    
  
  42.                         Method configure = domconfiguratorobj.getClass().getMethod("configure", URL.class);
    43. 
  
    
    
  
  43.                         URL url = org.apache.rocketmq.client.log.ClientLogger.class.getClassLoader().getResource(log4JResourceFile);
    44. 
  
    
    
  
  44.                         configure.invoke(domconfiguratorobj, url);
    45. 
  
    
    
  
  45.                     } else {
    46. 
  
    
    
  
  46.                         Method configure = domconfiguratorobj.getClass().getMethod("configure", String.class);
    47. 
  
    
    
  
  47.                         configure.invoke(domconfiguratorobj, logConfigFilePath);
    48. 
  
    
    
  
  48.                     }
    49. 
  
    
    
  

    50. 
  
    
    
  
  50.                 } else if (classType.getName().equals("ch.qos.logback.classic.LoggerContext")) {
    51. 
  
    
    
  
  51.                     Class<?> joranConfigurator;
    52. 
  
    
    
  
  52.                     Class<?> context = Class.forName("ch.qos.logback.core.Context");
    53. 
  
    
    
  
  53.                     Object joranConfiguratoroObj;
    54. 
  
    
    
  
  54.                     joranConfigurator = Class.forName("ch.qos.logback.classic.joran.JoranConfigurator");
    55. 
  
    
    
  
  55.                     joranConfiguratoroObj = joranConfigurator.newInstance();
    56. 
  
    
    
  
  56.                     Method setContext = joranConfiguratoroObj.getClass().getMethod("setContext", context);
    57. 
  
    
    
  
  57.                     setContext.invoke(joranConfiguratoroObj, iLoggerFactory);
    58. 
  
    
    
  
  58.                     if (null == logConfigFilePath) {
    59. 
  
    
    
  
  59.                         URL url = org.apache.rocketmq.client.log.ClientLogger.class.getClassLoader().getResource(logbackResourceFile);
    60. 
  
    
    
  
  60.                         Method doConfigure =
    61. 
  
    
    
  
  61.                             joranConfiguratoroObj.getClass().getMethod("doConfigure", URL.class);
    62. 
  
    
    
  
  62.                         doConfigure.invoke(joranConfiguratoroObj, url);
    63. 
  
    
    
  
  63.                     } else {
    64. 
  
    
    
  
  64.                         Method doConfigure =
    65. 
  
    
    
  
  65.                             joranConfiguratoroObj.getClass().getMethod("doConfigure", String.class);
    66. 
  
    
    
  
  66.                         doConfigure.invoke(joranConfiguratoroObj, logConfigFilePath);
    67. 
  
    
    
  
  67.                     }
    68. 
  
    
    
  

    69. 
  
    
    
  
  69.                 } else if (classType.getName().equals("org.apache.logging.slf4j.Log4jLoggerFactory")) {
    70. 
  
    
    
  
  70.                     Class<?> joranConfigurator = Class.forName("org.apache.logging.log4j.core.config.Configurator");
    71. 
  
    
    
  
  71.                     Method initialize = joranConfigurator.getDeclaredMethod("initialize", String.class, String.class);
    72. 
  
    
    
  
  72.                     if (null == logConfigFilePath) {
    73. 
  
    
    
  
  73.                         initialize.invoke(joranConfigurator, "log4j2", log4J2ResourceFile);
    74. 
  
    
    
  
  74.                     } else {
    75. 
  
    
    
  
  75.                         initialize.invoke(joranConfigurator, "log4j2", logConfigFilePath);
    76. 
  
    
    
  
  76.                     }
    77. 
  
    
    
  
  77.                 }
    78. 
  
    
    
  
  78.             } catch (Exception e) {
    79. 
  
    
    
  
  79.                 System.err.println(e);
    80. 
  
    
    
  
  80.             }
    81. 
  
    
    
  
  81.         }
    82. 
  
    
    
  
  82.         return LoggerFactory.getLogger(LoggerName.CLIENT_LOGGER_NAME);
    83. 
  
    
    
  
  83.     }
    84. 
  
    
    
  

    85. 
  
    
    
  
  85.     public static Logger getLog() {
    86. 
  
    
    
  
  86.         if (log == null) {
    87. 
  
    
    
  
  87.             log = createLogger(LoggerName.CLIENT_LOGGER_NAME);
    88. 
  
    
    
  
  88.             return log;
    89. 
  
    
    
  
  89.         } else {
    90. 
  
    
    
  
  90.             return log;
    91. 
  
    
    
  
  91.         }
    92. 
  
    
    
  
  92.     }
    93. 
  
    
    
  

    94. 
  
    
    
  
  94.     public static void setLog(Logger log) {
    95. 
  
    
    
  
  95.         org.apache.rocketmq.client.log.ClientLogger.log = log;
    96. 
  
    
    
  
  96.     }
    97. 
  
    
    
  

    98. 
  
    
    
  
  98. }
    99.
经过分析可知：我们可以通过 System.setProperty来设置一些属性，屏蔽mq的日志配置，所以我们在mq的配置bean中设置：
 
   
   
 
    
  
    
    
  
  1. RocketMQConfiguration(){
    2. 
  
    
    
  
  2.    System.setProperty("rocketmq.client.log.loadconfig","false");
    3. 
  
    
    
  
  3. }
    4.

参考文章： https://www.cnblogs.com/devilfeng/p/6869166.html https://blog.csdn.net/wyfk2013/article/details/78218221


以上是关于自定义Log4j配置文件和RocketMQ-Client.jar下log文件冲突问题解决的主要内容，如果未能解决你的问题，请参考以下文章

自定义Log4j配置文件和RocketMQ-Client.jar下log文件冲突问题解决

log4j +spring aop+自定义注解方式输出日志

Log4j 自定义配置为每个级别分隔日志 - Playframework 1.2.5

2019-07-03 log4j2 自定义ElasticSearch Appender

Java日志框架 -- LOG4J（Log4j入门案例日志级别Log4j组件（LoggersAppendersLayouts）配置文件内置日志记录自定义Logger）

Java日志框架 -- LOG4J（Log4j入门案例日志级别Log4j组件（LoggersAppendersLayouts）配置文件内置日志记录自定义Logger）