集群中某一个节点logback日志文件写入不成功排查历程

时间  2021-08-12
标签 html java api 性能优化 服务器 app 框架 异步 async ide 栏目 负载均衡 繁體版
原文   原文链接

问题背景

个人日志路径是 /opt/logs/xxxx.log，集群中共有两台服务器：html

  • 一台服务器的日志文件最新更新时间 是今天，
  • 另外一台服务器的日志文件最新更新时间 倒是昨天甚至更久以前。

换言之，一台服务器从过去某个时间点开始，日志就不能正常打印了。另外，交代一下，这个项目不是我从零开始搭建的，是我接手维护的项目。我使用的日志框架是 slf4j + logback。java

一开始，我在百度上找的解决方案：api

<?xml version="1.0" encoding="UTF-8"?>
<jboss-deployment-structure>
    <deployment>
        <!-- Exclusions allow you to prevent the server from automatically adding some dependencies     -->
        <exclusions>
            <module name="org.slf4j" />
            <module name="org.slf4j.impl" />
            <!-- 若是项目中用到jcl－over－slf4j，能够将下面这个module也毙了 -->
            <module name="org.slf4j.jcl-over-slf4j" />
        </exclusions>
    </deployment>
</jboss-deployment-structure>

我看了一下个人项目中：
性能优化

jcl-over-slf4j jul-to-slf4j log4j-over-slf4j slf4j-api 都有，因而我试了一下服务器

遗憾的是，问题没能解决，只好继续分析，我也猜不到缘由，又看不到报错，因此就想着能不能在源码里找到一些对解决问题有帮助的异常。app

源码分析

例如，咱们有一个简单的 UserService 的例子，调用了 log.info 方法：框架

package service;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class UserService {
    
    private static final Logger log = LoggerFactory.getLogger("service.UserService");

    public String getPhoneByUsername(String username) {
        String result = "12345678901";
        log.info("{}'s phone number is {}", username, result);
        return result;
    }
}

logback 中实现 org.slf4j.Logger 接口的实例是类 ch.qos.logback.classic.Logger。咱们发现它的 trace/debug/info/warn/error 方法，都会调用私有方法 buildLoggingEventAndAppend ：异步

private void buildLoggingEventAndAppend(final String localFQCN, final Marker marker, final Level level, final String msg, final Object[] params,
                final Throwable t) {
    // 建立一个 LoggingEvent 对象
    LoggingEvent le = new LoggingEvent(localFQCN, this, level, msg, t, params);
    le.setMarker(marker);
    // 调用 Appenders 来处理 LoggingEvent
    callAppenders(le);
}

接下来，来看 callAppenders 的源码:async

/**
 * Invoke all the appenders of this logger.
 * 
 * @param event
 *          The event to log
 */
public void callAppenders(ILoggingEvent event) {
    int writes = 0;
    for (Logger l = this; l != null; l = l.parent) {
        writes += l.appendLoopOnAppenders(event);
        if (!l.additive) {
            break;
        }
    }
    // No appenders in hierarchy
    if (writes == 0) {
        loggerContext.noAppenderDefinedWarning(this);
    }
}

咱们来看这个循环 for (Logger l = this; l != null; l = l.parent) { }，这里从当前 Logger 向上查找父 Logger，拿 service.userService 举例来讲：
ide

这个树状的 Logger 结构，是在 LoggerFactory.getLogger("service.UserService") 时建立的。在 logback 中，类 ch.qos.logback.classic.LoggerContext#getLogger 承担了该任务。

ch.qos.logback.classic.Logger 的代码继续往下挖，到了 appendLoopOnAppenders 方法，这个方法可否继续执行，关键就是 aai 是否为 null ？

transient private AppenderAttachableImpl<ILoggingEvent> aai;

private int appendLoopOnAppenders(ILoggingEvent event) {
    if (aai != null) {
        return aai.appendLoopOnAppenders(event);
    } else {
        return 0;
    }
}

依然是 ch.qos.logback.classic.Logger 的源码，aai 是在 addAppender 的时候建立的，若是Logger没有一个appender，aai就是null：

public synchronized void addAppender(Appender<ILoggingEvent> newAppender) {
    if (aai == null) {
        aai = new AppenderAttachableImpl<ILoggingEvent>();
    }
    aai.addAppender(newAppender);
}

来看一下个人配置，位于 resources 文件夹下的 logback.xml:

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
	<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
                <!-- 这里我粘贴的是官方的配置，没有粘贴我排查出问题的配置 -->
		<file>logFile.log</file>
		<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
			<!-- daily rollover -->
			<fileNamePattern>logFile.%d{yyyy-MM-dd}.log</fileNamePattern>
			<!-- keep 30 days' worth of history capped at 3GB total size -->
			<maxHistory>30</maxHistory>
			<totalSizeCap>3GB</totalSizeCap>
		</rollingPolicy>
		<encoder>
			<pattern>%-4relative [%thread] %-5level %logger{35} - %msg%n</pattern>
		</encoder>
	</appender>
	<appender name="ASYNC_FILE" class="ch.qos.logback.classic.AsyncAppender">
		<appender-ref ref="FILE"/>
	</appender>
	<root level="INFO">
		<appender-ref ref="ASYNC_FILE"/>
	</root>
