18

在某些情况下，我需要立即强制刷新 logback 的文件附加程序。我在文档中发现此选项默认启用。神秘的是，这不起作用。正如我在源代码中看到的那样，底层过程涉及BufferedOutputSream正确。有什么问题BufferedOutputSream.flush()吗？可能这与冲洗问题有关。

更新：我在 Windows XP Pro SP 3 和 Red Hat Enterprise Linux Server 版本 5.3 (Tikanga) 上发现了这个问题。我使用了这些库：

jcl-over-slf4j-1.6.6.jar
logback-classic-1.0.6.jar
logback-core-1.0.6.jar
slf4j-api-1.6.6.jar

是logback.xml：

<configuration>
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>/somepath/file.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy">
            <fileNamePattern>file.log.%i</fileNamePattern>
            <minIndex>1</minIndex>
            <maxIndex>3</maxIndex>
        </rollingPolicy>
        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
            <maxFileSize>5MB</maxFileSize>
        </triggeringPolicy>
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>
        </encoder>
    </appender>

    <root level="debug">
        <appender-ref ref="FILE"/>
    </root>
</configuration>

更新： 我会提供一个单元测试，但这似乎并不那么简单。让我更清楚地描述这个问题。

  1. 发生记录事件
  2. 事件被传递到文件追加器
  3. 事件以定义的模式序列化
  4. 事件的序列化消息被传递到文件附加程序，并即将写出到输出流
  5. 写入流完成，输出流被刷新（我已经检查了实现）。请注意，immidiateFlush默认情况下为 true，因此flush()显式调用方法
  6. 文件中没有结果！

稍后，当一些底层缓冲区流动时，该事件出现在文件中。所以问题是：输出流是否保证立即刷新？

老实说，我已经通过实施我自己ImmediateRollingFileAppender的利用FileDescriptor即时同步工具来解决这个问题。有兴趣的可以关注这个。

所以这不是一个 logback 问题。

4

3 回答 3

10

我决定把我的解决方案带给大家。首先让我澄清一下，这不是 logback 问题，也不是 JRE 问题。这在javadoc中进行了描述，并且在您遇到一些关于文件同步的老式集成解决方案之前，通常不应该成为问题。

所以这是一个实现立即刷新的 logback appender：

public class ImmediateFileAppender<E> extends RollingFileAppender<E> {

    @Override
    public void openFile(String file_name) throws IOException {
        synchronized (lock) {
            File file = new File(file_name);
            if (FileUtil.isParentDirectoryCreationRequired(file)) {
                boolean result = FileUtil.createMissingParentDirectories(file);
                if (!result) {
                    addError("Failed to create parent directories for [" + file.getAbsolutePath() + "]");
                }
            }

            ImmediateResilientFileOutputStream resilientFos = new ImmediateResilientFileOutputStream(file, append);
            resilientFos.setContext(context);
            setOutputStream(resilientFos);
        }
    }

    @Override
    protected void writeOut(E event) throws IOException {
        super.writeOut(event);
    }

}

这是相应的输出流实用程序类。由于最初ResilientOutputStreamBase应该用于扩展的某些原始方法和字段具有打包的访问修饰符，因此我不得不进行扩展OutputStream，并且只需将其余部分和未更改的部分复制ResilientOutputStreamBase到ResilientFileOutputStream这个新的部分。我只是显示更改后的代码：

public class ImmediateResilientFileOutputStream extends OutputStream {

    // merged code from ResilientOutputStreamBase and ResilientFileOutputStream

    protected FileOutputStream os;

    public FileOutputStream openNewOutputStream() throws IOException {
        return new FileOutputStream(file, true);
    }

    @Override
    public void flush() {
        if (os != null) {
            try {
                os.flush();
                os.getFD().sync(); // this's make sence
                postSuccessfulWrite();
            } catch (IOException e) {
                postIOFailure(e);
            }
        }
    }

}

最后是配置：

<appender name="FOR_INTEGRATION" class="package.ImmediateFileAppender">
    <file>/somepath/for_integration.log</file>
    <rollingPolicy class="ch.qos.logback.core.rolling.FixedWindowRollingPolicy">
        <fileNamePattern>for_integration.log.%i</fileNamePattern>
        <minIndex>1</minIndex>
        <maxIndex>3</maxIndex>
    </rollingPolicy>
    <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
        <maxFileSize>5MB</maxFileSize>
    </triggeringPolicy>
    <encoder>
        <pattern>%d{HH:mm:ss.SSS} - %msg%n</pattern>
        <immediateFlush>true</immediateFlush>
    </encoder>
</appender>
于 2012-08-10T05:21:37.237 回答
2

你做得很好——做得很好。这是一个更简洁的建议：

public class ImmediateFlushPatternLayoutEncoder extends PatternLayoutEncoder {
    public void doEncode(ILoggingEvent event) throws IOException {
        super.doEncode(event);
        if (isImmediateFlush()) {
             if (outputStream.os instanceof FileOutputStream) {
                 ((FileOutputStream) outputStream.os).getFD().sync();
             }
        }
    }
}

在配置中，您必须使用该特定编码器：

<encoder class="ch.qos.logback.core.recovery.ImmediateFlushPatternLayoutEncoder">

未测试。可能会有字段可见性问题，需要使用 logbackch.qos.logback.core.recovery包本身。

顺便说一句，我邀请您向 logback提交错误报告immediateSync，以获得关于LayoutWrappingEncoder.

于 2012-08-16T10:22:25.620 回答
-1

许多监控中间件通过检查时间戳和文件大小的更新来发现新事件。为此，它需要记录事件的时间，更新时间戳和文件大小。

这门课可以解决

public class MyFileAppender<E> extends FileAppender<E> {
    protected void writeOut(E event) throws IOException {
        super.writeOut(event);
        ResilientFileOutputStream resilientFos = (ResilientFileOutputStream) super.getOutputStream();
        resilientFos.flush();
        resilientFos.getChannel().force(true);
    }
}

为 appender 设置 MyFileAppender 类。

<appender name="FILE" class="MyFileAppender">

我希望这是 logback 解决了这个问题。

于 2013-06-08T11:55:03.080 回答