Java 實時讀取日志文件

需求：正在開發一個監控系統，要求將日志信息實時采集出來，然后保存到ElasticSearch，后期對日志數據進行展示和分析

運用的技術：RandomAccessFile類中seek方法可以從指定位置讀取文件，可以用來實現文件實時讀取，JDK文檔有對RandomAccessFile的介紹。

關鍵點：采用一個文件讀取指針游標，每次讀取完文件后，將文件的指針位置保存到文件讀取指針游標中，下次讀取的話從文件讀取指針游標位置處開始

源代碼：

package es.test.esjavaclient;

import java.io.File;
import java.io.RandomAccessFile;

/**
 * 實時讀取日志文件
 * @author think
 *
 */
public class FileRead {
    //文件讀取指針游標
    public static long pointer = 0;
    
    public static void main(String[] agrs){
        while (true){
            System.out.println("pointer:"+pointer);
            String paht ="D:/test.txt";
            randomRed(paht);
            try {
                System.out.println("停頓開始："+System.currentTimeMillis());
                //停頓10秒，方便操作日志文件，看效果。
                Thread.sleep(10000);
                System.out.println("停頓結束："+System.currentTimeMillis());
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
    }
    
    /** 
     * 讀取文件的方法 
     * @param path 文件路徑  
     * **/  
    public static void randomRed(String path){  
        try{
            File file = new File(path);
            if(file == null){
                System.out.println("文件不存在");
                return;
            }
            RandomAccessFile raf=new RandomAccessFile(file, "r"); 
            //獲取RandomAccessFile對象文件指針的位置，初始位置是0  
            System.out.println("RandomAccessFile文件指針的初始位置:"+raf.getFilePointer());  
            raf.seek(pointer);//移動文件指針位置  
            String line =null; 
            //循環讀取 
            while((line = raf.readLine())!=null){
                if(line.equals("")){
                    continue;
                }
                //打印讀取的內容,並將字節轉為字符串輸入，做轉碼處理，要不然中文會亂碼 
                line = new String(line.getBytes("ISO-8859-1"),"gb2312");
                System.out.println("line :"+line); 
            }  
            //文件讀取完畢后，將文件指針游標設置為當前指針位置 。 運用這個方法可以做很多文章，比如查到自己想要的行的話，可以記下來，下次直接從這行讀取
            pointer = raf.getFilePointer();   
                  
        }catch(Exception e){  
            System.out.println("異常："+ e.getMessage());
            e.printStackTrace();  
        }    
    }  
    
}

 

大家也可以參考下面這篇文章：

http://blog.csdn.net/ycb1689/article/details/53330832#；

這篇文章是將文件的大小記下來，然后下次讀取的話直接移動位置到文件末尾。 個人感覺沒有我的靈活

 

關於操作ElasticSearch部分，后續博客再更新