Package org.shoulder.log.operation.logger.impl

Class BufferedOperationLogger

java.lang.Object

org.shoulder.log.operation.logger.impl.BufferedOperationLogger

All Implemented Interfaces:

OperationLogger

public class BufferedOperationLogger
extends Object
implements OperationLogger

带缓冲的操作日志记录器（针对频繁记录单条操作日志做优化，批量操作不优化） 将日志放入 buffer 中，当 buffer 中日志达到一定数量 / 每隔一定时间，执行一次批量保存

Author:

lym

Constructor Summary

Constructors

Constructor	Description
BufferedOperationLogger(Queue<OperationLogDTO> logBuffer, OperationLogger delegate, ScheduledExecutorService scheduledExecutorService, long flushInterval, int flushThreshold, int perFlushMax)

Method Summary

Modifier and Type	Method	Description
void	addInterceptor(OperationLoggerInterceptor logInterceptor)	注册拦截器
void	consumerLog()
OperationLogger	getDelegate()
void	log(Collection<? extends OperationLogDTO> opLogList)	记录多条操作日志
void	log(OperationLogDTO opLog)	记录一条操作日志
void	log(OperationLogDTO opLog, List<? extends Operable> operableList)	组装并记录多条操作日志
void	preDestroy()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.shoulder.log.operation.logger.OperationLogger

log

Constructor Details

BufferedOperationLogger

public BufferedOperationLogger(Queue<OperationLogDTO> logBuffer,
 OperationLogger delegate,
 ScheduledExecutorService scheduledExecutorService,
 long flushInterval,
 int flushThreshold,
 int perFlushMax)

Method Details

log

public void log(@Nonnull
 OperationLogDTO opLog)

记录一条操作日志

Specified by:

log in interface OperationLogger

Parameters:

opLog - 操作日志对象

log

public void log(@Nonnull
 Collection<? extends OperationLogDTO> opLogList)

记录多条操作日志

Specified by:

log in interface OperationLogger

Parameters:

opLogList - 操作日志对象集合

log

public void log(@Nonnull
 OperationLogDTO opLog,
 List<? extends Operable> operableList)

Description copied from interface: OperationLogger

组装并记录多条操作日志

Specified by:

log in interface OperationLogger

Parameters:

opLog - 记录模板

operableList - 被操作对象集合

addInterceptor

public void addInterceptor(OperationLoggerInterceptor logInterceptor)

Description copied from interface: OperationLogger

注册拦截器

Specified by:

addInterceptor in interface OperationLogger

Parameters:

logInterceptor - 拦截器

getDelegate

public OperationLogger getDelegate()

consumerLog

public void consumerLog()

preDestroy

@PreDestroy
public void preDestroy()