Java中的MarkerFilter的應(yīng)用場景及使用示例詳解
背景
- 有一個系統(tǒng)是負責(zé)從消息隊列收集日志的,現(xiàn)在系統(tǒng)收集到的日志能和這個系統(tǒng)本身的日志分開
- 使用log4j2
<!--log4j2依賴-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-log4j2</artifactId>
<version>2.0.1.RELEASE</version>
</dependency>
<!-- Log4j2 異步支持 -->
<dependency>
<groupId>com.lmax</groupId>
<artifactId>disruptor</artifactId>
<version>3.3.6</version>
</dependency>解決方案
給我們需要的日志時間給一個特定的標(biāo)記(Marker),然后使用MarkerFilter來區(qū)分收集的日志與系統(tǒng)本身的日志
代碼
log4j2.xml配置示例
<?xml version="1.0" encoding="UTF-8"?>
<!-- Configuration后面的status,這個用于設(shè)置log4j2自身內(nèi)部的信息輸出,可以不設(shè)置,當(dāng)設(shè)置成trace時,
你會看到log4j2內(nèi)部各種詳細輸出。可以設(shè)置成OFF(關(guān)閉)或Error(只輸出錯誤信息)
-->
<Configuration status="error" monitorInterval="60">
<!-- 日志文件目錄和壓縮文件目錄配置 -->
<Properties>
<Property name="level">debug</Property>
<Property name="fileName">./logs/test-program</Property>
<Property name="fileGz">./logs/test-program</Property>
<Property name="LOG_PATTERN">
%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level - %logger{36}.%M[%L] - %msg%xEx%n
</Property>
</Properties>
<Appenders>
<!-- 輸出控制臺日志的配置 -->
<Console name="console" target="SYSTEM_OUT">
<!--控制臺只輸出level及以上級別的信息(onMatch),其他的直接拒絕(onMismatch)-->
<ThresholdFilter level="ERROR" onMatch="ACCEPT" onMismatch="DENY"/>
<!-- 輸出日志的格式 -->
<PatternLayout pattern="${LOG_PATTERN}"/>
</Console>
<!-- 打印出所有的信息,每次大小超過size,則這size大小的日志會自動存入按年份-月份建立的文件夾下面并進行壓縮,作為存檔 -->
<RollingRandomAccessFile name="appLogAppender" fileName="${fileName}/app.log" immediateFlush="false"
filePattern="${fileGz}/$${date:yyyy-MM}/app-%d{MM-dd-yyyy}-%i.gz">
<PatternLayout pattern="${LOG_PATTERN}"/>
<Policies>
<TimeBasedTriggeringPolicy interval="6" modulate="true"/>
<SizeBasedTriggeringPolicy size="100 MB"/>
</Policies>
<Filters>
<!--如果日志事件LogEvent中有COLLECTED標(biāo)記,則直接拒絕這個日志事件-->
<MarkerFilter marker="COLLECTED" onMatch="DENY" onMismatch="NEUTRAL"/>
<!--如果日志事件LogEvent中的日志等級為${level}及以上,則接受這個日志事件-->
<ThresholdFilter level="${level" onMatch="ACCEPT" onMismatch="DENY"/>
</Filters>
<!-- 指定每天的最大壓縮包個數(shù),默認7個,超過了會覆蓋之前的 -->
<DefaultRolloverStrategy max="10"/>
</RollingRandomAccessFile>
<!-- 打印出所有的信息,每次大小超過size,則這size大小的日志會自動存入按年份-月份建立的文件夾下面并進行壓縮,作為存檔 -->
<RollingRandomAccessFile name="collectedLogAppender" fileName="${fileName}/collected.log" immediateFlush="false"
filePattern="${fileGz}/$${date:yyyy-MM}/collected-%d{MM-dd-yyyy}-%i.gz">
<PatternLayout pattern="%msg%xEx%n"/>
<Policies>
<TimeBasedTriggeringPolicy interval="6" modulate="true"/>
<SizeBasedTriggeringPolicy size="500 MB"/>
</Policies>
<Filters>
<!--如果日志事件LogEvent中有COLLECTED標(biāo)記,則繼續(xù)走接下來的filter,如果接下來沒有其他的filter,onMatch的動作填A(yù)CCEPT就好了-->
<MarkerFilter marker="COLLECTED" onMatch="NEUTRAL" onMismatch="DENY"/>
<ThresholdFilter level="${level" onMatch="ACCEPT" onMismatch="DENY"/>
</Filters>
<!-- 指定每天的最大壓縮包個數(shù),默認7個,超過了會覆蓋之前的 -->
<DefaultRolloverStrategy max="1000"/>
</RollingRandomAccessFile>
</Appenders>
<!-- 全局配置,默認所有的Logger都繼承此配置 -->
<Loggers>
<Root level="${level}" additivity="false" includeLocation="true">
<AppenderRef ref="collectedLogAppender"/>
<AppenderRef ref="appLogAppender"/>
<AppenderRef ref="console"/>
</Root>
</Loggers>
</Configuration>代碼示例
//需要引入lombok的依賴
import lombok.extern.slf4j.Slf4j;
//這里包名容易搞錯,需要特別注意
import org.slf4j.Marker;
import org.slf4j.MarkerFactory;
import org.slf4j.Marker;
@Slf4j
public class LogCollector {
private static final Marker COLLECTED_MARKER = MarkerFactory.getMarker("test_marker");
public static void main(String[] args) {
log.info(COLLECTED_MARKER, "Test message~");
}
}結(jié)果
可以發(fā)現(xiàn)在./logs/test-program目錄下,有兩個日志文件:
- 一個只有收集到的日志:collected.log
- 一個只有系統(tǒng)日志: app.log
到此這篇關(guān)于Java中的MarkerFilter的應(yīng)用場景及使用示例詳解的文章就介紹到這了,更多相關(guān)MarkerFilter應(yīng)用場景及使用示例內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
MyBatis自定義TypeHandler實現(xiàn)字段加密解密
本文主要介紹了MyBatis自定義TypeHandler實現(xiàn)字段加密解密,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2025-03-03
Gson中@JsonAdater注解的幾種方式總結(jié)
這篇文章主要介紹了Gson中@JsonAdater注解的幾種方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-08-08
kafka運維consumer-groups.sh消費者組管理
這篇文章主要為大家介紹了kafka運維consumer-groups.sh消費者組管理,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-11-11
全面理解java中的構(gòu)造方法以及this關(guān)鍵字的用法
本篇文章主要概述了如何用構(gòu)造方法初始化對象,this屬性名訪問成員變量方法,和this()的用法,感興趣的小伙伴一起來學(xué)習(xí)吧2023-03-03
關(guān)于Java父類沒有無參構(gòu)造方法子類處理方法
父類無參構(gòu)造方法,子類不寫,其實會默認調(diào)用父類的無參構(gòu)造方法也就是用super(),編譯運行后,會打印出"子類會調(diào)用Father的第一個構(gòu)造方法,這篇文章給大家介紹關(guān)于Java父類沒有無參構(gòu)造方法子類處理方法,感興趣的朋友一起看看吧2024-01-01

