Rozwiązanie Neila Coffeya jest dobre, jeśli czytają pliki o stałej długości. Jednak w przypadku plików o zmiennej długości (dane przychodzą) wystąpią problemy z używaniem BufferedReader bezpośrednio w strumieniu wejściowym FileInputStream lub FileChannel za pośrednictwem InputStreamReader. Dla ex rozważyć przypadki
1) Chcesz odczytać dane z niektórych przesunięcie do bieżącej długości pliku. Używasz BR w FileInputStream/FileChannel (przez InputStreamReader) i używasz metody readLine. Ale gdy jesteś zajęty czytaniem danych, powiedz, że dodano pewne dane, które powodują, że readLine BF odczytuje więcej danych niż oczekiwałeś (poprzednia długość pliku):
2) Skończyłeś czytać, ale kiedy próbujesz przeczytać bieżąca długość pliku/pozycja kanału niektóre dane zostały dodane nagle, co powoduje wzrost aktualnej długości pliku/pozycji kanału, ale już przeczytałeś mniej danych niż to.
W obu powyższych przypadkach trudno jest poznać rzeczywiste dane masz prawa odczytu (nie można po prostu użyć długość odczyt danych za pomocą readLine ponieważ pomija niektóre znaki, takie jak powrót karetki)
Tak lepiej jest odczytać dane w zbuforowanych bajtach i używać w tym celu opakowania BufferedReader.Napisałem kilka metod, jak ten
/** 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();
}