Common Log provides async appenders, these appenders implements log4j appender or other log frameworks
AsyncAppenderSkeleton is abstract class, base on common-utils Producer Consumer.
AsyncAppenderSkeleton is store logs on disk and consumer it async.
Based on common-utils Producer Consumer, Log data never be lost even if unexpected exit of the program, and retry consume if fail and until consume success.
AsyncKafkaAppender extends AsyncAppenderSkeleton, aync consume data from disk log to kafka
log4j.appender.kafka=org.zicat.common.log.log4j.kafka.AsyncKafkaAppender
log4j.appender.kafka.layout=org.apache.log4j.PatternLayout
log4j.appender.kafka.consumerMaxIntervalTimeMillis=50
log4j.appender.kafka.consumerMaxCount=50
log4j.appender.kafka.threadCount=3 # thread count
log4j.appender.kafka.filePath=bbb.mg # file name
log4j.appender.kafka.topic=${topic name} # topic name
log4j.appender.kafka.brokerList=${broke list} #format ip1:port1,ip2:port2AsyncSMTPAppender extends SMTPAppender, aync consume data from disk log to smtp server.
AsyncReducedSMTPAppender extends AsyncSMTPAppender, Duplicate removal by mail detail
AsyncSubjectReducedSMTPAppender extends AsyncSMTPAppender, Duplicate removal by mail subject
log4j.appender.MAIL2=org.zicat.common.log.log4j.mail.AsyncSubjectReducedSMTPAppender
log4j.appender.MAIL2.layout=org.apache.log4j.PatternLayout
log4j.appender.MAIL2.Threshold=ERROR
log4j.appender.MAIL2.consumerMaxIntervalTimeMillis=50
log4j.appender.MAIL2.consumerMaxCount=50
log4j.appender.MAIL2.BufferSize=512
log4j.appender.MAIL2.SMTPHost=${smpt host}
log4j.appender.MAIL2.SMTPUsername=
log4j.appender.MAIL2.SMTPPassword=
log4j.appender.MAIL2.From=${from mail}
log4j.appender.MAIL2.Subject=[Local] Testing ERROR2
log4j.appender.MAIL2.To=${to mail}AsyncHttpAppender extends AsyncAppenderSkeleton abstract class.
User need to extends AsyncHttpAppender to finish detail send logic using RestfullClient api
Define:
/**
* use client to send http request
*
* @param client
* @param elements
* @throws Exception
*/
public abstract void consume(RestfullClient client, List<LoggingEvent> elements) throws Exception;
/**
* deal with Exception, if dealException throw exception, data will be roll
* back and consumer again else data will be discard and continue to
* consumer next data
*
* @param client
* @param elements
* @param e
*/
public abstract void dealException(RestfullClient client, List<LoggingEvent> elements, Exception e);