</configuration>

根据上面的 xml 配置，解析获得的 root logger 以下图所示：

按照我我的的理解：<logger> 标签支持 <append-ref> 子标签，若是它包含至少一个 <append-ref>，那么该 Logger 就有 aai 属性。

另外，ch.qos.logback.classic.AsyncAppender 自带 aai，则是由于它的父类 ch.qos.logback.core.AsyncAppenderBase 有 aai:

public class AsyncAppenderBase<E> extends UnsynchronizedAppenderBase<E> implements AppenderAttachable<E> {
    AppenderAttachableImpl<E> aai = new AppenderAttachableImpl<E>();
}

再来看继承体系：

咱们经常使用的 ConsoleAppender, FileAppender, RollingFileAppender 这些是没有 aai 属性的！

如今，咱们回到 ch.qos.logback.core.spi.AppenderAttachableImpl 源码中的 appendLoopOnAppenders 方法，它调用了 doAppend

/**
 * Call the <code>doAppend</code> method on all attached appenders.
 */
public int appendLoopOnAppenders(E e) {
    int size = 0;
    for (Appender<E> appender : appenderList) {
        appender.doAppend(e);
        size++;
    }
    return size;
}

调试关键点

AsyncAppender

若是想弄清楚 AsyncAppender 的异步工做过程，建议断点打在两处：
一、ch.qos.logback.core.AsyncAppenderBase 第 156 行，put 方法处：

此时调用堆栈以下图所示：

二、ch.qos.logback.core.AsyncAppenderBase 第 265 行，内部类 Worker 的 run 方法内的循环处:

内部类 Worker 工做的线程名是以 AsyncAppender-Worker- 为前缀的。

RollingFileAppender

如今，咱们把断点放在 ch.qos.logback.core.rolling.RollingFileAppender 的 222 行，看一下 subAppend 的执行：

/**
* This method differentiates RollingFileAppender from its super class.
*/
@Override
protected void subAppend(E event) {
    // The roll-over check must precede actual writing. This is the
    // only correct behavior for time driven triggers.
    // We need to synchronize on triggeringPolicy so that only one rollover
    // occurs at a time
    synchronized (triggeringPolicy) {
        if (triggeringPolicy.isTriggeringEvent(currentlyActiveFile, event)) {
            rollover();
        }
    }
    // 调用父类 OutputStreamAppender 的 subAppend 方法，这个父类方法是实际发生写入的方法，若是不执行就无法正常写入日志！
    super.subAppend(event);
}

下图是我运行到 subAppend 时的调用栈信息：

我遇到的问题就在这个 rollover

我先贴一下，我有问题的 logback.xml:

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>logFile.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy">
            <FileNamePattern>biz-%d{yyyy-MM-dd_HH}.%i.txt</FileNamePattern>
            <MinIndex>1</MinIndex>
            <!-- 最多保留20份历史日志 -->
            <MaxIndex>20</MaxIndex>
        </rollingPolicy>
        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
            <!-- 每一个文件最大1KB，这里是为了测试才改为 1KB 的 -->
            <MaxFileSize>1KB</MaxFileSize>
        </triggeringPolicy>
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <pattern>%date{yyyy-MM-dd HH:mm:ss.SSS} %level [%thread] %logger{36} %msg%n</pattern>
        </encoder>
    </appender>
    <appender name="ASYNC_FILE" class="ch.qos.logback.classic.AsyncAppender">
        <appender-ref ref="FILE"/>
    </appender>
    <root level="INFO">
        <appender-ref ref="ASYNC_FILE"/>
    </root>
</configuration>

而后，我把打印日志的方法 UserService#getPhoneByUsername 循环执行个 200 次:

for (int i = 0; i < 100; i++) {
  String result = getPhoneByUsername("Mi");
}

ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy 的 isTriggeringEvent 方法返回了 true，这就和我那台不打印日志的服务器的状况同样了：

public boolean isTriggeringEvent(final File activeFile, final E event) {
    long now = System.currentTimeMillis();
    if (invocationGate.isTooSoon(now))
        return false;
    // 当日志文件大小超过了设置的大小（默认是 10MB，我这里改为了 1KB），则返回true
    return (activeFile.length() >= maxFileSize.getSize());
}

断点能够设置在 rollover 这个方法所在行。接下来，当文件大小超过指定大小，调用 rollback 时出现了异常，这个异常被 ch.qos.logback.core.UnsynchronizedAppenderBase 的 doAppend 方法捕获了：

而后，真正写入日志的方法没有被执行，即 ch.qos.logback.core.OutputStreamAppender 的 subAppend 方法没有被执行：

/**
 * Actual writing occurs here.
 * <p>
 * Most subclasses of <code>WriterAppender</code> will need to override this
 * method.
 * 
 * @since 0.9.0
 */
