SpringBoot Log4j2發訊息到Kafka以及動態新增KafkaAppender
阿新 • • 發佈：2019-02-05
方法一：log4j2.xml檔案配置
<Appenders>
<Kafkaname
="KAFKA"topic="log4j-kafka" syncSend="false">
<!-- <ThresholdFilter level="error" onMatch="ACCEPT" onMismatch="DENY" /> -->
<MarkerFiltermarker ="kafkaLog"onMatch
="ACCEPT"onMismatch=
"DENY"/>
<PatternLayoutpattern 
Markers類的內容 import org.slf4j.Marker; import org.slf4j.MarkerFactory; publicclass Markers { publicstatic final Marker DB = MarkerFactory.getMarker("dbLog"); publicstatic final Marker KAFKA = MarkerFactory.getMarker("kafkaLog"); } 方法二：動態新增（SpringBoot專案） import java.nio.charset.Charset; import java.util.ArrayList; import java.util.List; import javax.annotation.PostConstruct; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.core.Appender; import org.apache.logging.log4j.core.Filter; import org.apache.logging.log4j.core.Layout; import org.apache.logging.log4j.core.Logger; import org.apache.logging.log4j.core.LoggerContext; import org.apache.logging.log4j.core.appender.mom.kafka.KafkaAppender; import org.apache.logging.log4j.core.config.Configuration; import org.apache.logging.log4j.core.config.DefaultConfiguration; import org.apache.logging.log4j.core.config.Property; import org.apache.logging.log4j.core.filter.MarkerFilter; import org.apache.logging.log4j.core.layout.PatternLayout; import org.springframework.stereotype.Component; @Component publicclass KafkaLogAppender { @PostConstruct publicvoid init(){ final LoggerContext ctx = (LoggerContext) LogManager.getContext(false); final Configuration config = ctx .getConfiguration(); final Logger interLogger = ctx .getLogger("com.hhaip"); //需要寫日誌到資料庫的包名 List<Property>list = new ArrayList<>(); list .add(Property.createProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG ,"0.0.0.0:9092" )); list .add(Property.createProperty(ProducerConfig.ACKS_CONFIG , "1")); list .add(Property.createProperty(ProducerConfig.RETRIES_CONFIG , "3")); list .add(Property.createProperty(ProducerConfig.LINGER_MS_CONFIG , "10000")); list .add(Property.createProperty(ProducerConfig.BUFFER_MEMORY_CONFIG ,"10485760")); list .add(Property.createProperty(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG ,"1000")); Property[]props = list .toArray(new Property[list .size()]); //配置Marker過濾器(標記過濾器和方法一的一樣) MarkerFilterfilter = MarkerFilter.createFilter("kafkaLog", Filter.Result.ACCEPT , Filter.Result.DENY); Configurationconfiguration = new DefaultConfiguration(); Layout<String>layout = PatternLayout.createLayout("%date %message",null , configuration , null , Charset.forName ("UTF-8" ),false , false , null,null); Appenderappender = KafkaAppender.createAppender(layout,filter, "KAFKA" ,true , "log4j-kafka" , props , configuration ); config .addAppender(appender ); interLogger .addAppender(appender ); appender .start(); ctx .updateLoggers(); } } 方法二和方法一的使用是一樣的，也許要定義一個Markers類. 注意：0.0.0.0換成你自己的IP地址
Markers類的內容 import org.slf4j.Marker; import org.slf4j.MarkerFactory; publicclass Markers { publicstatic final Marker DB = MarkerFactory.getMarker("dbLog"); publicstatic final Marker KAFKA = MarkerFactory.getMarker("kafkaLog"); } 方法二：動態新增（SpringBoot專案） import java.nio.charset.Charset; import java.util.ArrayList; import java.util.List; import javax.annotation.PostConstruct; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.core.Appender; import org.apache.logging.log4j.core.Filter; import org.apache.logging.log4j.core.Layout; import org.apache.logging.log4j.core.Logger; import org.apache.logging.log4j.core.LoggerContext; import org.apache.logging.log4j.core.appender.mom.kafka.KafkaAppender; import org.apache.logging.log4j.core.config.Configuration; import org.apache.logging.log4j.core.config.DefaultConfiguration; import org.apache.logging.log4j.core.config.Property; import org.apache.logging.log4j.core.filter.MarkerFilter; import org.apache.logging.log4j.core.layout.PatternLayout; import org.springframework.stereotype.Component; @Component publicclass KafkaLogAppender { @PostConstruct publicvoid init(){ final LoggerContext ctx = (LoggerContext) LogManager.getContext(false); final Configuration config = ctx .getConfiguration(); final Logger interLogger = ctx .getLogger("com.hhaip"); //需要寫日誌到資料庫的包名 List<Property>list = new ArrayList<>(); list .add(Property.createProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG ,"0.0.0.0:9092" )); list .add(Property.createProperty(ProducerConfig.ACKS_CONFIG , "1")); list .add(Property.createProperty(ProducerConfig.RETRIES_CONFIG , "3")); list .add(Property.createProperty(ProducerConfig.LINGER_MS_CONFIG , "10000")); list .add(Property.createProperty(ProducerConfig.BUFFER_MEMORY_CONFIG ,"10485760")); list .add(Property.createProperty(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG ,"1000")); Property[]props = list .toArray(new Property[list .size()]); //配置Marker過濾器(標記過濾器和方法一的一樣) MarkerFilterfilter = MarkerFilter.createFilter("kafkaLog", Filter.Result.ACCEPT , Filter.Result.DENY); Configurationconfiguration = new DefaultConfiguration(); Layout<String>layout = PatternLayout.createLayout("%date %message",null , configuration , null , Charset.forName ("UTF-8" ),false , false , null,null); Appenderappender = KafkaAppender.createAppender(layout,filter, "KAFKA" ,true , "log4j-kafka" , props , configuration ); config .addAppender(appender ); interLogger .addAppender(appender ); appender .start(); ctx .updateLoggers(); } } 方法二和方法一的使用是一樣的，也許要定義一個Markers類. 注意：0.0.0.0換成你自己的IP地址