Java基于Log4j2实现异步日志系统的性能优化实践指南

// 1. 在初始化时创建 Disruptor
RingBuffer<LogEvent> ringBuffer = RingBuffer.create(
    ProducerType.MULTI,
    LogEvent::new,
    bufferSize,
    new SleepingWaitStrategy()
);
SequenceBarrier barrier = ringBuffer.newBarrier();
WorkerPool<LogEvent> workerPool = new WorkerPool<>(
    ringBuffer,
    barrier,
    new FatalExceptionHandler(),
    new LogEventConsumer(appender)
);

// 2. 提交事件
public void append(LogEvent event) {
    long seq = ringBuffer.next();
    try {
        LogEvent slot = ringBuffer.get(seq);
        slot.setEvent(event.toImmutable());
    } finally {
        ringBuffer.publish(seq);
    }
}

<dependencies>
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-core</artifactId>
        <version>2.17.1</version>
    </dependency>
    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-slf4j-impl</artifactId>
        <version>2.17.1</version>
    </dependency>
</dependencies>

<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="WARN" packages="">
  <Appenders>
    <!-- 异步Appender，容量 1024 -->
    <Async name="AsyncFile" bufferSize="1024" blocking="true">
      <File name="File" fileName="logs/app.log" append="true">
        <PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
      </File>
    </Async>
  </Appenders>
  
  <Loggers>
    <Root level="INFO">
      <AppenderRef ref="AsyncFile"/>
    </Root>
  </Loggers>
</Configuration>

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class LoggingApplication implements CommandLineRunner {
    private static final Logger logger = LoggerFactory.getLogger(LoggingApplication.class);

    public static void main(String[] args) {
        SpringApplication.run(LoggingApplication.class, args);
    }

    @Override
    public void run(String... args) {
        for (int i = 0; i < 1000000; i++) {
            logger.info("Log message number {}", i);
        }
        logger.info("Logging Completed");
    }
}