protected void subAppend(E event) {
    if (!isStarted()) {
        return;
    }
    try {
        // this step avoids LBCLASSIC-139
        if (event instanceof DeferredProcessingAware) {
            ((DeferredProcessingAware) event).prepareForDeferredProcessing();
        }
        // the synchronization prevents the OutputStream from being closed while we
        // are writing. It also prevents multiple threads from entering the same
        // converter. Converters assume that they are in a synchronized block.
        lock.lock();
        try {
            writeOut(event);
        } finally {
            lock.unlock();
        }
    } catch (IOException ioe) {
        // as soon as an exception occurs, move to non-started state
        // and add a single ErrorStatus to the SM.
        this.started = false;
        addStatus(new ErrorStatus("IO failure in appender", this, ioe));
    }
}

而后，咱们能够看一下发生异常的栈信息：

我选择从 ch.qos.logback.core.rolling.FixedWindowRollingPolicy 继续细化分析问题：

这行还有 fileNamePattern 这个变量名，让我联想到了 xml 中 的 <FileNamePattern> 标签。

模拟出错的地方FileNamePattern

而后我就专门写了一段代码来模拟 FileNamePattern 的行为：

FileNamePattern pattern = new FileNamePattern("biz-%d{yyyy-MM-dd_HH}.%i.txt", new LoggerContext());
String s = pattern.convertInt(1);

调试参考点

断点打在 ch.qos.logback.core.rolling.helper.FileNamePattern 第 65 行，看 parse 方法第 64 行的结果：

如图所示，logback 中自制的分词器将 biz-%d{yyyy-MM-dd_HH}.%i.txt 解析成了 tokenList。

接下来代码执行到第 67 行，看一下 Node 的结果：

%d{yyyy-MM-dd_HH} 和 %i 被解析成了关键字，其余则保持字面值。

关键字 d 和 i 对应不一样的转换器：

static final Map<String, String> CONVERTER_MAP = new HashMap<String, String>();
    static {
        // i 对应 IntegerTokenConverter
        CONVERTER_MAP.put(IntegerTokenConverter.CONVERTER_KEY, IntegerTokenConverter.class.getName());
        // d 对应 DateTokenConverter
        CONVERTER_MAP.put(DateTokenConverter.CONVERTER_KEY, DateTokenConverter.class.getName());
    }

又由于 FixedWindowRollingPolicy 产生的参数值只有 Integer 型的，因此遇到 %d{yyyy-MM-dd_HH} 就会出错。

至此“结案”了！

解决方案

这个能够求教官方文档 阅读，解决 FileNamePattern 和 rollingPolicy 不匹配的问题。

FixedWindowRollingPolicy

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>logFile.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy">
            <!-- 修改的部分 Begin-->
            <FileNamePattern>biz.%i.txt</FileNamePattern>
            <!-- 修改的部分 END -->
            <MinIndex>1</MinIndex>
            <!-- 最多保留20份历史日志 -->
            <MaxIndex>20</MaxIndex>
        </rollingPolicy>
        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
            <!-- 每一个文件最大1KB，这里是为了测试才改为 1KB 的 -->
            <MaxFileSize>1KB</MaxFileSize>
        </triggeringPolicy>
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <pattern>%date{yyyy-MM-dd HH:mm:ss.SSS} %level [%thread] %logger{36} %msg%n</pattern>
        </encoder>
    </appender>
    <appender name="ASYNC_FILE" class="ch.qos.logback.classic.AsyncAppender">
        <appender-ref ref="FILE"/>
    </appender>
    <root level="INFO">
        <appender-ref ref="ASYNC_FILE"/>
    </root>
</configuration>

SizeAndTimeBasedRollingPolicy

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>logFile.log</file>
        <!-- 修改的部分 Begin-->
        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
            <!-- rollover daily -->
            <fileNamePattern>biz-%d{yyyy-MM-dd_HH}.%i.txt</fileNamePattern>
            <!-- each file should be at most 100MB, keep 60 days worth of history, but at most 20GB -->
            <maxFileSize>100MB</maxFileSize>
            <maxHistory>60</maxHistory>
            <totalSizeCap>20GB</totalSizeCap>
        </rollingPolicy>
        <!-- 修改的部分 END -->
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <pattern>%date{yyyy-MM-dd HH:mm:ss.SSS} %level [%thread] %logger{36} %msg%n</pattern>
        </encoder>
    </appender>
    <appender name="ASYNC_FILE" class="ch.qos.logback.classic.AsyncAppender">
        <appender-ref ref="FILE"/>
    </appender>
    <root level="INFO">
        <appender-ref ref="ASYNC_FILE"/>
    </root>
</configuration>

总结

个人一台服务器的日志文件 logFile.log 小于设置的 MaxFileSize（50MB），所以能够正常工做；
另外一台服务器的日志文件大小大于 MaxFileSize，在执行 rollback 方法时出错，致使没法继续正常写入日志。

而致使 rollback 不能正常工做的缘由是 FileNamePattern 和 rollingPolicy 不匹配。

参考文档

logback Manual -- Chapter 4: Appenders 阅读
jboss logback slf4j 日志文件不生成问题 阅读
logback性能优化及源码分析 阅读

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程