第關(guān)于log4j2的異步日志輸出方式第二種實(shí)現(xiàn)異步方式AsyncLogger

Log4j2中的AsyncLogger的內(nèi)部使用了Disruptor框架。

Disruptor簡介

Disruptor是英國外匯交易公司LMAX開發(fā)的一個(gè)高性能隊(duì)列，基于Disruptor開發(fā)的系統(tǒng)單線程能支撐每秒600萬訂單。

目前，包括ApacheStrom、Log4j2在內(nèi)的很多知名項(xiàng)目都應(yīng)用了Disruptor來獲取高性能。

Disruptor框架內(nèi)部核心數(shù)據(jù)結(jié)構(gòu)為RingBuffer，其為無鎖環(huán)形隊(duì)列。

Disruptor為什么這么快？

lock-free-使用了CAS來實(shí)現(xiàn)線程安全

使用緩存行填充解決偽共享問題

首先在pom單中應(yīng)用相關(guān)的包

dependency

groupIdcom.lmax/groupId

artifactIddisruptor/artifactId

version3.4.2/version

/dependency

第二步在log4j2的xml文件中配置AsyncLogger

log4j2.xml配置如下：

xmlversion="1.0"encoding="UTF-8"

Configurationstatus="debug"name="MyApp"packages=""

Appenders

Consolename="Console"target="SYSTEM_OUT"

PatternLayoutpattern="%d{HH:mm:ss.SSS}[%t]%-5level%logger{36}-%msg%n"/

/Console

RollingFilename="RollingFile"fileName="logs/app.log"

filePattern="logs/app-%d{yyyy-MM-ddHH}.log"

PatternLayout

Pattern%d%p%c{1.}[%t]%m%n/Pattern

/PatternLayout

Policies

SizeBasedTriggeringPolicysize="500MB"/

/Policies

/RollingFile

RollingFilename="RollingFile2"fileName="logs/app2.log"

filePattern="logs/app2-%d{yyyy-MM-ddHH}.log"

PatternLayout

Pattern%d%p%c{1.}[%t]%m%n/Pattern

/PatternLayout

Policies

SizeBasedTriggeringPolicysize="500MB"/

/Policies

/RollingFile

/Appenders

Loggers

!--上面的配置都和原配置一樣，就是在下方這直接定義AsyncLogger，他的name在java類中被引用即可--

AsyncLoggername="com.meituan.Main"level="trace"additivity="false"

appender-refref="RollingFile"/

/AsyncLogger

AsyncLoggername="RollingFile2"level="trace"additivity="false"

appender-refref="RollingFile2"/

/AsyncLogger

Rootlevel="debug"

AppenderRefref="Console"/

AppenderRefref="RollingFile"/

/Root

/Loggers

/Configuration

java代碼如下：

publicclassMain{

publicstaticvoidmain(Stringargs[]){

//引用com.meituan.Main日志輸出器

Loggerlogger=LogManager.getLogger(Main.class);

//引用的名為RollingFile2的異步AsyncLogger

Loggerlogger2=LogManager.getLogger("RollingFile2");

Personperson=newPerson("Li","lei");

("hello,{}",person);

("goodbye,{}",person);

}

上述log4j2.xml中配置了兩個(gè)AsyncLogger，名字分別為com.meituan.Main和RollingFile2。

并且，在main方法中分別使用兩個(gè)logger來輸出兩條日志。

在加載log4j2.xml的啟動(dòng)階段，如果檢測到配置了AsyncRoot或AsyncLogger，將啟動(dòng)一個(gè)disruptor實(shí)例。

log4j2異步注意事項(xiàng)

log4j2異步類型

1)使用Async標(biāo)簽

示例：

Asyncname="asyncKafkaLog"

AppenderRefref="Failover"/

/Async

注意事項(xiàng)：此類異步隊(duì)列是BockingQueue，隊(duì)列默認(rèn)大小是128

2)使用AsyncLogger標(biāo)簽

示例：

AsyncLoggername="kafkaLogger"level="trace"includeLocation="false"

AppenderRefref="Failover"/

/AsyncLogger

注意事項(xiàng)：此類異步隊(duì)列是Disruptor隊(duì)列默認(rèn)大小是4096

3)使用JVM參數(shù)

示例：

#啟動(dòng)參數(shù)方式

-DLog4jContextSelector=org.apache.logging.log4j.core.async.AsyncLoggerContextSelector

#代碼方式

System.setProperty("Log4jContextSelector","org.apache.logging.log4j.core.async.AsyncLoggerContextSelector");

注意事項(xiàng)：此類異步是全量異步，log4j配置文件里所有l(wèi)ogger都自動(dòng)異步，使用異步隊(duì)列為Disruptor，隊(duì)列默認(rèn)大小4096

小提示

①Disruptor隊(duì)列性能遠(yuǎn)勝于BlockingQueue，這也是log4j2性能提升的重要原因之一

②如果啟用了全量異步，又使用了AsyncLogger會(huì)如何？

log4j2會(huì)新建兩個(gè)Disruptor隊(duì)列，AsyncLogger之流使用一個(gè)，其他的使用另外一個(gè)，所以建議將可能發(fā)生阻塞的logger歸類使用一個(gè)Disruptor，畢竟是隊(duì)列，一個(gè)阻塞了其他的得乖乖等著

③如果默認(rèn)隊(duì)列長度不足咋辦？

#第一步：加大兩個(gè)Disruptor隊(duì)列的長度

-DAsyncLogger.Ring