請支援原創部落格 http://blog.csdn.net/cl59452/article/details/38408741

lucene2.9 之後推出了nrtmanager  近實時搜尋，但是很多人在lucene4.x 中找不到了，我通過查閱apache 的log 發現，lucene已經用ControlledRealTimeReopenThread將nrtmanager替代了具體的實現過程如下：

public class IndexUtil {
    
    private SearcherManager mgr;
    private IndexWriter writer;
    private TrackingIndexWriter tkWriter;
    private ControlledRealTimeReopenThread<IndexSearcher> crtThread;
//    private String path ;
    
    public IndexUtil(String path){
        try {
            Directory fsDir = FSDirectory.open(new File(path));
            //建立writer
            writer = new IndexWriter(fsDir,new IndexWriterConfig(Version.LUCENE_47,new IKAnalyzer(true)));
            //新建SearcherManager
            //true 表示在記憶體中刪除，false可能刪可能不刪，設為false效能會更好一些
            mgr = new SearcherManager(writer,false,new SearcherFactory());
            //ControlledRealTimeReopenThread 構造是必須有的，主要將writer裝，每個方法都沒有commit 操作。
            tkWriter = new TrackingIndexWriter(writer);//為writer 包裝了一層
            //建立執行緒，執行緒安全的，我們不須處理    
            crtThread = new ControlledRealTimeReopenThread<IndexSearcher>(tkWriter, mgr, 5.0, 0.025);
            crtThread.setDaemon(true);//設為後臺程序
            crtThread.setName("我是好人");
            crtThread.start();//啟動執行緒
//            crtThread.
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    
    public void search(){
        IndexSearcher searcher = null;
        try {
 
            //更新看看記憶體中索引是否有變化如果，有一個更新了，其他執行緒也會更新
 
           mgr.maybeRefresh();
 
            //利用acquire 方法獲取search，執行此方法前須執行maybeRefresh
            searcher = mgr.acquire();
           IndexSearcher tr = mgr.refreshIfNeeded(searcher);
 
            String fields[] = {"body","name"};
            QueryParser qp = new MultiFieldQueryParser(Version.LUCENE_47,fields,new IKAnalyzer(true));
            Query query =new TermQuery(new Term("id", "2"));// qp.parse("中國");
            TopDocs tds = searcher.search(query, 5);
            ScoreDoc[] sds = tds.scoreDocs;
            for(ScoreDoc sd:sds){
                Document d = searcher.doc(sd.doc);
                System.out.println(d.get("name")+d.get("body")/*+d.get("id")*/);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } /*catch (ParseException e) {
            e.printStackTrace();
        }*/finally{
 
            try {
 
               //釋放searcher，
                mgr.release(searcher);
            } catch (IOException e) {
                e.printStackTrace();
            }
            System.out.println("------------------------------------------------------------------------------------------------");
        }
 
    }
}
實現原理：
只有Index Writer上的commit操作才會導致ram directory上的資料完全同步到檔案。Index Writer提供了實時獲得reader的API，這個呼叫將導致flush操作，生成新的segment，但不會commit（fsync），從而減少 了IO。新的segment被加入到新生成的
reader裡。從返回的reader裡，可以看到更新。所以，只要每次新的搜尋都從IndexWriter獲得一個新的reader，就可以搜尋到最新的內容。這一操作的開銷僅僅是flush，相對commit來說，開銷很小。

Lucene的index組織方式為一個index目錄下的多個segment。新的doc會加入新的segment裡，這些新的小segment每隔一段時間就合併起來。因為合併，總的segment數

量保持的較小，總體search速度仍然很快。為了防止讀寫衝突，lucene只建立新的segment，並在任何active的reader不在使用後刪除掉老的segment。

flush是把資料寫入到作業系統的緩衝區，只要緩衝區不滿，就不會有硬碟操作。

commit是把所有記憶體緩衝區的資料寫入到硬碟，是完全的硬碟操作。

重量級操作。這是因為，Lucene索引中最主要的結構posting通過VINT和delta的格式存

儲並緊密排列。合併時要對同一個term的posting進行歸併排序，是一個讀出，合併再生

成的過程。
--------------------- 
作者：cl59452 
來源：CSDN 
原文：https://blog.csdn.net/cl59452/article/details/38408741 
版權宣告：本文為博主原創文章，轉載請附上博文連結！