18

状況によっては、logbackのファイルアペンダーですぐにフラッシュを強制する必要があります。ドキュメントで、このオプションはデフォルトで有効になっていることがわかりました。不思議なことに、これは機能しません。私がソースで見るように、基礎となるプロセスはBufferedOutputSream正しく関与しています。何か問題はありますBufferedOutputSream.flush()か？おそらく、これはむしろフラッシングの問題に関連しています。

更新：Windows XP ProSP3およびRedHatEnterprise 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興味のある人は誰でもこれをフォローできます。

したがって、これはログバックの問題ではありません。

4

3 に答える 3

10

私は自分の解決策をみんなに届けることにしました。まず、これはログバックの問題ではなく、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'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">

未検証。おそらく、フィールドに可視性の問題があり、ログバックパッケージ自体を使用する必要がありch.qos.logback.core.recoveryます。

ちなみに、ログバックにバグレポートを送信して、の追加オプションを取得することをお勧めし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);
    }
}

アペンダーのMyFileAppenderクラスを設定します。

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

ログバックがこの問題を解決することを願っています。

于 2013-06-08T11:55:03.080 に答える