java.util ロギング クラスを使用して、ローリング ファイル アペンダーを作成しています。データが書き込まれるときにこれらのログから読み取るログ リーダーを作成したいと考えています。
ローリング ログ アペンダー コードは、単独で正常に動作します。しかし、一度リーダー スレッドを開始すると、新しいファイルは作成されません。つまり、ローリング ログ アペンダーが 5 つのファイルを使用するように設定されている場合、1og.0、log.1、log.2 などが作成されますが、リーダー スレッドが開始された場合は、 create log.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..
}
}