集成RocketMQ,項目啟動后rocketmq_client.log日志文件配置


項目添加RocketMQ以后啟動項目時會在user.home下創建一個rocketmq_client.log日志文件,文件全路徑是:${user.home}/logs/rocketmqlogs/rocketmq_client.log。由於我們的服務器數據盤不在home路徑下,會導致系統盤空間占用不斷增大,所以需要配置日志目錄到其他路徑。

通過源碼org.apache.rocketmq.client.log.ClientLogger可以看到,在項目啟動時會讀取是否啟動slf4j配置,讀取的配置名稱是:rocketmq.client.logUseSlf4j,如果是則會直接獲取logger名稱為RocketmqClient,Appender名稱為RocketmqClientAppender的配置,以下是源碼:

public class ClientLogger {

    public static final String CLIENT_LOG_USESLF4J = "rocketmq.client.logUseSlf4j";
    public static final String CLIENT_LOG_ROOT = "rocketmq.client.logRoot";
    public static final String CLIENT_LOG_MAXINDEX = "rocketmq.client.logFileMaxIndex";
    public static final String CLIENT_LOG_FILESIZE = "rocketmq.client.logFileMaxSize";
    public static final String CLIENT_LOG_LEVEL = "rocketmq.client.logLevel";
    public static final String CLIENT_LOG_ADDITIVE = "rocketmq.client.log.additive";
    public static final String CLIENT_LOG_FILENAME = "rocketmq.client.logFileName";
    public static final String CLIENT_LOG_ASYNC_QUEUESIZE = "rocketmq.client.logAsyncQueueSize";
    public static final String ROCKETMQ_CLIENT_APPENDER_NAME = "RocketmqClientAppender";

    private static final InternalLogger CLIENT_LOGGER;

    private static final boolean CLIENT_USE_SLF4J;

    //private static Appender rocketmqClientAppender = null;

    static {
        // 獲取是否啟動slf4j配置
        CLIENT_USE_SLF4J = Boolean.parseBoolean(System.getProperty(CLIENT_LOG_USESLF4J, "false"));
        if (!CLIENT_USE_SLF4J) {
            InternalLoggerFactory.setCurrentLoggerType(InnerLoggerFactory.LOGGER_INNER);
            CLIENT_LOGGER = createLogger(LoggerName.CLIENT_LOGGER_NAME);
            createLogger(LoggerName.COMMON_LOGGER_NAME);
            createLogger(RemotingHelper.ROCKETMQ_REMOTING);
        } else {
            // 獲取logger
            CLIENT_LOGGER = InternalLoggerFactory.getLogger(LoggerName.CLIENT_LOGGER_NAME);
        }
    }

    // .........
}

網上很多文章都說可以通過在配置文件中添加rocketmq.client.logUseSlf4j即可,但是我添加后通過debug上面的static塊發現並沒有讀取到,所以只能在項目啟動類中添加以下代碼:

public class Application {
    public static void main(String[] args) {
        System.setProperty(ClientLogger.CLIENT_LOG_USESLF4J,"true");
        SpringApplication.run(Application.class, args);
    }
}

添加完以上代碼后,然后在配置日志的輸出,我用的logback作為日志輸出,具體配置如下:

<!-- rocketmq日志 -->
    <appender name="RocketmqClientAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${LOG_DIR}/${APP_NAME}/rocketmq_client.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
            <fileNamePattern>${LOG_DIR}/${APP_NAME}/history/rocketmq_client.%d{yyyyMMdd}.%i.log</fileNamePattern>
            <maxFileSize>${LOG_MAXFILESIZE}</maxFileSize>
            <!--保留時間,單位:天-->
            <maxHistory>${LOG_FILEMAXDAY}</maxHistory>
        </rollingPolicy>
        <encoder charset="UTF-8">
            <pattern>%d{yy-MM-dd.HH:mm:ss.SSS} [%-16t] %-5p %-22c{0} %X{ServiceId} - %m%n</pattern>
        </encoder>
    </appender>
    <logger name="RocketmqClient" additivity="false">
        <level value="warn" />
        <appender-ref ref="RocketmqClientAppender"/>
    </logger>

上面的變量可以直接固定,我的項目中所有服務模塊中使用了一個統一的日志文件,所以需要在日志配置的xml頂部配置屬性,如果使用的是logback.xml則把下面的springProperty標簽換成property標簽,我使用的是logback-spring.xml,所以使用的springProperty標簽:

<configuration>
    <contextName>${APP_NAME}</contextName>
    <springProperty name="APP_NAME" scope="context" source="spring.application.name"/>
    <springProperty name="LOG_DIR" scope="context" source="platform.logging.dir" defaultValue="../logs/${APP_NAME}"/>
    <springProperty name="LOG_LEVEL" scope="context" source="platform.logging.level" defaultValue="INFO"/>
    <springProperty name="LOG_POINT_FILE" scope="context" source="platform.logging.dir" defaultValue="../logs/point"/>
    <springProperty name="LOG_MAXFILESIZE" scope="context" source="platform.logging.maxsize" defaultValue="200MB"/>
    <springProperty name="LOG_FILEMAXDAY" scope="context" source="platform.logging.maxday" defaultValue="60"/>
    <springProperty name="ServerIP" scope="context" source="spring.cloud.client.ip-address" defaultValue="0.0.0.0"/>
    <springProperty name="ServerPort" scope="context" source="server.port" defaultValue="0000"/>
</configuration>

配置完畢,啟動項目可以看到日志文件已經到指定的位置了


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM