近實時搜索就是他能打開一個IndexWriter快速搜索索引變更的內(nèi)容，而不必關(guān)閉writer，或者向writer提交，這個功能是在2.9版本以后引入的，在以前沒有這個功能時，必須調(diào)用writer的commit方法，然后重新打開reader，這個過程很耗費時間，因為writer的提交必須對索引里的所有新文件進(jìn)行同步，同步操作耗費系統(tǒng)資源，近實時搜索使我們能夠?qū)π聞?chuàng)建還未提交的索引進(jìn)行搜索。

?

? 在4.5的版本上做一個簡單的測試示例，參考lucene in action

?

[java]?view plaincopyprint?

import?junit.framework.TestCase;??

import?org.apache.lucene.analysis.standard.StandardAnalyzer;??

import?org.apache.lucene.document.Document;??

import?org.apache.lucene.document.Field;??

import?org.apache.lucene.document.FieldType;??

import?org.apache.lucene.document.TextField;??

import?org.apache.lucene.index.*;??

import?org.apache.lucene.search.IndexSearcher;??

import?org.apache.lucene.search.Query;??

import?org.apache.lucene.search.TermQuery;??

import?org.apache.lucene.search.TopDocs;??

import?org.apache.lucene.store.Directory;??

import?org.apache.lucene.store.RAMDirectory;??

import?org.apache.lucene.util.Version;??

??

??

public?class?NearRealTimeTest?extends?TestCase?{??

??public?void?testNearRealTime()?throws?Exception?{??

????Directory?dir?=?new?RAMDirectory();??

????IndexWriterConfig?config?=??new?IndexWriterConfig(Version.LUCENE_45,new?StandardAnalyzer(Version.LUCENE_45));??

????IndexWriter?writer?=?new?IndexWriter(dir,?config);??

??????FieldType?fieldType?=?new?FieldType();??

??????fieldType.setIndexed(false);//set?是否索引??

??????fieldType.setStored(false);//set?是否存儲??

??????fieldType.setTokenized(true);//set?是否分類??

??????fieldType.setOmitNorms(false);??

????for(int?i=0;i<10;i++)?{??

??????Document?doc?=?new?Document();??

??????doc.add(new?Field("id",?""+i,?fieldType));??

??????doc.add(new?Field("test",?"aaa",?TextField.TYPE_NOT_STORED));??

??????writer.addDocument(doc);??

????}??

????//IndexReader?reader?=?writer.getReader();?????????????????//?老版本的??3.x??

????DirectoryReader?reader?=?DirectoryReader.open(writer,true);???//創(chuàng)建近實時reader??

????IndexSearcher?searcher?=?new?IndexSearcher(reader);???//將reader封裝在IndexSearcher??

??

????Query?query?=?new?TermQuery(new?Term("test",?"aaa"));??

????TopDocs?docs?=?searcher.search(query,?1);??

????assertEquals(10,?docs.totalHits);????????????????????????//?返回10個搜索結(jié)果??

??

????writer.deleteDocuments(new?Term("id",?"7"));?????????????//?刪除一個文檔??

??

????Document?doc?=?new?Document();??

??

????doc.add(new?Field("id",?"11",??fieldType));??

????doc.add(new?Field("test",?"bbb",??TextField.TYPE_NOT_STORED));??

????writer.addDocument(doc);??

??????

????//IndexReader?newReader?=?reader.reopen();?????????????????//老版本3.x??

????IndexReader?newReader?=?DirectoryReader.openIfChanged(reader,writer,true);???//重啟reader??

????reader.close();??

????assertFalse(reader?==?newReader);??

????reader.close();??

????searcher?=?new?IndexSearcher(newReader);??

??

????TopDocs?hits?=?searcher.search(query,?10);??

????assertEquals(9,?hits.totalHits);??

??

????query?=?new?TermQuery(new?Term("text",?"bbb"));??

????hits?=?searcher.search(query,?1);??

????assertEquals(1,?hits.totalHits);??

??

????newReader.close();??

????writer.close();??

??}??

}??

可以看到更新文檔后用 DirctoryReader.openIfChanged來獲取Reader，如果有新內(nèi)容，則返回新的Reader，這時我們需要關(guān)閉老的Reader。

?

最后測試通過

轉(zhuǎn)載于:https://www.cnblogs.com/zhwl/p/3499557.html

總結(jié)

以上是生活随笔為你收集整理的lucene4.5近实时搜索的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。