Прикладной файл журнала не сразу скрывается

Ответ 1

Я решил принести свое решение всем. Позвольте мне в первую очередь уточнить, что это не проблема журнала, а не проблема JRE. Это описано в javadoc и, как правило, не должно быть проблемой, пока вы не столкнетесь с некоторыми старыми школьными интеграционными решениями по синхронизации файлов.

Итак, это приложение для резервного копирования, которое выполняется для немедленного скрытия:

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 make sence
                postSuccessfulWrite();
            } catch (IOException e) {
                postIOFailure(e);
            }
        }
    }

}

И, наконец, config:

<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>

Ответ 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">

Не тестировалось. Вероятно, будут проблемы с видимостью с полями, , требующие использования самого пакета журнала ch.qos.logback.core.recovery.

Кстати, я приглашаю вас отправить отчет об ошибках в журнал, чтобы получить дополнительную опцию immediateSync on LayoutWrappingEncoder.

Ответ 3

Много промежуточного программного обеспечения мониторинга обнаруживают новые события, проверяя обновления отметки времени и размера файла. По этой причине необходимо время, в которое записывается событие, отметка времени и размер файла обновляются.

Этот класс может решить его

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);
    }
}

Установить класс MyFileAppender для appender.

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

Надеюсь, что этот журнал решает эту проблему.