Neil Coffey'in çözümü sizin için iyidir. Sabit uzunluktaki dosyaları okuyor. Ancak, değişken uzunluğa sahip olan dosyalar için (veriler gelmeye devam eder), bir FileStreamReader aracılığıyla doğrudan FileInputStream veya FileChannel giriş akışında BufferedReader kullanımıyla ilgili bazı sorunlar vardır. eski davaları dikkate For You istediğiniz
1) geçerli dosya uzunluğuna ofset bazı veri okumak için. Dolayısıyla, FileInputStream/FileChannel'de (bir InputStreamReader aracılığıyla) BR kullanır ve readLine yöntemini kullanırsınız. Okuduğunuz meşgulken Ancak veriler bazı veriler (önceki dosya uzunluğu)
2) beklenenden daha fazla veri okumak için BF en taleb neden olan ilave var diyelim Sen readline şeyler bitmiş ama okumaya çalıştığınızda Mevcut dosya uzunluğu/kanal pozisyonu aniden eklenir, bu da mevcut dosya uzunluk/kanal pozisyonunun artmasına neden olur, fakat bundan daha az veri okudunuz. Yukarıdaki her iki durumda
o yüzden
(o satırbaşı gibi bazı karakter atlar çünkü sadece taleb kullanılarak okunan verilerin uzunluğunu kullanamazsınız) okuduğunuz gerçek verileri bilmek zordur Verileri arabelleğe alınmış baytlarda okumak ve bunun etrafında bir BufferedReader sarıcısı kullanmak daha iyidir.Ben benzer bir sorun vardı bu
/** Read data from offset to length bytes in RandomAccessFile using BufferedReader
* @param offset
* @param length
* @param accessFile
* @throws IOException
*/
public static void readBufferedLines(long offset, long length, RandomAccessFile accessFile) throws IOException{
if(accessFile == null) return;
int bufferSize = BYTE_BUFFER_SIZE;// constant say 4096
if(offset < length && offset >= 0){
int index = 1;
long curPosition = offset;
/*
* iterate (length-from)/BYTE_BUFFER_SIZE times to read into buffer no matter where new line occurs
*/
while((curPosition + (index * BYTE_BUFFER_SIZE)) < length){
accessFile.seek(offset); // seek to last parsed data rather than last data read in to buffer
byte[] buf = new byte[bufferSize];
int read = accessFile.read(buf, 0, bufferSize);
index++;// Increment whether or not read successful
if(read > 0){
int lastnewLine = getLastLine(read,buf);
if(lastnewLine <= 0){ // no new line found in the buffer reset buffer size and continue
bufferSize = bufferSize+read;
continue;
}
else{
bufferSize = BYTE_BUFFER_SIZE;
}
readLine(buf, 0, lastnewLine); // read the lines from buffer and parse the line
offset = offset+lastnewLine; // update the last data read
}
}
// Read last chunk. The last chunk size in worst case is the total file when no newline occurs
if(offset < length){
accessFile.seek(offset);
byte[] buf = new byte[(int) (length-offset)];
int read = accessFile.read(buf, 0, buf.length);
if(read > 0){
readLine(buf, 0, read);
offset = offset+read; // update the last data read
}
}
}
}
private static void readLine(byte[] buf, int from , int lastnewLine) throws IOException{
String readLine = "";
BufferedReader reader = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(buf,from,lastnewLine)));
while((readLine = reader.readLine()) != null){
//do something with readLine
System.out.println(readLine);
}
reader.close();
}
private static int getLastLine(int read, byte[] buf) {
if(buf == null) return -1;
if(read > buf.length) read = buf.length;
while(read > 0 && !(buf[read-1] == '\n' || buf[read-1] == '\r')) read--;
return read;
}
public static void main(String[] args) throws IOException {
RandomAccessFile accessFile = new RandomAccessFile("C:/sri/test.log", "r");
readBufferedLines(0, accessFile.length(), accessFile);
accessFile.close();
}