Logback文件追加器不会立即刷新 - java

在某些情况下,我需要立即强制在logback的文件附加器中刷新。我在docs中发现此选项默认为启用。神秘地,这是行不通的。正如我在源代码中看到的那样,基础流程正确地涉及BufferedOutputSreamBufferedOutputSream.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>

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

  • 发生记录事件
  • 事件传递到文件附加程序
  • 事件使用定义的模式
  • 序列化

  • 事件的序列化消息传递到文件追加程序,并且
    即将写出输出流
  • 写入流完成,输出流被刷新(我已经
    检查执行情况)。注意immidiateFlush是true
    默认,所以方法flush()被显式调用
  • 文件中没有结果!
  • 稍后,当一些基础缓冲区流动时,该事件出现在文件中。
    所以问题是:输出流是否保证立即刷新?

    老实说,我已经通过实现自己的ImmediateRollingFileAppender来解决此问题,该代码利用了立即同步FileDescriptor的功能。任何感兴趣的人都可以关注this。

    因此,这不是注销问题。

    参考方案

    我决定将解决方案带给每个人。
    首先让我澄清一下,这不是回滚问题,也不是JRE问题。这在javadoc中进行了描述,通常不应该成为问题,直到您在文件同步方面遇到一些老派的集成解决方案为止。

    因此,这是一个实现立即刷新的logback追加程序:

    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,而仅将ResilientOutputStreamBaseResilientFileOutputStream的其余部分和未更改的部分复制到此新版本中。我只显示更改的代码:

    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>
    

    Java Applet的URLConnection与PHP无效 - java

    我已经研究了Oracle文档和示例,但仍然无法正常工作。我有一个Java Applet,它只是尝试使用URLConnection和OutputStreamWriter通过POST将文本字段发送到PHP脚本。 Java方面似乎工作正常,没有引发异常,但是PHP在我的页面上未显示任何输出。我是PHP新手,因此请耐心等待。这是相关的Java部分: try { UR…

    页面加载而不是提交时发生struts验证 - java

    请原谅我;我对Struts有点陌生。我遇到一个问题,即页面加载而不是我实际提交表单时发生了验证。我整天都在论坛上搜寻和搜寻,没有任何运气。我显然做错了一些事情,应该很容易确定,但是我还没有发现问题所在。这是我的struts.xml的片段:<action name="*Test" method="{1}" clas…

    DataSourceTransactionManager和JndiObjectFactoryBean和JdbcTemplate的用途是什么? - java

    以下的用途是什么:org.springframework.jdbc.core.JdbcTemplate org.springframework.jdbc.datasource.DataSourceTransactionManager org.springframework.jndi.JndiObjectFactoryBean <tx:annotatio…

    Struts2中的错误处理 - java

    我对如何在Struts2中进行错误处理感到困惑。我希望在发生错误时将用户引导到一个中心页面。此外,当发生错误时,我希望将其记录下来,因为我使用的是log4j,因此我将其记录为log.error(e.getMessage(), e);但是,在动作类中,如果我捕获到错误(将我的所有代码放入try / catch中),则不会出现中央/常见错误页面。因此,我决定不捕…

    通过Maven编译器插件不会发生有限的包含和排除 - java

    我正在使用3.6.0版的maven编译器插件,在此我们只想在特定文件夹中编译一个文件,而在该位置编译所有其他文件。例如:在文件夹应用程序中有14个文件,从那我只希望编译1个文件,但它编译了所有文件,如果我要排除,则它也不起作用。 <sourceDirectory>${basedir}/../src/java</sourceDirectory…