尝试同时读取时Java滚动文件创建失败

我正在使用java.util日志记录类创建滚动文件appender。我想创建一个日志阅读器，在数据写入它们时从这些日志中读取数据。尝试同时读取时Java滚动文件创建失败

滚动日志appender代码自行正常工作。但是一旦我启动读取器线程，就不会创建新文件，即如果将滚动日志appender设置为使用5个文件，它将创建1og.0，log.1，log.2等，但是如果读取器线程启动，创建日志0，不会创建其他文件。我在java日志记录和log4j中注意到了这一点。

我正在使用nio在日志阅读器中读取。所以我的疑惑是，在同一个文件上创建另一个FileChannel会产生一些问题？或者我错过了一些基本的NIO东西，这是造成问题的原因。

这里是代码..

public class Test { 

    private static final long initialTime = System.currentTimeMillis(); 
    private static Logger logger = Logger.getLogger(Test.class.getName()); 
    public static void main(String[] args) { 

     logger.setLevel(Level.INFO); 
     try { 
      BufferedReader reader = new BufferedReader(
              new InputStreamReader(
                new FileInputStream(
                  new File(System.getProperty("user.dir")+File.separator+"input.dat")))); 

      FileHandler handler = new FileHandler("log/test.log", 1024, 5, true); 
      handler.setFormatter(new SimpleFormatter()); 
      logger.addHandler(handler); 
      logger.setUseParentHandlers(false); 
      //If I comment the next two lines the rolling appender works as expected both in java logging 
      //and when using log4j. however once I start the log reader only one file is created. 
      Thread logReader = new Thread(new LogReader("log/test.log.0")); 
      logReader.start(); 
      while(reader.ready()) 
      { 
       String strToLog = reader.readLine(); 
       logger.info(strToLog); 
       //Only want to run this for 10 secs. 
       if(System.currentTimeMillis() - initialTime > 10000) 
        System.exit(0); 
      } 
     } catch (FileNotFoundException e) { 
      e.printStackTrace(); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
     finally{ 

     } 
    } 

} 
class LogReader implements Runnable { 


    private final int BUFFER_SIZE = 1024; 

    private RandomAccessFile file; 

    private FileChannel chan; 

    private long offset; 

    private ByteBuffer buf; 

    private Charset charset = Charset.forName("UTF-8"); 

    private String filename = "output.log"; 

    public LogReader(String logfile) throws IOException { 
     System.out.println("Starting log reader from " + logfile); 
     file = new RandomAccessFile(logfile, "r"); 
     offset = file.length(); 
     chan = file.getChannel(); 
     chan.position(offset); 
     buf = ByteBuffer.allocateDirect(BUFFER_SIZE); 
     System.out.println("Started log reader from " + logfile); 
    } 

    public void run() { 
     //Even if I have nothing here..the problem exists.. 
     } 
}

来源

2010-08-31 Guru

我想可能有一些并发问题与RandomAccessFile。

我建议你使用不同的类读取文件。例如。 java.io.FileReader

来源

2010-09-01 02:46:32

是的，问题出在RandonAccessFile – Guru 2010-09-01 08:59:15

尝试同时读取时Java滚动文件创建失败

回答

相关问题